Go database/sql Rows.NextResultSet 怎么处理多结果集：遍历顺序与驱动兼容判断

一条数据库调用如果返回多组结果，最容易踩的坑是把 Rows.Next() 当成“继续读下一组结果”。它只负责当前结果集的行遍历；读完这一组后，要先检查 Rows.Err()，再调用 Rows.NextResultSet()，成功切换后才能继续读取下一组。

先分清两个 Next：行游标和结果集游标

*sql.Rows 同时暴露了两个层次的推进方法。Next() 把行游标移动到当前结果集的下一行；当它返回 false 时，当前结果集结束，但这不代表所有结果都结束了。NextResultSet() 用来请求下一组结果，返回 true 才能继续调用 Columns、Scan 和 Next。

标准遍历顺序应该长什么样

把代码分成“结果集循环”和“行循环”两层，最不容易把边界条件写乱。外层由 NextResultSet 控制，内层由 Next 控制；每次内层结束后立刻检查错误。

rows, err := db.QueryContext(ctx, query, args...)
if err != nil {
    return err
}
defer rows.Close()

for {
    columns, err := rows.Columns()
    if err != nil {
        return err
    }

    for rows.Next() {
        values := make([]any, len(columns))
        destinations := make([]any, len(columns))
        for i := range values {
            destinations[i] = &values[i]
        }
        if err := rows.Scan(destinations...); err != nil {
            return err
        }
        // 在这里处理当前结果集的一行。
    }
    if err := rows.Err(); err != nil {
        return err
    }
    if !rows.NextResultSet() {
        if err := rows.Err(); err != nil {
            return err
        }
        break
    }
}

这段代码有一个刻意保留的细节：每次切换前都先做一次 Rows.Err()。如果网络断开、服务器取消执行或驱动在读取结果时出错，直接把 false 当成“正常结束”，调用方就会得到一份不完整的数据。

如何判断驱动到底支持多结果集

支持多结果集不是 database/sql 接口本身替你兜底的能力，真正结果取决于数据库协议、驱动实现和查询写法。不要仅凭文档里看到一个 SQL 示例就把业务逻辑上线。

可以在集成测试中使用实际驱动连接真实测试数据库：让一次调用返回两组结构明显不同的结果，第一组包含一个可识别字段，第二组包含另一个字段；分别记录 Columns() 返回值，确认第二次 NextResultSet() 后确实发生了变化。若驱动不支持，应该让测试明确失败，或者把接口改成两次独立查询。

空结果、列变化和半途报错怎么处理

某一组结果集可以没有任何行，但仍然可能有列定义。进入结果集后先取 Columns()，再运行 Next()；不要用“没有读到行”推断“没有下一组结果”。列结构也可能在结果集之间变化，复用上一组的目标变量会让 Scan 语义变得含混，按当前列数重新准备接收容器更安全。

如果第二组读取到一半报错，返回值必须带上错误，不要把第一组已经处理的记录当成完整事务结果。业务层可以选择丢弃整批数据、标记为部分成功，或者改成可重试的独立查询；这取决于数据是否允许重复处理。

常见问题

只调用 Rows.Next，不调用 NextResultSet 会怎样？

只能读取第一组结果集。第一组读完后 Next 返回 false，后续结果不会自动暴露给行循环。

NextResultSet 返回 false 就一定是正常结束吗？

不一定。先检查 Rows.Err()；有错误时应返回错误，没有错误才表示没有更多结果集或驱动已经正常结束。

能不能把多结果集改成一个大结构体接收？

不建议。每个结果集的列定义可能不同，按结果集读取列并在边界处转换成业务对象，通常比强行复用结构体更清晰。

最后的检查清单

• 查询返回的 *sql.Rows 已经 defer Close。
• 内层 Next 结束后检查了 Rows.Err。
• 外层用 NextResultSet 切换，并再次检查错误。
• 集成测试覆盖空结果集、列变化和中途断开。
• 真实数据库驱动已确认多结果集能力，不把驱动差异藏在业务代码里。