diff --git a/dbpool.go b/dbpool.go index 59df024..51fb7e4 100644 --- a/dbpool.go +++ b/dbpool.go @@ -147,9 +147,10 @@ func (this *dbPool) BatchLoadFullTable( var lastIdx int64 done := false for !done && resultErr == nil { - this.SyncSelectCustomQuery( + this.syncInternalQuery( dataSource, sqlCb(lastIdx), + params, func (err error, ds *DataSet) { if err != nil { resultErr = err