This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 93c63d17e2 [Fix][Flink-starter]Hotfix flink checkpoint default value
(#7040)
add d663398739 [Feature][Connector-V2] Support jdbc hana catalog and type
convertor (#6950)
No new revisions were added by this update.
Summary of changes:
.../cdc/base/dialect/JdbcDataSourceDialect.java | 1 +
.../seatunnel/common/source/TypeDefineUtils.java | 6 +-
.../catalog/AbstractJdbcCreateTableSqlBuilder.java | 42 ++
.../jdbc/catalog/saphana/SapHanaCatalog.java | 259 ++++++++++
.../SapHanaCatalogFactory.java} | 10 +-
.../SapHanaCreateTableSqlBuilder.java} | 112 ++---
.../SapHanaURLParser.java} | 20 +-
.../seatunnel/jdbc/catalog/utils/CatalogUtils.java | 1 +
.../internal/dialect/saphana/SapHanaDialect.java | 76 ++-
.../dialect/saphana/SapHanaTypeConverter.java | 487 +++++++++++++++++++
.../dialect/saphana/SapHanaTypeMapper.java | 105 +----
.../SapHanaCreateTableSqlBuilderTest.java} | 55 +--
.../SapHanaTypeConverterTest.java} | 523 +++++++++------------
seatunnel-dist/pom.xml | 7 +
.../src/main/assembly/assembly-bin-ci.xml | 1 +
.../connectors/seatunnel/jdbc/AbstractJdbcIT.java | 26 +-
.../connectors/seatunnel/jdbc/JdbcCase.java | 1 +
.../resources/jdbc_sap_hana_source_and_sink.conf | 54 ---
.../connector-jdbc-e2e-part-6/pom.xml | 6 +
.../connectors/seatunnel/jdbc/JdbcHanaIT.java | 246 ++++++++++
.../resources/jdbc_sap_hana_source_and_sink.conf} | 29 +-
.../container/seatunnel/SeaTunnelContainer.java | 4 +-
.../engine/server/CoordinatorService.java | 8 +-
.../server/checkpoint/CheckpointManager.java | 6 +-
24 files changed, 1504 insertions(+), 581 deletions(-)
create mode 100644
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/AbstractJdbcCreateTableSqlBuilder.java
create mode 100644
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/saphana/SapHanaCatalog.java
copy
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/{psql/PostgresCatalogFactory.java
=> saphana/SapHanaCatalogFactory.java} (89%)
copy
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/{iris/IrisCreateTableSqlBuilder.java
=> saphana/SapHanaCreateTableSqlBuilder.java} (55%)
copy
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/{oracle/OracleURLParser.java
=> saphana/SapHanaURLParser.java} (66%)
create mode 100644
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/saphana/SapHanaTypeConverter.java
copy
seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/{sql/IrisCreateTableSqlBuilderTest.java
=> saphana/SapHanaCreateTableSqlBuilderTest.java} (61%)
copy
seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/{xugu/XuguTypeConverterTest.java
=> saphana/SapHanaTypeConverterTest.java} (53%)
delete mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-2/src/test/resources/jdbc_sap_hana_source_and_sink.conf
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-6/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcHanaIT.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/{connector-jdbc-e2e-part-5/src/test/resources/jdbc_dm_source_and_dm_upset_sink.conf
=>
connector-jdbc-e2e-part-6/src/test/resources/jdbc_sap_hana_source_and_sink.conf}
(69%)
