Merge pull request julien-duponchelle#85 from baloo/features/parse-gtid

julien-duponchelle · julien-duponchelle · commit b50dea6860f4 · 2014-08-29T16:31:32.000+02:00
Parse gtid events
diff --git a/README.md b/README.md
@@ -286,6 +286,7 @@ Other contributors:
 * Daniel Gavrila more MySQL error codes https://github.com/danielduduta
 * Bernardo Sulzbach code cleanup https://github.com/mafagafo
 * Darioush Jalali Python 2.6 backport https://github.com/darioush
+* Arthur Gautier gtid https://github.com/baloose
 
 Licence
 =======
diff --git a/pymysqlreplication/event.py b/pymysqlreplication/event.py
@@ -36,6 +36,32 @@ def _dump(self):
         pass
 
 
+class GtidEvent(BinLogEvent):
+    """GTID change in binlog event
+    """
+    def __init__(self, from_packet, event_size, table_map, ctl_connection):
+        super(GtidEvent, self).__init__(from_packet, event_size, table_map,
+                                          ctl_connection)
+
+        self.commit_flag = byte2int(self.packet.read(1)) == 1
+        self.sid = self.packet.read(16)
+        self.gno = struct.unpack('<Q', self.packet.read(8))[0]
+
+    @property
+    def gtid(self):
+        """GTID = source_id:transaction_id
+        Eg: 3E11FA47-71CA-11E1-9E33-C80AA9429562:23
+        See: http://dev.mysql.com/doc/refman/5.6/en/replication-gtids-concepts.html"""
+        gtid = "%s%s%s%s-%s%s-%s%s-%s%s-%s%s%s%s%s%s" %\
+               tuple("{:02x}".format(ord(c)) for c in self.sid)
+        gtid += ":%d" % self.gno
+        return gtid
+
+    def _dump(self):
+        print("Commit: %s" % self.commit_flag)
+        print("GTID_NEXT: %s" % self.gtid)
+
+
 class RotateEvent(BinLogEvent):
     """Change MySQL bin log file
 
diff --git a/pymysqlreplication/packet.py b/pymysqlreplication/packet.py
@@ -32,7 +32,7 @@ class BinLogPacketWrapper(object):
         constants.FORMAT_DESCRIPTION_EVENT: event.FormatDescriptionEvent,
         constants.XID_EVENT: event.XidEvent,
         constants.INTVAR_EVENT: event.NotImplementedEvent,
-        constants.GTID_LOG_EVENT: event.NotImplementedEvent,
+        constants.GTID_LOG_EVENT: event.GtidEvent,
         constants.STOP_EVENT: event.NotImplementedEvent,
         # row_event
         constants.UPDATE_ROWS_EVENT_V1: row_event.UpdateRowsEvent,
