This is an automated email from the ASF dual-hosted git repository.
davidzollo pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new c1011f00c0 [Test][E2E] Normalize JDBC validation URLs in CDC ITs
(#11207)
c1011f00c0 is described below
commit c1011f00c04e466c7fda48ad7b80c6bdddf8236c
Author: Daniel <[email protected]>
AuthorDate: Thu Jul 2 23:03:00 2026 +0800
[Test][E2E] Normalize JDBC validation URLs in CDC ITs (#11207)
Co-authored-by: DanielLeens <[email protected]>
---
.../org/apache/seatunnel/common/utils/JdbcUrlUtilTest.java | 12 ++++++++++++
.../jdbc/catalog/sqlserver/SqlServerURLParserTest.java | 12 ++++++++++++
.../src/test/resources/oraclecdc_to_metadata_trans.conf | 2 +-
.../resources/oraclecdc_to_mysql_with_schema_change.conf | 2 +-
.../src/test/resources/oraclecdc_to_oracle.conf | 4 ++--
.../test/resources/oraclecdc_to_oracle_skip_analysis.conf | 4 ++--
.../src/test/resources/oraclecdc_to_oracle_timestamp.conf | 4 ++--
.../test/resources/oraclecdc_to_oracle_use_select_count.conf | 4 ++--
.../oraclecdc_to_oracle_with_custom_primary_key.conf | 4 ++--
.../test/resources/oraclecdc_to_oracle_with_heartbeat.conf | 4 ++--
.../oraclecdc_to_oracle_with_multi_table_mode_one_table.conf | 4 ++--
.../oraclecdc_to_oracle_with_multi_table_mode_two_table.conf | 4 ++--
.../resources/oraclecdc_to_oracle_with_no_primary_key.conf | 4 ++--
.../test/resources/oraclecdc_to_oracle_with_partition.conf | 4 ++--
.../resources/oraclecdc_to_oracle_with_schema_change.conf | 4 ++--
.../oraclecdc_to_oracle_with_schema_change_exactly_once.conf | 4 ++--
.../test/resources/sqlservercdc_earliest_to_sqlserver.conf | 2 +-
.../src/test/resources/sqlservercdc_special_db_name.conf | 2 +-
.../src/test/resources/sqlservercdc_to_console.conf | 2 +-
.../resources/sqlservercdc_to_console_with_heartbeat.conf | 2 +-
.../test/resources/sqlservercdc_to_sqlserver_timestamp.conf | 2 +-
.../sqlservercdc_to_sqlserver_with_custom_primary_key.conf | 2 +-
...rvercdc_to_sqlserver_with_multi_table_mode_two_table.conf | 2 +-
.../sqlservercdc_to_sqlserver_with_no_primary_key.conf | 2 +-
.../sqlservercdc_to_sqlserver_with_schema_change.conf | 2 +-
.../resources/mysqlcdc_to_sqlserver_with_schema_change.conf | 2 +-
...ysqlcdc_to_sqlserver_with_schema_change_exactly_once.conf | 2 +-
.../src/test/resources/jdbc_sqlserver_source_to_sink.conf | 4 ++--
28 files changed, 63 insertions(+), 39 deletions(-)
diff --git
a/seatunnel-common/src/test/java/org/apache/seatunnel/common/utils/JdbcUrlUtilTest.java
b/seatunnel-common/src/test/java/org/apache/seatunnel/common/utils/JdbcUrlUtilTest.java
index f104b1fc34..dc7c426e7f 100644
---
a/seatunnel-common/src/test/java/org/apache/seatunnel/common/utils/JdbcUrlUtilTest.java
+++
b/seatunnel-common/src/test/java/org/apache/seatunnel/common/utils/JdbcUrlUtilTest.java
@@ -53,4 +53,16 @@ public class JdbcUrlUtilTest {
Assertions.assertEquals(5310, urlInfo.getPort());
Assertions.assertEquals(urlInfo,
JdbcUrlUtil.getUrlInfo("jdbc:mysql://192.168.1.1:5310/"));
}
+
+ @Test
+ public void testOracleServiceUrlWithDatabase() {
+ JdbcUrlUtil.UrlInfo urlInfo =
+
JdbcUrlUtil.getUrlInfo("jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB");
+ Assertions.assertTrue(urlInfo.getUrlWithDatabase().isPresent());
+ Assertions.assertEquals("ORCLCDB", urlInfo.getDefaultDatabase().get());
+ Assertions.assertEquals(
+ "jdbc:oracle:thin:@//oracle-host:1521",
urlInfo.getUrlWithoutDatabase());
+ Assertions.assertEquals("oracle-host", urlInfo.getHost());
+ Assertions.assertEquals(1521, urlInfo.getPort());
+ }
}
diff --git
a/seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerURLParserTest.java
b/seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerURLParserTest.java
index 3971853cdd..a129d6cd84 100644
---
a/seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerURLParserTest.java
+++
b/seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerURLParserTest.java
@@ -136,4 +136,16 @@ class SqlServerURLParserTest {
assertEquals(
"jdbc:sqlserver://sqlserver:1433;encrypt=false",
urlInfo.getUrlWithoutDatabase());
}
+
+ @Test
+ public void testWithDatabaseNameAndEncryptSuffix() {
+ String url =
"jdbc:sqlserver://sqlserver;databaseName=master;encrypt=false;";
+ JdbcUrlUtil.UrlInfo urlInfo = SqlServerURLParser.parse(url);
+ assertEquals("sqlserver", urlInfo.getHost());
+ assertEquals(1433, urlInfo.getPort());
+ assertEquals("master", urlInfo.getDefaultDatabase().get());
+ assertEquals("encrypt=false", urlInfo.getSuffix());
+ assertEquals(
+ "jdbc:sqlserver://sqlserver:1433;encrypt=false",
urlInfo.getUrlWithoutDatabase());
+ }
}
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_metadata_trans.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_metadata_trans.conf
index d24f797838..82ed0f766c 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_metadata_trans.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_metadata_trans.conf
@@ -33,7 +33,7 @@ source {
password = "top_secret"
database-names = ["ORCLCDB"]
schema-names = ["DEBEZIUM"]
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
source.reader.close.timeout = 120000
connection.pool.size = 1
debezium {
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_mysql_with_schema_change.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_mysql_with_schema_change.conf
index 3cf7e83dbd..255184ff71 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_mysql_with_schema_change.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_mysql_with_schema_change.conf
@@ -34,7 +34,7 @@ source {
database-names = ["ORCLCDB"]
schema-names = ["DEBEZIUM"]
table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES"]
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
source.reader.close.timeout = 120000
connection.pool.size = 1
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle.conf
index 50c1db8cdd..1e853471f6 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle.conf
@@ -34,7 +34,7 @@ source {
database-names = ["ORCLCDB"]
schema-names = ["DEBEZIUM"]
table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES"]
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
source.reader.close.timeout = 120000
connection.pool.size = 1
debezium {
@@ -52,7 +52,7 @@ sink {
Jdbc {
plugin_input = "customers"
driver = "oracle.jdbc.driver.OracleDriver"
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
username = "system"
password = "top_secret"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_skip_analysis.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_skip_analysis.conf
index 7174b16d47..8fb0742b26 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_skip_analysis.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_skip_analysis.conf
@@ -35,7 +35,7 @@ source {
database-names = ["ORCLCDB"]
schema-names = ["DEBEZIUM"]
table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES"]
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
source.reader.close.timeout = 120000
connection.pool.size = 1
debezium {
@@ -53,7 +53,7 @@ sink {
Jdbc {
plugin_input = "customers"
driver = "oracle.jdbc.driver.OracleDriver"
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
username = "system"
password = "top_secret"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_timestamp.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_timestamp.conf
index a4daae48fc..6b6b69a847 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_timestamp.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_timestamp.conf
@@ -29,7 +29,7 @@ source {
database-names = ["ORCLCDB"]
schema-names = ["DEBEZIUM"]
table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES"]
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
source.reader.close.timeout = 120000
connection.pool.size = 1
startup.mode = "timestamp"
@@ -44,7 +44,7 @@ sink {
Jdbc {
plugin_input = "customers"
driver = "oracle.jdbc.driver.OracleDriver"
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
username = "system"
password = "top_secret"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_use_select_count.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_use_select_count.conf
index ecba4aa1ea..87a3ab2d12 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_use_select_count.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_use_select_count.conf
@@ -35,7 +35,7 @@ source {
database-names = ["ORCLCDB"]
schema-names = ["DEBEZIUM"]
table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES"]
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
source.reader.close.timeout = 120000
connection.pool.size = 1
debezium {
@@ -53,7 +53,7 @@ sink {
Jdbc {
plugin_input = "customers"
driver = "oracle.jdbc.driver.OracleDriver"
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
username = "system"
password = "top_secret"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_custom_primary_key.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_custom_primary_key.conf
index bff44da32a..c6039fabbe 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_custom_primary_key.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_custom_primary_key.conf
@@ -33,7 +33,7 @@ source {
password = "top_secret"
database-names = ["ORCLCDB"]
schema-names = ["DEBEZIUM"]
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
source.reader.close.timeout = 120000
connection.pool.size = 1
debezium {
@@ -58,7 +58,7 @@ sink {
Jdbc {
plugin_input = "customers"
driver = "oracle.jdbc.driver.OracleDriver"
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
username = "system"
password = "top_secret"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_heartbeat.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_heartbeat.conf
index 09abaaaf1f..eb858102a9 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_heartbeat.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_heartbeat.conf
@@ -34,7 +34,7 @@ source {
database-names = ["ORCLCDB"]
schema-names = ["DEBEZIUM"]
table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES"]
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
source.reader.close.timeout = 120000
connection.pool.size = 1
debezium {
@@ -54,7 +54,7 @@ sink {
Jdbc {
plugin_input = "customers"
driver = "oracle.jdbc.driver.OracleDriver"
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
username = "system"
password = "top_secret"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_multi_table_mode_one_table.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_multi_table_mode_one_table.conf
index fb20e0e38f..8c9e608578 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_multi_table_mode_one_table.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_multi_table_mode_one_table.conf
@@ -34,7 +34,7 @@ source {
database-names = ["ORCLCDB"]
schema-names = ["DEBEZIUM"]
table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES"]
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
source.reader.close.timeout = 120000
connection.pool.size = 1
debezium {
@@ -53,7 +53,7 @@ Jdbc {
connection.pool.size = 1
plugin_input = "customers"
driver = "oracle.jdbc.driver.OracleDriver"
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
username = "system"
password = "top_secret"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_multi_table_mode_two_table.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_multi_table_mode_two_table.conf
index 39087065a7..c16b6046ca 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_multi_table_mode_two_table.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_multi_table_mode_two_table.conf
@@ -34,7 +34,7 @@ source {
database-names = ["ORCLCDB"]
schema-names = ["DEBEZIUM"]
table-names =
["ORCLCDB.DEBEZIUM.FULL_TYPES","ORCLCDB.DEBEZIUM.FULL_TYPES2"]
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
source.reader.close.timeout = 120000
connection.pool.size = 1
debezium {
@@ -53,7 +53,7 @@ Jdbc {
connection.pool.size = 1
plugin_input = "customers"
driver = "oracle.jdbc.driver.OracleDriver"
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
username = "system"
password = "top_secret"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_no_primary_key.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_no_primary_key.conf
index 93cbc9a64e..4013f52f4b 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_no_primary_key.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_no_primary_key.conf
@@ -34,7 +34,7 @@ source {
database-names = ["ORCLCDB"]
schema-names = ["DEBEZIUM"]
table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES_NO_PRIMARY_KEY"]
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
source.reader.close.timeout = 120000
connection.pool.size = 1
debezium {
@@ -55,7 +55,7 @@ sink {
connection.pool.size = 1
plugin_input = "customers"
driver = "oracle.jdbc.driver.OracleDriver"
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
username = "system"
password = "top_secret"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_partition.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_partition.conf
index f9439c764f..897aea96bf 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_partition.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_partition.conf
@@ -34,7 +34,7 @@ source {
database-names = ["ORCLCDB"]
schema-names = ["DEBEZIUM"]
table-names = ["ORCLCDB.DEBEZIUM.PARTITION_SOURCE_TABLE"]
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
source.reader.close.timeout = 120000
connection.pool.size = 1
debezium {
@@ -50,7 +50,7 @@ sink {
Jdbc {
plugin_input = "customers"
driver = "oracle.jdbc.driver.OracleDriver"
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
username = "system"
password = "top_secret"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_schema_change.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_schema_change.conf
index 179d26134b..c945268cd4 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_schema_change.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_schema_change.conf
@@ -34,7 +34,7 @@ source {
database-names = ["ORCLCDB"]
schema-names = ["DEBEZIUM"]
table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES"]
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
source.reader.close.timeout = 120000
connection.pool.size = 1
@@ -53,7 +53,7 @@ sink {
Jdbc {
plugin_input = "customers"
driver = "oracle.jdbc.driver.OracleDriver"
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
username = "dbzuser"
password = "dbz"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_schema_change_exactly_once.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_schema_change_exactly_once.conf
index d423e5fec6..77bc350512 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_schema_change_exactly_once.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/resources/oraclecdc_to_oracle_with_schema_change_exactly_once.conf
@@ -34,7 +34,7 @@ source {
database-names = ["ORCLCDB"]
schema-names = ["DEBEZIUM"]
table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES"]
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
source.reader.close.timeout = 120000
connection.pool.size = 1
@@ -53,7 +53,7 @@ sink {
Jdbc {
plugin_input = "customers"
driver = "oracle.jdbc.driver.OracleDriver"
- url = "jdbc:oracle:thin:@oracle-host:1521/ORCLCDB"
+ url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
username = "dbzuser"
password = "dbz"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_earliest_to_sqlserver.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_earliest_to_sqlserver.conf
index 6dfef86e9f..b75ea03199 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_earliest_to_sqlserver.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_earliest_to_sqlserver.conf
@@ -46,7 +46,7 @@ sink {
Jdbc {
plugin_input = "customers"
driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
- url = "jdbc:sqlserver://sqlserver-host:1433;encrypt=false"
+ url =
"jdbc:sqlserver://sqlserver-host:1433;databaseName=column_type_test;encrypt=false"
user = "sa"
password = "Password!"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_special_db_name.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_special_db_name.conf
index 530263ad5e..3c96938737 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_special_db_name.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_special_db_name.conf
@@ -43,7 +43,7 @@ sink {
Jdbc {
plugin_input = "customers"
driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
- url = "jdbc:sqlserver://sqlserver-host:1433;encrypt=false"
+ url =
"jdbc:sqlserver://sqlserver-host:1433;databaseName=test-db-name;encrypt=false"
user = "sa"
password = "Password!"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_console.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_console.conf
index 1d282d29cf..4685e451a8 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_console.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_console.conf
@@ -44,7 +44,7 @@ sink {
Jdbc {
plugin_input = "customers"
driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
- url = "jdbc:sqlserver://sqlserver-host:1433;encrypt=false"
+ url =
"jdbc:sqlserver://sqlserver-host:1433;databaseName=column_type_test;encrypt=false"
user = "sa"
password = "Password!"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_console_with_heartbeat.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_console_with_heartbeat.conf
index af265a9c16..c8c427cc83 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_console_with_heartbeat.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_console_with_heartbeat.conf
@@ -48,7 +48,7 @@ sink {
Jdbc {
plugin_input = "customers"
driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
- url = "jdbc:sqlserver://sqlserver-host:1433;encrypt=false"
+ url =
"jdbc:sqlserver://sqlserver-host:1433;databaseName=column_type_test;encrypt=false"
user = "sa"
password = "Password!"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_timestamp.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_timestamp.conf
index f0e178ebfb..b13a96a694 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_timestamp.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_timestamp.conf
@@ -45,7 +45,7 @@ sink {
Jdbc {
plugin_input = "customers"
driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
- url = "jdbc:sqlserver://sqlserver-host:1433;encrypt=false"
+ url =
"jdbc:sqlserver://sqlserver-host:1433;databaseName=column_type_test;encrypt=false"
user = "sa"
password = "Password!"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_with_custom_primary_key.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_with_custom_primary_key.conf
index 2b30a642df..3bb3ea9408 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_with_custom_primary_key.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_with_custom_primary_key.conf
@@ -52,7 +52,7 @@ sink {
Jdbc {
plugin_input = "customers"
driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
- url = "jdbc:sqlserver://sqlserver-host:1433;encrypt=false"
+ url =
"jdbc:sqlserver://sqlserver-host:1433;databaseName=column_type_test;encrypt=false"
user = "sa"
password = "Password!"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_with_multi_table_mode_two_table.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_with_multi_table_mode_two_table.conf
index f367f29e4b..8046389c3b 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_with_multi_table_mode_two_table.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_with_multi_table_mode_two_table.conf
@@ -44,7 +44,7 @@ sink {
Jdbc {
plugin_input = "customers"
driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
- url = "jdbc:sqlserver://sqlserver-host:1433;encrypt=false"
+ url =
"jdbc:sqlserver://sqlserver-host:1433;databaseName=column_type_test;encrypt=false"
user = "sa"
password = "Password!"
# Pre-create both sink tables so this E2E only validates multi-table CDC
routing.
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_with_no_primary_key.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_with_no_primary_key.conf
index 36aa8280de..f954f471e2 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_with_no_primary_key.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_with_no_primary_key.conf
@@ -46,7 +46,7 @@ sink {
Jdbc {
plugin_input = "customers"
driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
- url = "jdbc:sqlserver://sqlserver-host:1433;encrypt=false"
+ url =
"jdbc:sqlserver://sqlserver-host:1433;databaseName=column_type_test;encrypt=false"
user = "sa"
password = "Password!"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_with_schema_change.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_with_schema_change.conf
index 3ea0f5983c..99593b4ae3 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_with_schema_change.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-sqlserver-e2e/src/test/resources/sqlservercdc_to_sqlserver_with_schema_change.conf
@@ -40,7 +40,7 @@ sink {
Jdbc {
plugin_input = "products"
driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
- url = "jdbc:sqlserver://sqlserver-host:1433;encrypt=false"
+ url =
"jdbc:sqlserver://sqlserver-host:1433;databaseName=schema_change_test;encrypt=false"
user = "sa"
password = "Password!"
generate_sink_sql = true
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-ddl/src/test/resources/mysqlcdc_to_sqlserver_with_schema_change.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-ddl/src/test/resources/mysqlcdc_to_sqlserver_with_schema_change.conf
index ad8457c6de..d340b76e59 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-ddl/src/test/resources/mysqlcdc_to_sqlserver_with_schema_change.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-ddl/src/test/resources/mysqlcdc_to_sqlserver_with_schema_change.conf
@@ -41,7 +41,7 @@ source {
sink {
jdbc {
- url = "jdbc:sqlserver://sqlserver:1433"
+ url = "jdbc:sqlserver://sqlserver:1433;databaseName=master"
driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
username = "sa"
password = "paanssy1234$"
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-ddl/src/test/resources/mysqlcdc_to_sqlserver_with_schema_change_exactly_once.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-ddl/src/test/resources/mysqlcdc_to_sqlserver_with_schema_change_exactly_once.conf
index 5b496f81ae..20ece04924 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-ddl/src/test/resources/mysqlcdc_to_sqlserver_with_schema_change_exactly_once.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-ddl/src/test/resources/mysqlcdc_to_sqlserver_with_schema_change_exactly_once.conf
@@ -41,7 +41,7 @@ source {
sink {
jdbc {
- url = "jdbc:sqlserver://sqlserver:1433"
+ url = "jdbc:sqlserver://sqlserver:1433;databaseName=master"
driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
username = "sa"
password = "paanssy1234$"
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/resources/jdbc_sqlserver_source_to_sink.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/resources/jdbc_sqlserver_source_to_sink.conf
index 3519289012..e454a44e47 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/resources/jdbc_sqlserver_source_to_sink.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/resources/jdbc_sqlserver_source_to_sink.conf
@@ -27,7 +27,7 @@ source {
# This is a example source plugin **only for test and demonstrate the
feature source plugin**
Jdbc {
driver = com.microsoft.sqlserver.jdbc.SQLServerDriver
- url = "jdbc:sqlserver://sqlserver;encrypt=false;"
+ url = "jdbc:sqlserver://sqlserver;databaseName=master;encrypt=false;"
username = SA
password = "A_Str0ng_Required_Password"
query = "select * from dbo.source"
@@ -46,7 +46,7 @@ transform {
sink {
Jdbc {
driver = com.microsoft.sqlserver.jdbc.SQLServerDriver
- url = "jdbc:sqlserver://sqlserver;encrypt=false;"
+ url = "jdbc:sqlserver://sqlserver;databaseName=master;encrypt=false;"
username = SA
password = "A_Str0ng_Required_Password"
database = "master"
