From 92f24bd02ea1b0aab409b585087ff763161e91dd Mon Sep 17 00:00:00 2001 From: Chuanyi Li Date: Wed, 8 Aug 2018 20:59:09 +0800 Subject: [PATCH] Remove dirty test case --- .../mysql/tablemeta/NoStorageTest.java | 38 --------- .../inbound/mysql/tablemeta/StorageTest.java | 77 ------------------- 2 files changed, 115 deletions(-) delete mode 100644 parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/tablemeta/NoStorageTest.java delete mode 100644 parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/tablemeta/StorageTest.java diff --git a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/tablemeta/NoStorageTest.java b/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/tablemeta/NoStorageTest.java deleted file mode 100644 index 04fd95ea..00000000 --- a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/tablemeta/NoStorageTest.java +++ /dev/null @@ -1,38 +0,0 @@ -package com.alibaba.otter.canal.parse.inbound.mysql.tablemeta; - -import com.alibaba.otter.canal.parse.inbound.TableMeta; -import com.alibaba.otter.canal.parse.inbound.mysql.MysqlConnection; -import com.alibaba.otter.canal.protocol.position.EntryPosition; -import org.junit.Test; - -import java.net.InetSocketAddress; -import java.util.Date; - -public class NoStorageTest { - final String DBNAME = "testdb"; - final String TBNAME = "testtb"; - final String DDL = "CREATE TABLE `testtb` (\n" + - " `id` int(11) NOT NULL AUTO_INCREMENT,\n" + - " `name` varchar(2048) DEFAULT NULL,\n" + - " `datachange_lasttime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最晚更新时间',\n" + - " `otter_testcol` varchar(45) DEFAULT NULL,\n" + - " `otter_testcol1` varchar(45) DEFAULT NULL,\n" + - " `otter_testcol2` varchar(45) DEFAULT NULL,\n" + - " `otter_testcol3` varchar(45) DEFAULT NULL,\n" + - " `otter_testcol4` varchar(45) DEFAULT NULL,\n" + - " `otter_testcol5` varchar(45) DEFAULT NULL,\n" + - " PRIMARY KEY (`id`)\n" + - " ) ENGINE=InnoDB AUTO_INCREMENT=58333898 DEFAULT CHARSET=utf8mb4"; - @Test - public void nostorage() { - MysqlConnection connection = new MysqlConnection(new InetSocketAddress("127.0.0.1", 3306), "root", "hello"); - TableMetaCacheWithStorage tableMetaCacheWithStorage = new TableMetaCacheWithStorage(connection, null); - EntryPosition entryPosition = new EntryPosition(); - entryPosition.setTimestamp(new Date().getTime()); - String fullTableName = DBNAME + "." + TBNAME; - tableMetaCacheWithStorage.apply(entryPosition, fullTableName, DDL, null); - entryPosition.setTimestamp(new Date().getTime() + 1000L); - TableMeta result = tableMetaCacheWithStorage.getTableMeta(DBNAME, TBNAME, false, entryPosition); - assert result.getDdl().equalsIgnoreCase(DDL); - } -} diff --git a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/tablemeta/StorageTest.java b/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/tablemeta/StorageTest.java deleted file mode 100644 index 0ec16607..00000000 --- a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/tablemeta/StorageTest.java +++ /dev/null @@ -1,77 +0,0 @@ -package com.alibaba.otter.canal.parse.inbound.mysql.tablemeta; - -import com.alibaba.otter.canal.parse.inbound.TableMeta; -import com.alibaba.otter.canal.parse.inbound.mysql.MysqlConnection; -import com.alibaba.otter.canal.parse.inbound.mysql.tablemeta.impl.mysql.MySqlTableMetaCallback; -import com.alibaba.otter.canal.parse.inbound.mysql.tablemeta.impl.mysql.MySqlTableMetaStorageFactory; -import com.alibaba.otter.canal.protocol.position.EntryPosition; -import com.alibaba.otter.canal.protocol.position.Position; -import org.junit.Test; - -import java.net.InetSocketAddress; -import java.util.ArrayList; -import java.util.Date; -import java.util.List; - -public class StorageTest { - - final String DBNAME = "testdb"; - final String TBNAME = "testtb"; - final String DDL = "CREATE TABLE `testtb` (\n" + - " `id` int(11) NOT NULL AUTO_INCREMENT,\n" + - " `name` varchar(2048) DEFAULT NULL,\n" + - " `datachange_lasttime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '最晚更新时间',\n" + - " `otter_testcol` varchar(45) DEFAULT NULL,\n" + - " `otter_testcol1` varchar(45) DEFAULT NULL,\n" + - " `otter_testcol2` varchar(45) DEFAULT NULL,\n" + - " `otter_testcol3` varchar(45) DEFAULT NULL,\n" + - " `otter_testcol4` varchar(45) DEFAULT NULL,\n" + - " `otter_testcol5` varchar(45) DEFAULT NULL,\n" + - " PRIMARY KEY (`id`)\n" + - " ) ENGINE=InnoDB AUTO_INCREMENT=58333898 DEFAULT CHARSET=utf8mb4"; - - @Test - public void storage() { - - MySqlTableMetaStorageFactory factory = 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); - MysqlConnection connection = new MysqlConnection(new InetSocketAddress("127.0.0.1", 3306), "root", "hello"); - TableMetaCacheWithStorage tableMetaCacheWithStorage = new TableMetaCacheWithStorage(connection, factory.getTableMetaStorage()); - EntryPosition entryPosition = new EntryPosition(); - entryPosition.setTimestamp(new Date().getTime()); - String fullTableName = DBNAME + "." + TBNAME; - tableMetaCacheWithStorage.apply(entryPosition, fullTableName, DDL, null); - - entryPosition.setTimestamp(new Date().getTime() + 1000L); - TableMeta result = tableMetaCacheWithStorage.getTableMeta(DBNAME, TBNAME, false, entryPosition); - assert result.getDdl().equalsIgnoreCase(DDL); - } -}