diff --git a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/RowsLogBuffer.java b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/RowsLogBuffer.java index 1905a627..75f560dd 100644 --- a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/RowsLogBuffer.java +++ b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/RowsLogBuffer.java @@ -163,10 +163,13 @@ public final class RowsLogBuffer { case LogEvent.MYSQL_TYPE_TIMESTAMP: case LogEvent.MYSQL_TYPE_DATETIME: + case LogEvent.MYSQL_TYPE_TIMESTAMP2: + case LogEvent.MYSQL_TYPE_DATETIME2: javaType = Types.TIMESTAMP; break; case LogEvent.MYSQL_TYPE_TIME: + case LogEvent.MYSQL_TYPE_TIME2: javaType = Types.TIME; break;