liuxiaolong
2020-05-13 99c049b8efe577815ea9af4eec182d3632d427a1
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())