This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-jdbc.git
from ffee715 [FLINK-30963][ci] Streamline binary URL configuration
new 45306bb [FLINK-30790] Change log level to off on CI
new 0246064 [FLINK-30790] Refactor JdbcDataTypeTest create tests by
dialect
new ba9dbc9 [FLINK-30790] Refactor JdbcExactlyOnceSinkE2eTest create
tests by dialect
new 7addee1 [FLINK-30790] Refactor MySqlCatalogITCase create tests by
database version
new b0a25a6 [FLINK-30790] Create unified databases for testing
new d2564a9 [FLINK-30790] Change H2 and some Derby tests to new
implementation
new a4e200f [FLINK-30790] Change Oracle tests to use new OracleDatabase
new 5623cb7 [FLINK-30790] Change SqlServer tests to use new
SqlServerDatabase
new 97fa114 [FLINK-30790] Change Postgres tests to use new
PostgresDatabase
new 0bc576a [FLINK-30790] Change MySql tests to use new MySqlDatabase
new 12720ae [FLINK-30790] Remove DockerImageVersions
new 867fc0f [FLINK-30790] Fix JdbcExactlyOnceSinkE2eTest loop on failure
new cbb1c35 [FLINK-30790] Small test fixings
new 753ea0e [FLINK-30790] Cleaning metadata deprecated methods and
disableOnMac annotation
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:
.../6b9ab1b0-c14d-4667-bab5-407b81fba98b | 12 +
flink-connector-jdbc/pom.xml | 2 +-
.../flink/connector/jdbc/JdbcDataTestBase.java | 9 +-
.../flink/connector/jdbc/JdbcDataTypeTest.java | 230 ---------
.../apache/flink/connector/jdbc/JdbcITCase.java | 15 +-
.../flink/connector/jdbc/JdbcInputFormatTest.java | 52 +-
.../connector/jdbc/JdbcRowOutputFormatTest.java | 25 +-
.../apache/flink/connector/jdbc/JdbcTestBase.java | 12 +-
.../flink/connector/jdbc/JdbcTestFixture.java | 31 +-
...ablePathTest.java => MySql56CatalogITCase.java} | 22 +-
...ablePathTest.java => MySql57CatalogITCase.java} | 22 +-
.../connector/jdbc/catalog/MySqlCatalogITCase.java | 366 +-------------
.../jdbc/catalog/MySqlCatalogTestBase.java | 396 +++++++++++++--
.../jdbc/catalog/PostgresCatalogTestBase.java | 26 +-
.../catalog/factory/JdbcCatalogFactoryTest.java | 26 +-
.../DatabaseMetadata.java} | 38 +-
.../DatabaseTest.java} | 12 +-
.../jdbc/databases/derby/DerbyDatabase.java | 51 ++
.../derby/DerbyMetadata.java} | 37 +-
.../h2/H2Metadata.java} | 44 +-
.../connector/jdbc/databases/h2/H2XaDatabase.java | 50 ++
.../h2/xa}/H2XaConnectionWrapper.java | 2 +-
.../{xa/h2 => databases/h2/xa}/H2XaDsWrapper.java | 4 +-
.../h2/xa}/H2XaResourceWrapper.java | 2 +-
.../{xa/h2 => databases/h2/xa}/package-info.java | 2 +-
.../jdbc/databases/mysql/MySqlDatabase.java | 214 ++++++++
.../jdbc/databases/mysql/MySqlMetadata.java | 92 ++++
.../oracle/OracleDatabase.java} | 38 +-
.../oracle/OracleImages.java} | 12 +-
.../jdbc/databases/oracle/OracleMetadata.java | 97 ++++
.../oracle/OracleXaDatabase.java} | 39 +-
.../jdbc/databases/postgres/PostgresDatabase.java | 85 ++++
.../jdbc/databases/postgres/PostgresMetadata.java | 92 ++++
.../databases/sqlserver/SqlServerDatabase.java | 47 ++
.../databases/sqlserver/SqlServerMetadata.java | 93 ++++
.../jdbc/dialect/JdbcDialectTypeTest.java | 135 +++++
.../jdbc/dialect/mysql/MySqlDialectTypeTest.java | 65 +++
.../dialect/mysql/MySqlExactlyOnceSinkE2eTest.java | 35 ++
.../jdbc/dialect/oracle/OracleContainer.java | 99 ----
.../jdbc/dialect/oracle/OracleDialectTypeTest.java | 60 +++
.../oracle/OracleExactlyOnceSinkE2eTest.java | 31 ++
.../jdbc/dialect/oracle/OracleTableSinkITCase.java | 63 ++-
.../dialect/oracle/OracleTableSourceITCase.java | 30 +-
.../dialect/postgres/PostgresDialectTypeTest.java | 65 +++
.../postgres/PostgresExactlyOnceSinkE2eTest.java | 35 ++
.../sqlserver/SqlServerTableSinkITCase.java | 93 ++--
.../sqlserver/SqlServerTableSourceITCase.java | 29 +-
.../connector/jdbc/internal/JdbcFullTest.java | 15 +-
.../jdbc/internal/JdbcTableOutputFormatTest.java | 12 +-
.../jdbc/table/JdbcAppendOnlyWriterTest.java | 17 +-
.../jdbc/table/JdbcDynamicTableSinkITCase.java | 15 +-
.../connector/jdbc/table/JdbcOutputFormatTest.java | 27 +-
.../jdbc/table/JdbcRowDataInputFormatTest.java | 24 +-
.../jdbc/table/UnsignedTypeConversionITCase.java | 37 +-
.../jdbc/xa/JdbcExactlyOnceSinkE2eTest.java | 554 ++-------------------
.../connector/jdbc/xa/JdbcXaFacadeImplTest.java | 8 +-
.../connector/jdbc/xa/JdbcXaFacadeTestHelper.java | 44 +-
.../connector/jdbc/xa/JdbcXaSinkDerbyTest.java | 16 +-
.../flink/connector/jdbc/xa/JdbcXaSinkH2Test.java | 12 +-
.../connector/jdbc/xa/JdbcXaSinkMigrationTest.java | 17 +-
.../jdbc/xa/JdbcXaSinkNoInsertionTest.java | 12 +-
.../connector/jdbc/xa/JdbcXaSinkTestBase.java | 21 +-
tools/ci/log4j.properties | 4 +-
63 files changed, 2107 insertions(+), 1765 deletions(-)
delete mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcDataTypeTest.java
copy
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/{PostgresTablePathTest.java
=> MySql56CatalogITCase.java} (57%)
copy
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/{PostgresTablePathTest.java
=> MySql57CatalogITCase.java} (57%)
rename
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/{DbMetadata.java
=> databases/DatabaseMetadata.java} (56%)
rename
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/{test/DockerImageVersions.java
=> databases/DatabaseTest.java} (64%)
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/derby/DerbyDatabase.java
rename
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/{DerbyDbMetadata.java
=> databases/derby/DerbyMetadata.java} (67%)
rename
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/{xa/h2/H2DbMetadata.java
=> databases/h2/H2Metadata.java} (62%)
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/h2/H2XaDatabase.java
rename
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/{xa/h2 =>
databases/h2/xa}/H2XaConnectionWrapper.java (97%)
rename
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/{xa/h2 =>
databases/h2/xa}/H2XaDsWrapper.java (95%)
rename
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/{xa/h2 =>
databases/h2/xa}/H2XaResourceWrapper.java (99%)
copy flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/{xa/h2
=> databases/h2/xa}/package-info.java (94%)
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/MySqlDatabase.java
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/mysql/MySqlMetadata.java
copy
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/{xa/XidSerializersTest.java
=> databases/oracle/OracleDatabase.java} (52%)
rename
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/{xa/h2/package-info.java
=> databases/oracle/OracleImages.java} (76%)
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/OracleMetadata.java
copy
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/{xa/XidSerializersTest.java
=> databases/oracle/OracleXaDatabase.java} (50%)
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/PostgresDatabase.java
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/postgres/PostgresMetadata.java
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/sqlserver/SqlServerDatabase.java
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/sqlserver/SqlServerMetadata.java
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectTypeTest.java
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/mysql/MySqlDialectTypeTest.java
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/mysql/MySqlExactlyOnceSinkE2eTest.java
delete mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/oracle/OracleContainer.java
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/oracle/OracleDialectTypeTest.java
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/oracle/OracleExactlyOnceSinkE2eTest.java
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/postgres/PostgresDialectTypeTest.java
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/postgres/PostgresExactlyOnceSinkE2eTest.java
