Google Cloud Spanner是否支持游标分页？Go SDK实现示例咨询

Google Cloud Spanner Go SDK完全支持基于游标（恢复令牌ResumeToken）的分页功能，以下针对你的帖子查询场景给出具体实现方案：

核心原理 #

Spanner的分页通过查询结果返回的ResumeToken实现，这个令牌是一个字节数组，记录了当前查询的终止位置。下次查询时传入该令牌，就能从上次结束的位置继续获取数据，避免重复返回结果。

完整代码实现 #

1. 封装分页查询函数 #

针对你的posts表场景，封装通用分页查询函数：

import (
    "context"
    "fmt"
    "cloud.google.com/go/spanner"
    "google.golang.org/api/iterator"
)

// 定义Post结构体，匹配你的posts表字段
type Post struct {
    ID      string
    Time    spanner.Timestamp
    Content string
    // 其他字段根据实际表结构补充
}

// executeQueryWithLimitAndCursor 执行分页查询，返回结果集和下一页恢复令牌
func executeQueryWithLimitAndCursor(ctx context.Context, client *spanner.Client, resumeToken []byte, minTime spanner.Timestamp) ([]Post, []byte, error) {
    // 注意：必须添加ORDER BY保证排序稳定，否则分页结果可能异常
    stmt := spanner.NewStatement(`
        SELECT ID, Time, Content 
        FROM posts 
        WHERE Time > @minTime 
        ORDER BY Time ASC 
        LIMIT 10
    `)
    stmt.Params = map[string]interface{}{
        "minTime": minTime,
    }

    opts := spanner.QueryOptions{}
    if resumeToken != nil {
        opts.ResumeToken = resumeToken
    }

    iter := client.Single().QueryWithOptions(ctx, stmt, opts)
    defer iter.Stop()

    var posts []Post
    for {
        row, err := iter.Next()
        if err == iterator.Done {
            break
        }
        if err != nil {
            return nil, nil, fmt.Errorf("fetch row failed: %w", err)
        }
        var post Post
        if err := row.ToStruct(&post); err != nil {
            return nil, nil, fmt.Errorf("parse row failed: %w", err)
        }
        posts = append(posts, post)
    }

    // 获取下一页的恢复令牌
    nextToken := iter.ResumeToken()
    return posts, nextToken, nil
}

2. 分页调用示例 #

对应你给出的伪代码逻辑，实际调用流程如下：

func main() {
    ctx := context.Background()
    // 初始化Spanner客户端，替换为你的项目/实例/数据库ID
    client, err := spanner.NewClient(ctx, "projects/your-project/instances/your-instance/databases/your-db")
    if err != nil {
        panic(err)
    }
    defer client.Close()

    // 初始查询：传入起始时间，resumeToken传nil
    initialMinTime := spanner.Timestamp{} // 替换为业务实际的起始时间
    firstPagePosts, storedCursor, err := executeQueryWithLimitAndCursor(ctx, client, nil, initialMinTime)
    if err != nil {
        panic(err)
    }
    // 处理第一页结果
    fmt.Println("第一页帖子：")
    for _, p := range firstPagePosts {
        fmt.Printf("ID: %s, Time: %v\n", p.ID, p.Time)
    }

    // 用户请求下一页：传入存储的cursor
    secondPagePosts, storedCursor, err := executeQueryWithLimitAndCursor(ctx, client, storedCursor, initialMinTime)
    if err != nil {
        panic(err)
    }
    // 处理第二页结果
    fmt.Println("\n第二页帖子：")
    for _, p := range secondPagePosts {
        fmt.Printf("ID: %s, Time: %v\n", p.ID, p.Time)
    }

    // 后续分页重复上述逻辑即可
}

关键注意事项 #

• 必须保持查询一致性：分页过程中，查询的WHERE条件、ORDER BY规则、LIMIT值必须完全一致，否则恢复令牌会失效。
• 令牌存储方式：ResumeToken是字节数组，可序列化为Base64字符串存储在客户端（如LocalStorage、Cookie）或服务端缓存，使用时再解码为字节数组。
• 排序的必要性：Spanner依赖稳定的排序顺序来定位分页位置，缺失ORDER BY会导致分页结果出现重复或数据遗漏。

内容的提问来源于stack exchange，提问作者Mohammad Arshad