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-03-27 09:04:12 +08:00
parent d731e1cb0a
commit ba7db1fa1f
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
dbpool.go
View File

@ -111,7 +111,7 @@ func (this *dbPool) SyncSelectCustomQuery(dataSource string, sql string, cb Quer
} }
func (this *dbPool) SyncBatchLoadFullTable(dataSource string, sqlTpl string, func (this *dbPool) SyncBatchLoadFullTable(dataSource string, sqlTpl string,
cb func(*DataSet), errCb func(error)) { cb func(*DataSet), errCb func(error)) int64 {
var lastIdx int64 var lastIdx int64
var done = false var done = false
for !done { for !done {
@ -137,6 +137,7 @@ func (this *dbPool) SyncBatchLoadFullTable(dataSource string, sqlTpl string,
} }
}) })
} }
return lastIdx
} }
func (this *dbPool) SelectLike( func (this *dbPool) SelectLike(