bigint unsigned

Author: todd5167

pom.xml

@@ -10,19 +10,19 @@
     <url>http://maven.apache.org</url>
     <modules>
         <module>core</module>
-        <module>kafka09</module>
-        <module>kafka10</module>
+        <!--<module>kafka09</module>-->
+        <!--<module>kafka10</module>-->
         <module>kafka11</module>
         <module>mysql</module>
-        <module>hbase</module>
-        <module>elasticsearch5</module>
-        <module>mongo</module>
-        <module>redis5</module>
+        <!--<module>hbase</module>-->
+        <!--<module>elasticsearch5</module>-->
+        <!--<module>mongo</module>-->
+        <!--<module>redis5</module>-->
         <module>launcher</module>
         <module>rdb</module>
-        <module>sqlserver</module>
-        <module>oracle</module>
-        <module>cassandra</module>
+        <!--<module>sqlserver</module>-->
+        <!--<module>oracle</module>-->
+        <!--<module>cassandra</module>-->
     </modules>
 
 

rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/util/MathUtil.java

@@ -48,6 +48,8 @@ public static Long getLongVal(Object obj) {
             return Long.valueOf(obj.toString());
         } else if (obj instanceof BigDecimal) {
             return ((BigDecimal) obj).longValue();
+        } else if (obj instanceof BigInteger) {
+            return ((BigInteger) obj).longValue();
         }
 
         throw new RuntimeException("not support type of " + obj.getClass() + " convert to Long.");

rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/util/SwitchUtil.java

@@ -42,6 +42,7 @@ public static Object getTarget(Object obj, String targetType) {
                 return MathUtil.getIntegerVal(obj);
 
             case "bigint":
+            case "bigintunsigned":
             case "intunsigned":
             case "integerunsigned":
                 return MathUtil.getLongVal(obj);