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 <[email protected]> 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;
