[seatunnel] branch dev updated: [Improve][connector-cdc-mysql] avoid listing tables under unnecessary databases (#5365)

[fanjia]

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

fanjia 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 3e5d018b35 [Improve][connector-cdc-mysql] avoid listing tables under 
unnecessary databases (#5365)
3e5d018b35 is described below

commit 3e5d018b3597a46b9fcc4833a45444c3d7deed60
Author: Kunni <1365976...@qq.com>
AuthorDate: Thu Aug 31 19:04:49 2023 +0800

    [Improve][connector-cdc-mysql] avoid listing tables under unnecessary 
databases (#5365)
---
 .../connectors/seatunnel/cdc/mysql/utils/TableDiscoveryUtils.java    | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/TableDiscoveryUtils.java
 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/TableDiscoveryUtils.java
index 151dcca2f3..0f635c5c7a 100644
--- 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/TableDiscoveryUtils.java
+++ 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/TableDiscoveryUtils.java
@@ -48,7 +48,10 @@ public class TableDiscoveryUtils {
                 "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);