Refactor test method in TestMariadbBinlogStreamReader class

Author: [email protected]

docker-compose.yml

@@ -15,3 +15,16 @@ services:
     ports:
       - 3307:3307
     command: mysqld --log-bin=mysql-bin.log --server-id 1 --binlog-format=row --gtid_mode=on --enforce-gtid-consistency=on --log_slave_updates -P 3307
+
+  mariadb-10.6:
+    image: mariadb:10.6
+    environment:
+      MARIADB_ALLOW_EMPTY_ROOT_PASSWORD: 1
+    ports:
+      - "3308:3306"
+    command: |
+      --server-id=1
+      --default-authentication-plugin=mysql_native_password
+      --log-bin=master-bin
+      --binlog-format=row
+      --log-slave-updates=on

pymysqlreplication/tests/test_basic.py

@@ -1005,8 +1005,16 @@ def test_parsing(self):
 class TestMariadbBinlogStreaReader(base.PyMySQLReplicationTestCase):
     def setUp(self):
         super(TestMariadbBinlogStreaReader,self).setUp()
-        if not self.isMariaDB():
-            raise unittest.SkipTest("Skipping test: Not a MariaDB instance")
+        self.stream.close()
+        maria_db = copy.copy(self.database)
+        maria_db["db"] = None
+        maria_db["port"] = 3308
+        self.connect_conn_control(maria_db)
+        self.execute("DROP DATABASE IF EXISTS pymysqlreplication_test")
+        self.execute("CREATE DATABASE pymysqlreplication_test")
+        self.isMariaDB()
+        self.stream = BinLogStreamReader(maria_db, server_id=1024,
+                                         ignored_events=self.ignoredEvents())
 
     def test_gtid_list_event(self):
         event = self.stream.fetchone()