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) + } } }