1
0
life 1 жил өмнө
parent
commit
7b769b3bfd

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

@@ -79,6 +79,9 @@ public class OracleColumnValue extends AbstractColumnValue<Expression> {
 
 
     @Override
     @Override
     public BigDecimal asBigDecimal() {
     public BigDecimal asBigDecimal() {
+        if (asString() == null){
+            return null;
+        }
         return new BigDecimal(asString());
         return new BigDecimal(asString());
     }
     }
 
 
@@ -119,6 +122,7 @@ public class OracleColumnValue extends AbstractColumnValue<Expression> {
                     return toDate(value);
                     return toDate(value);
                 case "TO_TIMESTAMP":
                 case "TO_TIMESTAMP":
                     return toTimestamp(value);
                     return toTimestamp(value);
+
             }
             }
         } catch (Exception e) {
         } catch (Exception e) {
             logger.error(e.getMessage(), e);
             logger.error(e.getMessage(), e);
@@ -133,7 +137,11 @@ public class OracleColumnValue extends AbstractColumnValue<Expression> {
 
 
     @Override
     @Override
     public BigInteger asBigInteger() {
     public BigInteger asBigInteger() {
-        return new BigInteger(asString());
+        Object ob = asString();
+        if (ob == null){
+            return null;
+        }
+        return new BigInteger(ob.toString());
     }
     }
 
 
     private Timestamp toDate(Object value) {
     private Timestamp toDate(Object value) {
@@ -143,4 +151,5 @@ public class OracleColumnValue extends AbstractColumnValue<Expression> {
     private Timestamp toTimestamp(Object value) {
     private Timestamp toTimestamp(Object value) {
         return DateFormatUtil.stringToTimestamp(StringUtil.replace(Objects.toString(value), StringUtil.POINT, StringUtil.EMPTY));
         return DateFormatUtil.stringToTimestamp(StringUtil.replace(Objects.toString(value), StringUtil.POINT, StringUtil.EMPTY));
     }
     }
+
 }
 }