소스 검색

支持BigDecimal同步Tinyint

Signed-off-by: AE86 <836391306@qq.com>
AE86 2 년 전
부모
커밋
8db4fcd013
1개의 변경된 파일6개의 추가작업 그리고 0개의 파일을 삭제
  1. 6 0
      dbsyncer-connector/src/main/java/org/dbsyncer/connector/schema/TinyintValueMapper.java

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

@@ -4,6 +4,8 @@ import org.dbsyncer.common.spi.ConnectorMapper;
 import org.dbsyncer.connector.AbstractValueMapper;
 import org.dbsyncer.connector.AbstractValueMapper;
 import org.dbsyncer.connector.ConnectorException;
 import org.dbsyncer.connector.ConnectorException;
 
 
+import java.math.BigDecimal;
+
 /**
 /**
  * @author AE86
  * @author AE86
  * @version 1.0.0
  * @version 1.0.0
@@ -25,6 +27,10 @@ public class TinyintValueMapper extends AbstractValueMapper<Integer> {
             String s = (String) val;
             String s = (String) val;
             return new Integer(s);
             return new Integer(s);
         }
         }
+        if (val instanceof BigDecimal) {
+            BigDecimal bigDecimal = (BigDecimal) val;
+            return bigDecimal.intValue();
+        }
         throw new ConnectorException(String.format("%s can not find type [%s], val [%s]", getClass().getSimpleName(), val.getClass(), val));
         throw new ConnectorException(String.format("%s can not find type [%s], val [%s]", getClass().getSimpleName(), val.getClass(), val));
     }
     }
 }
 }