diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/clickhouse/ClickhouseDialect.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/clickhouse/ClickhouseDialect.java deleted file mode 100644 index 0222e033..00000000 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/clickhouse/ClickhouseDialect.java +++ /dev/null @@ -1,78 +0,0 @@ -package org.apache.flink.connector.jdbc.dialect.clickhouse; - -import org.apache.flink.connector.jdbc.converter.AbstractJdbcRowConverter; -import org.apache.flink.connector.jdbc.dialect.AbstractDialect; -import org.apache.flink.connector.jdbc.internal.converter.ClickhouseRowConvert; -import org.apache.flink.table.types.logical.LogicalTypeRoot; -import org.apache.flink.table.types.logical.RowType; - -import java.util.EnumSet; -import java.util.Optional; -import java.util.Set; - -/** */ -public class ClickhouseDialect extends AbstractDialect { - - private static final long serialVersionUID = 1L; - - // Define MAX/MIN precision of TIMESTAMP type according to Mysql docs: - // https://dev.mysql.com/doc/refman/8.0/en/fractional-seconds.html - private static final int MAX_TIMESTAMP_PRECISION = 6; - private static final int MIN_TIMESTAMP_PRECISION = 1; - - // Define MAX/MIN precision of DECIMAL type according to Mysql docs: - // https://dev.mysql.com/doc/refman/8.0/en/fixed-point-types.html - private static final int MAX_DECIMAL_PRECISION = 65; - private static final int MIN_DECIMAL_PRECISION = 1; - - @Override - public AbstractJdbcRowConverter getRowConverter(RowType rowType) { - return new ClickhouseRowConvert(rowType); - } - - @Override - public String getLimitClause(long limit) { - return "LIMIT " + limit; - } - - @Override - public Optional defaultDriverName() { - return Optional.of("com.clickhouse.jdbc.ClickHouseDriver"); - } - - @Override - public String quoteIdentifier(String identifier) { - return "`" + identifier + "`"; - } - - @Override - public Optional getUpsertStatement( - String tableName, String[] fieldNames, String[] uniqueKeyFields) { - return Optional.empty(); - } - - @Override - public String dialectName() { - return "Clickhouse"; - } - - @Override - public Set supportedTypes() { - // LegacyTypeInfoDataTypeConverter. - return EnumSet.of( - LogicalTypeRoot.CHAR, - LogicalTypeRoot.VARCHAR, - LogicalTypeRoot.BOOLEAN, - LogicalTypeRoot.VARBINARY, - LogicalTypeRoot.DECIMAL, - LogicalTypeRoot.TINYINT, - LogicalTypeRoot.SMALLINT, - LogicalTypeRoot.INTEGER, - LogicalTypeRoot.BIGINT, - LogicalTypeRoot.FLOAT, - LogicalTypeRoot.DOUBLE, - LogicalTypeRoot.DATE, - LogicalTypeRoot.TIME_WITHOUT_TIME_ZONE, - LogicalTypeRoot.TIMESTAMP_WITHOUT_TIME_ZONE); - } -} diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/clickhouse/ClickhouseDialectFactory.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/clickhouse/ClickhouseDialectFactory.java deleted file mode 100644 index 4924e487..00000000 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/clickhouse/ClickhouseDialectFactory.java +++ /dev/null @@ -1,19 +0,0 @@ -package org.apache.flink.connector.jdbc.dialect.clickhouse; - -import org.apache.flink.annotation.Internal; -import org.apache.flink.connector.jdbc.dialect.JdbcDialect; -import org.apache.flink.connector.jdbc.dialect.JdbcDialectFactory; - -/** */ -@Internal -public class ClickhouseDialectFactory implements JdbcDialectFactory { - @Override - public boolean acceptsURL(String url) { - return url.startsWith("jdbc:clickhouse:"); - } - - @Override - public JdbcDialect create() { - return new ClickhouseDialect(); - } -}