oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/ConcurrentTableWriterTask.java [482:592]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - protected PreparedStatement fillPreparedStatement(PreparedStatement preparedStatement, Record record) throws SQLException { for (int i = 0; i < this.columnNumber; i++) { int columnSqltype = this.resultSetMetaData.getMiddle().get(i); String typeName = this.resultSetMetaData.getRight().get(i); preparedStatement = fillPreparedStatementColumnType(preparedStatement, i, columnSqltype, typeName, record.getColumn(i)); } return preparedStatement; } protected PreparedStatement fillPreparedStatementColumnType(PreparedStatement preparedStatement, int columnIndex, int columnSqltype, String typeName, Column column) throws SQLException { java.util.Date utilDate; switch (columnSqltype) { case Types.CHAR: case Types.NCHAR: case Types.CLOB: case Types.NCLOB: case Types.VARCHAR: case Types.LONGVARCHAR: case Types.NVARCHAR: case Types.LONGNVARCHAR: preparedStatement.setString(columnIndex + 1, column .asString()); break; case Types.SMALLINT: case Types.INTEGER: case Types.BIGINT: case Types.NUMERIC: case Types.DECIMAL: case Types.FLOAT: case Types.REAL: case Types.DOUBLE: String strValue = column.asString(); if (emptyAsNull && "".equals(strValue)) { preparedStatement.setString(columnIndex + 1, null); } else { preparedStatement.setString(columnIndex + 1, strValue); } break; //tinyint is a little special in some database like mysql {boolean->tinyint(1)} case Types.TINYINT: Long longValue = column.asLong(); if (null == longValue) { preparedStatement.setString(columnIndex + 1, null); } else { preparedStatement.setString(columnIndex + 1, longValue.toString()); } break; // for mysql bug, see http://bugs.mysql.com/bug.php?id=35115 case Types.DATE: if (typeName == null) { typeName = this.resultSetMetaData.getRight().get(columnIndex); } if (typeName.equalsIgnoreCase("year")) { if (column.asBigInteger() == null) { preparedStatement.setString(columnIndex + 1, null); } else { preparedStatement.setInt(columnIndex + 1, column.asBigInteger().intValue()); } } else { java.sql.Date sqlDate = null; try { utilDate = column.asDate(); } catch (DataXException e) { throw new SQLException(String.format( "Date 类型转换错误：[%s]", column)); } if (null != utilDate) { sqlDate = new java.sql.Date(utilDate.getTime()); } preparedStatement.setDate(columnIndex + 1, sqlDate); } break; case Types.TIME: java.sql.Time sqlTime = null; try { utilDate = column.asDate(); } catch (DataXException e) { throw new SQLException(String.format( "TIME 类型转换错误：[%s]", column)); } if (null != utilDate) { sqlTime = new java.sql.Time(utilDate.getTime()); } preparedStatement.setTime(columnIndex + 1, sqlTime); break; case Types.TIMESTAMP: java.sql.Timestamp sqlTimestamp = null; try { utilDate = column.asDate(); } catch (DataXException e) { throw new SQLException(String.format( "TIMESTAMP 类型转换错误：[%s]", column)); } if (null != utilDate) { sqlTimestamp = new java.sql.Timestamp( utilDate.getTime()); } preparedStatement.setTimestamp(columnIndex + 1, sqlTimestamp); break; - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/writer/CommonRdbmsWriter.java [412:522]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - protected PreparedStatement fillPreparedStatement(PreparedStatement preparedStatement, Record record) throws SQLException { for (int i = 0; i < this.columnNumber; i++) { int columnSqltype = this.resultSetMetaData.getMiddle().get(i); String typeName = this.resultSetMetaData.getRight().get(i); preparedStatement = fillPreparedStatementColumnType(preparedStatement, i, columnSqltype, typeName, record.getColumn(i)); } return preparedStatement; } protected PreparedStatement fillPreparedStatementColumnType(PreparedStatement preparedStatement, int columnIndex, int columnSqltype, String typeName, Column column) throws SQLException { java.util.Date utilDate; switch (columnSqltype) { case Types.CHAR: case Types.NCHAR: case Types.CLOB: case Types.NCLOB: case Types.VARCHAR: case Types.LONGVARCHAR: case Types.NVARCHAR: case Types.LONGNVARCHAR: preparedStatement.setString(columnIndex + 1, column .asString()); break; case Types.SMALLINT: case Types.INTEGER: case Types.BIGINT: case Types.NUMERIC: case Types.DECIMAL: case Types.FLOAT: case Types.REAL: case Types.DOUBLE: String strValue = column.asString(); if (emptyAsNull && "".equals(strValue)) { preparedStatement.setString(columnIndex + 1, null); } else { preparedStatement.setString(columnIndex + 1, strValue); } break; //tinyint is a little special in some database like mysql {boolean->tinyint(1)} case Types.TINYINT: Long longValue = column.asLong(); if (null == longValue) { preparedStatement.setString(columnIndex + 1, null); } else { preparedStatement.setString(columnIndex + 1, longValue.toString()); } break; // for mysql bug, see http://bugs.mysql.com/bug.php?id=35115 case Types.DATE: if (typeName == null) { typeName = this.resultSetMetaData.getRight().get(columnIndex); } if (typeName.equalsIgnoreCase("year")) { if (column.asBigInteger() == null) { preparedStatement.setString(columnIndex + 1, null); } else { preparedStatement.setInt(columnIndex + 1, column.asBigInteger().intValue()); } } else { java.sql.Date sqlDate = null; try { utilDate = column.asDate(); } catch (DataXException e) { throw new SQLException(String.format( "Date 类型转换错误：[%s]", column)); } if (null != utilDate) { sqlDate = new java.sql.Date(utilDate.getTime()); } preparedStatement.setDate(columnIndex + 1, sqlDate); } break; case Types.TIME: java.sql.Time sqlTime = null; try { utilDate = column.asDate(); } catch (DataXException e) { throw new SQLException(String.format( "TIME 类型转换错误：[%s]", column)); } if (null != utilDate) { sqlTime = new java.sql.Time(utilDate.getTime()); } preparedStatement.setTime(columnIndex + 1, sqlTime); break; case Types.TIMESTAMP: java.sql.Timestamp sqlTimestamp = null; try { utilDate = column.asDate(); } catch (DataXException e) { throw new SQLException(String.format( "TIMESTAMP 类型转换错误：[%s]", column)); } if (null != utilDate) { sqlTimestamp = new java.sql.Timestamp( utilDate.getTime()); } preparedStatement.setTimestamp(columnIndex + 1, sqlTimestamp); break; - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -