chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

fixed issue #442 , compareTableMetaDbAndMemory

Browse Source
This commit is contained in:
agapple
2017-12-08 22:54:22 +08:00
parent d1c83ea7bb
commit 8b57b9a0a5
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/DatabaseTableMeta.java
View File

@@ -248,7 +248,7 @@ public class DatabaseTableMeta implements TableMetaTSDB {
boolean compareAll = true; boolean compareAll = true;
for (Schema schema : tmpMemoryTableMeta.getRepository().getSchemas()) { for (Schema schema : tmpMemoryTableMeta.getRepository().getSchemas()) {
for (String table : schema.showTables()) { for (String table : schema.showTables()) {
if (!compareTableMetaDbAndMemory(connection, schema.getName(), table)) { if (!compareTableMetaDbAndMemory(connection, tmpMemoryTableMeta, schema.getName(), table)) {
compareAll = false; compareAll = false;
} }
} }
@@ -284,7 +284,8 @@ public class DatabaseTableMeta implements TableMetaTSDB {
return false; return false;
} }
private boolean compareTableMetaDbAndMemory(MysqlConnection connection, final String schema, final String table) { private boolean compareTableMetaDbAndMemory(MysqlConnection connection, MemoryTableMeta memoryTableMeta,
final String schema, final String table) {
TableMeta tableMetaFromMem = memoryTableMeta.find(schema, table); TableMeta tableMetaFromMem = memoryTableMeta.find(schema, table);
TableMeta tableMetaFromDB = new TableMeta(); TableMeta tableMetaFromDB = new TableMeta();