diff --git a/dbpool.go b/dbpool.go index 5d1a317..4436ce8 100644 --- a/dbpool.go +++ b/dbpool.go @@ -111,7 +111,7 @@ func (this *dbPool) SyncSelectCustomQuery(dataSource string, sql string, cb Quer } 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 done = false for !done { @@ -137,6 +137,7 @@ func (this *dbPool) SyncBatchLoadFullTable(dataSource string, sqlTpl string, } }) } + return lastIdx } func (this *dbPool) SelectLike(