Support parsing of ndb info

Refer to [ndb info
layout](https://github.com/mysql/mysql-server/blob/beb865a960b9a8a16cf999c323e46c5b0c67f21f/libbinlogevents/include/rows_event.h#L782-L788)

Author: dongwook-chan

pymysqlreplication/row_event.py

@@ -59,15 +59,20 @@ def __init__(self, from_packet, event_size, table_map, ctl_connection, **kwargs)
                 self.flags, self.extra_data_length = struct.unpack('<HH', self.packet.read(4))
                 if self.extra_data_length > 2:
                     self.extra_data_type = struct.unpack('<B', self.packet.read(1))[0]
+
+                    # ndb information
+                    if self.extra_data_type == 0:
+                        self.nbd_info_length, self.nbd_info_format = struct.unpack('<BB', self.packet.read(1))
+                        self.nbd_info = self.packet.read(self.nbd_info_length - 2)
                     # partition information
-                    if self.extra_data_type == 1:
+                    elif self.extra_data_type == 1:
                         if self.event_type == BINLOG.UPDATE_ROWS_EVENT_V2:
                             self.partition_id, self.source_partition_id = struct.unpack('<HH', self.packet.read(4))
                         else:
                             self.partition_id = struct.unpack('<H', self.packet.read(2))[0]
-                    # NDB information etc.
+                    # etc
                     else:
-                        self.extra_data = self.packet.read(self.extra_data_length - 3)
+                        self.extra_data = self.packet.read(self.extra_info_length - 3)
         else:
             self.flags = struct.unpack('<H', self.packet.read(2))[0]
 

pymysqlreplication/tests/test_data_type.py

@@ -634,7 +634,7 @@ def test_extra_data(self):
                 PARTITION p1 VALUES LESS THAN (2),   \
                 PARTITION p2 VALUES LESS THAN (3),   \
                 PARTITION p3 VALUES LESS THAN (4),   \
-                PARTITION p4 VALUES LESS THAN (5),   \
+                PARTITION p4 VALUES LESS THAN (5)    \
             )"
         insert_query = "INSERT INTO test (id) VALUES(3)"
         event = self.create_and_insert_value(create_query, insert_query)