Merge pull request #147 from mastak/dev-intvar-event

added intvar event

Author: julien-duponchelle

pymysqlreplication/constants/BINLOG.py

@@ -36,3 +36,8 @@
 GTID_LOG_EVENT = 0x21
 ANONYMOUS_GTID_LOG_EVENT = 0x22
 PREVIOUS_GTIDS_LOG_EVENT = 0x23
+
+# INTVAR types
+INTVAR_INVALID_INT_EVENT = 0x00
+INTVAR_LAST_INSERT_ID_EVENT = 0x01
+INTVAR_INSERT_ID_EVENT = 0x02

pymysqlreplication/event.py

@@ -213,6 +213,27 @@ def _dump(self):
         print("Dup handling flags: %d" % (self.dup_handling_flags))
 
 
+class IntvarEvent(BinLogEvent):
+    """
+
+    Attributes:
+        type
+        value
+    """
+    def __init__(self, from_packet, event_size, table_map, ctl_connection, **kwargs):
+        super(IntvarEvent, self).__init__(from_packet, event_size, table_map,
+                                          ctl_connection, **kwargs)
+
+        # Payload
+        self.type = self.packet.read_uint8()
+        self.value = self.packet.read_uint32()
+
+    def _dump(self):
+        super(IntvarEvent, self)._dump()
+        print("type: %d" % (self.type))
+        print("Value: %d" % (self.value))
+
+
 class NotImplementedEvent(BinLogEvent):
     def __init__(self, from_packet, event_size, table_map, ctl_connection, **kwargs):
         super(NotImplementedEvent, self).__init__(

pymysqlreplication/packet.py

@@ -31,7 +31,7 @@ class BinLogPacketWrapper(object):
         constants.ROTATE_EVENT: event.RotateEvent,
         constants.FORMAT_DESCRIPTION_EVENT: event.FormatDescriptionEvent,
         constants.XID_EVENT: event.XidEvent,
-        constants.INTVAR_EVENT: event.NotImplementedEvent,
+        constants.INTVAR_EVENT: event.IntvarEvent,
         constants.GTID_LOG_EVENT: event.GtidEvent,
         constants.STOP_EVENT: event.StopEvent,
         constants.BEGIN_LOAD_QUERY_EVENT: event.BeginLoadQueryEvent,