修复对join过程中未取别名解析bug

xuchao · xuchao · commit 0b241599be00 · 2020-03-30T17:35:48.000+08:00
diff --git a/core/src/main/java/com/dtstack/flink/sql/side/JoinNodeDealer.java b/core/src/main/java/com/dtstack/flink/sql/side/JoinNodeDealer.java
@@ -114,6 +114,9 @@ public JoinInfo dealJoinNode(SqlJoin joinNode,
             AliasInfo aliasInfo = (AliasInfo) sideSQLParser.parseSql(leftNode, sideTableSet, queueInfo, parentWhere, parentSelectList, parentGroupByList);
             leftTbName = aliasInfo.getName();
             leftTbAlias = aliasInfo.getAlias();
+        } else if(leftNode.getKind() == IDENTIFIER){
+            leftTbName = leftNode.toString();
+            leftTbAlias = leftTbName;
         }
 
         boolean leftIsSide = checkIsSideTable(leftTbName, sideTableSet);

Original file line number	Diff line number	Diff line change
`@@ -114,6 +114,9 @@ public JoinInfo dealJoinNode(SqlJoin joinNode,`
`114`	`114`	`AliasInfo aliasInfo = (AliasInfo) sideSQLParser.parseSql(leftNode, sideTableSet, queueInfo, parentWhere, parentSelectList, parentGroupByList);`
`115`	`115`	`leftTbName = aliasInfo.getName();`
`116`	`116`	`leftTbAlias = aliasInfo.getAlias();`
	`117`	`+ } else if(leftNode.getKind() == IDENTIFIER){`
	`118`	`+ leftTbName = leftNode.toString();`
	`119`	`+ leftTbAlias = leftTbName;`
`117`	`120`	`}`
`118`	`121`
`119`	`122`	`boolean leftIsSide = checkIsSideTable(leftTbName, sideTableSet);`