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

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

diff --git a/dbpool.go b/dbpool.go
index 768e021..989ec38 100644
--- a/dbpool.go
+++ b/dbpool.go
@@ -136,6 +136,7 @@ func (this *dbPool) SyncBatchLoadFullTable(dataSource string, sqlTpl string,
 
 func (this *dbPool) LoopLoad(
 	dataSource string,
+	name string,
 	watchTable string,
 	watchTimeCb func() int64,
 	sqlCb func(int64) string,
@@ -180,6 +181,11 @@ func (this *dbPool) LoopLoad(
 		cond.L.Lock()
 		cond.Wait()
 		cond.L.Unlock()
+		if !hasNextData {
+			GetSysLog().Info("dbpool.LoopLoad %s fetch next batch last_idx:%d", name, lastIdx)
+		} else {
+			GetSysLog().Info("dbpool.LoopLoad %s fetch next round last_idx:%d", name, lastIdx)
+		}
 	}
 }