server_common/f5
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2024-04-10 17:37:25 +08:00
parent 36d0006a85
commit cce0b0b5db
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
dbpool.go
View File

@ -419,6 +419,9 @@ func (this *dbPool) internalQuery(dataSource string, sql string, params []string
} }
rows, err := ds.conn.Query(sql, q5.ToInterfaces(params)...) rows, err := ds.conn.Query(sql, q5.ToInterfaces(params)...)
this.returnConn(ds) this.returnConn(ds)
if err != nil {
GetSysLog().Warning("f5.dbpool.internalQuery error:%s sql:%s", err, sql)
}
if this.style == GO_STYLE_DB { if this.style == GO_STYLE_DB {
cb(err, NewDataSet(rows)) cb(err, NewDataSet(rows))
@ -439,6 +442,9 @@ func (this *dbPool) internalQueryNoMainThread(dataSource string, sql string, par
} }
rows, err := ds.conn.Query(sql, q5.ToInterfaces(params)...) rows, err := ds.conn.Query(sql, q5.ToInterfaces(params)...)
this.returnConn(ds) this.returnConn(ds)
if err != nil {
GetSysLog().Warning("f5.dbpool.internalQueryNoMainThread error:%s sql:%s", err, sql)
}
cb(err, NewDataSet(rows)) cb(err, NewDataSet(rows))
} }
@ -452,6 +458,9 @@ func (this *dbPool) internalQueryOne(dataSource string, sql string, params []str
} }
rows, err := ds.conn.Query(sql, q5.ToInterfaces(params)...) rows, err := ds.conn.Query(sql, q5.ToInterfaces(params)...)
this.returnConn(ds) this.returnConn(ds)
if err != nil {
GetSysLog().Warning("f5.dbpool.internalQueryOne error:%s sql:%s", err, sql)
}
var dataSet *DataSet var dataSet *DataSet
if err == nil { if err == nil {