1

2024-06-22 14:21:56 +08:00 · 2024-06-22 14:21:56 +08:00 · bf49efd5a0
commit bf49efd5a0
parent 04c7b77bd7
1 changed files with 3 additions and 3 deletions
--- a/dbpool.go
+++ b/dbpool.go
@ -147,11 +147,11 @@ func (this *dbPool) LoopLoad(
 				if err == nil {
 					for ds.Next() {
 						idx := q5.ToInt64(ds.GetByName("idx"))
+						if !doCb(ds) {
+							return
+						}
 						if idx > lastIdx {
 							lastIdx = idx
-						}
-						if doCb(ds) {
-
 						}
 						hasNextData = true
 					}