Skip to content

Commit 2d2c7b6

Browse files
add quotes in set slave_uuid (#615)
1 parent ab9a5ca commit 2d2c7b6

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pymysqlreplication/binlogstream.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -360,7 +360,7 @@ def __connect_to_stream(self):
360360
if self.slave_uuid:
361361
cur = self._stream_connection.cursor()
362362
cur.execute(
363-
f"SET @slave_uuid = {self.slave_uuid}, @replica_uuid = {self.slave_uuid}"
363+
f"SET @slave_uuid = '{self.slave_uuid}', @replica_uuid = '{self.slave_uuid}'"
364364
)
365365
cur.close()
366366

0 commit comments

Comments
 (0)