登录
首页 >  Golang >  Go问答

使用Scylla gocqlx实现游标式的分页功能

来源:stackoverflow

时间:2024-02-15 15:39:23 246浏览 收藏

IT行业相对于一般传统行业,发展更新速度更快,一旦停止了学习,很快就会被行业所淘汰。所以我们需要踏踏实实的不断学习,精进自己的技术,尤其是初学者。今天golang学习网给大家整理了《使用Scylla gocqlx实现游标式的分页功能》,聊聊,我们一起来看看吧!

问题内容

我正在使用 scylla 保存用户创建的聚会。下面的方法返回用户创建的各方的列表。我目前返回所有各方,但不允许分页,但我正在尝试为下面的方法实现分页,但我仍然不太明白 scylla 是如何处理分页的。

我的猜测是游标可以传递给查询。根据此示例,看起来 pagestate 可用于传递类似于光标的内容。

我希望能简短地解释一下 pagestate 是什么以及我是否应该使用它来完成基于令牌的分页。如果可以提供一个示例来展示如何将新的 pagestate 返回给客户端并用于在第二次请求时获取新页面,那就太好了。

func (pq *partyquery) getbyuser(ctx context.context, uid string) ([]datastruct.party, error) {
    var result []datastruct.party
    stmt, names := qb.
        select(table_name).
        where(qb.eq("user_id")).
        tocql()

    err := pq.sess.
        query(stmt, names).
        bindmap((qb.m{"user_id": uid})).
        pagesize(10).
        iter().
        select(&result)
    if err != nil {
        log.println(err)
        return []datastruct.party{}, errors.new("no parties found")
    }

    return result, nil
}

提前致谢,非常感谢您的宝贵时间。

编辑

对于任何感兴趣的人,这就是我如何转换我的函数以允许分页:

func (pq *partyQuery) GetByUser(ctx context.Context, uId string, page []byte) (result []datastruct.Party, nextPage []byte, err error) {
    stmt, names := qb.
        Select(TABLE_NAME).
        Where(qb.Eq("user_id")).
        ToCql()

    q := pq.sess.
        Query(stmt, names).
        BindMap((qb.M{"user_id": uId}))
    defer q.Release()

    q.PageState(page)
    q.PageSize(10)

    iter := q.Iter()
    err = iter.Select(&result)
    if err != nil {
        log.Println(err)
        return []datastruct.Party{}, nil, errors.New("no parties found")
    }

    return result, iter.PageState(), nil
}

正确答案


这里是 gocqlx 作者,您好。

请看一下这个示例 https://github.com/scylladb/gocqlx/blob/25d81de30ebcdfa02d3d849b518fc57b839e4399/example_test.go#L482

getUserVideos := func(userID int, page []byte) (userVideos []Video, nextPage []byte, err error) {
        q := videoTable.SelectQuery(session).Bind(userID)
        defer q.Release()
        q.PageState(page)
        q.PageSize(itemsPerPage)
    
        iter := q.Iter()
        return userVideos, iter.PageState(), iter.Select(&userVideos)
    }

您需要将页面状态发送给调用者。

今天带大家了解了的相关知识,希望对你有所帮助;关于Golang的技术知识我们会一点点深入介绍,欢迎大家关注golang学习网公众号,一起学习编程~

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>