version 2.0.0

lib/lib/flinkParser.js

@@ -20,6 +20,9 @@ class SqlErrorListener extends error_1.ErrorListener {
     }
 }
 function parserSingle(sql) {
+    if (!sql || !sql.trim()) {
+        return null;
+    }
     const inputStream = new antlr4.InputStream(sql.toUpperCase());
     const lexer = new sqlLexer_1.sqlLexer(inputStream);
     const tokenStream = new antlr4.CommonTokenStream(lexer);

lib/lib/parser.js

@@ -9,6 +9,7 @@ var sqlType;
     sqlType["None"] = "sql";
     sqlType["Impala"] = "impala";
 })(sqlType || (sqlType = {}));
+exports.sqlType = sqlType;
 function sqlToParserArgs(sql) {
     let preSql = '', sufSql = '';
     if (Object.prototype.toString.call(sql) == '[object Array]') {