From 6beddd664dd90fc4a46a28fb4f58ebd948f09e12 Mon Sep 17 00:00:00 2001 From: boyce Date: Thu, 7 Mar 2019 14:44:21 +0800 Subject: [PATCH] =?UTF-8?q?=E9=94=99=E8=AF=AF=E5=88=A4=E6=96=AD=EF=BC=8C?= =?UTF-8?q?=E6=97=A5=E5=BF=97=E8=AE=B0=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sysmodule/DBModule.go | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/sysmodule/DBModule.go b/sysmodule/DBModule.go index 5009de2..da350f5 100644 --- a/sysmodule/DBModule.go +++ b/sysmodule/DBModule.go @@ -296,7 +296,17 @@ func (slf *SyncDBResult) Get(timeoutMs int) DBResult { // Query ... func (slf *DBModule) Query(query string, args ...interface{}) DBResult { + if slf.db == nil { + ret := DBResult{} + service.GetLogger().Printf(service.LEVER_ERROR, "cannot connect database:%s", query) + ret.Err = fmt.Errorf("cannot connect database!") + return ret + } rows, err := slf.db.Query(query, args...) + if err != nil { + service.GetLogger().Printf(service.LEVER_ERROR, "Query:%s(%v)", query, err) + } + return DBResult{ Err: err, res: rows, @@ -331,11 +341,16 @@ func (slf *DBModule) SyncQuery(query string, args ...interface{}) SyncDBResult { func (slf *DBModule) Exec(query string, args ...interface{}) DBResult { ret := DBResult{} if slf.db == nil { + service.GetLogger().Printf(service.LEVER_ERROR, "cannot connect database:%s", query) ret.Err = fmt.Errorf("cannot connect database!") return ret } res, err := slf.db.Exec(query, args...) + if err != nil { + service.GetLogger().Printf(service.LEVER_ERROR, "Exec:%s(%v)", query, err) + } + ret.Err = err ret.LastInsertID, _ = res.LastInsertId() ret.RowsAffected, _ = res.RowsAffected()