From a7aa34795bd99c32964289d3b0b8fbb2f37315ba Mon Sep 17 00:00:00 2001
From: Mr Chen <midoks@163.com>
Date: Thu, 4 Jul 2024 03:37:22 +0800
Subject: [PATCH] update

---
 plugins/mysql-yum/index.py | 11 +++++++----
 plugins/mysql/index.py     |  2 +-
 2 files changed, 8 insertions(+), 5 deletions(-)

diff --git a/plugins/mysql-yum/index.py b/plugins/mysql-yum/index.py
index 2dd2f6e0e..0de2b3517 100755
--- a/plugins/mysql-yum/index.py
+++ b/plugins/mysql-yum/index.py
@@ -3218,11 +3218,14 @@ def doFullSyncUser(version=''):
         return False
 
     if not os.path.exists(bak_file):
-
+        dmp_option += ' '
         if isSimpleSyncCmd(cmd):
-            dmp_option += " --master-data=1 --apply-slave-statements --include-master-host-port "
-        else:
-            dmp_option += ' '
+            if mw.inArray(mdb8,version):
+                # --compression-algorithms
+                dmp_option += " --source-data=1 --apply-replica-statements --include-source-host-port "
+            else:
+                dmp_option += " --master-data=1 --apply-slave-statements --include-master-host-port --compress "
+            
 
         dump_sql_data = getServerDir() + "/bin/usr/bin/mysqldump --single-transaction --default-character-set=utf8mb4 --compress -q " + dmp_option + " -h" + \
             ip + " -P" + port + " -u" + user + ' -p"' + apass + '" --ssl-mode=DISABLED ' + sync_db + " > " + bak_file
diff --git a/plugins/mysql/index.py b/plugins/mysql/index.py
index e91484c51..16f59d174 100755
--- a/plugins/mysql/index.py
+++ b/plugins/mysql/index.py
@@ -3492,7 +3492,7 @@ def doFullSyncUser(version=''):
 
     time_s = time.time()
     if not os.path.exists(bak_file):
-        dmp_option = ' '
+        dmp_option += ' '
         if mw.inArray(mdb8,version):
                 # --compression-algorithms
                 dmp_option += " --source-data=1 --apply-replica-statements --include-source-host-port "