v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/processing/dml/DMLGenerator.java [355:382]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private static String getMappedColumnValue(
      SpannerColumnDefinition spannerColDef,
      SourceColumnDefinition sourceColDef,
      JSONObject valuesJson,
      String sourceDbTimezoneOffset) {

    String colInputValue = "";
    String colType = spannerColDef.getType().getName();
    String colName = spannerColDef.getName();
    if ("FLOAT64".equals(colType)) {
      colInputValue = valuesJson.getBigDecimal(colName).toString();
    } else if ("BOOL".equals(colType)) {
      colInputValue = (new Boolean(valuesJson.getBoolean(colName))).toString();
    } else if ("STRING".equals(colType) && spannerColDef.getType().getIsArray()) {
      colInputValue =
          valuesJson.getJSONArray(colName).toList().stream()
              .map(String::valueOf)
              .collect(Collectors.joining(","));
    } else if ("BYTES".equals(colType)) {
      colInputValue = "FROM_BASE64('" + valuesJson.getString(colName) + "')";
    } else {
      colInputValue = valuesJson.getString(colName);
    }
    String response =
        getColumnValueByType(
            sourceColDef.getType().getName(), colInputValue, sourceDbTimezoneOffset, colType);
    return response;
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/MySQLDMLGenerator.java [355:382]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private static String getMappedColumnValue(
      SpannerColumnDefinition spannerColDef,
      SourceColumnDefinition sourceColDef,
      JSONObject valuesJson,
      String sourceDbTimezoneOffset) {

    String colInputValue = "";
    String colType = spannerColDef.getType().getName();
    String colName = spannerColDef.getName();
    if ("FLOAT64".equals(colType)) {
      colInputValue = valuesJson.getBigDecimal(colName).toString();
    } else if ("BOOL".equals(colType)) {
      colInputValue = (new Boolean(valuesJson.getBoolean(colName))).toString();
    } else if ("STRING".equals(colType) && spannerColDef.getType().getIsArray()) {
      colInputValue =
          valuesJson.getJSONArray(colName).toList().stream()
              .map(String::valueOf)
              .collect(Collectors.joining(","));
    } else if ("BYTES".equals(colType)) {
      colInputValue = "FROM_BASE64('" + valuesJson.getString(colName) + "')";
    } else {
      colInputValue = valuesJson.getString(colName);
    }
    String response =
        getColumnValueByType(
            sourceColDef.getType().getName(), colInputValue, sourceDbTimezoneOffset, colType);
    return response;
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -