This is an automated email from the ASF dual-hosted git repository.
zongwen pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from ae981df67 [feature][connector] add mysql cdc reader (#3455)
add b12a908f0 [feature][connector][jdbc] Support write cdc changelog event
in jdbc sink (#3444)
No new revisions were added by this update.
Summary of changes:
docs/en/connector-v2/sink/Jdbc.md | 38 ++++-
.../seatunnel/api/table/type/SeaTunnelRow.java | 20 +++
.../seatunnel/jdbc/config/JdbcConfig.java | 4 +-
.../seatunnel/jdbc/config/JdbcSinkOptions.java | 14 +-
.../seatunnel/jdbc/config/JdbcSourceOptions.java | 2 +
.../seatunnel/jdbc/internal/JdbcInputFormat.java | 2 +-
.../jdbc/internal/JdbcOutputFormatBuilder.java | 174 ++++++++++++++++++++
.../converter/AbstractJdbcRowConverter.java | 177 +++++++++++++++------
.../jdbc/internal/converter/JdbcRowConverter.java | 6 +-
.../jdbc/internal/dialect/JdbcDialect.java | 111 ++++++++++++-
.../jdbc/internal/dialect/db2/DB2Dialect.java | 7 +
.../internal/dialect/db2/DB2JdbcRowConverter.java | 10 --
.../jdbc/internal/dialect/dm/DmdbDialect.java | 7 +
.../internal/dialect/dm/DmdbJdbcRowConverter.java | 10 --
.../internal/dialect/gbase8a/Gbase8aDialect.java | 7 +
.../dialect/gbase8a/Gbase8aJdbcRowConverter.java | 12 --
.../jdbc/internal/dialect/mysql/MysqlDialect.java | 17 ++
.../dialect/mysql/MysqlJdbcRowConverter.java | 10 --
.../internal/dialect/oracle/OracleDialect.java | 48 ++++++
.../dialect/oracle/OracleJdbcRowConverter.java | 10 --
.../internal/dialect/phoenix/PhoenixDialect.java | 7 +
.../dialect/phoenix/PhoenixJdbcRowConverter.java | 10 --
.../internal/dialect/psql/PostgresDialect.java | 17 ++
.../dialect/psql/PostgresJdbcRowConverter.java | 10 --
.../dialect/sqlserver/SqlServerDialect.java | 47 ++++++
.../sqlserver/SqlserverJdbcRowConverter.java | 10 --
.../dialect/tablestore/TablestoreDialect.java | 8 +-
.../tablestore/TablestoreJdbcRowConverter.java | 10 --
.../internal/executor/BiConsumerWithException.java | 61 -------
.../BufferReducedBatchStatementExecutor.java | 117 ++++++++++++++
...or.java => BufferedBatchStatementExecutor.java} | 61 +++----
.../InsertOrUpdateBatchStatementExecutor.java | 118 ++++++++++++++
.../executor/SimpleBatchStatementExecutor.java | 61 +++----
...StatementBuilder.java => StatementFactory.java} | 14 +-
.../internal/options/JdbcConnectionOptions.java | 6 -
.../jdbc/sink/JdbcExactlyOnceSinkWriter.java | 15 +-
.../connectors/seatunnel/jdbc/sink/JdbcSink.java | 21 +--
.../seatunnel/jdbc/sink/JdbcSinkWriter.java | 22 ++-
.../seatunnel/jdbc/source/JdbcSource.java | 2 +-
.../connectors/seatunnel/jdbc/utils/JdbcUtils.java | 158 ------------------
.../connector-jdbc-e2e/pom.xml | 17 ++
.../seatunnel/jdbc/JdbcAutoGenerateSQLIT.java} | 105 ++++++------
.../resources/jdbc_sink_auto_generate_sql.conf} | 49 +++---
.../jdbc_sink_auto_generate_upsql_sql.conf} | 50 +++---
44 files changed, 1100 insertions(+), 582 deletions(-)
create mode 100644
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormatBuilder.java
delete mode 100644
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/BiConsumerWithException.java
create mode 100644
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/BufferReducedBatchStatementExecutor.java
copy
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/{SimpleBatchStatementExecutor.java
=> BufferedBatchStatementExecutor.java} (51%)
create mode 100644
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/InsertOrUpdateBatchStatementExecutor.java
rename
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/{JdbcStatementBuilder.java
=> StatementFactory.java} (77%)
delete mode 100644
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/JdbcUtils.java
copy
seatunnel-e2e/{seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/FakeSourceToJdbcIT.java
=>
seatunnel-connector-v2-e2e/connector-jdbc-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcAutoGenerateSQLIT.java}
(50%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-redis-e2e/src/test/resources/redis-to-redis.conf
=> connector-jdbc-e2e/src/test/resources/jdbc_sink_auto_generate_sql.conf}
(55%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-redis-e2e/src/test/resources/redis-to-redis.conf
=>
connector-jdbc-e2e/src/test/resources/jdbc_sink_auto_generate_upsql_sql.conf}
(54%)
