支持pgobject类型序列化

dbsyncer-storage/src/main/java/org/dbsyncer/storage/util/BinlogMessageUtil.java

@@ -10,6 +10,7 @@ import org.dbsyncer.storage.StorageException;
 import org.dbsyncer.storage.binlog.BinlogColumnValue;
 import org.dbsyncer.storage.binlog.proto.BinlogMap;
 import org.dbsyncer.storage.enums.BinlogByteEnum;
+import org.postgresql.util.PGobject;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -80,6 +81,9 @@ public abstract class BinlogMessageUtil {
             // 字符串
             case "java.lang.String":
                 return ByteString.copyFromUtf8((String) v);
+            case "org.postgresql.util.PGobject":
+                PGobject pgObject = (PGobject) v;
+                return ByteString.copyFromUtf8(pgObject.getValue());
 
             // 时间
             case "java.sql.Timestamp":