You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2023/01/10 00:05:27 UTC
[flink] branch master updated (627d293b693 -> 13fd4f270a3)
This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 627d293b693 [hotfix] Sync English version of gcs.md to Chinese version due to being out-of-sync
add 13fd4f270a3 [FLINK-30465][Connector/JDBC] Remove JDBC connector and refer to externalized docs. This closes #21536
No new revisions were added by this update.
Summary of changes:
docs/content.zh/docs/connectors/datastream/jdbc.md | 90 ---
docs/content.zh/docs/connectors/table/jdbc.md | 799 -------------------
docs/content/docs/connectors/datastream/jdbc.md | 336 --------
docs/content/docs/connectors/table/jdbc.md | 789 -------------------
docs/data/sql_connectors.yml | 2 +-
docs/setup_docs.sh | 1 +
.../5b9eed8a-5fb6-4373-98ac-3be2a71941b8 | 9 +-
.../b8900323-6aab-4e7e-9b17-f53b3c3dca46 | 42 -
.../e577412e-8d38-496c-a680-b842112e4b94 | 2 -
.../flink-architecture-tests-production/pom.xml | 5 -
flink-architecture-tests/pom.xml | 7 -
.../0f94f11b-9bc8-445a-8be8-e7dfd8a384b0 | 0
.../6b9ab1b0-c14d-4667-bab5-407b81fba98b | 24 -
.../archunit-violations/stored.rules | 4 -
flink-connectors/flink-connector-jdbc/pom.xml | 209 -----
.../connector/jdbc/JdbcConnectionOptions.java | 120 ---
.../connector/jdbc/JdbcExactlyOnceOptions.java | 179 -----
.../flink/connector/jdbc/JdbcExecutionOptions.java | 108 ---
.../flink/connector/jdbc/JdbcInputFormat.java | 431 ----------
.../flink/connector/jdbc/JdbcRowOutputFormat.java | 150 ----
.../org/apache/flink/connector/jdbc/JdbcSink.java | 116 ---
.../flink/connector/jdbc/JdbcStatementBuilder.java | 38 -
.../jdbc/catalog/AbstractJdbcCatalog.java | 541 -------------
.../flink/connector/jdbc/catalog/JdbcCatalog.java | 126 ---
.../connector/jdbc/catalog/JdbcCatalogUtils.java | 61 --
.../flink/connector/jdbc/catalog/MySqlCatalog.java | 171 ----
.../connector/jdbc/catalog/PostgresCatalog.java | 177 -----
.../connector/jdbc/catalog/PostgresTablePath.java | 102 ---
.../jdbc/catalog/factory/JdbcCatalogFactory.java | 80 --
.../catalog/factory/JdbcCatalogFactoryOptions.java | 48 --
.../jdbc/converter/AbstractJdbcRowConverter.java | 269 -------
.../connector/jdbc/converter/JdbcRowConverter.java | 52 --
.../connector/jdbc/dialect/AbstractDialect.java | 267 -------
.../flink/connector/jdbc/dialect/JdbcDialect.java | 157 ----
.../connector/jdbc/dialect/JdbcDialectFactory.java | 49 --
.../connector/jdbc/dialect/JdbcDialectLoader.java | 106 ---
.../jdbc/dialect/JdbcDialectTypeMapper.java | 32 -
.../connector/jdbc/dialect/derby/DerbyDialect.java | 110 ---
.../jdbc/dialect/derby/DerbyDialectFactory.java | 37 -
.../connector/jdbc/dialect/mysql/MySqlDialect.java | 147 ----
.../jdbc/dialect/mysql/MySqlDialectFactory.java | 37 -
.../jdbc/dialect/mysql/MySqlTypeMapper.java | 223 ------
.../jdbc/dialect/oracle/OracleDialect.java | 162 ----
.../jdbc/dialect/oracle/OracleDialectFactory.java | 37 -
.../jdbc/dialect/psql/PostgresDialect.java | 131 ----
.../jdbc/dialect/psql/PostgresDialectFactory.java | 37 -
.../jdbc/dialect/psql/PostgresTypeMapper.java | 176 -----
.../jdbc/dialect/sqlserver/SqlServerDialect.java | 160 ----
.../dialect/sqlserver/SqlServerDialectFactory.java | 37 -
.../jdbc/internal/GenericJdbcSinkFunction.java | 77 --
.../connector/jdbc/internal/JdbcOutputFormat.java | 418 ----------
.../jdbc/internal/TableJdbcUpsertOutputFormat.java | 209 -----
.../connection/JdbcConnectionProvider.java | 67 --
.../connection/SimpleJdbcConnectionProvider.java | 150 ----
.../jdbc/internal/converter/DerbyRowConverter.java | 40 -
.../jdbc/internal/converter/MySQLRowConverter.java | 40 -
.../internal/converter/OracleRowConverter.java | 183 -----
.../internal/converter/PostgresRowConverter.java | 101 ---
.../internal/converter/SqlServerRowConverter.java | 51 --
.../executor/InsertOrUpdateJdbcExecutor.java | 137 ----
.../executor/JdbcBatchStatementExecutor.java | 52 --
.../executor/KeyedBatchStatementExecutor.java | 89 ---
.../executor/SimpleBatchStatementExecutor.java | 85 --
.../TableBufferReducedStatementExecutor.java | 111 ---
.../executor/TableBufferedStatementExecutor.java | 72 --
.../TableInsertOrUpdateStatementExecutor.java | 117 ---
.../executor/TableSimpleStatementExecutor.java | 74 --
.../internal/options/JdbcConnectorOptions.java | 211 -----
.../jdbc/internal/options/JdbcDmlOptions.java | 152 ----
.../jdbc/internal/options/JdbcInsertOptions.java | 51 --
.../jdbc/internal/options/JdbcReadOptions.java | 173 ----
.../internal/options/JdbcTypedQueryOptions.java | 48 --
.../CompositeJdbcParameterValuesProvider.java | 58 --
.../split/JdbcGenericParameterValuesProvider.java | 44 --
.../JdbcNumericBetweenParametersProvider.java | 118 ---
.../jdbc/split/JdbcParameterValuesProvider.java | 36 -
.../statement/FieldNamedPreparedStatement.java | 248 ------
.../statement/FieldNamedPreparedStatementImpl.java | 240 ------
.../connector/jdbc/statement/StatementFactory.java | 29 -
.../connector/jdbc/table/JdbcConnectorOptions.java | 177 -----
.../jdbc/table/JdbcDynamicTableFactory.java | 340 --------
.../connector/jdbc/table/JdbcDynamicTableSink.java | 125 ---
.../jdbc/table/JdbcDynamicTableSource.java | 296 -------
...JdbcFilterPushdownPreparedStatementVisitor.java | 201 -----
.../jdbc/table/JdbcOutputFormatBuilder.java | 261 ------
.../jdbc/table/JdbcRowDataInputFormat.java | 401 ----------
.../jdbc/table/JdbcRowDataLookupFunction.java | 192 -----
.../jdbc/table/ParameterizedPredicate.java | 59 --
.../flink/connector/jdbc/utils/JdbcTypeUtil.java | 133 ----
.../flink/connector/jdbc/utils/JdbcUtils.java | 171 ----
.../flink/connector/jdbc/xa/CheckpointAndXid.java | 91 ---
.../jdbc/xa/CheckpointAndXidSerializer.java | 135 ----
.../connector/jdbc/xa/JdbcXaSinkFunction.java | 370 ---------
.../connector/jdbc/xa/JdbcXaSinkFunctionState.java | 73 --
.../connector/jdbc/xa/SemanticXidGenerator.java | 110 ---
.../apache/flink/connector/jdbc/xa/XaFacade.java | 122 ---
.../flink/connector/jdbc/xa/XaFacadeImpl.java | 462 -----------
.../connector/jdbc/xa/XaFacadePoolingImpl.java | 193 -----
.../apache/flink/connector/jdbc/xa/XaGroupOps.java | 99 ---
.../flink/connector/jdbc/xa/XaGroupOpsImpl.java | 143 ----
.../connector/jdbc/xa/XaSinkStateHandler.java | 31 -
.../connector/jdbc/xa/XaSinkStateHandlerImpl.java | 95 ---
.../connector/jdbc/xa/XaSinkStateSerializer.java | 159 ----
.../flink/connector/jdbc/xa/XidGenerator.java | 71 --
.../apache/flink/connector/jdbc/xa/XidImpl.java | 98 ---
.../flink/connector/jdbc/xa/XidSerializer.java | 140 ----
.../flink/connector/jdbc/xa/package-info.java | 23 -
...flink.connector.jdbc.dialect.JdbcDialectFactory | 20 -
.../org.apache.flink.table.factories.Factory | 17 -
.../architecture/TestCodeArchitectureTest.java | 40 -
.../apache/flink/connector/jdbc/DbMetadata.java | 49 --
.../flink/connector/jdbc/DerbyDbMetadata.java | 61 --
.../connector/jdbc/JdbcConnectionOptionsTest.java | 53 --
.../flink/connector/jdbc/JdbcDataTestBase.java | 81 --
.../flink/connector/jdbc/JdbcDataTypeTest.java | 228 ------
.../apache/flink/connector/jdbc/JdbcITCase.java | 180 -----
.../flink/connector/jdbc/JdbcInputFormatTest.java | 412 ----------
.../connector/jdbc/JdbcRowOutputFormatTest.java | 358 ---------
.../apache/flink/connector/jdbc/JdbcTestBase.java | 41 -
.../flink/connector/jdbc/JdbcTestCheckpoint.java | 33 -
.../flink/connector/jdbc/JdbcTestFixture.java | 256 ------
.../jdbc/catalog/JdbcCatalogUtilsTest.java | 41 -
.../connector/jdbc/catalog/MySqlCatalogITCase.java | 382 ---------
.../jdbc/catalog/MySqlCatalogTestBase.java | 149 ----
.../jdbc/catalog/PostgresCatalogITCase.java | 196 -----
.../jdbc/catalog/PostgresCatalogTest.java | 177 -----
.../jdbc/catalog/PostgresCatalogTestBase.java | 374 ---------
.../jdbc/catalog/PostgresTablePathTest.java | 32 -
.../catalog/factory/JdbcCatalogFactoryTest.java | 111 ---
.../converter/AbstractJdbcRowConverterTest.java | 61 --
.../jdbc/dialect/mysql/MySqlDialectTest.java | 41 -
.../jdbc/dialect/oracle/OracleContainer.java | 99 ---
.../oracle/OraclePreparedStatementTest.java | 175 -----
.../jdbc/dialect/oracle/OracleTableSinkITCase.java | 450 -----------
.../dialect/oracle/OracleTableSourceITCase.java | 247 ------
.../sqlserver/SqlServerPreparedStatementTest.java | 94 ---
.../sqlserver/SqlServerTableSinkITCase.java | 492 ------------
.../sqlserver/SqlServerTableSourceITCase.java | 229 ------
.../flink/connector/jdbc/fakedb/FakeDBUtils.java | 42 -
.../jdbc/fakedb/driver/FakeConnection.java | 328 --------
.../jdbc/fakedb/driver/FakeConnection1.java | 24 -
.../jdbc/fakedb/driver/FakeConnection2.java | 24 -
.../jdbc/fakedb/driver/FakeConnection3.java | 24 -
.../connector/jdbc/fakedb/driver/FakeDriver1.java | 80 --
.../connector/jdbc/fakedb/driver/FakeDriver2.java | 80 --
.../connector/jdbc/fakedb/driver/FakeDriver3.java | 71 --
.../connector/jdbc/internal/JdbcFullTest.java | 195 -----
.../jdbc/internal/JdbcTableOutputFormatTest.java | 264 -------
...ProviderDriverClassConcurrentLoadingITCase.java | 108 ---
.../SimpleJdbcConnectionProviderTest.java | 181 -----
.../NumericBetweenParametersProviderTest.java | 126 ---
.../FieldNamedPreparedStatementImplTest.java | 170 ----
.../jdbc/table/JdbcAppendOnlyWriterTest.java | 120 ---
.../jdbc/table/JdbcDynamicTableFactoryTest.java | 400 ----------
.../jdbc/table/JdbcDynamicTableSinkITCase.java | 450 -----------
.../jdbc/table/JdbcDynamicTableSourceITCase.java | 529 -------------
...FilterPushdownPreparedStatementVisitorTest.java | 297 -------
.../connector/jdbc/table/JdbcLookupTestBase.java | 113 ---
.../connector/jdbc/table/JdbcOutputFormatTest.java | 517 ------------
.../jdbc/table/JdbcRowDataInputFormatTest.java | 374 ---------
.../jdbc/table/JdbcRowDataLookupFunctionTest.java | 126 ---
.../connector/jdbc/table/JdbcTablePlanTest.java | 67 --
.../jdbc/table/UnsignedTypeConversionITCase.java | 199 -----
.../connector/jdbc/utils/JdbcTypeUtilTest.java | 45 --
.../jdbc/xa/CheckpointAndXidSerializersTest.java | 47 --
.../jdbc/xa/JdbcExactlyOnceSinkE2eTest.java | 872 ---------------------
.../connector/jdbc/xa/JdbcXaFacadeImplTest.java | 105 ---
.../connector/jdbc/xa/JdbcXaFacadeTestHelper.java | 116 ---
.../connector/jdbc/xa/JdbcXaSinkDerbyTest.java | 175 -----
.../flink/connector/jdbc/xa/JdbcXaSinkH2Test.java | 77 --
.../connector/jdbc/xa/JdbcXaSinkMigrationTest.java | 229 ------
.../jdbc/xa/JdbcXaSinkNoInsertionTest.java | 69 --
.../connector/jdbc/xa/JdbcXaSinkTestBase.java | 388 ---------
.../connector/jdbc/xa/JdbcXaSinkTestHelper.java | 92 ---
.../jdbc/xa/SemanticXidGeneratorTest.java | 64 --
.../flink/connector/jdbc/xa/XidImplTest.java | 66 --
.../connector/jdbc/xa/XidSerializersTest.java | 47 --
.../flink/connector/jdbc/xa/h2/H2DbMetadata.java | 56 --
.../jdbc/xa/h2/H2XaConnectionWrapper.java | 74 --
.../flink/connector/jdbc/xa/h2/H2XaDsWrapper.java | 78 --
.../connector/jdbc/xa/h2/H2XaResourceWrapper.java | 247 ------
.../flink/connector/jdbc/xa/h2/package-info.java | 22 -
.../resources/META-INF/services/java.sql.Driver | 19 -
.../src/test/resources/archunit.properties | 31 -
.../src/test/resources/log4j2-test.properties | 28 -
.../mysql-scripts/catalog-init-for-test.sql | 129 ---
.../connector/jdbc/table/JdbcTablePlanTest.xml | 71 --
flink-connectors/pom.xml | 1 -
flink-python/pom.xml | 2 +-
.../org/apache/flink/util/DockerImageVersions.java | 2 -
tools/azure-pipelines/cache_docker_images.sh | 2 +-
tools/ci/stage.sh | 1 -
192 files changed, 5 insertions(+), 28483 deletions(-)
delete mode 100644 docs/content.zh/docs/connectors/datastream/jdbc.md
delete mode 100644 docs/content.zh/docs/connectors/table/jdbc.md
delete mode 100644 docs/content/docs/connectors/datastream/jdbc.md
delete mode 100644 docs/content/docs/connectors/table/jdbc.md
delete mode 100644 flink-connectors/flink-connector-jdbc/archunit-violations/0f94f11b-9bc8-445a-8be8-e7dfd8a384b0
delete mode 100644 flink-connectors/flink-connector-jdbc/archunit-violations/6b9ab1b0-c14d-4667-bab5-407b81fba98b
delete mode 100644 flink-connectors/flink-connector-jdbc/archunit-violations/stored.rules
delete mode 100644 flink-connectors/flink-connector-jdbc/pom.xml
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExactlyOnceOptions.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcInputFormat.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcRowOutputFormat.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcSink.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcStatementBuilder.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalog.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalogUtils.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/MySqlCatalog.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/PostgresCatalog.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/PostgresTablePath.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/factory/JdbcCatalogFactory.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/factory/JdbcCatalogFactoryOptions.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/converter/AbstractJdbcRowConverter.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/converter/JdbcRowConverter.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/AbstractDialect.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectFactory.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectLoader.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectTypeMapper.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/derby/DerbyDialect.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/derby/DerbyDialectFactory.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/mysql/MySqlDialect.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/mysql/MySqlDialectFactory.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/mysql/MySqlTypeMapper.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/oracle/OracleDialect.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/oracle/OracleDialectFactory.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/psql/PostgresDialect.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/psql/PostgresDialectFactory.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/psql/PostgresTypeMapper.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/sqlserver/SqlServerDialect.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/sqlserver/SqlServerDialectFactory.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/GenericJdbcSinkFunction.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcOutputFormat.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/TableJdbcUpsertOutputFormat.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/connection/JdbcConnectionProvider.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/connection/SimpleJdbcConnectionProvider.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/DerbyRowConverter.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/MySQLRowConverter.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/OracleRowConverter.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/PostgresRowConverter.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/SqlServerRowConverter.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/InsertOrUpdateJdbcExecutor.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/JdbcBatchStatementExecutor.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/KeyedBatchStatementExecutor.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/SimpleBatchStatementExecutor.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferReducedStatementExecutor.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferedStatementExecutor.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableInsertOrUpdateStatementExecutor.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableSimpleStatementExecutor.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcConnectorOptions.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcDmlOptions.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcInsertOptions.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcReadOptions.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcTypedQueryOptions.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/CompositeJdbcParameterValuesProvider.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcGenericParameterValuesProvider.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcNumericBetweenParametersProvider.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcParameterValuesProvider.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/statement/FieldNamedPreparedStatement.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/statement/FieldNamedPreparedStatementImpl.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/statement/StatementFactory.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcConnectorOptions.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableFactory.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSink.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSource.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownPreparedStatementVisitor.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcOutputFormatBuilder.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataInputFormat.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/ParameterizedPredicate.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/utils/JdbcTypeUtil.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/utils/JdbcUtils.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/CheckpointAndXid.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/CheckpointAndXidSerializer.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkFunction.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkFunctionState.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/SemanticXidGenerator.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XaFacade.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XaFacadeImpl.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XaFacadePoolingImpl.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XaGroupOps.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XaGroupOpsImpl.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XaSinkStateHandler.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XaSinkStateHandlerImpl.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XaSinkStateSerializer.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XidGenerator.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XidImpl.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XidSerializer.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/package-info.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/resources/META-INF/services/org.apache.flink.connector.jdbc.dialect.JdbcDialectFactory
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/DbMetadata.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/DerbyDbMetadata.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcConnectionOptionsTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcDataTestBase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcDataTypeTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcITCase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcInputFormatTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcRowOutputFormatTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcTestBase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcTestCheckpoint.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcTestFixture.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalogUtilsTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/MySqlCatalogITCase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/MySqlCatalogTestBase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/PostgresCatalogITCase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/PostgresCatalogTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/PostgresCatalogTestBase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/PostgresTablePathTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/factory/JdbcCatalogFactoryTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/converter/AbstractJdbcRowConverterTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/mysql/MySqlDialectTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/oracle/OracleContainer.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/oracle/OraclePreparedStatementTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/oracle/OracleTableSinkITCase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/oracle/OracleTableSourceITCase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/sqlserver/SqlServerPreparedStatementTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/sqlserver/SqlServerTableSinkITCase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/sqlserver/SqlServerTableSourceITCase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/fakedb/FakeDBUtils.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeConnection.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeConnection1.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeConnection2.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeConnection3.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeDriver1.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeDriver2.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeDriver3.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/internal/JdbcFullTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/internal/JdbcTableOutputFormatTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/internal/connection/SimpleJdbcConnectionProviderDriverClassConcurrentLoadingITCase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/internal/connection/SimpleJdbcConnectionProviderTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/split/NumericBetweenParametersProviderTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/statement/FieldNamedPreparedStatementImplTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcAppendOnlyWriterTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableFactoryTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSinkITCase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSourceITCase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownPreparedStatementVisitorTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcLookupTestBase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcOutputFormatTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcRowDataInputFormatTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunctionTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcTablePlanTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/UnsignedTypeConversionITCase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/utils/JdbcTypeUtilTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/CheckpointAndXidSerializersTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcExactlyOnceSinkE2eTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaFacadeImplTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaFacadeTestHelper.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkDerbyTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkH2Test.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkMigrationTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkNoInsertionTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkTestBase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkTestHelper.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/SemanticXidGeneratorTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/XidImplTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/XidSerializersTest.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/h2/H2DbMetadata.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/h2/H2XaConnectionWrapper.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/h2/H2XaDsWrapper.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/h2/H2XaResourceWrapper.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/h2/package-info.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/resources/META-INF/services/java.sql.Driver
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/resources/archunit.properties
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/resources/log4j2-test.properties
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/resources/mysql-scripts/catalog-init-for-test.sql
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/resources/org/apache/flink/connector/jdbc/table/JdbcTablePlanTest.xml