优化日志及异常提示

Author: FlechazoW

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

@@ -170,6 +170,10 @@ private static void rebuildSelectNode(SqlNodeList selectList, SqlSelect sqlSelec
             }
 
             if (!selectList.get(index).getClass().equals(SqlIdentifier.class)) {
+                if (selectList.get(index).getKind().equals(SqlKind.LITERAL)) {
+                    throw new IllegalArgumentException(String.format("Constants %s in the SELECT statement must be aliased!",
+                            selectList.get(index).toString()));
+                }
                 throw new RuntimeException(String.format("Illegal statement! Please check the statement: %s",
                         selectList.get(index).toString()));
             }

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

@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
- 
+
 
 package com.dtstack.flink.sql.parser;
 
@@ -27,6 +27,8 @@
 import org.apache.commons.lang3.StringUtils;
 import com.google.common.collect.Lists;
 import com.google.common.base.Strings;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -42,6 +44,7 @@
  */
 
 public class SqlParser {
+    private static final Logger LOG = LoggerFactory.getLogger(SqlParser.class);
 
     private static final char SQL_DELIMITER = ';';
 
@@ -84,13 +87,18 @@ public static SqlTree parseSql(String sql, String pluginLoadMode) throws Excepti
             }
             boolean result = false;
             for(IParser sqlParser : sqlParserList){
-                if(!sqlParser.verify(childSql)){
-                    continue;
-                }
+                try {
+                    if (!sqlParser.verify(childSql)) {
+                        continue;
+                    }
 
-                sqlParser.parseSql(childSql, sqlTree);
-                result = true;
-                break;
+                    sqlParser.parseSql(childSql, sqlTree);
+                    result = true;
+                    break;
+                } catch (Exception e) {
+                    LOG.error("'{}' parser error, detail info: {}", childSql, e.getMessage(), e);
+                    throw e;
+                }
             }
 
             if(!result){