From fb6981356f93ac9f9b892ac4be13791251729ab9 Mon Sep 17 00:00:00 2001 From: "jianghang.loujh" Date: Tue, 13 Sep 2022 22:28:49 +0800 Subject: [PATCH] fixed mariadb 10.x --- .../src/main/java/com/taobao/tddl/dbsync/binlog/LogEvent.java | 2 +- .../java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogEvent.java b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogEvent.java index 698381852e..ace5f2fdac 100644 --- a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogEvent.java +++ b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogEvent.java @@ -229,7 +229,7 @@ public abstract class LogEvent { public static final int DELETE_ROWS_COMPRESSED_EVENT = 171; /** 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 diff --git a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java index cf5f0c1e77..e617ccc178 100644 --- a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java +++ b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java @@ -711,6 +711,7 @@ private final void unpackVariables(LogBuffer buffer, final int end) throws IOExc case Q_XID: // xid= uint8korr(pos); buffer.forward(8); + break; case Q_GTID_FLAGS3: // gtid_flags_extra= *pos++; // if (gtid_flags_extra & (Gtid_log_event::FL_COMMIT_ALTER_E1 | @@ -725,6 +726,7 @@ private final void unpackVariables(LogBuffer buffer, final int end) throws IOExc if ((gtid_flags_extra & (FL_COMMIT_ALTER_E1 | FL_ROLLBACK_ALTER_E1))> 0) { buffer.forward(8); } + break; default: /* * That's why you must write status vars in growing