[bug] Fix datax task type error parse clickhouse reader sql (#8091)

apache · Jan 18, 2022 · f1a0215 · f1a0215
1 parent e0a99dd
commit f1a0215
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...er-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxUtils.java b/...er-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxUtils.java
@@ -19,6 +19,7 @@
 
 import org.apache.dolphinscheduler.spi.enums.DbType;
 
+import com.alibaba.druid.sql.dialect.clickhouse.parser.ClickhouseStatementParser;
 import com.alibaba.druid.sql.dialect.mysql.parser.MySqlStatementParser;
 import com.alibaba.druid.sql.dialect.oracle.parser.OracleStatementParser;
 import com.alibaba.druid.sql.dialect.postgresql.parser.PGSQLStatementParser;
@@ -91,6 +92,8 @@ public static SQLStatementParser getSqlStatementParser(DbType dbType, String sql
                 return new OracleStatementParser(sql);
             case SQLSERVER:
                 return new SQLServerStatementParser(sql);
+            case CLICKHOUSE:
+                return new ClickhouseStatementParser(sql);
             default:
                 return null;
         }