别名优化

Author: zoudaokoulife

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

@@ -93,6 +93,6 @@ public String getTargetFieldName(String tableName, String fieldName){
             return null;
         }
 
-        return mappingTable.get(preNode.getTargetTableName(), preNodeTargetFieldName);
+        return mappingTable.get(preNode.getTargetTableAlias(), preNodeTargetFieldName);
     }
 }

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

@@ -246,6 +246,7 @@ private JoinInfo dealJoinNode(SqlJoin joinNode, Set<String> sideTableSet, Queue<
             //处理连续join
             SqlBasicCall sqlBasicCall = dealNestJoin((SqlJoin) leftNode, sideTableSet, queueInfo);
             leftTbName = sqlBasicCall.getOperands()[0].toString();
+            leftTbAlias = sqlBasicCall.getOperands()[1].toString();
             leftTbisTmp = true;
         } else if (leftNode.getKind() == AS) {
             AliasInfo aliasInfo = (AliasInfo) parseSql(leftNode, sideTableSet, queueInfo);

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

@@ -24,6 +24,7 @@
 import com.dtstack.flink.sql.util.DtStringUtil;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
+import org.apache.commons.lang3.StringUtils;
 
 import java.util.List;
 import java.util.Map;
@@ -85,6 +86,10 @@ public void parseFieldsInfo(String fieldsInfo, TableInfo tableInfo){
         for(String fieldRow : fieldRows){
             fieldRow = fieldRow.trim();
 
+            if(StringUtils.isBlank(fieldRow)){
+                throw new RuntimeException(String.format("table [%s],exists field empty.", tableInfo.getName()));
+            }
+
             String[] filedInfoArr = fieldRow.split("\\s+");
             if(filedInfoArr.length < 2 ){
                 throw new RuntimeException(String.format("table [%s] field [%s] format error.", tableInfo.getName(), fieldRow));