added dbms property in BinLogEvent

Author: roy0424

pymysqlreplication/event.py

@@ -27,6 +27,7 @@ def __init__(
         ignore_decode_errors=False,
         verify_checksum=False,
         optional_meta_data=False,
+        dbms=None,
     ):
         self.packet = from_packet
         self.table_map = table_map
@@ -43,6 +44,7 @@ def __init__(
         self._processed = True
         self.complete = True
         self._verify_event()
+        self.dbms = dbms
 
     def _read_table_id(self):
         # Table ID is 6 byte
@@ -104,7 +106,7 @@ def __init__(self, from_packet, event_size, table_map, ctl_connection, **kwargs)
         self.gno = struct.unpack("<Q", self.packet.read(8))[0]
         self.lt_type = self.packet.read(1)[0]
 
-        if self.mysql_version >= (5, 7):
+        if not self.is_mariadb and self.mysql_version >= (5, 7):
             self.last_committed = struct.unpack("<Q", self.packet.read(8))[0]
             self.sequence_number = struct.unpack("<Q", self.packet.read(8))[0]
 
@@ -367,6 +369,10 @@ def __init__(self, from_packet, event_size, table_map, ctl_connection, **kwargs)
         self.binlog_version = struct.unpack("<H", self.packet.read(2))
         self.mysql_version_str = self.packet.read(50).rstrip(b"\0").decode()
         numbers = self.mysql_version_str.split("-")[0]
+        if "MariaDB" in self.mysql_version_str:
+            self.dbms = "mariadb"
+        else:
+            self.dbms = "mysql"
         self.mysql_version = tuple(map(int, numbers.split(".")))
         self.created = struct.unpack("<I", self.packet.read(4))[0]
         self.common_header_len = struct.unpack("<B", self.packet.read(1))[0]