在开发过程中,经常会涉及到从数据库查询数据,当数据小于一定条数时可以在一页进行显示,当条数比较多时往往希望分页显示。本文主要介绍通过golang实现hbase的分页查询。
使用到的库有:
“github.com/tsuna/gohbase”
“github.com/tsuna/gohbase/filter”
“github.com/tsuna/gohbase/hrpc”
具体代码如下,其中startRow为页码列表的开始索引,stopRow页码列表的结束索引,limit每页显示多少条
func PagedQuery(table, startRow, stopRow string, limit int64) (rsp []*hrpc.Result, err error) {
var (
scanRequest *hrpc.Scan
res *hrpc.Result
)
pFilter := filter.NewPageFilter(limit + 1)
scanRequest, err = hrpc.NewScanRangeStr(context.Background(), table, startRow, stopRow, hrpc.Reversed(), hrpc.Filters(pFilter))
if err != nil {
log4go.Error("hrpc.NewScanStr: %s", err.Error())
}
scanner := client.Scan(scanRequest)
for {
res, err = scanner.Next()
if err == io.EOF || res == nil {
break
}
if err != nil {
log4go.Error("hrpc.Scan: %s", err.Error())
}
rsp = append(rsp, res)
}
return rsp, err
}
根据分页查找获取索引,得到查找结果和下一页开始索引nextIndex。如果查找结果小于每页显示多少条limit,nextIndex = “”;如果查找结果大于limit,nextIndex = string(temScanner[limit].Cells[0].Row)
func GetHbaseIndex(startRow,stopRow, table string, limit int64) (rsp []*hrpc.Result, str string) {
var nextIndex string
temScanner, err := PagedQuery(table, startRow, stopRow, limit)
if err != nil {
fmt.Println("GetHbaseIndex with limit: ", err)
}
if int64(len(temScanner)) <= limit {
nextIndex = ""
return temScanner, nextIndex
} else {
nextIndex = string(temScanner[limit].Cells[0].Row)
return temScanner[:len(temScanner)-1], nextIndex
}
}
如有不对欢迎指正,相互学习,共同进步。