You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ty...@apache.org on 2023/03/24 03:34:54 UTC
[incubator-seatunnel] branch dev updated (39dbe21a2 -> c4e3f2dc0)

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

tyrantlucifer pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


    from 39dbe21a2 [Hotfix][Zeta] Fix LogicalDagGeneratorTest testcase (#4401)
     add c4e3f2dc0 [Feature][CDC][SqlServer] Support multi-table read (#4377)

No new revisions were added by this update.

Summary of changes:
 docs/en/connector-v2/source/SqlServer-CDC.md       |  34 ++---
 .../seatunnel/api/table/catalog/TablePath.java     |  50 ++++--
 .../cdc/base/utils/SourceRecordUtils.java          |   2 +-
 .../row/SeaTunnelRowDebeziumDeserializeSchema.java |   8 +-
 .../connector-cdc/connector-cdc-sqlserver/pom.xml  |   6 +
 .../config/SqlServerSourceConfigFactory.java       |  11 +-
 .../source/source/SqlServerIncrementalSource.java  |  53 ++++---
 .../source/SqlServerIncrementalSourceFactory.java  |  51 ++++++-
 .../fetch/scan/SqlServerSnapshotSplitReadTask.java |  15 +-
 .../SqlServerCatalog.java}                         |  69 ++++-----
 .../SqlServerCatalogFactory.java}                  |  12 +-
 .../sqlserver/SqlServerDataTypeConvertor.java      | 149 ++++++++++++++++++
 .../jdbc/catalog/sqlserver/SqlServerType.java      | 167 +++++++++++++++++++++
 .../jdbc/catalog/sqlserver/SqlServerURLParser.java | 120 +++++++++++++++
 .../test/resources/sqlservercdc_to_console.conf    |   7 +-
 15 files changed, 637 insertions(+), 117 deletions(-)
 copy seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/{mysql/MySqlCatalog.java => sqlserver/SqlServerCatalog.java} (81%)
 copy seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/{mysql/MySqlCatalogFactory.java => sqlserver/SqlServerCatalogFactory.java} (85%)
 create mode 100644 seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerDataTypeConvertor.java
 create mode 100644 seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerType.java
 create mode 100644 seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerURLParser.java