From bf49efd5a029a9e0749019c03fb4295dd89bf350 Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Sat, 22 Jun 2024 14:21:56 +0800
Subject: [PATCH] 1

---
 dbpool.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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
 					}