diff --git a/dbpool.go b/dbpool.go
index 641a2fa..3a4f6ba 100644
--- 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
 					}