Merge branch '1.5_v3.6.0' into v1.5.0_dev

# Conflicts:
#	core/src/main/java/com/dtstack/flink/sql/Main.java
#	core/src/main/java/com/dtstack/flink/sql/side/SideSqlExec.java

Author: zoudaokoulife

.gitignore

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

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,38 +36,55 @@ public class ClassUtil {
     public static Class<?> stringConvertClass(String str) {
         switch (str.toLowerCase()) {
             case "boolean":
+            case "bit":
                 return Boolean.class;
 
+            case "smallint":
+            case "smallintunsigned":
+            case "tinyint":
+            case "tinyintunsigned":
+            case "mediumint":
+            case "mediumintunsigned":
             case "integer":
             case "int":
                 return Integer.class;
 
-            case "bigint":
-                return Long.class;
-
-            case "tinyint":
+            case "blob":
                 return Byte.class;
 
-            case "smallint":
-                return Short.class;
+            case "bigint":
+            case "intunsigned":
+            case "integerunsigned":
+            case "bigintunsigned":
+                return Long.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":
                 return Date.class;
 
+            case "datetime":
             case "timestamp":
                 return Timestamp.class;
 
+            case "time":
+                return Time.class;
+
             case "decimal":
+            case "decimalunsigned":
                 return BigDecimal.class;
 
         }

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

@@ -57,13 +57,16 @@ public static List<String> splitIgnoreQuota(String str, char delimiter){
         List<String> tokensList = new ArrayList<>();
         boolean inQuotes = false;
         boolean inSingleQuotes = false;
+        int bracketLeftNum = 0;
         StringBuilder b = new StringBuilder();
         for (char c : str.toCharArray()) {
             if(c == delimiter){
                 if (inQuotes) {
                     b.append(c);
                 } else if(inSingleQuotes){
                     b.append(c);
+                } else if(bracketLeftNum > 0){
+                    b.append(c);
                 }else {
                     tokensList.add(b.toString());
                     b = new StringBuilder();
@@ -74,6 +77,12 @@ public static List<String> splitIgnoreQuota(String str, char delimiter){
             }else if(c == '\''){
                 inSingleQuotes = !inSingleQuotes;
                 b.append(c);
+            }else if(c == '('){
+                bracketLeftNum++;
+                b.append(c);
+            }else if(c == ')'){
+                bracketLeftNum--;
+                b.append(c);
             }else{
                 b.append(c);
             }

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

@@ -30,29 +30,52 @@ public class SwitchUtil {
     public static Object getTarget(Object obj, String targetType) {
         targetType = targetType.toLowerCase();
         switch (targetType) {
-            case "int":
+
+            case "smallint":
+            case "smallintunsigned":
+            case "tinyint":
+            case "tinyintunsigned":
+            case "mediumint":
+            case "mediumintunsigned":
             case "integer":
+            case "int":
                 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":
+            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":
                 return MathUtil.getDate(obj);
+
             case "timestamp":
+            case "datetime":
                 return MathUtil.getTimestamp(obj);
         }
         return obj;