(flink-connector-jdbc) branch main updated (099cda71 -> 39ba942c)

[fanrui]

This is an automated email from the ASF dual-hosted git repository.

fanrui pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-jdbc.git


    from 099cda71 [hotfix][test] Change the modifier visibility of JUnit5.
     new 26655e5e [FLINK-35370] Add temp module to test backward compatibility
     new b5c030bb [FLINK-35364] Create core module and move code
     new a0011519 [FLINK-35365] Reorganize dialect code
     new d8e5665c [FLINK-35365] Reorganize catalog code
     new e07ec5f4 [FLINK-35366] Create all database modules
     new 2f8995c1 [FLINK-35366] Reorganize database modules packages
     new 48842334 [FLINK-35366] Bump containers and fix forkCountItCase
     new 0dfaf067 [FLINK-35366] Fix version from release
     new 64b4c824 [FLINK-35367] Reorganize sinks
     new 231542bb [FLINK-35494] Reorganize sources
     new e9d7c321 [FLINK-35788] Deprecate JdbcXaSinkFunction
     new 67046e0a [FLINK-35368] Reorganize table code
     new 9d535c6f [FLINK-35363] Fix deprecated documentation
     new 39ba942c [FLINK-35363] Modify tests to clean up unused docker images

The 14 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .github/workflows/backwards_compatibility.yml      | 103 ++++
 .../pom.xml                                        |  86 ++++
 .../backward/compatibility/DataStreamSinkTest.java | 125 +++++
 .../compatibility/DataStreamSourceTest.java        | 112 +++--
 .../compatibility/DynamicTableSinkTest.java        | 107 +---
 .../compatibility/DynamicTableSourceTest.java      |  45 +-
 .../src/test/resources/log4j2-test.properties      |   0
 .../0c7b60d6-a12c-432d-8a72-747cabaeb7ed           |   0
 .../0f94f11b-9bc8-445a-8be8-e7dfd8a384b0           |   0
 .../4bca2274-65a9-4a61-81ef-767d58233ea0           |   0
 .../596bd7eb-1ed5-4963-a56a-941766d61233           |   0
 .../6b9ab1b0-c14d-4667-bab5-407b81fba98b           |   0
 .../b10c194a-0517-4744-830f-81abfb71ab18           |   0
 .../d45c3af5-52c6-45fd-9926-75e75e77473a           |   0
 .../f242ee43-a122-4d2f-a291-6439cdb9029f           |   0
 .../archunit-violations/stored.rules               |   4 +-
 flink-connector-jdbc-core/pom.xml                  | 186 +++++++
 .../connector/jdbc/JdbcConnectionOptions.java      |   0
 .../connector/jdbc/JdbcExactlyOnceOptions.java     |   0
 .../flink/connector/jdbc/JdbcExecutionOptions.java |   0
 .../flink/connector/jdbc/JdbcInputFormat.java      |   7 +-
 .../flink/connector/jdbc/JdbcRowOutputFormat.java  |   0
 .../flink/connector/jdbc/JdbcStatementBuilder.java |   0
 .../connector/jdbc/core/database/JdbcFactory.java  |  41 +-
 .../jdbc/core/database/JdbcFactoryLoader.java      |  83 +++-
 .../database}/catalog/AbstractJdbcCatalog.java     |  49 +-
 .../jdbc/core/database/catalog/JdbcCatalog.java    |  10 +
 .../database/catalog/JdbcCatalogTypeMapper.java    |   6 +-
 .../catalog/factory/JdbcCatalogFactory.java        |  27 +-
 .../catalog/factory/JdbcCatalogFactoryOptions.java |   6 +-
 .../core/database}/dialect/AbstractDialect.java    |  12 +-
 .../database/dialect/AbstractDialectConverter.java |   6 +-
 .../jdbc/core/database}/dialect/JdbcDialect.java   |   8 +-
 .../database/dialect/JdbcDialectConverter.java     |   4 +-
 .../flink/connector/jdbc/core/datastream/Jdbc.java |  27 +-
 .../jdbc/core/datastream}/sink/JdbcSink.java       |  14 +-
 .../core/datastream}/sink/JdbcSinkBuilder.java     |   2 +-
 .../datastream}/sink/committer/JdbcCommitable.java |   2 +-
 .../sink/committer/JdbcCommitableSerializer.java   |   4 +-
 .../datastream}/sink/committer/JdbcCommitter.java  |   4 +-
 .../core/datastream}/sink/writer/JdbcWriter.java   |   4 +-
 .../datastream}/sink/writer/JdbcWriterState.java   |   2 +-
 .../sink/writer/JdbcWriterStateSerializer.java     |   2 +-
 .../jdbc/core/datastream}/source/JdbcSource.java   |  20 +-
 .../core/datastream}/source/JdbcSourceBuilder.java |  29 +-
 .../core/datastream}/source/JdbcSourceOptions.java |   2 +-
 .../enumerator/JdbcSourceEnumStateSerializer.java  |   6 +-
 .../source/enumerator/JdbcSourceEnumerator.java    |   4 +-
 .../enumerator/JdbcSourceEnumeratorState.java      |   4 +-
 .../enumerator/JdbcSqlSplitEnumeratorBase.java     |   4 +-
 .../enumerator/SqlTemplateSplitEnumerator.java     |   6 +-
 .../source/reader/JdbcRecordEmitter.java           |   6 +-
 .../source/reader/JdbcSourceReader.java            |   6 +-
 .../source/reader/JdbcSourceSplitReader.java       |  16 +-
 .../datastream}/source/reader/RecordAndOffset.java |   4 +-
 .../source/reader/extractor/ResultExtractor.java   |   2 +-
 .../reader/extractor/RowResultExtractor.java       |   2 +-
 .../source/split/CheckpointedOffset.java           |   2 +-
 .../datastream}/source/split/JdbcSourceSplit.java  |   2 +-
 .../source/split/JdbcSourceSplitSerializer.java    |   2 +-
 .../source/split/JdbcSourceSplitState.java         |   2 +-
 .../jdbc/core}/table/JdbcConnectorOptions.java     |   4 +-
 .../jdbc/core}/table/JdbcDynamicTableFactory.java  |  58 +--
 .../core/table/sink}/JdbcDynamicTableSink.java     |   2 +-
 .../core/table/sink}/JdbcOutputFormatBuilder.java  |   8 +-
 .../core/table/source}/JdbcDynamicTableSource.java |   4 +-
 ...JdbcFilterPushdownPreparedStatementVisitor.java |   2 +-
 .../core/table/source}/JdbcRowDataInputFormat.java |  12 +-
 .../table/source}/JdbcRowDataLookupFunction.java   |  14 +-
 .../core/table/source}/ParameterizedPredicate.java |   2 +-
 .../connections/JdbcConnectionProvider.java        |   0
 .../connections/SimpleJdbcConnectionProvider.java  |   0
 .../xa/PoolingXaConnectionProvider.java            |   0
 .../connections/xa/SimpleXaConnectionProvider.java |   0
 .../jdbc/datasource/connections/xa/XaCommand.java  |   0
 .../connections/xa/XaConnectionProvider.java       |   0
 .../datasource/statements/JdbcQueryStatement.java  |   0
 .../statements/SimpleJdbcQueryStatement.java       |   0
 .../datasource/transactions/xa/XaTransaction.java  |   2 +-
 .../transactions/xa/XaTransactionResult.java       |   0
 .../transactions/xa/domain/TransactionId.java      |   0
 .../xa/exceptions/EmptyTransactionXaException.java |   9 +-
 .../xa/exceptions/TransientXaException.java        |   0
 .../transactions/xa/exceptions/XaError.java        |   0
 .../datasource/transactions/xa/xid}/XidImpl.java   |   6 +-
 .../transactions/xa/xid}/XidSerializer.java        |   2 +-
 .../jdbc/derby/database/DerbyFactory.java          |  23 +-
 .../jdbc/derby/database}/dialect/DerbyDialect.java |  10 +-
 .../database/dialect/DerbyDialectConverter.java    |   8 +-
 .../jdbc/internal/GenericJdbcSinkFunction.java     |   0
 .../connector/jdbc/internal/JdbcOutputFormat.java  |   0
 .../jdbc/internal/JdbcOutputSerializer.java        |   0
 .../jdbc/internal/RowJdbcOutputFormat.java         |   0
 .../jdbc/internal/TableJdbcUpsertOutputFormat.java |   0
 .../executor/InsertOrUpdateJdbcExecutor.java       |   0
 .../executor/JdbcBatchStatementExecutor.java       |   0
 .../executor/KeyedBatchStatementExecutor.java      |   0
 .../executor/SimpleBatchStatementExecutor.java     |   0
 .../TableBufferReducedStatementExecutor.java       |   0
 .../executor/TableBufferedStatementExecutor.java   |   0
 .../TableInsertOrUpdateStatementExecutor.java      |  14 +-
 .../executor/TableSimpleStatementExecutor.java     |   7 +-
 .../options/InternalJdbcConnectionOptions.java     |   8 +-
 .../jdbc/internal/options/JdbcDmlOptions.java      |   2 +-
 .../jdbc/internal/options/JdbcInsertOptions.java   |   0
 .../jdbc/internal/options/JdbcReadOptions.java     |   0
 .../internal/options/JdbcTypedQueryOptions.java    |   0
 .../CompositeJdbcParameterValuesProvider.java      |   0
 .../split/JdbcGenericParameterValuesProvider.java  |   0
 .../JdbcNumericBetweenParametersProvider.java      |   0
 .../jdbc/split/JdbcParameterValuesProvider.java    |   0
 .../split/JdbcSlideTimingParameterProvider.java    |   0
 .../statement/FieldNamedPreparedStatement.java     |   0
 .../statement/FieldNamedPreparedStatementImpl.java |   0
 .../connector/jdbc/statement/StatementFactory.java |   0
 .../jdbc/utils/ContinuousUnBoundingSettings.java   |   0
 .../flink/connector/jdbc/utils/JdbcTypeUtil.java   |   0
 .../flink/connector/jdbc/utils/JdbcUtils.java      |   4 +-
 ....flink.connector.jdbc.core.database.JdbcFactory |  10 +-
 .../org.apache.flink.table.factories.Factory       |   4 +-
 .../ProductionCodeArchitectureTest.java            |   0
 .../architecture/TestCodeArchitectureTest.java     |   0
 .../reader/splitreader/TestingSplitsChange.java    |   2 +-
 .../connector/jdbc/JdbcConnectionOptionsTest.java  |   0
 .../flink/connector/jdbc/JdbcDataTestBase.java     |   4 +-
 .../apache/flink/connector/jdbc/JdbcITCase.java    |  22 +-
 .../flink/connector/jdbc/JdbcInputFormatTest.java  |   0
 .../connector/jdbc/JdbcRowOutputFormatTest.java    |   0
 .../apache/flink/connector/jdbc/JdbcTestBase.java  |   2 +-
 .../flink/connector/jdbc/JdbcTestCheckpoint.java   |   0
 .../flink/connector/jdbc/JdbcTestFixture.java      |   2 +-
 .../database/catalog/AbstractJdbcCatalogTest.java  |  15 +-
 .../database/dialect/JdbcDialectConverterTest.java |  10 +-
 .../core/database/dialect/JdbcDialectTest.java     |  63 +--
 .../datastream}/sink/AtLeastOnceJdbcSinkTest.java  |   2 +-
 .../core/datastream}/sink/BaseJdbcSinkTest.java    |   8 +-
 .../datastream}/sink/ExactlyOnceJdbcSinkTest.java  |   2 +-
 .../sink/writer/AlLeastOnceJdbcWriterTest.java     |   4 +-
 .../sink/writer/BaseJdbcWriterTest.java            |  12 +-
 .../sink/writer/ExactlyOnceJdbcWriterTest.java     |   4 +-
 .../sink/writer/JdbcWriterStateSerializerTest.java |   7 +-
 .../sink/writer/JdbcWriterStateTest.java           |   7 +-
 .../datastream}/source/JdbcSourceBuilderTest.java  |  12 +-
 .../core/datastream}/source/JdbcSourceITCase.java  |   7 +-
 .../source/JdbcSourceStreamRelatedITCase.java      |  11 +-
 .../JdbcSourceEnumStateSerializerTest.java         |  13 +-
 .../enumerator/JdbcSourceEnumeratorTest.java       |  11 +-
 .../source/reader/JdbcSourceReaderTest.java        |  10 +-
 .../source/reader/JdbcSourceSplitReaderTest.java   |  11 +-
 .../split/JdbcSourceSplitSerializerTest.java       |   7 +-
 .../core}/table/JdbcDynamicTableFactoryTest.java   |   4 +-
 .../jdbc/core}/table/JdbcTablePlanTest.java        |   2 +-
 .../core/table/sink}/JdbcAppendOnlyWriterTest.java |   6 +-
 .../table/sink}/JdbcDynamicTableSinkITCase.java    |   2 +-
 .../core/table/sink}/JdbcOutputFormatTest.java     |   2 +-
 .../source}/JdbcDynamicTableSourceITCase.java      |   2 +-
 ...FilterPushdownPreparedStatementVisitorTest.java |   8 +-
 .../core/table/source}/JdbcLookupTestBase.java     |   4 +-
 .../table/source}/JdbcRowDataInputFormatTest.java  |   4 +-
 .../source}/JdbcRowDataLookupFunctionTest.java     |   2 +-
 .../xa/SimpleXaConnectionProviderTest.java         |   2 +-
 .../xa/TransactionIdConnectionTest.java            |   2 +-
 .../transactions/xa/domain/TransactionIdTest.java  |   0
 .../datasource/transactions/xa/xid}/XaXidTest.java |   7 +-
 .../transactions/xa/xid}/XidSerializersTest.java   |   2 +-
 .../flink/connector/jdbc}/derby/DerbyTestBase.java |   4 +-
 .../jdbc/derby/database/DerbyDialectTest.java      |  31 +-
 .../derby/table/DerbyDynamicTableSinkITCase.java   |   8 +-
 .../derby/table/DerbyDynamicTableSourceITCase.java |   8 +-
 .../jdbc/derby/testutils}/DerbyDatabase.java       |  59 ++-
 .../jdbc/derby/testutils}/DerbyMetadata.java       |   2 +-
 .../flink/connector/jdbc/fakedb/FakeDBUtils.java   |   0
 .../jdbc/fakedb/driver/FakeConnection.java         |   0
 .../jdbc/fakedb/driver/FakeConnection1.java        |   0
 .../jdbc/fakedb/driver/FakeConnection2.java        |   0
 .../jdbc/fakedb/driver/FakeConnection3.java        |   0
 .../connector/jdbc/fakedb/driver/FakeDriver1.java  |   0
 .../connector/jdbc/fakedb/driver/FakeDriver2.java  |   0
 .../connector/jdbc/fakedb/driver/FakeDriver3.java  |   0
 .../flink/connector/jdbc}/h2/H2XaTestBase.java     |   4 +-
 .../connector/jdbc/h2/testutils}/H2Metadata.java   |   4 +-
 .../connector/jdbc/h2/testutils}/H2XaDatabase.java |  45 +-
 .../h2/testutils}/xa/H2XaConnectionWrapper.java    |   2 +-
 .../jdbc/h2/testutils}/xa/H2XaDsWrapper.java       |   2 +-
 .../jdbc/h2/testutils}/xa/H2XaResourceWrapper.java |   2 +-
 .../jdbc/h2/testutils}/xa/package-info.java        |   4 +-
 .../connector/jdbc/internal/JdbcFullTest.java      |   0
 .../jdbc/internal/JdbcOutputSerializerTest.java    |   0
 .../jdbc/internal/JdbcTableOutputFormatTest.java   |   0
 ...ProviderDriverClassConcurrentLoadingITCase.java |   0
 .../SimpleJdbcConnectionProviderTest.java          |   0
 .../NumericBetweenParametersProviderTest.java      |   0
 .../jdbc/testutils/DatabaseExtension.java          |  88 ++--
 .../connector/jdbc/testutils/DatabaseMetadata.java |   0
 .../connector/jdbc/testutils/DatabaseResource.java |  15 +
 .../connector/jdbc/testutils/DatabaseTest.java     |   0
 .../connector/jdbc/testutils/JdbcITCaseBase.java   |   0
 .../connector/jdbc/testutils/TableManaged.java     |   0
 .../testutils/functions/JdbcResultSetBuilder.java  |   0
 .../jdbc/testutils/resources/DockerResource.java   |  61 +++
 .../jdbc/testutils/resources/MemoryResource.java   |   6 +
 .../connector/jdbc/testutils/tables/TableBase.java |   0
 .../jdbc/testutils/tables/TableBuilder.java        |   0
 .../jdbc/testutils/tables/TableBuilderTest.java    |   0
 .../jdbc/testutils/tables/TableField.java          |   0
 .../connector/jdbc/testutils/tables/TableRow.java  |   0
 .../testutils/tables/templates/BooksTable.java     |   0
 .../connector/jdbc/utils/JdbcTypeUtilTest.java     |   0
 .../resources/META-INF/services/java.sql.Driver    |   0
 .../src/test/resources/archunit.properties         |   0
 .../src/test/resources/log4j2-test.properties      |   0
 .../jdbc/core}/table/JdbcTablePlanTest.xml         |   0
 flink-connector-jdbc-cratedb/pom.xml               | 118 +++++
 .../jdbc/cratedb/database/CrateDBFactory.java      |  25 +-
 .../cratedb/database}/catalog/CrateDBCatalog.java  |   4 +-
 .../database}/catalog/CrateDBTablePath.java        |   6 +-
 .../database}/catalog/CrateDBTypeMapper.java       |   4 +-
 .../cratedb/database}/dialect/CrateDBDialect.java  |  16 +-
 .../database/dialect/CrateDBDialectConverter.java  |  14 +-
 ....flink.connector.jdbc.core.database.JdbcFactory |   3 +-
 .../connector/jdbc/cratedb}/CrateDBTestBase.java   |   4 +-
 .../database}/catalog/CrateDBCatalogITCase.java    |   4 +-
 .../database}/catalog/CrateDBCatalogTest.java      |  19 +-
 .../database}/catalog/CrateDBCatalogTestBase.java  |  27 +-
 .../database}/catalog/CrateDBTablePathTest.java    |   2 +-
 .../database/dialect/CrateDBDialectTest.java       |  14 +-
 .../jdbc/cratedb/testutils}/CrateDBDatabase.java   |  17 +-
 .../jdbc/cratedb/testutils/CrateDBImages.java      |   6 +-
 .../jdbc/cratedb/testutils}/CrateDBMetadata.java   |   2 +-
 .../src/test/resources/log4j2-test.properties      |   0
 flink-connector-jdbc-db2/pom.xml                   | 103 ++++
 .../connector/jdbc/db2/database/Db2Factory.java    |  23 +-
 .../jdbc/db2/database}/dialect/Db2Dialect.java     |  12 +-
 .../db2/database/dialect/Db2DialectConverter.java  |  10 +-
 ....flink.connector.jdbc.core.database.JdbcFactory |   3 +-
 .../flink/connector/jdbc}/db2/Db2TestBase.java     |   4 +-
 .../jdbc/db2/database/dialect/Db2DialectTest.java  |  13 +-
 .../dialect/Db2PreparedStatementTest.java          |   9 +-
 .../database}/table/Db2DynamicTableSinkITCase.java |   8 +-
 .../table/Db2DynamicTableSourceITCase.java         |   8 +-
 .../connector/jdbc/db2/testutils}/Db2Database.java |  16 +-
 .../connector/jdbc/db2/testutils/Db2Images.java    |   6 +
 .../connector/jdbc/db2/testutils}/Db2Metadata.java |   2 +-
 .../src/test/resources/log4j2-test.properties      |   0
 flink-connector-jdbc-mysql/pom.xml                 | 108 ++++
 .../jdbc/mysql/database/MySqlFactory.java          |  24 +-
 .../jdbc/mysql/database}/catalog/MySqlCatalog.java |   8 +-
 .../mysql/database}/catalog/MySqlTypeMapper.java   |   9 +-
 .../database/dialect/MySQLDialectConverter.java    |   8 +-
 .../jdbc/mysql/database}/dialect/MySqlDialect.java |  10 +-
 ....flink.connector.jdbc.core.database.JdbcFactory |   3 +-
 .../flink/connector/jdbc}/mysql/MySqlTestBase.java |   4 +-
 .../database}/catalog/MySqlCatalogITCase.java      |   4 +-
 .../database}/catalog/MySqlCatalogTestBase.java    |   2 +-
 .../mysql/database/dialect/MySqlDialectTest.java   |  30 +-
 .../dialect/MysqlPreparedStatementTest.java        |  12 +-
 .../mysql/table/MySqlDynamicTableSinkITCase.java   |   8 +-
 .../mysql/table/MySqlDynamicTableSourceITCase.java |   8 +-
 .../mysql/table/UnsignedTypeConversionITCase.java  |   4 +-
 .../jdbc/mysql/testutils}/MySqlContainer.java      |   2 +-
 .../jdbc/mysql/testutils}/MySqlDatabase.java       |  14 +-
 .../jdbc/mysql/testutils}/MySqlImages.java         |   6 +-
 .../jdbc/mysql/testutils}/MySqlMetadata.java       |   2 +-
 .../src/test/resources/log4j2-test.properties      |   0
 flink-connector-jdbc-oceanbase/pom.xml             | 117 +++++
 .../jdbc/oceanbase/database/OceanBaseFactory.java  |  25 +-
 .../database}/dialect/OceanBaseDialect.java        |  14 +-
 .../dialect/OceanBaseDialectConverter.java         |   8 +-
 ....flink.connector.jdbc.core.database.JdbcFactory |   3 +-
 .../jdbc}/oceanbase/OceanBaseMysqlTestBase.java    |   6 +-
 .../jdbc}/oceanbase/OceanBaseOracleTestBase.java   |  12 +-
 .../database}/dialect/OceanBaseDialectTest.java    |   2 +-
 .../dialect/OceanBaseMysqlDialectTest.java         |  18 +-
 .../dialect/OceanBaseOracleDialectTest.java        |  18 +-
 .../OceanBaseMySqlDynamicTableSinkITCase.java      |   6 +-
 .../OceanBaseMySqlDynamicTableSourceITCase.java    |   6 +-
 .../OceanBaseOracleDynamicTableSinkITCase.java     |   6 +-
 .../OceanBaseOracleDynamicTableSourceITCase.java   |   6 +-
 .../jdbc}/oceanbase/table/OceanBaseTableRow.java   |   2 +-
 .../oceanbase/testutils}/OceanBaseDatabase.java    |  33 +-
 .../jdbc/oceanbase/testutils}/OceanBaseImages.java |   7 +-
 .../oceanbase/testutils}/OceanBaseMetadata.java    |   6 +-
 .../src/test/resources/log4j2-test.properties      |   0
 flink-connector-jdbc-oracle/pom.xml                | 101 ++++
 .../jdbc/oracle/database/OracleFactory.java        |  23 +-
 .../oracle/database}/dialect/OracleDialect.java    |  10 +-
 .../database/dialect/OracleDialectConverter.java   |   8 +-
 ....flink.connector.jdbc.core.database.JdbcFactory |   3 +-
 .../connector/jdbc}/oracle/OracleTestBase.java     |   4 +-
 .../oracle/database/dialect/OracleDialectTest.java |  14 +-
 .../dialect/OraclePreparedStatementTest.java       |   8 +-
 .../oracle/table/OracleDynamicTableSinkITCase.java |  52 +-
 .../table/OracleDynamicTableSourceITCase.java      |  53 +-
 .../oracle/table/OracleTableSourceITCase.java      |  66 ++-
 .../jdbc/oracle/testutils}/OracleDatabase.java     |  12 +-
 .../jdbc/oracle/testutils}/OracleImages.java       |   3 +-
 .../jdbc/oracle/testutils}/OracleMetadata.java     |   2 +-
 .../src/test/resources/log4j2-test.properties      |   0
 flink-connector-jdbc-postgres/pom.xml              | 123 +++++
 .../jdbc/postgres/database/PostgresFactory.java    |  25 +-
 .../database}/catalog/PostgresCatalog.java         |  12 +-
 .../database}/catalog/PostgresTablePath.java       |   2 +-
 .../database}/catalog/PostgresTypeMapper.java      |   6 +-
 .../dialect/CompatiblePostgresDialect.java         |  29 +-
 .../CompatiblePostgresDialectConverter.java        |  20 +-
 .../postgres/database/dialect/PostgresDialect.java |  25 +-
 .../database/dialect/PostgresDialectConverter.java |  20 +-
 ....flink.connector.jdbc.core.database.JdbcFactory |   3 +-
 .../connector/jdbc}/postgres/PostgresTestBase.java |   4 +-
 .../postgres/database/PostgresFactoryTest.java     |  25 +-
 .../database}/catalog/PostgresCatalogITCase.java   |   4 +-
 .../database}/catalog/PostgresCatalogTest.java     |  18 +-
 .../database}/catalog/PostgresCatalogTestBase.java |   6 +-
 .../database}/catalog/PostgresTablePathTest.java   |   2 +-
 .../database/dialect/PostgresDialectTest.java      |  14 +-
 .../table/PostgresDynamicTableSinkITCase.java      |   8 +-
 .../table/PostgresDynamicTableSourceITCase.java    |   8 +-
 .../jdbc/postgres/testutils}/PostgresDatabase.java |  15 +-
 .../jdbc/postgres/testutils}/PostgresImages.java   |   6 +-
 .../jdbc/postgres/testutils}/PostgresMetadata.java |   5 +-
 .../src/test/resources/log4j2-test.properties      |   0
 flink-connector-jdbc-sqlserver/pom.xml             | 102 ++++
 .../jdbc/sqlserver/database/SqlServerFactory.java  |  23 +-
 .../database}/dialect/SqlServerDialect.java        |  10 +-
 .../dialect/SqlServerDialectConverter.java         |   8 +-
 ....flink.connector.jdbc.core.database.JdbcFactory |   3 +-
 .../jdbc}/sqlserver/SqlServerTestBase.java         |   4 +-
 .../dialect/SqlServerPreparedStatementTest.java    |   8 +-
 .../table/SqlServerDynamicTableSinkITCase.java     |   8 +-
 .../table/SqlServerDynamicTableSourceITCase.java   |   8 +-
 .../table/SqlServerTableSourceITCase.java          |   6 +-
 .../sqlserver/testutils}/SqlServerDatabase.java    |  12 +-
 .../jdbc/sqlserver/testutils}/SqlServerImages.java |   2 +-
 .../sqlserver/testutils}/SqlServerMetadata.java    |   2 +-
 .../src/test/resources/log4j2-test.properties      |   0
 flink-connector-jdbc-trino/pom.xml                 | 112 +++++
 .../jdbc/trino/database/TrinoFactory.java          |  23 +-
 .../jdbc/trino/database}/dialect/TrinoDialect.java |  10 +-
 .../database/dialect/TrinoDialectConverter.java    |   8 +-
 ....flink.connector.jdbc.core.database.JdbcFactory |   3 +-
 .../flink/connector/jdbc}/trino/TrinoTestBase.java |   6 +-
 .../trino/database/dialect/TrinoDialectTest.java   |  17 +-
 .../dialect/TrinoPreparedStatementTest.java        |   9 +-
 .../trino/table/TrinoDynamicTableSinkITCase.java   |   8 +-
 .../trino/table/TrinoDynamicTableSourceITCase.java |   8 +-
 .../jdbc/trino/testutils}/TrinoDatabase.java       |  81 +--
 .../jdbc/trino/testutils}/TrinoImages.java         |   4 +-
 .../jdbc/trino/testutils}/TrinoMetadata.java       |   2 +-
 .../src/test/resources/log4j2-test.properties      |   0
 flink-connector-jdbc/pom.xml                       | 257 +++-------
 .../org/apache/flink/connector/jdbc/JdbcSink.java  |  11 +-
 .../jdbc/catalog/AbstractJdbcCatalog.java          | 547 +--------------------
 .../flink/connector/jdbc/catalog/JdbcCatalog.java  |   8 +-
 .../connector/jdbc/catalog/JdbcCatalogUtils.java   |  57 ++-
 .../jdbc/catalog/factory/JdbcCatalogFactory.java   |  24 +-
 .../jdbc/converter/AbstractJdbcRowConverter.java   | 253 +---------
 .../connector/jdbc/converter/JdbcRowConverter.java |  29 +-
 .../connector/jdbc/dialect/AbstractDialect.java    | 244 +--------
 .../flink/connector/jdbc/dialect/JdbcDialect.java  | 135 +----
 .../connector/jdbc/dialect/JdbcDialectFactory.java |  53 +-
 .../jdbc/dialect/JdbcDialectTypeMapper.java        |  19 +-
 .../apache/flink/connector/jdbc/sink/JdbcSink.java |  14 +-
 .../flink/connector/jdbc/sink/JdbcSinkBuilder.java |   7 +-
 .../flink/connector/jdbc/source/JdbcSource.java    |  25 +-
 .../connector/jdbc/source/JdbcSourceBuilder.java   |  32 +-
 .../source/reader/extractor/ResultExtractor.java   |  34 +-
 .../connector/jdbc/table/JdbcConnectorOptions.java | 168 +------
 .../flink/connector/jdbc/xa/CheckpointAndXid.java  |   1 +
 .../jdbc/xa/CheckpointAndXidSerializer.java        |   2 +
 .../connector/jdbc/xa/JdbcXaSinkFunction.java      |   1 +
 .../connector/jdbc/xa/JdbcXaSinkFunctionState.java |   1 +
 .../apache/flink/connector/jdbc/xa/JobSubtask.java |   1 +
 .../connector/jdbc/xa/SemanticXidGenerator.java    |   2 +
 .../apache/flink/connector/jdbc/xa/XaFacade.java   |   1 +
 .../flink/connector/jdbc/xa/XaFacadeImpl.java      |   1 +
 .../connector/jdbc/xa/XaFacadePoolingImpl.java     |   1 +
 .../apache/flink/connector/jdbc/xa/XaGroupOps.java |   1 +
 .../flink/connector/jdbc/xa/XaGroupOpsImpl.java    |   1 +
 .../connector/jdbc/xa/XaSinkStateHandler.java      |   1 +
 .../connector/jdbc/xa/XaSinkStateHandlerImpl.java  |   1 +
 .../connector/jdbc/xa/XaSinkStateSerializer.java   |   2 +
 .../flink/connector/jdbc/xa/XidGenerator.java      |   1 +
 .../flink/connector/jdbc/xa/package-info.java      |   1 +
 .../org.apache.flink.table.factories.Factory       |   1 -
 .../db2/xa/Db2ExactlyOnceSinkE2eTest.java          |  25 -
 .../derby/xa/DerbyExactlyOnceSinkE2eTest.java      |  28 --
 .../mysql/catalog/MySql56CatalogITCase.java        |  35 --
 .../mysql/catalog/MySql57CatalogITCase.java        |  34 --
 .../databases/mysql/dialect/MySqlDialectTest.java  |  41 --
 .../mysql/xa/MySqlExactlyOnceSinkE2eTest.java      |  28 --
 .../oracle/xa/OracleExactlyOnceSinkE2eTest.java    |  25 -
 .../xa/PostgresExactlyOnceSinkE2eTest.java         |  29 --
 .../xa/SqlServerExactlyOnceSinkE2eTest.java        |  29 --
 .../jdbc/dialect/JdbcDialectTypeTest.java          | 122 +----
 .../testutils/databases/mysql/MySql56Database.java |  57 ---
 .../testutils/databases/mysql/MySql57Database.java |  57 ---
 .../databases/oceanbase/OceanBaseContainer.java    |  74 ---
 .../databases/oceanbase/OceanBaseTestDatabase.java |  25 -
 .../jdbc/xa/CheckpointAndXidSerializersTest.java   |   2 +
 .../jdbc/xa/JdbcExactlyOnceSinkE2eTest.java        |  29 +-
 .../connector/jdbc/xa/JdbcXaFacadeImplTest.java    |   1 +
 .../connector/jdbc/xa/JdbcXaFacadeTestHelper.java  |   1 +
 .../connector/jdbc/xa/JdbcXaSinkDerbyTest.java     |   1 +
 .../flink/connector/jdbc/xa/JdbcXaSinkH2Test.java  |   7 +-
 .../connector/jdbc/xa/JdbcXaSinkMigrationTest.java |   7 +-
 .../jdbc/xa/JdbcXaSinkNoInsertionTest.java         |   5 +-
 .../connector/jdbc/xa/JdbcXaSinkTestBase.java      |   1 +
 .../connector/jdbc/xa/JdbcXaSinkTestHelper.java    |   1 +
 .../jdbc/xa/SemanticXidGeneratorTest.java          |   2 +
 pom.xml                                            |  33 +-
 410 files changed, 3459 insertions(+), 3530 deletions(-)
 create mode 100644 .github/workflows/backwards_compatibility.yml
 create mode 100644 flink-connector-jdbc-backward-compatibility/pom.xml
 create mode 100644 
