@@ -115,7 +115,7 @@ def _read_column_data(self, cols_bitmap, row_image_type=None):
115
115
partial_bitmap = None
116
116
if (
117
117
self .event_type == BINLOG .PARTIAL_UPDATE_ROWS_EVENT
118
- and row_image_type == EnumRowImageType .UpdateAI
118
+ and row_image_type == RowImageType .UpdateAI
119
119
):
120
120
binlog_row_value_option = self .packet .read_length_coded_binary ()
121
121
self .is_partial_json_update = binlog_row_value_option & 0b10000001 != 0
@@ -139,7 +139,7 @@ def _read_column_data(self, cols_bitmap, row_image_type=None):
139
139
140
140
if (
141
141
self .is_partial_json_update
142
- and row_image_type == EnumRowImageType .UpdateAI
142
+ and row_image_type == RowImageType .UpdateAI
143
143
and column .type == FIELD_TYPE .JSON
144
144
):
145
145
if BitGet (partial_bitmap , partial_bitmap_index ) > 0 :
@@ -1171,12 +1171,12 @@ def __init__(self, from_packet, event_size, table_map, ctl_connection, **kwargs)
1171
1171
1172
1172
def _fetch_one_row (self ):
1173
1173
row = {}
1174
- row_image_type = EnumRowImageType .UpdateBI
1174
+ row_image_type = RowImageType .UpdateBI
1175
1175
row ["before_values" ] = self ._read_column_data (
1176
1176
self .columns_present_bitmap , row_image_type
1177
1177
)
1178
1178
row ["before_none_sources" ] = self ._get_none_sources (row ["before_values" ])
1179
- row_image_type = EnumRowImageType .UpdateAI
1179
+ row_image_type = RowImageType .UpdateAI
1180
1180
row ["after_values" ] = self ._read_column_data (
1181
1181
self .columns_present_bitmap2 , row_image_type
1182
1182
)
@@ -1223,12 +1223,13 @@ def by_index(index):
1223
1223
return MetadataFieldType (index )
1224
1224
1225
1225
1226
- class EnumRowImageType (Enum ):
1226
+ class RowImageType (Enum ):
1227
+ # https://github.com/mysql/mysql-server/blob/1bfe02bdad6604d54913c62614bde57a055c8332/sql/rpl_record.h#L39
1227
1228
WriteAI = 0
1228
1229
UpdateBI = 1
1229
1230
UpdateAI = 2
1230
1231
DeleteBI = 3
1231
1232
1232
1233
@staticmethod
1233
1234
def by_index (index ):
1234
- return EnumRowImageType (index )
1235
+ return RowImageType (index )
0 commit comments