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:30 UTC

[rocketmq-connect] 22/43: Update Schema.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 717d4a2572d50ef8ed7703e3706a2ce4995b4484
Author: Yuchen Li <yu...@126.com>
AuthorDate: Mon Sep 9 19:21:54 2019 +0800

    Update Schema.java
---
 src/main/java/org/apache/rocketmq/connect/jdbc/schema/Schema.java | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Schema.java b/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Schema.java
index 7434bbc..93b204f 100644
--- a/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Schema.java
+++ b/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Schema.java
@@ -27,19 +27,17 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import javax.sql.DataSource;
-//import io.openmessaging.mysql.binlog.EventProcessor;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 public class Schema {
-//    private static final Logger LOGGER = LoggerFactory.getLogger(EventProcessor.class);
 
     private static final String SQL = "select schema_name from information_schema.schemata";
-    //取得数据库
+    //acquiring databases
     private static final List<String> IGNORED_DATABASES = new ArrayList<>(
         Arrays.asList(new String[] {"information_schema", "mysql", "performance_schema", "sys"})
     );
-    //忽略的数据库
+    //ignored databases (System Databases)
     private DataSource dataSource;
 
     public Map<String, Database> dbMap;