fix: capitalize sql statements (julien-duponchelle#435)

Author: soulee-dev

pymysqlreplication/binlogstream.py

@@ -302,7 +302,7 @@ def __connect_to_stream(self):
         # we support it
         if self.__use_checksum:
             cur = self._stream_connection.cursor()
-            cur.execute("set @master_binlog_checksum= @@global.binlog_checksum")
+            cur.execute("SET @master_binlog_checksum= @@global.binlog_checksum")
             cur.close()
 
         if self.slave_uuid:
@@ -323,7 +323,7 @@ def __connect_to_stream(self):
             # master_heartbeat_period is nanoseconds
             heartbeat = int(heartbeat * 1000000000)
             cur = self._stream_connection.cursor()
-            cur.execute("set @master_heartbeat_period= %d" % heartbeat)
+            cur.execute("SET @master_heartbeat_period= %d" % heartbeat)
             cur.close()
 
         # When replicating from Mariadb 10.6.12 using binlog coordinates, a slave capability < 4 triggers a bug in

pymysqlreplication/tests/base.py

@@ -106,16 +106,16 @@ def set_sql_mode(self):
         """set sql_mode to test with same sql_mode (mysql 5.7 sql_mode default is changed)"""
         version = float(self.getMySQLVersion().rsplit('.', 1)[0])
         if version == 5.7:
-            self.execute("set @@sql_mode='NO_ENGINE_SUBSTITUTION'")
+            self.execute("SET @@sql_mode='NO_ENGINE_SUBSTITUTION'")
 
     def bin_log_format(self):
-        query = "select @@binlog_format"
+        query = "SELECT @@binlog_format"
         cursor = self.execute(query)
         result = cursor.fetchone()
         return result[0]
 
     def bin_log_basename(self):
-        cursor = self.execute('select @@log_bin_basename')
+        cursor = self.execute('SELECT @@log_bin_basename')
         bin_log_basename = cursor.fetchone()[0]
         bin_log_basename = bin_log_basename.split("/")[-1]
         return bin_log_basename