This is an automated email from the ASF dual-hosted git repository.
leonard pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from f74f49c [FLINK-25531][connectors/kafka] Force immediate shutdown of
FlinkInternalKafkaProducer to speed up testRetryComittableOnRetriableError
add c8c6e79 [FLINK-14100][jdbc] Introduce Oracle dialect for JDBC
Connector
No new revisions were added by this update.
Summary of changes:
docs/content.zh/docs/connectors/table/jdbc.md | 44 ++++-
docs/content/docs/connectors/table/jdbc.md | 42 ++++-
flink-connectors/flink-connector-jdbc/pom.xml | 17 ++
.../OracleDialect.java} | 107 +++++++-----
.../OracleDialectFactory.java} | 10 +-
.../internal/converter/OracleRowConverter.java | 183 +++++++++++++++++++++
...flink.connector.jdbc.dialect.JdbcDialectFactory | 1 +
.../flink/connector/jdbc/JdbcDataTypeTest.java | 24 ++-
.../flink/connector/jdbc/JdbcTestFixture.java | 2 +-
.../jdbc/dialect/oracle/OracleContainer.java | 99 +++++++++++
.../oracle/OraclePreparedStatementTest.java} | 62 +++----
.../oracle/OracleTableSinkITCase.java} | 92 +++++------
.../oracle/OracleTableSourceITCase.java} | 131 ++++++++-------
.../jdbc/table/JdbcDynamicTableSinkITCase.java | 12 +-
.../jdbc/table/JdbcDynamicTableSourceITCase.java | 20 ++-
.../jdbc/xa/JdbcExactlyOnceSinkE2eTest.java | 75 ++++++++-
16 files changed, 716 insertions(+), 205 deletions(-)
copy
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/{psql/PostgresDialect.java
=> oracle/OracleDialect.java} (55%)
copy
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/{derby/DerbyDialectFactory.java
=> oracle/OracleDialectFactory.java} (81%)
create mode 100644
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/OracleRowConverter.java
create mode 100644
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/oracle/OracleContainer.java
copy
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/{statement/FieldNamedPreparedStatementImplTest.java
=> dialect/oracle/OraclePreparedStatementTest.java} (65%)
copy
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/{table/JdbcDynamicTableSinkITCase.java
=> dialect/oracle/OracleTableSinkITCase.java} (88%)
copy
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/{table/JdbcDynamicTableSourceITCase.java
=> dialect/oracle/OracleTableSourceITCase.java} (61%)
