Support decoding rotate event

Author: julien-duponchelle

pymysqlreplication/event.py

@@ -31,9 +31,24 @@ def _dump(self):
         '''Core data dumped for the event'''
         pass
 
-
 class RotateEvent(BinLogEvent):
-    pass
+    """
+        Change MySQL bin log file
+
+        Attributes:
+            position: Position inside next binlog
+            next_binlog: Name of next binlog file
+    """
+    def __init__(self, from_packet, event_size, table_map, ctl_connection):
+        super(RotateEvent, self).__init__(from_packet, event_size, table_map, ctl_connection)
+        self.position = struct.unpack('<Q', self.packet.read(8))[0]
+        self.next_binlog = self.packet.read(event_size - 8).decode()
+
+    def dump(self):
+        print("=== %s ===" % (self.__class__.__name__))
+        print("Position: %d" % self.position)
+        print("Next binlog file: %d" % self.next_binlog)
+        print()
 
 
 class FormatDescriptionEvent(BinLogEvent):

pymysqlreplication/tests/test_basic.py

@@ -11,7 +11,10 @@ def test_read_query_event(self):
         self.execute(query)
 
         #RotateEvent
-        self.stream.fetchone()
+        event = self.stream.fetchone()
+        self.assertEqual(event.position, 4)
+        self.assertEqual(event.next_binlog, "mysql-bin.000001")
+
         #FormatDescription
         self.stream.fetchone()