This commit is contained in:
aozhiwei 2024-07-20 23:43:04 +08:00
parent bc47498259
commit 65c7e67581

View File

@ -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