From 117bbb69bc932af1da0fbd64d75648762de9976a Mon Sep 17 00:00:00 2001
From: midoks <midoks@163.com>
Date: Sat, 18 Jun 2022 21:29:59 +0800
Subject: [PATCH] Update index.py

---
 plugins/mysql/index.py | 43 ++++++++++++++++++++++++++++++++++++++++--
 1 file changed, 41 insertions(+), 2 deletions(-)

diff --git a/plugins/mysql/index.py b/plugins/mysql/index.py
index b63e2c55a..379507e73 100755
--- a/plugins/mysql/index.py
+++ b/plugins/mysql/index.py
@@ -413,7 +413,7 @@ def myOp(version, method):
         return str(e)
 
 
-def my57cmd(version, method):
+def my57_bb_cmd(version, method):
     init_file = initDreplace(version)
     cmd = init_file + ' ' + method
     gsDir = getServerDir()
@@ -474,6 +474,45 @@ flush privileges;"
         return str(e)
 
 
+def my57cmd(version, method):
+    # mysql 5.7 ok
+    init_file = initDreplace(version)
+    cmd = init_file + ' ' + method
+    try:
+        initMysql57Data()
+        if not mysql8IsInitedPasswd():
+            setSkipGrantTables(True)
+            cmd_init_start = init_file + ' start'
+            subprocess.Popen(cmd_init_start, stdout=subprocess.PIPE, shell=True,
+                             bufsize=4096, stderr=subprocess.PIPE)
+
+            time.sleep(6)
+            initMysql8Pwd()
+
+            cmd_init_stop = init_file + ' stop'
+            subprocess.Popen(cmd_init_stop, stdout=subprocess.PIPE, shell=True,
+                             bufsize=4096, stderr=subprocess.PIPE)
+            setSkipGrantTables(False)
+
+            time.sleep(3)
+            my8cmd(version, method)
+        else:
+            if method == "stop":
+                mw.execShell(cmd)
+                mw.execShell(
+                    "ps -ef|grep mysql|grep -v grep|grep -v py|awk '{print $2}'|xargs kill")
+                return "ok"
+
+            sub = subprocess.Popen(cmd, stdout=subprocess.PIPE, shell=True,
+                                   bufsize=4096, stderr=subprocess.PIPE)
+            sub.wait(5)
+        return 'ok'
+    except Exception as e:
+        return str(e)
+
+    return 'fail'
+
+
 def my8cmd(version, method):
     # mysql 8.0 ok
     init_file = initDreplace(version)
@@ -508,7 +547,7 @@ def my8cmd(version, method):
             sub.wait(5)
         return 'ok'
     except Exception as e:
-        print(e)
+        return str(e)
 
     return 'fail'