liuxiaolong
2020-05-14 a79ff0adc62e2d9e3e198d7299e7670063201607
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())