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

挪到最前面

Browse Source
This commit is contained in:
jianhao.dai
2017-07-20 11:37:24 +08:00
parent 34bcfbc3cb
commit 214e404e1b
1 changed files with 21 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java
View File

@@ -158,11 +158,6 @@ public class LogEventConvert extends AbstractCanalLifeCycle implements BinlogPar
String tableName = result.getTableName(); String tableName = result.getTableName();
EventType type = EventType.QUERY; EventType type = EventType.QUERY;
// fixed issue https://github.com/alibaba/canal/issues/58
if (result.getType() == EventType.ALTER || result.getType() == EventType.ERASE
|| result.getType() == EventType.CREATE || result.getType() == EventType.TRUNCATE
|| result.getType() == EventType.RENAME || result.getType() == EventType.CINDEX
|| result.getType() == EventType.DINDEX) { // 针对DDL类型
// 更新下table meta cache // 更新下table meta cache
if (tableMetaCache != null if (tableMetaCache != null
@@ -184,6 +179,12 @@ public class LogEventConvert extends AbstractCanalLifeCycle implements BinlogPar
} }
} }
// fixed issue https://github.com/alibaba/canal/issues/58
if (result.getType() == EventType.ALTER || result.getType() == EventType.ERASE
|| result.getType() == EventType.CREATE || result.getType() == EventType.TRUNCATE
|| result.getType() == EventType.RENAME || result.getType() == EventType.CINDEX
|| result.getType() == EventType.DINDEX) { // 针对DDL类型
if (filterQueryDdl) { if (filterQueryDdl) {
return null; return null;
} }