Skip to content

Commit 3a3bf1c

Browse files
committed
fix redmine 27343
1 parent 31f1ea1 commit 3a3bf1c

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

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

+3-2
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@
1616
* limitations under the License.
1717
*/
1818

19-
2019

2120
package com.dtstack.flink.sql.parser;
2221

@@ -153,14 +152,16 @@ private static void parseNode(SqlNode sqlNode, SqlParseResult sqlParseResult){
153152

154153
/**
155154
* 将第一层 select 中的 sqlNode 转化为 AsNode,解决字段名冲突问题
155+
* 仅对 table.xx 这种类型的字段进行替换
156156
* @param selectList select Node 的 select 字段
157157
* @param sqlSelect 第一层解析出来的 selectNode
158158
*/
159159
private static void rebuildSelectNode(SqlNodeList selectList, SqlSelect sqlSelect) {
160160
SqlNodeList sqlNodes = new SqlNodeList(selectList.getParserPosition());
161161

162162
for (int index = 0; index < selectList.size(); index++) {
163-
if (selectList.get(index).getKind().equals(SqlKind.AS)) {
163+
if (selectList.get(index).getKind().equals(SqlKind.AS)
164+
|| ((SqlIdentifier) selectList.get(index)).names.size() == 1) {
164165
sqlNodes.add(selectList.get(index));
165166
continue;
166167
}

0 commit comments

Comments
 (0)