feat: add logging for dbms and github actions for test

Author: mjs1995

.github/workflows/pytest.yml

@@ -46,5 +46,13 @@ jobs:
           pip install pytest
 
       - name: Run test suite
+        working-directory: pymysqlreplication/tests
         run: |
-          pytest -k "not test_no_trailing_rotate_event and not test_end_log_pos and not test_query_event_latin1"
+          dbms_versions=("mysql-5" "mysql-8")
+          for version in "${dbms_versions[@]}"; do
+            pytest -k "not test_no_trailing_rotate_event and not test_end_log_pos and not test_query_event_latin1" --dbms=$version
+          done
+
+      - name: Run tests for MariaDB
+        run: |
+          pytest -m mariadb -k "not test_no_trailing_rotate_event and not test_end_log_pos and not test_query_event_latin1"

pymysqlreplication/tests/base.py

@@ -17,7 +17,6 @@ def get_databases():
     return databases
 
 
-databases = get_databases()
 base = unittest.TestCase
 
 
@@ -27,6 +26,9 @@ def ignoredEvents(self):
 
     @pytest.fixture(autouse=True)
     def setUpDBMS(self, get_dbms):
+        databases = get_databases()
+        # For local testing, set the get_dbms parameter to one of the following values: 'mysql-5', 'mysql-8', mariadb-10'.
+        # This value should correspond to the desired database configuration specified in the 'config.json' file.
         self.database = databases[get_dbms]
         """
         self.database = {

pymysqlreplication/tests/test_basic.py

@@ -10,6 +10,7 @@
 from pymysqlreplication.row_event import *
 from pymysqlreplication.packet import BinLogPacketWrapper
 from pymysql.protocol import MysqlPacket
+import pytest
 
 __all__ = [
     "TestBasicBinLogStreamReader",
@@ -1299,6 +1300,7 @@ def tearDown(self):
         super(TestStatementConnectionSetting, self).tearDown()
 
 
+@pytest.mark.mariadb
 class TestMariadbBinlogStreamReader(base.PyMySQLReplicationTestCase):
     def setUp(self):
         super().setUp()
@@ -1335,6 +1337,7 @@ def test_binlog_checkpoint_event(self):
         self.assertEqual(event.filename, self.bin_log_basename() + ".000001")
 
 
+@pytest.mark.mariadb
 class TestMariadbBinlogStreamReader2(base.PyMySQLReplicationTestCase):
     def setUp(self):
         super().setUp()
@@ -1485,6 +1488,7 @@ def test_query_event_latin1(self):
         assert event.query == r"CREATE TABLE test_latin1_\xd6\xc6\xdb (a INT)"
 
 
+@pytest.mark.mariadb
 class TestOptionalMetaData(base.PyMySQLReplicationTestCase):
     def setUp(self):
         super(TestOptionalMetaData, self).setUp()