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'] + \