modify support create table field type(for match standard SQL)

Author: zoudaokoulife

README.md

@@ -139,9 +139,9 @@ sh submit.sh -sql D:\sideSql.txt  -name xctest -remoteSqlPluginPath /opt/dtstack
 
 ```
 CREATE TABLE MyTable(
-    name string,
-    channel STRING,
-    pv INT,
+    name varchar,
+    channel varchar,
+    pv int,
     xctime bigint,
     CHARACTER_LENGTH(channel) AS timeLeng
  )WITH(
@@ -154,8 +154,8 @@ CREATE TABLE MyTable(
  );
 
 CREATE TABLE MyResult(
-    channel VARCHAR,
-    pv VARCHAR
+    channel varchar,
+    pv varchar
  )WITH(
     type ='mysql',
     url ='jdbc:mysql://172.16.8.104:3306/test?charset=utf8',
@@ -166,8 +166,8 @@ CREATE TABLE MyResult(
  );
 
 CREATE TABLE workerinfo(
-    cast(logtime as TIMESTAMP)AS rtime,
-    cast(logtime)AS rtime
+    cast(logtime as TIMESTAMP) AS rtime,
+    cast(logtime) AS rtime
  )WITH(
     type ='hbase',
     zookeeperQuorum ='rdos1:2181',
@@ -178,8 +178,8 @@ CREATE TABLE workerinfo(
  );
 
 CREATE TABLE sideTable(
-    cf:name String as name,
-    cf:info String as info,
+    cf:name varchar as name,
+    cf:info varchar as info,
     PRIMARY KEY(name),
     PERIOD FOR SYSTEM_TIME
  )WITH(

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

@@ -20,6 +20,7 @@
 
 package com.dtstack.flink.sql.util;
 
+import java.math.BigDecimal;
 import java.sql.Date;
 import java.sql.Timestamp;
 
@@ -35,25 +36,24 @@ public static Class<?> stringConvertClass(String str) {
         switch (str.toLowerCase()) {
             case "boolean":
                 return Boolean.class;
+
+            case "integer":
             case "int":
                 return Integer.class;
 
             case "bigint":
                 return Long.class;
 
             case "tinyint":
-            case "byte":
                 return Byte.class;
 
-            case "short":
             case "smallint":
                 return Short.class;
 
-            case "char":
             case "varchar":
-            case "string":
                 return String.class;
 
+            case "real":
             case "float":
                 return Float.class;
 
@@ -66,6 +66,9 @@ public static Class<?> stringConvertClass(String str) {
             case "timestamp":
                 return Timestamp.class;
 
+            case "decimal":
+                return BigDecimal.class;
+
         }
 
         throw new RuntimeException("不支持 " + str + " 类型");

docs/colType.md

@@ -2,15 +2,14 @@
 | ------ | ----- |
 | boolean    | Boolean |
 | int        | Integer |
+| integer| Integer |
 | bigint     | Long |
 | tinyint    | Byte |
-| byte       | Byte |
-| short | Short | 
 | smallint | Short|
-| char | String|
 | varchar | String |
-| string | String|
+| real | Float |
 | float  | Float|
 | double | Double|
 | date   | Date |
-| timestamp | Timestamp |
+| timestamp | Timestamp |
+| decimal |BigDecimal|