add quotes in set slave_uuid (#615)

julien-duponchelle · Mar 31, 2024 · 2d2c7b6 · 2d2c7b6
1 parent ab9a5ca
commit 2d2c7b6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pymysqlreplication/binlogstream.py b/pymysqlreplication/binlogstream.py
@@ -360,7 +360,7 @@ def __connect_to_stream(self):
         if self.slave_uuid:
             cur = self._stream_connection.cursor()
             cur.execute(
-                f"SET @slave_uuid = {self.slave_uuid}, @replica_uuid = {self.slave_uuid}"
+                f"SET @slave_uuid = '{self.slave_uuid}', @replica_uuid = '{self.slave_uuid}'"
             )
             cur.close()