override def write()

in GlueCustomConnectors/development/Spark/SparkConnectorMySQL.scala [210:223]

• 14 lines of code
• 5 McCabe index (conditional complexity)

  override def write(record: InternalRow): Unit = {
    var i = 0
    while (i < numFields) {
      rddSchema.fields(i).dataType match {
        case IntegerType => preparedStatement.setInt(i + 1, record.getInt(i))
        case StringType => preparedStatement.setString(i + 1, record.getString(i))
        case dt: DecimalType =>
          preparedStatement.setBigDecimal(i + 1,
            record.getDecimal(i, dt.precision, dt.scale).toJavaBigDecimal)
      }
      i = i + 1
    }
    preparedStatement.addBatch()
  }