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 mariadb 10.x

Browse Source
This commit is contained in:
jianghang.loujh
2022-09-13 22:28:49 +08:00
parent c055737e24
commit fb6981356f
2 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogEvent.java
View File

@@ -229,7 +229,7 @@ public abstract class LogEvent {
public static final int DELETE_ROWS_COMPRESSED_EVENT = 171; public static final int DELETE_ROWS_COMPRESSED_EVENT = 171;
/** end marker */ /** end marker */
public static final int ENUM_END_EVENT = 165; public static final int ENUM_END_EVENT = 171;
/** /**
* 1 byte length, 1 byte format Length is total length in bytes, including 2 * 1 byte length, 1 byte format Length is total length in bytes, including 2

2
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java
View File

@@ -711,6 +711,7 @@ public class QueryLogEvent extends LogEvent {
case Q_XID: case Q_XID:
// xid= uint8korr(pos); // xid= uint8korr(pos);
buffer.forward(8); buffer.forward(8);
break;
case Q_GTID_FLAGS3: case Q_GTID_FLAGS3:
// gtid_flags_extra= *pos++; // gtid_flags_extra= *pos++;
// if (gtid_flags_extra & (Gtid_log_event::FL_COMMIT_ALTER_E1 | // if (gtid_flags_extra & (Gtid_log_event::FL_COMMIT_ALTER_E1 |
@@ -725,6 +726,7 @@ public class QueryLogEvent extends LogEvent {
if ((gtid_flags_extra & (FL_COMMIT_ALTER_E1 | FL_ROLLBACK_ALTER_E1))> 0) { if ((gtid_flags_extra & (FL_COMMIT_ALTER_E1 | FL_ROLLBACK_ALTER_E1))> 0) {
buffer.forward(8); buffer.forward(8);
} }
break;
default: default:
/* /*
* That's why you must write status vars in growing * That's why you must write status vars in growing