diff --git a/sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/reader/AbstractJdbcReader.java b/sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/reader/AbstractJdbcReader.java index 29dbd8f06146d296b2c1202bfc70193fa360acb5..8684a140b44403f866c7bc79954c0e37e6553b15 100755 --- a/sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/reader/AbstractJdbcReader.java +++ b/sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/reader/AbstractJdbcReader.java @@ -89,7 +89,8 @@ public abstract class AbstractJdbcReader extends AbstractRunner implements JdbcR record.setType("bootstrap-insert"); record.setFullTableName(String.format("%s.%s", conn.getCatalog(), rdbmsConfiguration.getTableName())); for (int i = 1; i <= metaData.getColumnCount(); i++) { - if (Types.TIME == rs.getMetaData().getColumnType(i)) { + if (Types.TIME == rs.getMetaData().getColumnType(i) + || Types.DATE == rs.getMetaData().getColumnType(i)) { // fix: jdbc Time objects represent a wall-clock time and not a duration as MySQL treats them record.addColumn(new Column(rs.getString(i), true)); } else {