diff --git a/plugins/mysql-apt/index.py b/plugins/mysql-apt/index.py index d535368c5..d4c29254d 100755 --- a/plugins/mysql-apt/index.py +++ b/plugins/mysql-apt/index.py @@ -2204,8 +2204,7 @@ def getMasterRepSlaveUserCmd(version): sql = '' if not mw.inArray(mdb8,version): base_sql = "CHANGE MASTER TO MASTER_HOST='" + ip + "', MASTER_PORT=" + port + ", MASTER_USER='" + \ - clist[0]['username'] + "', MASTER_PASSWORD='" + \ - clist[0]['password'] + "'" + clist[0]['username'] + "', MASTER_PASSWORD='" + clist[0]['password'] + "'" sql += base_sql; sql += "

"; @@ -2213,17 +2212,16 @@ def getMasterRepSlaveUserCmd(version): sql += base_sql + channel_name sql += "

"; - sql += base_sql + "', MASTER_LOG_FILE='" + mstatus[0]["File"] + "',MASTER_LOG_POS=" + str(mstatus[0]["Position"]) + channel_name + sql += base_sql + ", MASTER_LOG_FILE='" + mstatus[0]["File"] + "',MASTER_LOG_POS=" + str(mstatus[0]["Position"]) + channel_name else: base_sql = "CHANGE REPLICATION SOURCE TO SOURCE_HOST='" + ip + "', SOURCE_PORT=" + port + ", SOURCE_USER='" + \ - clist[0]['username'] + "', SOURCE_PASSWORD='" + \ - clist[0]['password']+"'" + clist[0]['username'] + "', SOURCE_PASSWORD='" + clist[0]['password']+"'" sql += base_sql; sql += "

"; # sql += base_sql + ", MASTER_AUTO_POSITION=1" + channel_name sql += base_sql + channel_name sql += "

"; - sql += base_sql + "', SOURCE_LOG_FILE='" + mstatus[0]["File"] + "',SOURCE_LOG_POS=" + str(mstatus[0]["Position"]) + channel_name + sql += base_sql + ", SOURCE_LOG_FILE='" + mstatus[0]["File"] + "',SOURCE_LOG_POS=" + str(mstatus[0]["Position"]) + channel_name data = {} diff --git a/plugins/mysql-yum/index.py b/plugins/mysql-yum/index.py index 032b153ad..5d994a959 100755 --- a/plugins/mysql-yum/index.py +++ b/plugins/mysql-yum/index.py @@ -2189,8 +2189,7 @@ def getMasterRepSlaveUserCmd(version): sql = '' if not mw.inArray(mdb8,version): base_sql = "CHANGE MASTER TO MASTER_HOST='" + ip + "', MASTER_PORT=" + port + ", MASTER_USER='" + \ - clist[0]['username'] + "', MASTER_PASSWORD='" + \ - clist[0]['password'] + "'" + clist[0]['username'] + "', MASTER_PASSWORD='" + clist[0]['password'] + "'" sql += base_sql; sql += "

"; @@ -2198,17 +2197,16 @@ def getMasterRepSlaveUserCmd(version): sql += base_sql + channel_name sql += "

"; - sql += base_sql + "', MASTER_LOG_FILE='" + mstatus[0]["File"] + "',MASTER_LOG_POS=" + str(mstatus[0]["Position"]) + channel_name + sql += base_sql + ", MASTER_LOG_FILE='" + mstatus[0]["File"] + "',MASTER_LOG_POS=" + str(mstatus[0]["Position"]) + channel_name else: base_sql = "CHANGE REPLICATION SOURCE TO SOURCE_HOST='" + ip + "', SOURCE_PORT=" + port + ", SOURCE_USER='" + \ - clist[0]['username'] + "', SOURCE_PASSWORD='" + \ - clist[0]['password']+"'" + clist[0]['username'] + "', SOURCE_PASSWORD='" + clist[0]['password']+"'" sql += base_sql; sql += "

"; # sql += base_sql + ", MASTER_AUTO_POSITION=1" + channel_name sql += base_sql + channel_name sql += "

"; - sql += base_sql + "', SOURCE_LOG_FILE='" + mstatus[0]["File"] + "',SOURCE_LOG_POS=" + str(mstatus[0]["Position"]) + channel_name + sql += base_sql + ", SOURCE_LOG_FILE='" + mstatus[0]["File"] + "',SOURCE_LOG_POS=" + str(mstatus[0]["Position"]) + channel_name data = {}