[Improve][connector-cdc-mysql] avoid listing tables under unnecessary…

… databases (#5365)
apache · Aug 31, 2023 · 3e5d018 · 3e5d018
1 parent b3ba5eb
commit 3e5d018
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...n/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/TableDiscoveryUtils.java b/...n/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/TableDiscoveryUtils.java
@@ -48,7 +48,10 @@ public static List<TableId> listTables(JdbcConnection jdbc, RelationalTableFilte
                 "SHOW DATABASES",
                 rs -> {
                     while (rs.next()) {
-                        databaseNames.add(rs.getString(1));
+                        String databaseName = rs.getString(1);
+                        if (tableFilters.databaseFilter().test(databaseName)) {
+                            databaseNames.add(databaseName);
+                        }
                     }
                 });
         LOG.info("\t list of available databases is: {}", databaseNames);