Insert with values as args

Author: paulvic

pymysqlreplication/tests/base.py

@@ -85,6 +85,11 @@ def execute(self, query):
         c = self.conn_control.cursor()
         c.execute(query)
         return c
+    
+    def execute_with_args(self, query, args):
+        c = self.conn_control.cursor()
+        c.execute(query, args)
+        return c
 
     def resetBinLog(self):
         self.execute("RESET MASTER")

pymysqlreplication/tests/test_basic.py

@@ -685,7 +685,7 @@ def test_ignore_decode_errors(self):
         self.execute("INSERT INTO test VALUES (1, 'A value')")
         self.execute("COMMIT")
         self.execute("ALTER TABLE test MODIFY COLUMN data VARCHAR(50) CHARACTER SET utf8mb4")
-        self.execute(f"INSERT INTO test VALUES (2, '{problematic_unicode_string}')")
+        self.execute_with_args("INSERT INTO test (id, data) VALUES (%s, %s)", (2, problematic_unicode_string))
         self.execute("COMMIT")
 
         self.stream = BinLogStreamReader(