You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/03/02 03:20:27 UTC

[rocketmq-connect] 19/43: Update Querier.java

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

zhoubo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git

commit e72688b6be2103d02ac7fe9313bdd786dc0c7c5f
Author: Yuchen Li <yu...@126.com>
AuthorDate: Fri Aug 16 14:20:54 2019 +0800

    Update Querier.java
---
 src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java | 2 --
 1 file changed, 2 deletions(-)

diff --git a/src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java b/src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java
index 0907d40..13cbda5 100644
--- a/src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java
+++ b/src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java
@@ -144,8 +144,6 @@ public class Querier {
             Connection conn = dataSource.getConnection();
             for (Map.Entry<String, Database> entry : schema.dbMap.entrySet()) {
                 String db = entry.getKey();
-                if (!db.contains("jdbc_db"))
-                    continue;
                 Iterator<Map.Entry<String, Table>> iterator = entry.getValue().tableMap.entrySet().iterator();
                 while (iterator.hasNext()) {
                     Map.Entry<String, Table> tableEntry = iterator.next();