[Feature][Connector] Support parse sql scripts to lineage (#578)

Author: zixi0825

datavines-connector/datavines-connector-plugins/datavines-connector-clickhouse/src/main/java/io/datavines/connector/plugin/ClickHouseConnectorFactory.java

@@ -16,6 +16,7 @@
  */
 package io.datavines.connector.plugin;
 
+import com.alibaba.druid.DbType;
 import io.datavines.connector.api.*;
 
 public class ClickHouseConnectorFactory extends AbstractJdbcConnectorFactory {
@@ -55,6 +56,11 @@ public TypeConverter getTypeConverter() {
         return new ClickHouseTypeConverter();
     }
 
+    @Override
+    public StatementParser getStatementParser() {
+        return new DefaultStatementParser(DbType.clickhouse);
+    }
+
     @Override
     public String getPluginName() {
         return "clickhouse";

datavines-connector/datavines-connector-plugins/datavines-connector-databend/src/main/java/io/datavines/connector/plugin/DatabendConnectorFactory.java

@@ -16,6 +16,7 @@
  */
 package io.datavines.connector.plugin;
 
+import com.alibaba.druid.DbType;
 import io.datavines.connector.api.*;
 
 public class DatabendConnectorFactory extends AbstractJdbcConnectorFactory {
@@ -45,6 +46,11 @@ public ConfigBuilder getConfigBuilder() {
         return new DatabendConfigBuilder();
     }
 
+    @Override
+    public StatementParser getStatementParser() {
+        return new DefaultStatementParser(DbType.mysql);
+    }
+
     @Override
     public String getPluginName() {
         return "databend";

datavines-connector/datavines-connector-plugins/datavines-connector-dm/src/main/java/io/datavines/connector/plugin/DmConnectorFactory.java

@@ -16,6 +16,7 @@
  */
 package io.datavines.connector.plugin;
 
+import com.alibaba.druid.DbType;
 import io.datavines.connector.api.*;
 
 public class DmConnectorFactory extends AbstractJdbcConnectorFactory {
@@ -45,6 +46,11 @@ public ConfigBuilder getConfigBuilder() {
         return new DmConfigBuilder();
     }
 
+    @Override
+    public StatementParser getStatementParser() {
+        return new DefaultStatementParser(DbType.dm);
+    }
+
     @Override
     public String getPluginName() {
         return "dm";

datavines-connector/datavines-connector-plugins/datavines-connector-doris/src/main/java/io/datavines/connector/plugin/DorisConnectorFactory.java

@@ -16,6 +16,7 @@
  */
 package io.datavines.connector.plugin;
 
+import com.alibaba.druid.DbType;
 import io.datavines.connector.api.*;
 
 public class DorisConnectorFactory extends AbstractJdbcConnectorFactory {
@@ -45,6 +46,11 @@ public ConfigBuilder getConfigBuilder() {
         return new DorisConfigBuilder();
     }
 
+    @Override
+    public StatementParser getStatementParser() {
+        return new DefaultStatementParser(DbType.mysql);
+    }
+
     @Override
     public String getPluginName() {
         return "doris";

datavines-connector/datavines-connector-plugins/datavines-connector-hive/src/main/java/io/datavines/connector/plugin/HiveConnectorFactory.java

@@ -16,6 +16,7 @@
  */
 package io.datavines.connector.plugin;
 
+import com.alibaba.druid.DbType;
 import io.datavines.connector.api.*;
 
 public class HiveConnectorFactory extends AbstractJdbcConnectorFactory {
@@ -55,6 +56,11 @@ public DataSourceClient getDataSourceClient() {
         return new HiveDataSourceClient();
     }
 
+    @Override
+    public StatementParser getStatementParser() {
+        return new DefaultStatementParser(DbType.hive);
+    }
+
     @Override
     public String getPluginName() {
         return "hive";

datavines-connector/datavines-connector-plugins/datavines-connector-impala/src/main/java/io/datavines/connector/plugin/ImpalaConnectorFactory.java

@@ -16,10 +16,12 @@
  */
 package io.datavines.connector.plugin;
 
+import com.alibaba.druid.DbType;
 import io.datavines.connector.api.Connector;
 import io.datavines.connector.api.ParameterConverter;
 import io.datavines.connector.api.Dialect;
 import io.datavines.connector.api.Executor;
+import io.datavines.connector.api.StatementParser;
 
 public class ImpalaConnectorFactory extends AbstractJdbcConnectorFactory {
 
@@ -43,6 +45,11 @@ public Executor getExecutor() {
         return new ImpalaExecutor(getDataSourceClient());
     }
 
+    @Override
+    public StatementParser getStatementParser() {
+        return new DefaultStatementParser(DbType.hive);
+    }
+
     @Override
     public String getPluginName() {
         return "impala";

datavines-connector/datavines-connector-plugins/datavines-connector-mysql/src/main/java/io/datavines/connector/plugin/MysqlConnectorFactory.java

@@ -16,6 +16,7 @@
  */
 package io.datavines.connector.plugin;
 
+import com.alibaba.druid.DbType;
 import io.datavines.connector.api.*;
 
 public class MysqlConnectorFactory extends AbstractJdbcConnectorFactory {
@@ -50,6 +51,11 @@ public MetricScript getMetricScript() {
         return new MysqlMetricScript();
     }
 
+    @Override
+    public StatementParser getStatementParser() {
+        return new DefaultStatementParser(DbType.mysql);
+    }
+
     @Override
     public String getPluginName() {
         return "mysql";

datavines-connector/datavines-connector-plugins/datavines-connector-oracle/src/main/java/io/datavines/connector/plugin/OracleConnectorFactory.java

@@ -16,6 +16,7 @@
  */
 package io.datavines.connector.plugin;
 
+import com.alibaba.druid.DbType;
 import io.datavines.connector.api.*;
 
 public class OracleConnectorFactory extends AbstractJdbcConnectorFactory{
@@ -55,6 +56,11 @@ public MetricScript getMetricScript() {
         return new OracleMetricScript();
     }
 
+    @Override
+    public StatementParser getStatementParser() {
+        return new DefaultStatementParser(DbType.oracle);
+    }
+
     @Override
     public String getPluginName() {
         return "oracle";

datavines-connector/datavines-connector-plugins/datavines-connector-postgresql/src/main/java/io/datavines/connector/plugin/PostgreSqlConnectorFactory.java

@@ -16,6 +16,7 @@
  */
 package io.datavines.connector.plugin;
 
+import com.alibaba.druid.DbType;
 import io.datavines.connector.api.*;
 
 public class PostgreSqlConnectorFactory extends AbstractJdbcConnectorFactory {
@@ -55,6 +56,11 @@ public MetricScript getMetricScript() {
         return new PostgreSqlMetricScript();
     }
 
+    @Override
+    public StatementParser getStatementParser() {
+        return new DefaultStatementParser(DbType.postgresql);
+    }
+
     @Override
     public String getPluginName() {
         return "postgresql";

datavines-connector/datavines-connector-plugins/datavines-connector-presto/src/main/java/io/datavines/connector/plugin/PrestoConnectorFactory.java

@@ -16,6 +16,7 @@
  */
 package io.datavines.connector.plugin;
 
+import com.alibaba.druid.DbType;
 import io.datavines.connector.api.*;
 
 public class PrestoConnectorFactory extends AbstractJdbcConnectorFactory {
@@ -50,6 +51,11 @@ public DataSourceClient getDataSourceClient() {
         return new PrestoDataSourceClient();
     }
 
+    @Override
+    public StatementParser getStatementParser() {
+        return new DefaultStatementParser(DbType.presto);
+    }
+
     @Override
     public String getPluginName() {
         return "presto";