This commit is contained in:
aozhiwei 2024-07-20 22:44:43 +08:00
parent 1b00affd82
commit bc47498259

View File

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