From 6ef6050a854cb9a20bef8005a5f2a8463374ef17 Mon Sep 17 00:00:00 2001
From: chenshijun <csj_sky@126.com>
Date: 星期二, 06 八月 2019 17:05:34 +0800
Subject: [PATCH] Merge branch 'master' of http://192.168.1.14:10010/r/syncdb
---
dbself.go | 21 ++++++++++++++++-----
1 files changed, 16 insertions(+), 5 deletions(-)
diff --git a/dbself.go b/dbself.go
index a264aa9..70b7024 100644
--- a/dbself.go
+++ b/dbself.go
@@ -10,18 +10,17 @@
"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
}
@@ -73,7 +72,7 @@
}
// 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)
@@ -84,6 +83,18 @@
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
--
Gitblit v1.8.0