Unverified Commit 6833b22a authored by aiwenmo's avatar aiwenmo Committed by GitHub

Fix FlinkSQL last semicolon bug

FlinkSql 校验问题
parents 9fb011ae 9df18f60
...@@ -10,11 +10,20 @@ import com.dlink.assertion.Asserts; ...@@ -10,11 +10,20 @@ import com.dlink.assertion.Asserts;
*/ */
public class SqlUtil { public class SqlUtil {
private static final String SEMICOLON = ";";
public static String[] getStatements(String sql, String sqlSeparator) { public static String[] getStatements(String sql, String sqlSeparator) {
if (Asserts.isNullString(sql)) { if (Asserts.isNullString(sql)) {
return new String[0]; return new String[0];
} }
return sql.split(sqlSeparator);
String[] splits = sql.split(sqlSeparator);
String lastStatement = splits[splits.length - 1].trim();
if (lastStatement.endsWith(SEMICOLON)){
splits[splits.length - 1] = lastStatement.substring(0,lastStatement.length()-1);
}
return splits;
} }
public static String removeNote(String sql) { public static String removeNote(String sql) {
......
...@@ -104,7 +104,7 @@ npm build ...@@ -104,7 +104,7 @@ npm build
Dinky开发环境配置有两种模式,分别是product环境和compile环境 Dinky开发环境配置有两种模式,分别是product环境和compile环境
- product:此环境适合已经存在安装包,可进行远程调试,此模式需要外部环境安装Flink; - product:此环境适合已经存在安装包,可进行远程调试,此模式需要外部环境安装Flink;
- compile:此环境适合二次开发或者熟悉源码,此模式不需要额外安装Flink,通过Flink自带的local模式可调试开发 - compile:此环境适合二次开发或者熟悉源码,此模式不需要额外安装Flink,通过Flink自带的local模式便可调试开发
## Dinky本地开发环境 ## Dinky本地开发环境
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment