From c767718aa4641ca073da443024432148953b4f23 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Fri, 28 Jun 2024 21:39:14 +0800 Subject: [PATCH] 1 --- dbpool.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/dbpool.go b/dbpool.go index 0776a82..b9a598f 100644 --- a/dbpool.go +++ b/dbpool.go @@ -375,7 +375,7 @@ func (this *dbPool) StreamPageQuery( } finalySql += fmt.Sprintf(" LIMIT %d ", pageSize + 1) //GetSysLog().Info("finalySql:%s", finalySql) - this.queryOne( + this.query( dataSource, finalySql, params, @@ -388,8 +388,9 @@ func (this *dbPool) StreamPageQuery( for rows.Next() { if (rows.NumOfReaded() <= int64(pageSize)) { fillCb(rows) - } else if (rows.NumOfReaded() == int64(pageSize)) { - pagination.NextCursor = q5.ToInt64(rows.GetByName("idx")) + if (rows.NumOfReaded() == int64(pageSize)) { + pagination.NextCursor = q5.ToInt64(rows.GetByName("idx")) + } } else if (rows.NumOfReaded() > int64(pageSize)) { pagination.Remaining = 1 }