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

compatiable polardb-x hippo&spc index status

Browse Source
This commit is contained in:
jianghang.loujh
2026-04-23 14:22:53 +08:00
parent c24307c893
commit ac6242bae9
2 changed files with 41 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
.gitignore vendored
View File

@@ -19,6 +19,8 @@ jtester.properties
*.rpm *.rpm
client-adapter/example/ client-adapter/example/
*.dat *.dat
.qwen/
.vscode/
conf/ conf/
canal-admin/canal-admin-ui/dist/ canal-admin/canal-admin-ui/dist/
canal-admin/canal-admin-ui/node/ canal-admin/canal-admin-ui/node/

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

@@ -301,6 +301,8 @@ public class QueryLogEvent extends LogEvent {
+ 1 + 1 /* type, default_table_encryption */ + 1 + 1 /* type, default_table_encryption */
+ 1 + 1 /* opt_flashback_area */ + 1 + 1 /* opt_flashback_area */
+ 1 + 1 /* type, opt_index_format_gpp_enabled */ + 1 + 1 /* type, opt_index_format_gpp_enabled */
+ 1 + 1 /* type, opt_index_format_hippo_enabled */
+ 1 + 1 /* type, opt_index_format_spc_enabled */
+ 1 + 1 /* type, opt_index_format_panda_enabled */ + 1 + 1 /* type, opt_index_format_panda_enabled */
+ 1 + 1 + NAME_LEN /* type, length, recycle_bin_table_name */); + 1 + 1 + NAME_LEN /* type, length, recycle_bin_table_name */);
@@ -620,8 +622,33 @@ public class QueryLogEvent extends LogEvent {
/** /**
* Replicate recycle_bin_table_name. * Replicate recycle_bin_table_name.
*/ */
/**
* Replicate opt_index_format_spc_enabled.
*
* @since PolarDB-X
*/
public static final int Q_OPT_INDEX_FORMAT_SPC_ENABLED = 252;
/**
* Replicate opt_index_format_hippo_enabled.
*
* @since PolarDB-X
*/
public static final int Q_OPT_INDEX_FORMAT_HIPPO_ENABLED = 253;
/*
Replicate recycle_bin_table_name.
@since PolarDB-X
*/
public static final int Q_OPT_RECYCLE_BIN_TABLE_NAME = 254; public static final int Q_OPT_RECYCLE_BIN_TABLE_NAME = 254;
/*
Replicate opt_index_format_panda_enabled.
Private codes are allocated from 255 downward (deployment order).
@since PolarDB-X
*/
public static final int Q_OPT_INDEX_FORMAT_PANDA_ENABLED = 255; public static final int Q_OPT_INDEX_FORMAT_PANDA_ENABLED = 255;
private static final String findCodeName(final int code) { private static final String findCodeName(final int code) {
@@ -669,6 +696,10 @@ public class QueryLogEvent extends LogEvent {
return "Q_OPT_FLASHBACK_AREA"; return "Q_OPT_FLASHBACK_AREA";
case Q_OPT_INDEX_FORMAT_GPP_ENABLED: case Q_OPT_INDEX_FORMAT_GPP_ENABLED:
return "Q_OPT_INDEX_FORMAT_GPP_ENABLED"; return "Q_OPT_INDEX_FORMAT_GPP_ENABLED";
case Q_OPT_INDEX_FORMAT_SPC_ENABLED:
return "Q_OPT_INDEX_FORMAT_SPC_ENABLED";
case Q_OPT_INDEX_FORMAT_HIPPO_ENABLED:
return "Q_OPT_INDEX_FORMAT_HIPPO_ENABLED";
case Q_OPT_RECYCLE_BIN_TABLE_NAME: case Q_OPT_RECYCLE_BIN_TABLE_NAME:
return "Q_OPT_RECYCLE_BIN_TABLE_NAME"; return "Q_OPT_RECYCLE_BIN_TABLE_NAME";
case Q_OPT_INDEX_FORMAT_PANDA_ENABLED: case Q_OPT_INDEX_FORMAT_PANDA_ENABLED:
@@ -844,6 +875,14 @@ public class QueryLogEvent extends LogEvent {
// prepareGCN = buffer.getLong64(); // prepareGCN = buffer.getLong64();
buffer.forward(8); buffer.forward(8);
break; break;
case Q_OPT_INDEX_FORMAT_SPC_ENABLED:
// *start++ = thd->variables.opt_index_format_spc_enabled;
buffer.forward(1);
break;
case Q_OPT_INDEX_FORMAT_HIPPO_ENABLED:
// *start++ = thd->variables.opt_index_format_hippo_enabled;
buffer.forward(1);
break;
case Q_OPT_RECYCLE_BIN_TABLE_NAME: case Q_OPT_RECYCLE_BIN_TABLE_NAME:
int recycle_bin_table_name_len = buffer.getUint8(); int recycle_bin_table_name_len = buffer.getUint8();
String recycle_bin_table_name = null; String recycle_bin_table_name = null;