Feature/remove column schema (#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
julien-duponchelle · Sep 20, 2023 · a301596 · a301596
1 parent 0c0805b
commit a301596
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 4 deletions.
diff --git a/pymysqlreplication/binlogstream.py b/pymysqlreplication/binlogstream.py
@@ -565,12 +565,10 @@ def __check_optional_meta_data(self):
                 logging.log(
                     logging.WARN,
                     """
-                       Setting The Variable Value BINLOG_ROW_METADATA = FULL 
+                       Setting The Variable Value BINLOG_ROW_METADATA = FULL, BINLOG_ROW_IMAGE = FULL. 
                        By Applying this, provide properly mapped column information on UPDATE,DELETE,INSERT. 
                         """,
                 )
-            else:
-                self.__optional_meta_data = True
 
     def fetchone(self):
         while True:

diff --git a/pymysqlreplication/row_event.py b/pymysqlreplication/row_event.py
@@ -71,7 +71,6 @@ def __init__(self, from_packet, event_size, table_map, ctl_connection, **kwargs)
                     self.nbd_info_length, self.nbd_info_format = struct.unpack(
                         "<BB", self.packet.read(2)
                     )
-
                     self.nbd_info = self.packet.read(self.nbd_info_length - 2)
                 # partition information
                 elif self.extra_data_type == 1: