Skip to content

Commit 3e5d018

Browse files
authored
[Improve][connector-cdc-mysql] avoid listing tables under unnecessary databases (#5365)
1 parent b3ba5eb commit 3e5d018

File tree

1 file changed

+4
-1
lines changed
  • seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils

1 file changed

+4
-1
lines changed

seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/TableDiscoveryUtils.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,10 @@ public static List<TableId> listTables(JdbcConnection jdbc, RelationalTableFilte
4848
"SHOW DATABASES",
4949
rs -> {
5050
while (rs.next()) {
51-
databaseNames.add(rs.getString(1));
51+
String databaseName = rs.getString(1);
52+
if (tableFilters.databaseFilter().test(databaseName)) {
53+
databaseNames.add(databaseName);
54+
}
5255
}
5356
});
5457
LOG.info("\t list of available databases is: {}", databaseNames);

0 commit comments

Comments
 (0)