From 080fbf9e4a742403b11cacadb631fdb474530a2b Mon Sep 17 00:00:00 2001
From: 554325746@qq.com <554325746@qq.com>
Date: 星期三, 25 十二月 2019 09:13:32 +0800
Subject: [PATCH] a
---
dbself.go | 9 ++++++---
1 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/dbself.go b/dbself.go
index 70b7024..5156b2b 100644
--- a/dbself.go
+++ b/dbself.go
@@ -64,6 +64,8 @@
}
defer tmpconn.Close()
+ syncMut.Lock()
+ defer syncMut.Unlock()
err = SerfDbConn.Backup(tmpconn)
if err != nil {
return "", err
@@ -72,10 +74,10 @@
}
// do exet when get querystring.
-func ExecuteWriteSql(sqlString []string) ([]*Result, error) {
+func ExecuteWriteSql(sqlString []string, tx bool) ([]*Result, error) {
syncMut.Lock()
defer syncMut.Unlock()
- allResults, err := SerfDbConn.Execute(sqlString, false, false)
+ allResults, err := SerfDbConn.Execute(sqlString, tx, false)
if err != nil {
fmt.Println("execute error!", err)
return nil, err
@@ -96,7 +98,8 @@
}
func Dumpdb() {
-
+ syncMut.Lock()
+ defer syncMut.Unlock()
var b strings.Builder
if err := SerfDbConn.Dump(&b); err != nil {
fmt.Println("dump file ", err.Error())
--
Gitblit v1.8.0