diff --git a/dbpool.go b/dbpool.go index e189b77..59df024 100644 --- a/dbpool.go +++ b/dbpool.go @@ -138,7 +138,7 @@ func (this *dbPool) BatchLoadFullTable( dataSource string, sqlCb func(int64) string, params []string, - nextTimeCb func() int64, + nextTimeCb func(), doCb func(*DataSet) bool) error { if this.style != GO_STYLE_DB { panic("dbpool.BatchLoadFullTable is not gostyle") @@ -168,6 +168,7 @@ func (this *dbPool) BatchLoadFullTable( done = true } }) + nextTimeCb() } return resultErr }