修复oracle精度对不同java类型问题

dbsyncer-connector/dbsyncer-connector-oracle/src/main/java/org/dbsyncer/connector/oracle/logminer/parser/AbstractParser.java

@@ -58,8 +58,7 @@ public abstract class AbstractParser implements Parser {
                     columnMap.get(field.getName()));
             switch (field.getType()) {
                 case Types.NUMERIC:
-                case Types.BIGINT:
-                    data.add(oracleColumnValue.asBigInteger());
+                    data.add(convertNumber(oracleColumnValue,field));
                     break;
                 case Types.DECIMAL:
                     data.add(oracleColumnValue.asBigDecimal());
@@ -79,6 +78,24 @@ public abstract class AbstractParser implements Parser {
         return data;
     }
 
+    private Object convertNumber(OracleColumnValue oracleColumnValue,Field field) {
+        if (field.getRatio() <=0){
+            int result =field.getColumnSize() - field.getRatio();
+            if ( result <10){
+                return oracleColumnValue.asInteger();
+            }
+            if (result <19){
+                return oracleColumnValue.asBigInteger();
+            }
+            if (result <39){
+                return oracleColumnValue.asBigDecimal();
+            }
+            return oracleColumnValue.asString();
+        }else{
+            return oracleColumnValue.asBigDecimal();
+        }
+    }
+
 
     public void setFields(List<Field> fields) {
         this.fields = fields;

dbsyncer-connector/dbsyncer-connector-oracle/src/main/java/org/dbsyncer/connector/oracle/logminer/parser/OracleColumnValue.java

@@ -54,6 +54,9 @@ public class OracleColumnValue extends AbstractColumnValue<Expression> {
 
     @Override
     public Integer asInteger() {
+        if (asString() == null){
+            return null;
+        }
        return Integer.valueOf(asString());
     }
 

dbsyncer-sdk/src/main/java/org/dbsyncer/sdk/model/Field.java

@@ -135,6 +135,22 @@ public class Field {
         return this;
     }
 
+    public int getColumnSize() {
+        return columnSize;
+    }
+
+    public void setColumnSize(int columnSize) {
+        this.columnSize = columnSize;
+    }
+
+    public int getRatio() {
+        return ratio;
+    }
+
+    public void setRatio(int ratio) {
+        this.ratio = ratio;
+    }
+
     @Override
     public String toString() {
         return JsonUtil.objToJson(this);