fixed version retrieval from get_server_info

Author: roy0424

pymysqlreplication/binlogstream.py

@@ -287,6 +287,7 @@ def __init__(
         else:
             self.pymysql_wrapper = pymysql.connect
         self.mysql_version = (0, 0, 0)
+        self.dbms = None
 
     def close(self):
         if self.__connected_stream:
@@ -748,14 +749,12 @@ def _allowed_event_list(
     def __get_dbms(self):
         if not self.__connected_ctl:
             self.__connect_to_ctl()
-
-        cur = self._ctl_connection.cursor()
-        cur.execute("SELECT VERSION();")
-
-        version_info = cur.fetchone().get("VERSION()", "")
-
-        if "MariaDB" in version_info:
+        if self.dbms:
+            return self.dbms
+        if "MariaDB" in self._ctl_connection.get_server_info():
+            self.dbms = "mariadb"
             return "mariadb"
+        self.dbms = "mysql"
         return "mysql"
 
     def __log_valid_parameters(self):

pymysqlreplication/event.py

@@ -27,7 +27,6 @@ def __init__(
         ignore_decode_errors=False,
         verify_checksum=False,
         optional_meta_data=False,
-        dbms=None,
     ):
         self.packet = from_packet
         self.table_map = table_map
@@ -44,7 +43,7 @@ def __init__(
         self._processed = True
         self.complete = True
         self._verify_event()
-        self.dbms = dbms
+        self.dbms = None
 
     def _read_table_id(self):
         # Table ID is 6 byte