server_common/f5
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2024-06-28 21:39:14 +08:00
parent af0bd957c2
commit c767718aa4
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dbpool.go
View File

@ -375,7 +375,7 @@ func (this *dbPool) StreamPageQuery(
} }
finalySql += fmt.Sprintf(" LIMIT %d ", pageSize + 1) finalySql += fmt.Sprintf(" LIMIT %d ", pageSize + 1)
//GetSysLog().Info("finalySql:%s", finalySql) //GetSysLog().Info("finalySql:%s", finalySql)
this.queryOne( this.query(
dataSource, dataSource,
finalySql, finalySql,
params, params,
@ -388,8 +388,9 @@ func (this *dbPool) StreamPageQuery(
for rows.Next() { for rows.Next() {
if (rows.NumOfReaded() <= int64(pageSize)) { if (rows.NumOfReaded() <= int64(pageSize)) {
fillCb(rows) fillCb(rows)
} else if (rows.NumOfReaded() == int64(pageSize)) { if (rows.NumOfReaded() == int64(pageSize)) {
pagination.NextCursor = q5.ToInt64(rows.GetByName("idx")) pagination.NextCursor = q5.ToInt64(rows.GetByName("idx"))
}
} else if (rows.NumOfReaded() > int64(pageSize)) { } else if (rows.NumOfReaded() > int64(pageSize)) {
pagination.Remaining = 1 pagination.Remaining = 1
} }