parse unsigned

Author: todd5167

.gitignore

@@ -10,6 +10,7 @@ target/
 plugins/
 lib/
 .vertx/
+.DS_Store
 bin/nohup.out
 
 bin/sideSql.txt

core/src/main/java/com/dtstack/flink/sql/util/ClassUtil.java

@@ -39,10 +39,14 @@ public static Class<?> stringConvertClass(String str) {
             case "bit":
                 return Boolean.class;
 
+            case "smallint":
+            case "smallintunsigned":
+            case "tinyint":
+            case "tinyintunsigned":
+            case "mediumint":
+            case "mediumintunsigned":
             case "integer":
             case "int":
-            case "mediumint":
-            case "tinyint":
                 return Integer.class;
 
             case "blob":
@@ -51,21 +55,22 @@ public static Class<?> stringConvertClass(String str) {
             case "bigint":
             case "intunsigned":
             case "integerunsigned":
+            case "bigintunsigned":
                 return Long.class;
 
-            case "smallint":
-                return Short.class;
-
             case "varchar":
             case "char":
             case "text":
                 return String.class;
 
             case "real":
             case "float":
+            case "realunsigned":
+            case "floatunsigned":
                 return Float.class;
 
             case "double":
+            case "doubleunsigned":
                 return Double.class;
 
             case "date":
@@ -79,6 +84,7 @@ public static Class<?> stringConvertClass(String str) {
                 return Time.class;
 
             case "decimal":
+            case "decimalunsigned":
                 return BigDecimal.class;
 
         }

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

@@ -31,10 +31,14 @@ public static Object getTarget(Object obj, String targetType) {
         targetType = targetType.toLowerCase();
         switch (targetType) {
 
+            case "smallint":
+            case "smallintunsigned":
             case "tinyint":
-            case "int":
-            case "integer":
+            case "tinyintunsigned":
             case "mediumint":
+            case "mediumintunsigned":
+            case "integer":
+            case "int":
                 return MathUtil.getIntegerVal(obj);
 
             case "bigint":
@@ -48,22 +52,23 @@ public static Object getTarget(Object obj, String targetType) {
             case "blob":
                 return MathUtil.getByte(obj);
 
-            case "smallint":
-                return MathUtil.getShort(obj);
-
             case "varchar":
             case "char":
             case "text":
                 return MathUtil.getString(obj);
 
             case "real":
             case "float":
+            case "realunsigned":
+            case "floatunsigned":
                 return MathUtil.getFloatVal(obj);
 
             case "double":
+            case "doubleunsigned":
                 return MathUtil.getDoubleVal(obj);
 
             case "decimal":
+            case "decimalunsigned":
                 return MathUtil.getBigDecimal(obj);
 
             case "date":