case upper and lower 2

Author: todd5167

core/src/main/java/com/dtstack/flink/sql/Main.java

@@ -191,7 +191,7 @@ public static void main(String[] args) throws Exception {
                             .configBuilder()
                             .setLex(Lex.MYSQL)
                             .build();
-                    SqlNode sqlNode = org.apache.calcite.sql.parser.SqlParser.create(realSql).parseStmt();
+                    SqlNode sqlNode = org.apache.calcite.sql.parser.SqlParser.create(realSql,config).parseStmt();
                     String tmpSql = ((SqlInsert) sqlNode).getSource().toString();
                     tmp.setExecSql(tmpSql);
                     sideSqlExec.registerTmpTable(tmp, sideTableMap, tableEnv, registerTableCache);
@@ -252,7 +252,7 @@ private static void registerUDF(SqlTree sqlTree, List<URL> jarURList, URLClassLo
                 classLoader = FlinkUtil.loadExtraJar(jarURList, parentClassloader);
             }
             classLoader.loadClass(funcInfo.getClassName());
-            FlinkUtil.registerUDF(funcInfo.getType(), funcInfo.getClassName(), funcInfo.getName().toUpperCase(),
+            FlinkUtil.registerUDF(funcInfo.getType(), funcInfo.getClassName(), funcInfo.getName(),
                     tableEnv, classLoader);
         }
     }

core/src/main/java/com/dtstack/flink/sql/parser/CreateTableParser.java

@@ -54,7 +54,7 @@ public boolean verify(String sql) {
     public void parseSql(String sql, SqlTree sqlTree) {
         Matcher matcher = PATTERN.matcher(sql);
         if(matcher.find()){
-            String tableName = matcher.group(1).toUpperCase();
+            String tableName = matcher.group(1);
             String fieldsInfoStr = matcher.group(2);
             String propsStr = matcher.group(3);
             Map<String, Object> props = parseProp(propsStr);

core/src/main/java/com/dtstack/flink/sql/parser/CreateTmpTableParser.java

@@ -63,7 +63,7 @@ public void parseSql(String sql, SqlTree sqlTree) {
             String tableName = null;
             String selectSql = null;
             if(matcher.find()) {
-                tableName = matcher.group(1).toUpperCase();
+                tableName = matcher.group(1);
                 selectSql = "select " + matcher.group(2);
             }
             SqlParser.Config config = SqlParser
@@ -93,7 +93,7 @@ public void parseSql(String sql, SqlTree sqlTree) {
                 String tableName = null;
                 String fieldsInfoStr = null;
                 if (matcher.find()){
-                    tableName = matcher.group(1).toUpperCase();
+                    tableName = matcher.group(1);
                     fieldsInfoStr = matcher.group(2);
                 }
                 CreateTmpTableParser.SqlParserResult sqlParseResult = new CreateTmpTableParser.SqlParserResult();

core/src/main/java/com/dtstack/flink/sql/side/SideSQLParser.java

@@ -53,7 +53,6 @@
 public class SideSQLParser {
 
     public Queue<Object> getExeQueue(String exeSql, Set<String> sideTableSet) throws SqlParseException {
-        exeSql = DtStringUtil.replaceIgnoreQuota(exeSql, "`", "");
         System.out.println("---exeSql---");
         System.out.println(exeSql);
         Queue<Object> queueInfo = Queues.newLinkedBlockingQueue();

core/src/main/java/com/dtstack/flink/sql/side/SideSqlExec.java

@@ -645,7 +645,7 @@ private boolean checkFieldsInfo(CreateTmpTableParser.SqlParserResult result, Tab
                 String[] filedNameArr = new String[filed.length - 1];
                 System.arraycopy(filed, 0, filedNameArr, 0, filed.length - 1);
                 String fieldName = String.join(" ", filedNameArr);
-                fieldNames.add(fieldName.toUpperCase());
+                fieldNames.add(fieldName);
                 String fieldType = filed[filed.length - 1 ].trim();
                 Class fieldClass = ClassUtil.stringConvertClass(fieldType);
                 Class tableField = table.getSchema().getType(i).get().getTypeClass();

core/src/main/java/com/dtstack/flink/sql/table/AbsTableParser.java

@@ -82,10 +82,6 @@ public void parseFieldsInfo(String fieldsInfo, TableInfo tableInfo){
         String[] fieldRows = DtStringUtil.splitIgnoreQuotaBrackets(fieldsInfo, ",");
         for(String fieldRow : fieldRows){
             fieldRow = fieldRow.trim();
-            if(fieldNameNeedsUpperCase()) {
-                fieldRow = fieldRow.toUpperCase();
-            }
-
             boolean isMatcherKey = dealKeyPattern(fieldRow, tableInfo);
 
             if(isMatcherKey){