Browse Source

支持PGobject转字符串

Signed-off-by: AE86 <836391306@qq.com>
AE86 1 year ago
parent
commit
8fbeadb303

+ 6 - 0
dbsyncer-connector/src/main/java/org/dbsyncer/connector/schema/VarcharValueMapper.java

@@ -4,6 +4,7 @@ import org.dbsyncer.common.spi.ConnectorMapper;
 import org.dbsyncer.common.util.DateFormatUtil;
 import org.dbsyncer.connector.AbstractValueMapper;
 import org.dbsyncer.connector.ConnectorException;
+import org.postgresql.util.PGobject;
 
 import java.sql.Date;
 import java.time.LocalDate;
@@ -43,6 +44,11 @@ public class VarcharValueMapper extends AbstractValueMapper<String> {
             return DateFormatUtil.dateToString((java.util.Date) val);
         }
 
+        if (val instanceof PGobject) {
+            PGobject pgObject = (PGobject) val;
+            return pgObject.getValue();
+        }
+
         throw new ConnectorException(String.format("%s can not find type [%s], val [%s]", getClass().getSimpleName(), val.getClass(), val));
     }
 }