Skip to content

Commit a301596

Browse files
authored
Feature/remove column schema (julien-duponchelle#477)
* feat: remove using column_schema remove using column_schema remove using column_schemas * remove testcase * remove set, enum * fix: testcase fix : testcase fix testcase fix: testcase * table init changed table init changed * remove ununsed variable * check possible optional metadata version And delete get Table information * Column Values add delete print * change comment BINLOG_ROW_IMAGE * retry github action
1 parent 0c0805b commit a301596

File tree

2 files changed

+1
-4
lines changed

2 files changed

+1
-4
lines changed

Diff for: pymysqlreplication/binlogstream.py

+1-3
Original file line numberDiff line numberDiff line change
@@ -565,12 +565,10 @@ def __check_optional_meta_data(self):
565565
logging.log(
566566
logging.WARN,
567567
"""
568-
Setting The Variable Value BINLOG_ROW_METADATA = FULL
568+
Setting The Variable Value BINLOG_ROW_METADATA = FULL, BINLOG_ROW_IMAGE = FULL.
569569
By Applying this, provide properly mapped column information on UPDATE,DELETE,INSERT.
570570
""",
571571
)
572-
else:
573-
self.__optional_meta_data = True
574572

575573
def fetchone(self):
576574
while True:

Diff for: pymysqlreplication/row_event.py

-1
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,6 @@ def __init__(self, from_packet, event_size, table_map, ctl_connection, **kwargs)
7171
self.nbd_info_length, self.nbd_info_format = struct.unpack(
7272
"<BB", self.packet.read(2)
7373
)
74-
7574
self.nbd_info = self.packet.read(self.nbd_info_length - 2)
7675
# partition information
7776
elif self.extra_data_type == 1:

0 commit comments

Comments
 (0)