From b53131553ed974544f881791302f53a939ed45f6 Mon Sep 17 00:00:00 2001 From: "charles.lin" <848497337@qq.com> Date: Thu, 9 Aug 2018 02:01:44 +0800 Subject: [PATCH] Commit test case --- .../mysql/RdsBinlogEventParserProxyTest.java | 30 ------------------- 1 file changed, 30 deletions(-) diff --git a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/RdsBinlogEventParserProxyTest.java b/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/RdsBinlogEventParserProxyTest.java index 18a217b8..c552a787 100644 --- a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/RdsBinlogEventParserProxyTest.java +++ b/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/RdsBinlogEventParserProxyTest.java @@ -58,36 +58,6 @@ public class RdsBinlogEventParserProxyTest { controller.setSecretkey(""); controller.setBatchSize(4); // controller.setRdsOpenApiUrl("https://rds.aliyuncs.com/"); - controller.setTableMetaStorageFactory(new MySqlTableMetaStorageFactory(new MySqlTableMetaCallback() { - @Override - public void save(String dbAddress, String schema, String table, String ddl, Long timestamp) { - - } - - @Override - public List fetch(String dbAddress, String dbName) { - TableMetaEntry tableMeta = new TableMetaEntry(); - tableMeta.setSchema(DBNAME); - tableMeta.setTable(TBNAME); - tableMeta.setDdl(DDL); - tableMeta.setTimestamp(new Date().getTime()); - List entries = new ArrayList(); - entries.add(tableMeta); - return entries; - } - - @Override - public List fetch(String dbAddress, String dbName, String tableName) { - TableMetaEntry tableMeta = new TableMetaEntry(); - tableMeta.setSchema(DBNAME); - tableMeta.setTable(TBNAME); - tableMeta.setDdl(DDL); - tableMeta.setTimestamp(new Date().getTime()); - List entries = new ArrayList(); - entries.add(tableMeta); - return entries; - } - }, DBNAME)); controller.setEventSink(new AbstractCanalEventSinkTest>() { @Override