Skip to content

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

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
zixi0825 merged 1 commit into from
Mar 31, 2026
Merged

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

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 6 additions & 0 deletions ...or-clickhouse/src/main/java/io/datavines/connector/plugin/ClickHouseConnectorFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
*/
package io.datavines.connector.plugin;

import com.alibaba.druid.DbType;
import io.datavines.connector.api.*;

public class ClickHouseConnectorFactory extends AbstractJdbcConnectorFactory {
Expand Down Expand Up @@ -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";
Expand Down
6 changes: 6 additions & 0 deletions ...nector-databend/src/main/java/io/datavines/connector/plugin/DatabendConnectorFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
*/
package io.datavines.connector.plugin;

import com.alibaba.druid.DbType;
import io.datavines.connector.api.*;

public class DatabendConnectorFactory extends AbstractJdbcConnectorFactory {
Expand Down Expand Up @@ -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";
Expand Down
6 changes: 6 additions & 0 deletions ...atavines-connector-dm/src/main/java/io/datavines/connector/plugin/DmConnectorFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
*/
package io.datavines.connector.plugin;

import com.alibaba.druid.DbType;
import io.datavines.connector.api.*;

public class DmConnectorFactory extends AbstractJdbcConnectorFactory {
Expand Down Expand Up @@ -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";
Expand Down
6 changes: 6 additions & 0 deletions ...es-connector-doris/src/main/java/io/datavines/connector/plugin/DorisConnectorFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
*/
package io.datavines.connector.plugin;

import com.alibaba.druid.DbType;
import io.datavines.connector.api.*;

public class DorisConnectorFactory extends AbstractJdbcConnectorFactory {
Expand Down Expand Up @@ -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";
Expand Down
6 changes: 6 additions & 0 deletions ...ines-connector-hive/src/main/java/io/datavines/connector/plugin/HiveConnectorFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
*/
package io.datavines.connector.plugin;

import com.alibaba.druid.DbType;
import io.datavines.connector.api.*;

public class HiveConnectorFactory extends AbstractJdbcConnectorFactory {
Expand Down Expand Up @@ -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";
Expand Down
7 changes: 7 additions & 0 deletions ...-connector-impala/src/main/java/io/datavines/connector/plugin/ImpalaConnectorFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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 {

Expand All @@ -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";
Expand Down
6 changes: 6 additions & 0 deletions ...es-connector-mysql/src/main/java/io/datavines/connector/plugin/MysqlConnectorFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
*/
package io.datavines.connector.plugin;

import com.alibaba.druid.DbType;
import io.datavines.connector.api.*;

public class MysqlConnectorFactory extends AbstractJdbcConnectorFactory {
Expand Down Expand Up @@ -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";
Expand Down
6 changes: 6 additions & 0 deletions ...-connector-oracle/src/main/java/io/datavines/connector/plugin/OracleConnectorFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
*/
package io.datavines.connector.plugin;

import com.alibaba.druid.DbType;
import io.datavines.connector.api.*;

public class OracleConnectorFactory extends AbstractJdbcConnectorFactory{
Expand Down Expand Up @@ -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";
Expand Down
6 changes: 6 additions & 0 deletions ...or-postgresql/src/main/java/io/datavines/connector/plugin/PostgreSqlConnectorFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
*/
package io.datavines.connector.plugin;

import com.alibaba.druid.DbType;
import io.datavines.connector.api.*;

public class PostgreSqlConnectorFactory extends AbstractJdbcConnectorFactory {
Expand Down Expand Up @@ -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";
Expand Down
6 changes: 6 additions & 0 deletions ...-connector-presto/src/main/java/io/datavines/connector/plugin/PrestoConnectorFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
*/
package io.datavines.connector.plugin;

import com.alibaba.druid.DbType;
import io.datavines.connector.api.*;

public class PrestoConnectorFactory extends AbstractJdbcConnectorFactory {
Expand Down Expand Up @@ -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";
Expand Down
6 changes: 6 additions & 0 deletions ...ctor-sqlserver/src/main/java/io/datavines/connector/plugin/SqlServerConnectorFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
*/
package io.datavines.connector.plugin;

import com.alibaba.druid.DbType;
import io.datavines.connector.api.*;

public class SqlServerConnectorFactory extends AbstractJdbcConnectorFactory {
Expand Down Expand Up @@ -50,6 +51,11 @@ public MetricScript getMetricScript() {
return new SqlServerMetricScript();
}

@Override
public StatementParser getStatementParser() {
return new DefaultStatementParser(DbType.sqlserver);
}

@Override
public String getPluginName() {
return "sqlserver";
Expand Down
6 changes: 6 additions & 0 deletions ...ctor-starrocks/src/main/java/io/datavines/connector/plugin/StarRocksConnectorFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
*/
package io.datavines.connector.plugin;

import com.alibaba.druid.DbType;
import io.datavines.connector.api.*;

public class StarRocksConnectorFactory extends AbstractJdbcConnectorFactory {
Expand Down Expand Up @@ -45,6 +46,11 @@ public ConfigBuilder getConfigBuilder() {
return new StarRocksConfigBuilder();
}

@Override
public StatementParser getStatementParser() {
return new DefaultStatementParser(DbType.mysql);
}

@Override
public String getPluginName() {
return "starrocks";
Expand Down
6 changes: 6 additions & 0 deletions ...es-connector-trino/src/main/java/io/datavines/connector/plugin/TrinoConnectorFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
*/
package io.datavines.connector.plugin;

import com.alibaba.druid.DbType;
import io.datavines.connector.api.*;

public class TrinoConnectorFactory extends AbstractJdbcConnectorFactory {
Expand Down Expand Up @@ -50,6 +51,11 @@ public DataSourceClient getDataSourceClient() {
return new TrinoDataSourceClient();
}

@Override
public StatementParser getStatementParser() {
return new DefaultStatementParser(DbType.presto);
}

@Override
public String getPluginName() {
return "trino";
Expand Down
Loading
Loading