Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-27 09:14:44 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

错误判断，日志记录

Browse Source
This commit is contained in:
boyce
2019-03-07 14:44:21 +08:00
parent c22c193e70
commit 6beddd664d
1 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
sysmodule/DBModule.go
View File

@@ -296,7 +296,17 @@ func (slf *SyncDBResult) Get(timeoutMs int) DBResult {
// Query ... // Query ...
func (slf *DBModule) Query(query string, args ...interface{}) DBResult { 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...) rows, err := slf.db.Query(query, args...)
if err != nil {
service.GetLogger().Printf(service.LEVER_ERROR, "Query:%s(%v)", query, err)
}
return DBResult{ return DBResult{
Err: err, Err: err,
res: rows, res: rows,
@@ -331,11 +341,16 @@ func (slf *DBModule) SyncQuery(query string, args ...interface{}) SyncDBResult {
func (slf *DBModule) Exec(query string, args ...interface{}) DBResult { func (slf *DBModule) Exec(query string, args ...interface{}) DBResult {
ret := DBResult{} ret := DBResult{}
if slf.db == nil { if slf.db == nil {
service.GetLogger().Printf(service.LEVER_ERROR, "cannot connect database:%s", query)
ret.Err = fmt.Errorf("cannot connect database!") ret.Err = fmt.Errorf("cannot connect database!")
return ret return ret
} }
res, err := slf.db.Exec(query, args...) 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.Err = err
ret.LastInsertID, _ = res.LastInsertId() ret.LastInsertID, _ = res.LastInsertId()
ret.RowsAffected, _ = res.RowsAffected() ret.RowsAffected, _ = res.RowsAffected()