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 #105 , seek method add format eventType parse

Browse Source
This commit is contained in:
agapple
2014-12-17 22:08:36 +08:00
parent 13bf7c85a0
commit ac4970ef3a
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlConnection.java
View File

@@ -84,6 +84,7 @@ public class MysqlConnection implements ErosaConnection {
fetcher.start(connector.getChannel()); fetcher.start(connector.getChannel());
LogDecoder decoder = new LogDecoder(); LogDecoder decoder = new LogDecoder();
decoder.handle(LogEvent.ROTATE_EVENT); decoder.handle(LogEvent.ROTATE_EVENT);
decoder.handle(LogEvent.FORMAT_DESCRIPTION_EVENT);
decoder.handle(LogEvent.QUERY_EVENT); decoder.handle(LogEvent.QUERY_EVENT);
decoder.handle(LogEvent.XID_EVENT); decoder.handle(LogEvent.XID_EVENT);
LogContext context = new LogContext(); LogContext context = new LogContext();
@@ -202,7 +203,6 @@ public class MysqlConnection implements ErosaConnection {
logger.warn(ExceptionUtils.getFullStackTrace(e)); logger.warn(ExceptionUtils.getFullStackTrace(e));
} }
try { try {
// mariadb针对特殊的类型，需要设置session变量 // mariadb针对特殊的类型，需要设置session变量
update("SET @mariadb_slave_capability='" + LogEvent.MARIA_SLAVE_CAPABILITY_MINE + "'"); update("SET @mariadb_slave_capability='" + LogEvent.MARIA_SLAVE_CAPABILITY_MINE + "'");