修复数据源语句解析类型判断

aiwenmo · Feb 14, 2022 · 21c774e · 21c774e
1 parent 58b133c
commit 21c774e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...adata/dlink-metadata-base/src/main/java/com/dlink/metadata/driver/AbstractJdbcDriver.java b/...adata/dlink-metadata-base/src/main/java/com/dlink/metadata/driver/AbstractJdbcDriver.java
@@ -330,7 +330,7 @@ public JdbcSelectResult query(String sql, Integer limit) {
 
     @Override
     public JdbcSelectResult executeSql(String sql, Integer limit) {
-        List<SQLStatement> stmtList = SQLUtils.parseStatements(sql,config.getType());
+        List<SQLStatement> stmtList = SQLUtils.parseStatements(sql,config.getType().toLowerCase());
         List<Object> resList = new ArrayList<>();
         JdbcSelectResult result = JdbcSelectResult.buildResult();
         for(SQLStatement item : stmtList){
@@ -367,7 +367,7 @@ public List<SqlExplainResult> explain(String sql){
         List<SqlExplainResult> sqlExplainResults = new ArrayList<>();
         String current = null;
         try {
-            List<SQLStatement> stmtList = SQLUtils.parseStatements(sql,config.getType());
+            List<SQLStatement> stmtList = SQLUtils.parseStatements(sql,config.getType().toLowerCase());
             for(SQLStatement item : stmtList){
                 current = item.toString();
                 String type = item.getClass().getSimpleName();