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 #5012 , support mariadb 11 for Q_CHARACTER_SET_COLLATIONS

Browse Source
This commit is contained in:
jianghang.loujh
2023-12-29 12:08:28 +08:00
parent 67e0928d80
commit e233bec66a
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -641,6 +641,8 @@ public class QueryLogEvent extends LogEvent {
public static final int Q_GTID_FLAGS3 = 130; public static final int Q_GTID_FLAGS3 = 130;
public static final int Q_CHARACTER_SET_COLLATIONS = 131;
private final void unpackVariables(LogBuffer buffer, final int end) throws IOException { private final void unpackVariables(LogBuffer buffer, final int end) throws IOException {
int code = -1; int code = -1;
try { try {
@@ -772,6 +774,11 @@ public class QueryLogEvent extends LogEvent {
buffer.forward(8); buffer.forward(8);
} }
break; break;
case Q_CHARACTER_SET_COLLATIONS :
// mariadb
int count = buffer.getUint8();
// character_set_collations= Lex_cstring((const char *) pos0 , (const char *) pos);
buffer.forward(count * 4);
default: default:
/* /*
* That's why you must write status vars in growing * That's why you must write status vars in growing
@@ -835,6 +842,8 @@ public class QueryLogEvent extends LogEvent {
return "Q_XID"; return "Q_XID";
case Q_GTID_FLAGS3: case Q_GTID_FLAGS3:
return "Q_GTID_FLAGS3"; return "Q_GTID_FLAGS3";
case Q_CHARACTER_SET_COLLATIONS :
return "Q_CHARACTER_SET_COLLATIONS";
} }
return "CODE#" + code; return "CODE#" + code;
} }