[Improve][CDC-Connector]Fix CDC option rule. (#6454)

apache · Mar 11, 2024 · 1ea27af · 1ea27af
1 parent b1332cb
commit 1ea27af
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 7 deletions.
diff --git a/...apache/seatunnel/connectors/seatunnel/cdc/mysql/source/MySqlIncrementalSourceFactory.java b/...apache/seatunnel/connectors/seatunnel/cdc/mysql/source/MySqlIncrementalSourceFactory.java
@@ -57,8 +57,8 @@ public OptionRule optionRule() {
                 .required(
                         JdbcSourceOptions.USERNAME,
                         JdbcSourceOptions.PASSWORD,
-                        CatalogOptions.TABLE_NAMES,
                         JdbcCatalogOptions.BASE_URL)
+                .exclusive(CatalogOptions.TABLE_NAMES, CatalogOptions.TABLE_PATTERN)
                 .optional(
                         JdbcSourceOptions.DATABASE_NAMES,
                         JdbcSourceOptions.SERVER_ID,

diff --git a/...ache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleIncrementalSourceFactory.java b/...ache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleIncrementalSourceFactory.java
@@ -54,10 +54,8 @@ public String factoryIdentifier() {
     @Override
     public OptionRule optionRule() {
         return JdbcSourceOptions.getBaseRule()
-                .required(
-                        JdbcSourceOptions.USERNAME,
-                        JdbcSourceOptions.PASSWORD,
-                        CatalogOptions.TABLE_NAMES)
+                .required(JdbcSourceOptions.USERNAME, JdbcSourceOptions.PASSWORD)
+                .exclusive(CatalogOptions.TABLE_NAMES, CatalogOptions.TABLE_PATTERN)
                 .bundled(JdbcSourceOptions.HOSTNAME, JdbcSourceOptions.PORT)
                 .optional(
                         JdbcCatalogOptions.BASE_URL,

diff --git a/.../seatunnel/connectors/seatunnel/cdc/postgres/source/PostgresIncrementalSourceFactory.java b/.../seatunnel/connectors/seatunnel/cdc/postgres/source/PostgresIncrementalSourceFactory.java
@@ -56,8 +56,8 @@ public OptionRule optionRule() {
                 .required(
                         JdbcSourceOptions.USERNAME,
                         JdbcSourceOptions.PASSWORD,
-                        CatalogOptions.TABLE_NAMES,
                         JdbcCatalogOptions.BASE_URL)
+                .exclusive(CatalogOptions.TABLE_NAMES, CatalogOptions.TABLE_PATTERN)
                 .optional(
                         JdbcSourceOptions.DATABASE_NAMES,
                         JdbcSourceOptions.SERVER_TIME_ZONE,

diff --git a/...l/connectors/seatunnel/cdc/sqlserver/source/source/SqlServerIncrementalSourceFactory.java b/...l/connectors/seatunnel/cdc/sqlserver/source/source/SqlServerIncrementalSourceFactory.java
@@ -58,8 +58,8 @@ public OptionRule optionRule() {
                 .required(
                         JdbcSourceOptions.USERNAME,
                         JdbcSourceOptions.PASSWORD,
-                        CatalogOptions.TABLE_NAMES,
                         JdbcCatalogOptions.BASE_URL)
+                .exclusive(CatalogOptions.TABLE_NAMES, CatalogOptions.TABLE_PATTERN)
                 .optional(
                         JdbcSourceOptions.DATABASE_NAMES,
                         JdbcSourceOptions.SERVER_TIME_ZONE,