| | |
| | | "sync" |
| | | ) |
| | | |
| | | |
| | | const ( |
| | | PersonSqliteDBPath = "/opt/workspace/DataBases/sync.db" |
| | | PersonSqliteDBPath = "~/workspace/gitblit/dbserver/config/testdb.db" |
| | | ) |
| | | |
| | | var syncMut sync.Mutex |
| | | var syncMut sync.Mutex |
| | | var SerfDbConn *Conn |
| | | |
| | | // get Conn of db for do execute. |
| | | func InitDbConn(dbPath string) error { |
| | | |
| | | if dbPath == "" { |
| | | if dbPath == "" { |
| | | dbPath = PersonSqliteDBPath |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | // do exet when get querystring. |
| | | func DoExecute(sqlString []string) ([]*Result, error) { |
| | | func ExecuteWriteSql(sqlString []string) ([]*Result, error) { |
| | | syncMut.Lock() |
| | | defer syncMut.Unlock() |
| | | allResults, err := SerfDbConn.Execute(sqlString, false, false) |
| | |
| | | return allResults, nil |
| | | } |
| | | |
| | | // do exet when get querystring. |
| | | func ExecuteQuerySql(sqlString []string) ([]*Rows, error) { |
| | | syncMut.Lock() |
| | | defer syncMut.Unlock() |
| | | rows, err := SerfDbConn.Query(sqlString, false, false) |
| | | if err != nil { |
| | | fmt.Println("execute error!", err) |
| | | return nil, err |
| | | } |
| | | return rows, nil |
| | | } |
| | | |
| | | func Dumpdb() { |
| | | |
| | | var b strings.Builder |