diff --git a/plugins/mysql/index.py b/plugins/mysql/index.py index a5ebf154c0..ae92960d39 100755 --- a/plugins/mysql/index.py +++ b/plugins/mysql/index.py @@ -2400,22 +2400,22 @@ def getMasterRepSlaveUserCmd(version): clist[0]['username'] + "', MASTER_PASSWORD='" + \ clist[0]['password'] + "'" - sql += base_sql +';' - sql += "

" + sql += base_sql; + sql += "

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

" + sql += "

"; 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']+"'" - sql += base_sql +';' - sql += "

" + sql += base_sql; + sql += "

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

" + sql += "

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