From d7e70aa70189f56a65ce43d561b087b9c002e87a Mon Sep 17 00:00:00 2001 From: Mr Chen Date: Mon, 5 Feb 2024 00:17:44 +0800 Subject: [PATCH] Update index.py --- plugins/mysql/index.py | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/plugins/mysql/index.py b/plugins/mysql/index.py index efd7ad9d0..cae6ad9b3 100755 --- a/plugins/mysql/index.py +++ b/plugins/mysql/index.py @@ -2955,7 +2955,13 @@ def doFullSyncUser(version=''): if mode == 'gtid': dmp_option = ' --set-gtid-purged=off ' - writeDbSyncStatus({'code': 1, 'msg': '远程导出数据...', 'progress': 20}) + writeDbSyncStatus({'code': 1, 'msg': '正在停止从库...', 'progress': 15}) + if version == '8.0': + db.query("stop slave user='{}' password='{}';".format(user, apass)) + else: + db.query("stop slave") + + writeDbSyncStatus({'code': 2, 'msg': '远程导出数据...', 'progress': 20}) if not os.path.exists(bak_file): dump_sql_data = getServerDir() + "/bin/mysqldump " + dmp_option + " --force --opt --default-character-set=utf8 --single-transaction -h" + ip + " -P" + \ @@ -2964,11 +2970,6 @@ def doFullSyncUser(version=''): print(dump_sql_data) mw.execShell(dump_sql_data) - writeDbSyncStatus({'code': 2, 'msg': '正在停止从库...', 'progress': 30}) - if version == '8.0': - db.query("stop slave user='{}' password='{}';".format(user, apass)) - else: - db.query("stop slave") writeDbSyncStatus({'code': 3, 'msg': '正在到本地导入数据中...', 'progress': 40}) if os.path.exists(bak_file):