Skip to content

Commit be12caa

Browse files
author
yanxi0227
committed
the value is case sensitive
1 parent 72df82e commit be12caa

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020

2121
package com.dtstack.flink.sql.parser;
2222

23+
import com.dtstack.flink.sql.util.DtStringUtil;
2324
import org.apache.calcite.sql.*;
2425
import org.apache.calcite.sql.parser.SqlParseException;
2526
import org.apache.calcite.sql.parser.SqlParser;
@@ -77,7 +78,8 @@ public void parseSql(String sql, SqlTree sqlTree) {
7778
parseNode(sqlNode, sqlParseResult);
7879

7980
sqlParseResult.setTableName(tableName);
80-
sqlParseResult.setExecSql(selectSql.toUpperCase());
81+
String transformSelectSql = DtStringUtil.replaceIgnoreQuota(sqlNode.toString(), "`", "");
82+
sqlParseResult.setExecSql(transformSelectSql);
8183
sqlTree.addTmpSql(sqlParseResult);
8284
sqlTree.addTmplTableInfo(tableName, sqlParseResult);
8385
} else {

0 commit comments

Comments
 (0)