flink-connector-jdbc-backward-compatibility/src/test/java/org/apache/flink/connector/jdbc/backward/compatibility/DataStreamSinkTest.java
 copy 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/source/JdbcSourceITCase.java
 => 
flink-connector-jdbc-backward-compatibility/src/test/java/org/apache/flink/connector/jdbc/backward/compatibility/DataStreamSourceTest.java
 (53%)
 copy 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSinkITCase.java
 => 
flink-connector-jdbc-backward-compatibility/src/test/java/org/apache/flink/connector/jdbc/backward/compatibility/DynamicTableSinkTest.java
 (76%)
 copy 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSourceITCase.java
 => 
flink-connector-jdbc-backward-compatibility/src/test/java/org/apache/flink/connector/jdbc/backward/compatibility/DynamicTableSourceTest.java
 (95%)
 copy {flink-connector-jdbc => 
flink-connector-jdbc-backward-compatibility}/src/test/resources/log4j2-test.properties
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/archunit-violations/0c7b60d6-a12c-432d-8a72-747cabaeb7ed
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/archunit-violations/0f94f11b-9bc8-445a-8be8-e7dfd8a384b0
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/archunit-violations/4bca2274-65a9-4a61-81ef-767d58233ea0
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/archunit-violations/596bd7eb-1ed5-4963-a56a-941766d61233
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/archunit-violations/6b9ab1b0-c14d-4667-bab5-407b81fba98b
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/archunit-violations/b10c194a-0517-4744-830f-81abfb71ab18
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/archunit-violations/d45c3af5-52c6-45fd-9926-75e75e77473a
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/archunit-violations/f242ee43-a122-4d2f-a291-6439cdb9029f
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/archunit-violations/stored.rules (97%)
 create mode 100644 flink-connector-jdbc-core/pom.xml
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/JdbcExactlyOnceOptions.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/JdbcInputFormat.java
 (98%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/JdbcRowOutputFormat.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/JdbcStatementBuilder.java
 (100%)
 copy 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectFactory.java
 => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/JdbcFactory.java
 (60%)
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectLoader.java
 => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/JdbcFactoryLoader.java
 (54%)
 copy {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database}/catalog/AbstractJdbcCatalog.java
 (92%)
 create mode 100644 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/JdbcCatalog.java
 copy 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectTypeMapper.java
 => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/JdbcCatalogTypeMapper.java
 (87%)
 copy {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database}/catalog/factory/JdbcCatalogFactory.java
 (65%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database}/catalog/factory/JdbcCatalogFactoryOptions.java
 (89%)
 copy {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database}/dialect/AbstractDialect.java
 (97%)
 copy 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/converter/AbstractJdbcRowConverter.java
 => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/dialect/AbstractDialectConverter.java
 (98%)
 copy {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database}/dialect/JdbcDialect.java
 (96%)
 copy 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/converter/JdbcRowConverter.java
 => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/dialect/JdbcDialectConverter.java
 (93%)
 copy 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/statements/JdbcQueryStatement.java
 => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/Jdbc.java
 (54%)
 copy {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/sink/JdbcSink.java
 (87%)
 copy {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/sink/JdbcSinkBuilder.java
 (98%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/sink/committer/JdbcCommitable.java
 (93%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/sink/committer/JdbcCommitableSerializer.java
 (88%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/sink/committer/JdbcCommitter.java
 (93%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/sink/writer/JdbcWriter.java
 (98%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/sink/writer/JdbcWriterState.java
 (98%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/sink/writer/JdbcWriterStateSerializer.java
 (97%)
 copy {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/JdbcSource.java
 (89%)
 copy {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/JdbcSourceBuilder.java
 (91%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/JdbcSourceOptions.java
 (97%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/enumerator/JdbcSourceEnumStateSerializer.java
 (94%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/enumerator/JdbcSourceEnumerator.java
 (98%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/enumerator/JdbcSourceEnumeratorState.java
 (95%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/enumerator/JdbcSqlSplitEnumeratorBase.java
 (95%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/enumerator/SqlTemplateSplitEnumerator.java
 (95%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/reader/JdbcRecordEmitter.java
 (86%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/reader/JdbcSourceReader.java
 (91%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/reader/JdbcSourceSplitReader.java
 (94%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/reader/RecordAndOffset.java
 (91%)
 copy {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/reader/extractor/ResultExtractor.java
 (95%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/reader/extractor/RowResultExtractor.java
 (94%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/split/CheckpointedOffset.java
 (97%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/split/JdbcSourceSplit.java
 (98%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/split/JdbcSourceSplitSerializer.java
 (98%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream}/source/split/JdbcSourceSplitState.java
 (98%)
 copy {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core}/table/JdbcConnectorOptions.java
 (98%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core}/table/JdbcDynamicTableFactory.java
 (84%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/sink}/JdbcDynamicTableSink.java
 (98%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/sink}/JdbcOutputFormatBuilder.java
 (97%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source}/JdbcDynamicTableSource.java
 (98%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source}/JdbcFilterPushdownPreparedStatementVisitor.java
 (99%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source}/JdbcRowDataInputFormat.java
 (97%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source}/JdbcRowDataLookupFunction.java
 (94%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source}/ParameterizedPredicate.java
 (96%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/JdbcConnectionProvider.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/SimpleJdbcConnectionProvider.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/PoolingXaConnectionProvider.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/SimpleXaConnectionProvider.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/XaCommand.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/XaConnectionProvider.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/datasource/statements/JdbcQueryStatement.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/datasource/statements/SimpleJdbcQueryStatement.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/XaTransaction.java
 (99%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/XaTransactionResult.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/domain/TransactionId.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/EmptyTransactionXaException.java
 (60%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/TransientXaException.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/XaError.java
 (100%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa 
=> 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/xid}/XidImpl.java
 (93%)
 rename {flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa 
=> 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/xid}/XidSerializer.java
 (98%)
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/derby/dialect/DerbyDialectFactory.java
 => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/derby/database/DerbyFactory.java
 (58%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/derby
 => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/derby/database}/dialect/DerbyDialect.java
 (91%)
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/derby/dialect/DerbyRowConverter.java
 => 
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/derby/database/dialect/DerbyDialectConverter.java
 (81%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/GenericJdbcSinkFunction.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcOutputFormat.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcOutputSerializer.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/RowJdbcOutputFormat.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/TableJdbcUpsertOutputFormat.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/executor/InsertOrUpdateJdbcExecutor.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/executor/JdbcBatchStatementExecutor.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/executor/KeyedBatchStatementExecutor.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/executor/SimpleBatchStatementExecutor.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferReducedStatementExecutor.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferedStatementExecutor.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableInsertOrUpdateStatementExecutor.java
 (91%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableSimpleStatementExecutor.java
 (90%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/options/InternalJdbcConnectionOptions.java
 (96%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcDmlOptions.java
 (98%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcInsertOptions.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcReadOptions.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcTypedQueryOptions.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/split/CompositeJdbcParameterValuesProvider.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/split/JdbcGenericParameterValuesProvider.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/split/JdbcNumericBetweenParametersProvider.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/split/JdbcParameterValuesProvider.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/split/JdbcSlideTimingParameterProvider.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/statement/FieldNamedPreparedStatement.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/statement/FieldNamedPreparedStatementImpl.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/statement/StatementFactory.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/utils/ContinuousUnBoundingSettings.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/utils/JdbcTypeUtil.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/java/org/apache/flink/connector/jdbc/utils/JdbcUtils.java
 (97%)
 rename 
flink-connector-jdbc/src/main/resources/META-INF/services/org.apache.flink.connector.jdbc.dialect.JdbcDialectFactory
 => 
flink-connector-jdbc-core/src/main/resources/META-INF/services/org.apache.flink.connector.jdbc.core.database.JdbcFactory
 (52%)
 copy {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
 (84%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/architecture/ProductionCodeArchitectureTest.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/base/source/reader/splitreader/TestingSplitsChange.java
 (92%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/JdbcConnectionOptionsTest.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/JdbcDataTestBase.java
 (94%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/JdbcITCase.java
 (87%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/JdbcInputFormatTest.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/JdbcRowOutputFormatTest.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/JdbcTestBase.java
 (97%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/JdbcTestCheckpoint.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/JdbcTestFixture.java
 (99%)
 rename 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalogUtilsTest.java
 => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/database/catalog/AbstractJdbcCatalogTest.java
 (71%)
 rename 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/converter/AbstractJdbcRowConverterTest.java
 => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/database/dialect/JdbcDialectConverterTest.java
 (89%)
 copy 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectTypeTest.java
 => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/database/dialect/JdbcDialectTest.java
 (54%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/datastream}/sink/AtLeastOnceJdbcSinkTest.java
 (96%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/datastream}/sink/BaseJdbcSinkTest.java
 (95%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/datastream}/sink/ExactlyOnceJdbcSinkTest.java
 (95%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/datastream}/sink/writer/AlLeastOnceJdbcWriterTest.java
 (94%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/datastream}/sink/writer/BaseJdbcWriterTest.java
 (94%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/datastream}/sink/writer/ExactlyOnceJdbcWriterTest.java
 (95%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/datastream}/sink/writer/JdbcWriterStateSerializerTest.java
 (85%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/datastream}/sink/writer/JdbcWriterStateTest.java
 (86%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/datastream}/source/JdbcSourceBuilderTest.java
 (93%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/datastream}/source/JdbcSourceITCase.java
 (97%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/datastream}/source/JdbcSourceStreamRelatedITCase.java
 (97%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/datastream}/source/enumerator/JdbcSourceEnumStateSerializerTest.java
 (88%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/datastream}/source/enumerator/JdbcSourceEnumeratorTest.java
 (91%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/datastream}/source/reader/JdbcSourceReaderTest.java
 (90%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/datastream}/source/reader/JdbcSourceSplitReaderTest.java
 (94%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/datastream}/source/split/JdbcSourceSplitSerializerTest.java
 (94%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core}/table/JdbcDynamicTableFactoryTest.java
 (98%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core}/table/JdbcTablePlanTest.java
 (99%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/table/sink}/JdbcAppendOnlyWriterTest.java
 (96%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/table/sink}/JdbcDynamicTableSinkITCase.java
 (99%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/table/sink}/JdbcOutputFormatTest.java
 (99%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/table/source}/JdbcDynamicTableSourceITCase.java
 (99%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/table/source}/JdbcFilterPushdownPreparedStatementVisitorTest.java
 (98%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/table/source}/JdbcLookupTestBase.java
 (97%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/table/source}/JdbcRowDataInputFormatTest.java
 (99%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/table/source}/JdbcRowDataLookupFunctionTest.java
 (99%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/datasource/connections/xa/SimpleXaConnectionProviderTest.java
 (99%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/datasource/connections/xa/TransactionIdConnectionTest.java
 (99%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/domain/TransactionIdTest.java
 (100%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa 
=> 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/xid}/XaXidTest.java
 (91%)
 rename {flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa 
=> 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/xid}/XidSerializersTest.java
 (95%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc}/derby/DerbyTestBase.java
 (89%)
 copy 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/dialect/MySqlDialectTypeTest.java
 => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/derby/database/DerbyDialectTest.java
 (70%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc}/derby/table/DerbyDynamicTableSinkITCase.java
 (77%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc}/derby/table/DerbyDynamicTableSourceITCase.java
 (91%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/derby
 => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/derby/testutils}/DerbyDatabase.java
 (52%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/derby
 => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/derby/testutils}/DerbyMetadata.java
 (96%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/fakedb/FakeDBUtils.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeConnection.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeConnection1.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeConnection2.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeConnection3.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeDriver1.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeDriver2.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeDriver3.java
 (100%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc}/h2/H2XaTestBase.java
 (90%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/h2
 => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/h2/testutils}/H2Metadata.java
 (92%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/h2
 => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/h2/testutils}/H2XaDatabase.java
 (52%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/h2
 => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/h2/testutils}/xa/H2XaConnectionWrapper.java
 (97%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/h2
 => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/h2/testutils}/xa/H2XaDsWrapper.java
 (97%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/h2
 => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/h2/testutils}/xa/H2XaResourceWrapper.java
 (99%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/h2
 => 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/h2/testutils}/xa/package-info.java
 (84%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/internal/JdbcFullTest.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/internal/JdbcOutputSerializerTest.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/internal/JdbcTableOutputFormatTest.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/internal/connection/SimpleJdbcConnectionProviderDriverClassConcurrentLoadingITCase.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/internal/connection/SimpleJdbcConnectionProviderTest.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/split/NumericBetweenParametersProviderTest.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/testutils/DatabaseExtension.java
 (76%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/testutils/DatabaseMetadata.java
 (100%)
 create mode 100644 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/testutils/DatabaseResource.java
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/testutils/DatabaseTest.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/testutils/JdbcITCaseBase.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/testutils/TableManaged.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/testutils/functions/JdbcResultSetBuilder.java
 (100%)
 create mode 100644 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/testutils/resources/DockerResource.java
 create mode 100644 
flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/testutils/resources/MemoryResource.java
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/testutils/tables/TableBase.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/testutils/tables/TableBuilder.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/testutils/tables/TableBuilderTest.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/testutils/tables/TableField.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/testutils/tables/TableRow.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/testutils/tables/templates/BooksTable.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/java/org/apache/flink/connector/jdbc/utils/JdbcTypeUtilTest.java
 (100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/resources/META-INF/services/java.sql.Driver 
(100%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/resources/archunit.properties (100%)
 copy {flink-connector-jdbc => 
flink-connector-jdbc-core}/src/test/resources/log4j2-test.properties (100%)
 rename 
{flink-connector-jdbc/src/test/resources/org/apache/flink/connector/jdbc => 
flink-connector-jdbc-core/src/test/resources/org/apache/flink/connector/jdbc/core}/table/JdbcTablePlanTest.xml
 (100%)
 create mode 100644 flink-connector-jdbc-cratedb/pom.xml
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/cratedb/dialect/CrateDBDialectFactory.java
 => 
flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/CrateDBFactory.java
 (54%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/cratedb
 => 
flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database}/catalog/CrateDBCatalog.java
 (97%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/cratedb
 => 
flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database}/catalog/CrateDBTablePath.java
 (91%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/cratedb
 => 
flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database}/catalog/CrateDBTypeMapper.java
 (92%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/cratedb
 => 
flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database}/dialect/CrateDBDialect.java
 (69%)
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/cratedb/dialect/CrateDBRowConverter.java
 => 
flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/dialect/CrateDBDialectConverter.java
 (73%)
 copy 
flink-connector-jdbc/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
 => 
flink-connector-jdbc-cratedb/src/main/resources/META-INF/services/org.apache.flink.connector.jdbc.core.database.JdbcFactory
 (85%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/cratedb/catalog
 => 
flink-connector-jdbc-cratedb/src/test/java/org/apache/flink/connector/jdbc/cratedb}/CrateDBTestBase.java
 (89%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/cratedb
 => 
flink-connector-jdbc-cratedb/src/test/java/org/apache/flink/connector/jdbc/cratedb/database}/catalog/CrateDBCatalogITCase.java
 (97%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/cratedb
 => 
flink-connector-jdbc-cratedb/src/test/java/org/apache/flink/connector/jdbc/cratedb/database}/catalog/CrateDBCatalogTest.java
 (89%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/cratedb
 => 
flink-connector-jdbc-cratedb/src/test/java/org/apache/flink/connector/jdbc/cratedb/database}/catalog/CrateDBCatalogTestBase.java
 (92%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/cratedb
 => 
flink-connector-jdbc-cratedb/src/test/java/org/apache/flink/connector/jdbc/cratedb/database}/catalog/CrateDBTablePathTest.java
 (97%)
 rename 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/cratedb/dialect/CrateDBDialectTypeTest.java
 => 
flink-connector-jdbc-cratedb/src/test/java/org/apache/flink/connector/jdbc/cratedb/database/dialect/CrateDBDialectTest.java
 (86%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/cratedb
 => 
flink-connector-jdbc-cratedb/src/test/java/org/apache/flink/connector/jdbc/cratedb/testutils}/CrateDBDatabase.java
 (90%)
 copy 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/trino/TrinoImages.java
 => 
flink-connector-jdbc-cratedb/src/test/java/org/apache/flink/connector/jdbc/cratedb/testutils/CrateDBImages.java
 (85%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/cratedb
 => 
flink-connector-jdbc-cratedb/src/test/java/org/apache/flink/connector/jdbc/cratedb/testutils}/CrateDBMetadata.java
 (96%)
 copy {flink-connector-jdbc => 
flink-connector-jdbc-cratedb}/src/test/resources/log4j2-test.properties (100%)
 create mode 100644 flink-connector-jdbc-db2/pom.xml
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/db2/dialect/Db2DialectFactory.java
 => 
flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/Db2Factory.java
 (58%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/db2
 => 
flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database}/dialect/Db2Dialect.java
 (93%)
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/db2/dialect/Db2RowConverter.java
 => 
flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2DialectConverter.java
 (80%)
 copy 
flink-connector-jdbc/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
 => 
flink-connector-jdbc-db2/src/main/resources/META-INF/services/org.apache.flink.connector.jdbc.core.database.JdbcFactory
 (85%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-db2/src/test/java/org/apache/flink/connector/jdbc}/db2/Db2TestBase.java
 (90%)
 rename 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/dialect/Db2DialectTypeTest.java
 => 
flink-connector-jdbc-db2/src/test/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2DialectTest.java
 (85%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2
 => 
flink-connector-jdbc-db2/src/test/java/org/apache/flink/connector/jdbc/db2/database}/dialect/Db2PreparedStatementTest.java
 (92%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2
 => 
flink-connector-jdbc-db2/src/test/java/org/apache/flink/connector/jdbc/db2/database}/table/Db2DynamicTableSinkITCase.java
 (88%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2
 => 
flink-connector-jdbc-db2/src/test/java/org/apache/flink/connector/jdbc/db2/database}/table/Db2DynamicTableSourceITCase.java
 (94%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/db2
 => 
flink-connector-jdbc-db2/src/test/java/org/apache/flink/connector/jdbc/db2/testutils}/Db2Database.java
 (82%)
 create mode 100644 
flink-connector-jdbc-db2/src/test/java/org/apache/flink/connector/jdbc/db2/testutils/Db2Images.java
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/db2
 => 
flink-connector-jdbc-db2/src/test/java/org/apache/flink/connector/jdbc/db2/testutils}/Db2Metadata.java
 (97%)
 copy {flink-connector-jdbc => 
flink-connector-jdbc-db2}/src/test/resources/log4j2-test.properties (100%)
 create mode 100644 flink-connector-jdbc-mysql/pom.xml
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/mysql/dialect/MySqlDialectFactory.java
 => 
flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/MySqlFactory.java
 (55%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/mysql
 => 
flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database}/catalog/MySqlCatalog.java
 (95%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/mysql
 => 
flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database}/catalog/MySqlTypeMapper.java
 (96%)
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/mysql/dialect/MySQLRowConverter.java
 => 
flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/dialect/MySQLDialectConverter.java
 (81%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/mysql
 => 
flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database}/dialect/MySqlDialect.java
 (93%)
 copy 
flink-connector-jdbc/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
 => 
flink-connector-jdbc-mysql/src/main/resources/META-INF/services/org.apache.flink.connector.jdbc.core.database.JdbcFactory
 (85%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-mysql/src/test/java/org/apache/flink/connector/jdbc}/mysql/MySqlTestBase.java
 (89%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql
 => 
flink-connector-jdbc-mysql/src/test/java/org/apache/flink/connector/jdbc/mysql/database}/catalog/MySqlCatalogITCase.java
 (87%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql
 => 
flink-connector-jdbc-mysql/src/test/java/org/apache/flink/connector/jdbc/mysql/database}/catalog/MySqlCatalogTestBase.java
 (99%)
 rename 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/dialect/MySqlDialectTypeTest.java
 => 
flink-connector-jdbc-mysql/src/test/java/org/apache/flink/connector/jdbc/mysql/database/dialect/MySqlDialectTest.java
 (65%)
 rename 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/statement/FieldNamedPreparedStatementImplTest.java
 => 
flink-connector-jdbc-mysql/src/test/java/org/apache/flink/connector/jdbc/mysql/database/dialect/MysqlPreparedStatementTest.java
 (94%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-mysql/src/test/java/org/apache/flink/connector/jdbc}/mysql/table/MySqlDynamicTableSinkITCase.java
 (88%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-mysql/src/test/java/org/apache/flink/connector/jdbc}/mysql/table/MySqlDynamicTableSourceITCase.java
 (91%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-mysql/src/test/java/org/apache/flink/connector/jdbc}/mysql/table/UnsignedTypeConversionITCase.java
 (97%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/mysql
 => 
flink-connector-jdbc-mysql/src/test/java/org/apache/flink/connector/jdbc/mysql/testutils}/MySqlContainer.java
 (99%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/mysql
 => 
flink-connector-jdbc-mysql/src/test/java/org/apache/flink/connector/jdbc/mysql/testutils}/MySqlDatabase.java
 (82%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/mysql
 => 
flink-connector-jdbc-mysql/src/test/java/org/apache/flink/connector/jdbc/mysql/testutils}/MySqlImages.java
 (82%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/mysql
 => 
flink-connector-jdbc-mysql/src/test/java/org/apache/flink/connector/jdbc/mysql/testutils}/MySqlMetadata.java
 (97%)
 copy {flink-connector-jdbc => 
flink-connector-jdbc-mysql}/src/test/resources/log4j2-test.properties (100%)
 create mode 100644 flink-connector-jdbc-oceanbase/pom.xml
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/oceanbase/dialect/OceanBaseDialectFactory.java
 => 
flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/OceanBaseFactory.java
 (59%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/oceanbase
 => 
flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database}/dialect/OceanBaseDialect.java
 (87%)
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/oceanbase/dialect/OceanBaseRowConverter.java
 => 
flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect/OceanBaseDialectConverter.java
 (95%)
 copy 
flink-connector-jdbc/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
 => 
flink-connector-jdbc-oceanbase/src/main/resources/META-INF/services/org.apache.flink.connector.jdbc.core.database.JdbcFactory
 (85%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc}/oceanbase/OceanBaseMysqlTestBase.java
 (86%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc}/oceanbase/OceanBaseOracleTestBase.java
 (73%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase
 => 
flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/database}/dialect/OceanBaseDialectTest.java
 (96%)
 rename 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/dialect/OceanBaseMysqlDialectTypeTest.java
 => 
flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect/OceanBaseMysqlDialectTest.java
 (85%)
 rename 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/dialect/OceanBaseOracleDialectTypeTest.java
 => 
flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect/OceanBaseOracleDialectTest.java
 (82%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc}/oceanbase/table/OceanBaseMySqlDynamicTableSinkITCase.java
 (93%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc}/oceanbase/table/OceanBaseMySqlDynamicTableSourceITCase.java
 (93%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc}/oceanbase/table/OceanBaseOracleDynamicTableSinkITCase.java
 (95%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc}/oceanbase/table/OceanBaseOracleDynamicTableSourceITCase.java
 (94%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc}/oceanbase/table/OceanBaseTableRow.java
 (96%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/oceanbase
 => 
flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/testutils}/OceanBaseDatabase.java
 (67%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/oceanbase
 => 
flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/testutils}/OceanBaseImages.java
 (81%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/oceanbase
 => 
flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/testutils}/OceanBaseMetadata.java
 (92%)
 copy {flink-connector-jdbc => 
flink-connector-jdbc-oceanbase}/src/test/resources/log4j2-test.properties (100%)
 create mode 100644 flink-connector-jdbc-oracle/pom.xml
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/oracle/dialect/OracleDialectFactory.java
 => 
flink-connector-jdbc-oracle/src/main/java/org/apache/flink/connector/jdbc/oracle/database/OracleFactory.java
 (58%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/oracle
 => 
flink-connector-jdbc-oracle/src/main/java/org/apache/flink/connector/jdbc/oracle/database}/dialect/OracleDialect.java
 (94%)
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/oracle/dialect/OracleRowConverter.java
 => 
flink-connector-jdbc-oracle/src/main/java/org/apache/flink/connector/jdbc/oracle/database/dialect/OracleDialectConverter.java
 (96%)
 copy 
flink-connector-jdbc/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
 => 
flink-connector-jdbc-oracle/src/main/resources/META-INF/services/org.apache.flink.connector.jdbc.core.database.JdbcFactory
 (85%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-oracle/src/test/java/org/apache/flink/connector/jdbc}/oracle/OracleTestBase.java
 (89%)
 rename 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/dialect/OracleDialectTypeTest.java
 => 
flink-connector-jdbc-oracle/src/test/java/org/apache/flink/connector/jdbc/oracle/database/dialect/OracleDialectTest.java
 (85%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle
 => 
flink-connector-jdbc-oracle/src/test/java/org/apache/flink/connector/jdbc/oracle/database}/dialect/OraclePreparedStatementTest.java
 (97%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-oracle/src/test/java/org/apache/flink/connector/jdbc}/oracle/table/OracleDynamicTableSinkITCase.java
 (58%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-oracle/src/test/java/org/apache/flink/connector/jdbc}/oracle/table/OracleDynamicTableSourceITCase.java
 (56%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-oracle/src/test/java/org/apache/flink/connector/jdbc}/oracle/table/OracleTableSourceITCase.java
 (75%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/oracle
 => 
flink-connector-jdbc-oracle/src/test/java/org/apache/flink/connector/jdbc/oracle/testutils}/OracleDatabase.java
 (84%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/oracle
 => 
flink-connector-jdbc-oracle/src/test/java/org/apache/flink/connector/jdbc/oracle/testutils}/OracleImages.java
 (88%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/oracle
 => 
flink-connector-jdbc-oracle/src/test/java/org/apache/flink/connector/jdbc/oracle/testutils}/OracleMetadata.java
 (97%)
 copy {flink-connector-jdbc => 
flink-connector-jdbc-oracle}/src/test/resources/log4j2-test.properties (100%)
 create mode 100644 flink-connector-jdbc-postgres/pom.xml
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/postgres/dialect/PostgresDialectFactory.java
 => 
flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/PostgresFactory.java
 (54%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/postgres
 => 
flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database}/catalog/PostgresCatalog.java
 (95%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/postgres
 => 
flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database}/catalog/PostgresTablePath.java
 (98%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/postgres
 => 
flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database}/catalog/PostgresTypeMapper.java
 (97%)
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/postgres/dialect/PostgresDialect.java
 => 
flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect/CompatiblePostgresDialect.java
 (61%)
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/postgres/dialect/PostgresRowConverter.java
 => 
flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect/CompatiblePostgresDialectConverter.java
 (67%)
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/AbstractPostgresCompatibleDialect.java
 => 
flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect/PostgresDialect.java
 (85%)
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/converter/AbstractPostgresCompatibleRowConverter.java
 => 
flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect/PostgresDialectConverter.java
 (87%)
 copy 
flink-connector-jdbc/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
 => 
flink-connector-jdbc-postgres/src/main/resources/META-INF/services/org.apache.flink.connector.jdbc.core.database.JdbcFactory
 (85%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-postgres/src/test/java/org/apache/flink/connector/jdbc}/postgres/PostgresTestBase.java
 (89%)
 rename 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/catalog/factory/JdbcCatalogFactoryTest.java
 => 
flink-connector-jdbc-postgres/src/test/java/org/apache/flink/connector/jdbc/postgres/database/PostgresFactoryTest.java
 (75%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres
 => 
flink-connector-jdbc-postgres/src/test/java/org/apache/flink/connector/jdbc/postgres/database}/catalog/PostgresCatalogITCase.java
 (97%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres
 => 
flink-connector-jdbc-postgres/src/test/java/org/apache/flink/connector/jdbc/postgres/database}/catalog/PostgresCatalogTest.java
 (89%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres
 => 
flink-connector-jdbc-postgres/src/test/java/org/apache/flink/connector/jdbc/postgres/database}/catalog/PostgresCatalogTestBase.java
 (98%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres
 => 
flink-connector-jdbc-postgres/src/test/java/org/apache/flink/connector/jdbc/postgres/database}/catalog/PostgresTablePathTest.java
 (97%)
 rename 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/dialect/PostgresDialectTypeTest.java
 => 
flink-connector-jdbc-postgres/src/test/java/org/apache/flink/connector/jdbc/postgres/database/dialect/PostgresDialectTest.java
 (86%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-postgres/src/test/java/org/apache/flink/connector/jdbc}/postgres/table/PostgresDynamicTableSinkITCase.java
 (76%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-postgres/src/test/java/org/apache/flink/connector/jdbc}/postgres/table/PostgresDynamicTableSourceITCase.java
 (90%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/postgres
 => 
flink-connector-jdbc-postgres/src/test/java/org/apache/flink/connector/jdbc/postgres/testutils}/PostgresDatabase.java
 (89%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/postgres
 => 
flink-connector-jdbc-postgres/src/test/java/org/apache/flink/connector/jdbc/postgres/testutils}/PostgresImages.java
 (84%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/postgres
 => 
flink-connector-jdbc-postgres/src/test/java/org/apache/flink/connector/jdbc/postgres/testutils}/PostgresMetadata.java
 (92%)
 copy {flink-connector-jdbc => 
flink-connector-jdbc-postgres}/src/test/resources/log4j2-test.properties (100%)
 create mode 100644 flink-connector-jdbc-sqlserver/pom.xml
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/sqlserver/dialect/SqlServerDialectFactory.java
 => 
flink-connector-jdbc-sqlserver/src/main/java/org/apache/flink/connector/jdbc/sqlserver/database/SqlServerFactory.java
 (57%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/sqlserver
 => 
flink-connector-jdbc-sqlserver/src/main/java/org/apache/flink/connector/jdbc/sqlserver/database}/dialect/SqlServerDialect.java
 (94%)
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/sqlserver/dialect/SqlServerRowConverter.java
 => 
flink-connector-jdbc-sqlserver/src/main/java/org/apache/flink/connector/jdbc/sqlserver/database/dialect/SqlServerDialectConverter.java
 (84%)
 copy 
flink-connector-jdbc/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
 => 
flink-connector-jdbc-sqlserver/src/main/resources/META-INF/services/org.apache.flink.connector.jdbc.core.database.JdbcFactory
 (85%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-sqlserver/src/test/java/org/apache/flink/connector/jdbc}/sqlserver/SqlServerTestBase.java
 (89%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/sqlserver
 => 
flink-connector-jdbc-sqlserver/src/test/java/org/apache/flink/connector/jdbc/sqlserver/database}/dialect/SqlServerPreparedStatementTest.java
 (94%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-sqlserver/src/test/java/org/apache/flink/connector/jdbc}/sqlserver/table/SqlServerDynamicTableSinkITCase.java
 (87%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-sqlserver/src/test/java/org/apache/flink/connector/jdbc}/sqlserver/table/SqlServerDynamicTableSourceITCase.java
 (94%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-sqlserver/src/test/java/org/apache/flink/connector/jdbc}/sqlserver/table/SqlServerTableSourceITCase.java
 (97%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/sqlserver
 => 
flink-connector-jdbc-sqlserver/src/test/java/org/apache/flink/connector/jdbc/sqlserver/testutils}/SqlServerDatabase.java
 (89%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/sqlserver
 => 
flink-connector-jdbc-sqlserver/src/test/java/org/apache/flink/connector/jdbc/sqlserver/testutils}/SqlServerImages.java
 (94%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/sqlserver
 => 
flink-connector-jdbc-sqlserver/src/test/java/org/apache/flink/connector/jdbc/sqlserver/testutils}/SqlServerMetadata.java
 (97%)
 copy {flink-connector-jdbc => 
flink-connector-jdbc-sqlserver}/src/test/resources/log4j2-test.properties (100%)
 create mode 100644 flink-connector-jdbc-trino/pom.xml
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/trino/dialect/TrinoDialectFactory.java
 => 
flink-connector-jdbc-trino/src/main/java/org/apache/flink/connector/jdbc/trino/database/TrinoFactory.java
 (58%)
 rename 
{flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/trino
 => 
flink-connector-jdbc-trino/src/main/java/org/apache/flink/connector/jdbc/trino/database}/dialect/TrinoDialect.java
 (91%)
 rename 
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/trino/dialect/TrinoRowConverter.java
 => 
flink-connector-jdbc-trino/src/main/java/org/apache/flink/connector/jdbc/trino/database/dialect/TrinoDialectConverter.java
 (89%)
 copy 
flink-connector-jdbc/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
 => 
flink-connector-jdbc-trino/src/main/resources/META-INF/services/org.apache.flink.connector.jdbc.core.database.JdbcFactory
 (85%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-trino/src/test/java/org/apache/flink/connector/jdbc}/trino/TrinoTestBase.java
 (88%)
 rename 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/trino/dialect/TrinoDialectTypeTest.java
 => 
flink-connector-jdbc-trino/src/test/java/org/apache/flink/connector/jdbc/trino/database/dialect/TrinoDialectTest.java
 (81%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/trino
 => 
flink-connector-jdbc-trino/src/test/java/org/apache/flink/connector/jdbc/trino/database}/dialect/TrinoPreparedStatementTest.java
 (95%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-trino/src/test/java/org/apache/flink/connector/jdbc}/trino/table/TrinoDynamicTableSinkITCase.java
 (89%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases 
=> 
flink-connector-jdbc-trino/src/test/java/org/apache/flink/connector/jdbc}/trino/table/TrinoDynamicTableSourceITCase.java
 (91%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/trino
 => 
flink-connector-jdbc-trino/src/test/java/org/apache/flink/connector/jdbc/trino/testutils}/TrinoDatabase.java
 (52%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/trino
 => 
flink-connector-jdbc-trino/src/test/java/org/apache/flink/connector/jdbc/trino/testutils}/TrinoImages.java
 (88%)
 rename 
{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/trino
 => 
flink-connector-jdbc-trino/src/test/java/org/apache/flink/connector/jdbc/trino/testutils}/TrinoMetadata.java
 (97%)
 rename {flink-connector-jdbc => 
flink-connector-jdbc-trino}/src/test/resources/log4j2-test.properties (100%)
 delete mode 100644 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/db2/xa/Db2ExactlyOnceSinkE2eTest.java
 delete mode 100644 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/derby/xa/DerbyExactlyOnceSinkE2eTest.java
 delete mode 100644 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySql56CatalogITCase.java
 delete mode 100644 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/catalog/MySql57CatalogITCase.java
 delete mode 100644 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/dialect/MySqlDialectTest.java
 delete mode 100644 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/xa/MySqlExactlyOnceSinkE2eTest.java
 delete mode 100644 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/xa/OracleExactlyOnceSinkE2eTest.java
 delete mode 100644 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/xa/PostgresExactlyOnceSinkE2eTest.java
 delete mode 100644 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/sqlserver/xa/SqlServerExactlyOnceSinkE2eTest.java
 delete mode 100644 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/mysql/MySql56Database.java
 delete mode 100644 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/mysql/MySql57Database.java
 delete mode 100644 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/oceanbase/OceanBaseContainer.java
 delete mode 100644 
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/testutils/databases/oceanbase/OceanBaseTestDatabase.java