blob Type not decode string retain binary format

julien-duponchelle · Nov 29, 2023 · 8f1163f · 8f1163f
1 parent 6850c0d
commit 8f1163f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pymysqlreplication/row_event.py b/pymysqlreplication/row_event.py
@@ -220,7 +220,7 @@ def __read_values_name(
         elif column.type == FIELD_TYPE.NEWDECIMAL:
             return self.__read_new_decimal(column)
         elif column.type == FIELD_TYPE.BLOB:
-            return self.__read_string(column.length_size, column)
+            return self.packet.read_length_coded_pascal_string(column.length_size)
         elif column.type == FIELD_TYPE.DATETIME:
             ret = self.__read_datetime()
             if ret is None:
@@ -849,6 +849,7 @@ def _get_optional_meta_data(self):
                 )
 
             elif field_type == MetadataFieldType.COLUMN_CHARSET:
+                print("times")
                 optional_metadata.column_charset = self._read_ints(length)
                 optional_metadata.charset_collation_list = (
                     self._parsed_column_charset_by_column_charset(
@@ -1073,6 +1074,7 @@ def _read_ints(self, length):
         read_until = self.packet.read_bytes + length
         while self.packet.read_bytes < read_until:
             result.append(self.packet.read_length_coded_binary())
+        print(result,"result!")
         return result
 
     def _read_column_names(self, length):