Browse Source

支持date转换字符类型

Signed-off-by: AE86 <836391306@qq.com>
AE86 2 years ago
parent
commit
45bf6dcc8d

+ 5 - 0
dbsyncer-connector/src/main/java/org/dbsyncer/connector/schema/LongVarcharValueMapper.java

@@ -4,6 +4,8 @@ import org.dbsyncer.connector.AbstractValueMapper;
 import org.dbsyncer.connector.ConnectorException;
 import org.dbsyncer.connector.ConnectorMapper;
 
+import java.sql.Date;
+
 /**
  * @author AE86
  * @version 1.0.0
@@ -16,6 +18,9 @@ public class LongVarcharValueMapper extends AbstractValueMapper<String> {
         if (val instanceof byte[]) {
             return new String((byte[]) val);
         }
+        if (val instanceof Date) {
+            return String.valueOf(val);
+        }
         throw new ConnectorException(String.format("%s can not find type [%s], val [%s]", getClass().getSimpleName(), val.getClass(), val));
     }
 }