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
 				}