| | |
| | | } |
| | | defer tmpconn.Close() |
| | | |
| | | syncMut.Lock() |
| | | defer syncMut.Unlock() |
| | | err = SerfDbConn.Backup(tmpconn) |
| | | if err != nil { |
| | | return "", err |
| | |
| | | } |
| | | |
| | | // 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 |
| | |
| | | } |
| | | |
| | | func Dumpdb() { |
| | | |
| | | syncMut.Lock() |
| | | defer syncMut.Unlock() |
| | | var b strings.Builder |
| | | if err := SerfDbConn.Dump(&b); err != nil { |
| | | fmt.Println("dump file ", err.Error()) |