From 76229b6651597c066b6d0522bf735f8c28be02eb Mon Sep 17 00:00:00 2001 From: Mr Chen Date: Wed, 15 May 2024 19:31:30 +0800 Subject: [PATCH] Update index.py --- plugins/mysql/index.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/plugins/mysql/index.py b/plugins/mysql/index.py index 1533f2b1f..8386f16cb 100755 --- a/plugins/mysql/index.py +++ b/plugins/mysql/index.py @@ -2403,8 +2403,8 @@ def getMasterRepSlaveUserCmd(version): clist[0]['password'] + \ "', MASTER_LOG_FILE='" + mstatus[0]["File"] + \ "',MASTER_LOG_POS=" + str(mstatus[0]["Position"]) + channel_name - - if version == '8.0': + + if version == '8.0' or version == '8.1' or version == '8.2' or version == '8.3': sql = "CHANGE REPLICATION SOURCE TO SOURCE_HOST='" + ip + "', SOURCE_PORT=" + port + ", SOURCE_USER='" + \ clist[0]['username'] + "', SOURCE_PASSWORD='" + \ clist[0]['password'] + \ @@ -2416,7 +2416,7 @@ def getMasterRepSlaveUserCmd(version): "', MASTER_LOG_FILE='" + mstatus[0]["File"] + \ "',MASTER_LOG_POS=" + str(mstatus[0]["Position"]) + channel_name - if version == "8.0": + if version == '8.0' or version == '8.1' or version == '8.2' or version == '8.3': sql = "CHANGE REPLICATION SOURCE TO SOURCE_HOST='" + ip + "', SOURCE_PORT=" + port + ", SOURCE_USER='" + \ clist[0]['username'] + "', SOURCE_PASSWORD='" + \ clist[0]['password'] + \