Skip to content

Commit 56d8382

Browse files
committed
modify as alias exception prompt
1 parent 396b5b2 commit 56d8382

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

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

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -163,10 +163,17 @@ private static void rebuildSelectNode(SqlNodeList selectList, SqlSelect sqlSelec
163163

164164
for (int index = 0; index < selectList.size(); index++) {
165165
if (selectList.get(index).getKind().equals(SqlKind.AS)
166-
|| ((SqlIdentifier) selectList.get(index)).names.size() == 1) {
166+
|| (selectList.get(index).getClass().equals(SqlIdentifier.class)
167+
&& ((SqlIdentifier) selectList.get(index)).names.size() == 1)) {
167168
sqlNodes.add(selectList.get(index));
168169
continue;
169170
}
171+
172+
if (!selectList.get(index).getClass().equals(SqlIdentifier.class)) {
173+
throw new RuntimeException(String.format("Illegal statement! Please check the statement: %s",
174+
selectList.get(index).toString()));
175+
}
176+
170177
sqlNodes.add(transformToAsNode(selectList.get(index)));
171178
}
172179
sqlSelect.setSelectList(sqlNodes);

0 commit comments

Comments
 (0)