integer unsigned parse

Author: todd5167

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

@@ -22,6 +22,7 @@
 
 import java.math.BigDecimal;
 import java.sql.Date;
+import java.sql.Time;
 import java.sql.Timestamp;
 
 /**
@@ -35,22 +36,29 @@ public class ClassUtil {
     public static Class<?> stringConvertClass(String str) {
         switch (str.toLowerCase()) {
             case "boolean":
+            case "bit":
                 return Boolean.class;
 
             case "integer":
             case "int":
+            case "mediumint":
+            case "tinyint":
                 return Integer.class;
 
+            case "blob":
+                return Byte.class;
+
             case "bigint":
+            case "intunsigned":
+            case "integerunsigned":
                 return Long.class;
 
-            case "tinyint":
-                return Byte.class;
-
             case "smallint":
                 return Short.class;
 
             case "varchar":
+            case "char":
+            case "text":
                 return String.class;
 
             case "real":
@@ -63,9 +71,13 @@ public static Class<?> stringConvertClass(String str) {
             case "date":
                 return Date.class;
 
+            case "datetime":
             case "timestamp":
                 return Timestamp.class;
 
+            case "time":
+                return Time.class;
+
             case "decimal":
                 return BigDecimal.class;
 

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

@@ -30,29 +30,47 @@ public class SwitchUtil {
     public static Object getTarget(Object obj, String targetType) {
         targetType = targetType.toLowerCase();
         switch (targetType) {
+
+            case "tinyint":
             case "int":
             case "integer":
+            case "mediumint":
                 return MathUtil.getIntegerVal(obj);
+
             case "bigint":
+            case "intunsigned":
+            case "integerunsigned":
                 return MathUtil.getLongVal(obj);
+
             case "boolean":
                 return MathUtil.getBoolean(obj);
-            case "tinyint":
+
+            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":
                 return MathUtil.getFloatVal(obj);
+
             case "double":
                 return MathUtil.getDoubleVal(obj);
+
             case "decimal":
                 return MathUtil.getBigDecimal(obj);
+
             case "date":
                 return MathUtil.getDate(obj);
+
             case "timestamp":
+            case "datetime":
                 return MathUtil.getTimestamp(obj);
         }
         return obj;