[Fix] fix time type convert (DataLinkDC#3348)

Co-authored-by: Zzm0809 <[email protected]>
Zzm0809 · Apr 2, 2024 · 66ae4f2 · 66ae4f2
1 parent 43c3a55
commit 66ae4f2
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/AbstractSinkBuilder.java b/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/AbstractSinkBuilder.java
@@ -51,6 +51,7 @@
 import org.apache.flink.table.types.logical.IntType;
 import org.apache.flink.table.types.logical.LogicalType;
 import org.apache.flink.table.types.logical.SmallIntType;
+import org.apache.flink.table.types.logical.TimeType;
 import org.apache.flink.table.types.logical.TimestampType;
 import org.apache.flink.table.types.logical.TinyIntType;
 import org.apache.flink.table.types.logical.VarBinaryType;
@@ -335,6 +336,9 @@ public LogicalType getLogicalType(Column column) {
             case INT:
             case INTEGER:
                 return new IntType();
+            case TIME:
+            case LOCALTIME:
+                return new TimeType(column.isNullable(), column.getPrecision() == null ? 0 : column.getPrecision());
             case DATE:
             case LOCAL_DATE:
                 return new DateType();

diff --git a/...ata/dinky-metadata-oracle/src/main/java/org/dinky/metadata/convert/OracleTypeConvert.java b/...ata/dinky-metadata-oracle/src/main/java/org/dinky/metadata/convert/OracleTypeConvert.java
@@ -36,6 +36,7 @@ public OracleTypeConvert() {
         this.convertMap.clear();
         register("char", ColumnType.STRING);
         register("date", ColumnType.LOCAL_DATETIME);
+        register("time", ColumnType.TIME);
         register("timestamp", ColumnType.TIMESTAMP);
         register("number", OracleTypeConvert::convertNumber);
         register("float", ColumnType.JAVA_LANG_FLOAT);