diff --git a/plugins/mysql/index.py b/plugins/mysql/index.py index 60bb26617..e32d7b498 100755 --- a/plugins/mysql/index.py +++ b/plugins/mysql/index.py @@ -2396,15 +2396,15 @@ def getMasterRepSlaveUserCmd(version): mdb8 = ['8.0','8.1','8.2','8.3'] if mode == "gtid": - sql = "CHANGE MASTER TO MASTER_HOST='" + ip + "', MASTER_PORT=" + port + ", MASTER_USER='" + \ - clist[0]['username'] + "', MASTER_PASSWORD='" + \ - clist[0]['password'] + "', MASTER_AUTO_POSITION=1" + channel_name - # sql = "CHANGE MASTER TO MASTER_HOST='" + ip + "', MASTER_PORT=" + port + ", MASTER_USER='" + \ - # clist[0]['username'] + "', MASTER_PASSWORD='" + \ - # clist[0]['password'] + \ - # "', MASTER_LOG_FILE='" + mstatus[0]["File"] + \ - # "',MASTER_LOG_POS=" + str(mstatus[0]["Position"]) + channel_name + # clist[0]['username'] + "', MASTER_PASSWORD='" + \ + # clist[0]['password'] + "', MASTER_AUTO_POSITION=1" + channel_name + + sql = "CHANGE MASTER TO MASTER_HOST='" + ip + "', MASTER_PORT=" + port + ", MASTER_USER='" + \ + clist[0]['username'] + "', MASTER_PASSWORD='" + \ + clist[0]['password'] + \ + "', MASTER_LOG_FILE='" + mstatus[0]["File"] + \ + "',MASTER_LOG_POS=0" + channel_name if mw.inArray(mdb8,version): sql = "CHANGE REPLICATION SOURCE TO SOURCE_HOST='" + ip + "', SOURCE_PORT=" + port + ", SOURCE_USER='" + \