登录
推荐 文章 Go 技术 课程 下载 专题 AI
首页 >  Golang >  Go问答

Go rows.Scan 成功后为什么还必须检查 rows.Err

来源:17golang原创

时间:2026-10-06 12:50:35 267浏览 收藏

因为 rows.Scan 只负责把“当前这一行”转换到目标变量,而 rows.Next 还可能在读取后续行时遇到驱动、网络或上下文取消错误。循环结束时,Next 返回 false 既可能表示正常读完,也可能表示迭代失败;只有检查 rows.Err(),才能把这两种情况分开。

要点速览
  • Scan == nil 只证明当前行的列数和类型转换通过。
  • Next() == false 不能直接当成结果集正常结束。
  • 只读查询通常在循环后检查 rows.Err();写入型结果集或多结果集还要认真处理 Close()。

为什么 Scan 成功仍不能证明结果集读完

多行查询是分段推进的:Next 先准备下一行,Scan 再复制当前行。比如前 99 行都已经成功转换,第 100 行之后连接被取消,前面的 Scan 仍然可以全部返回 nil,但应用拿到的只是一个不完整结果集。

Go database/sql 中 QueryContext、Rows.Next、Rows.Scan 与 Rows.Err 的迭代边界静态说明图
图1:Rows.Next、Rows.Scan 与 Rows.Err 的静态边界说明图,不是运行截图。

官方文档明确说明,Next 返回 false 时,可能是没有下一行,也可能是准备下一行时发生错误;Rows.Err 的职责就是报告迭代阶段遇到的错误。因此“扫描到多少行”与“查询是否完整成功”是两个不同结论。

Scan 和 Err 分别负责哪一层错误

检查点它回答的问题典型失败
QueryContext结果集是否成功建立SQL、连接或参数错误
rows.Scan当前行能否转换到目标变量列数不匹配、类型转换失败
rows.Err迭代过程是否完整结束驱动读错误、网络中断、context 取消
rows.Close关闭结果集时驱动是否报告错误写入型结果集提交或关闭失败

这也是为什么不能把 Scan 的错误变量当成整个查询的最终状态。它只覆盖当前行;如果 Next 在准备下一行时已经失败,循环体甚至不会再次执行,必须到循环后读取 Err。

可直接复用的 Rows 读取模板

对常见的只读查询,可以把职责拆成三处:查询建立失败立即返回,当前行转换失败立即停止,循环结束后统一检查迭代错误。

func loadUsers(ctx context.Context, db *sql.DB) ([]User, error) {
    // 让数据库操作继承请求取消信号,避免调用方已退出后仍继续读行。
    rows, err := db.QueryContext(ctx, `SELECT id, name FROM users WHERE enabled = ?`, true)
    if err != nil {
        return nil, fmt.Errorf("query users: %w", err)
    }
    defer rows.Close()

    users := make([]User, 0, 32)
    for rows.Next() {
        var u User
        // Scan 只判断当前行的列数和类型转换,不代表后续行已读完。
        if err := rows.Scan(&u.ID, &u.Name); err != nil {
            return nil, fmt.Errorf("scan user: %w", err)
        }
        users = append(users, u)
    }

    // Next 返回 false 后,必须区分正常结束与迭代阶段错误。
    if err := rows.Err(); err != nil {
        return nil, fmt.Errorf("iterate users: %w", err)
    }
    return users, nil
}

这个顺序的关键不是多写一个判断,而是保留错误发生的层级。调用方可以据此决定重试、返回部分结果,或把 context.Canceled 和 context.DeadlineExceeded 交给上层处理,而不是把半截数据当成完整成功。

Go Rows 多行查询中当前行转换、Rows.Close、Rows.Err 与 context 取消的静态结构图
图2:多行查询错误处理职责的静态结构图,不是运行截图。

Close、context 取消和多结果集怎么判断

只读查询在走到末尾且没有更多结果集时,Rows 会自动关闭,文档示例通常使用 defer rows.Close() 并在循环后检查 Err。如果查询涉及写入、批量语句或驱动可能在关闭时返回提交错误,就应显式检查 Close:

// 只有需要关注关闭阶段错误时,才把 Close 的返回值单独取出。
if err := rows.Close(); err != nil {
    return fmt.Errorf("close rows: %w", err)
}
// Close 不会替代 Err;仍要检查迭代阶段是否已经失败。
if err := rows.Err(); err != nil {
    return fmt.Errorf("read rows: %w", err)
}

使用 QueryContext 时,取消可能发生在两次 Next 之间,所以不要只在循环体里记录日志。若使用 NextResultSet 读取多结果集,也要在结果集切换返回 false 后检查 Err,否则无法判断是没有下一个结果集,还是切换过程失败。

相关问题

rows.Scan 返回 nil 后还可能拿到少量数据吗?

可能。已经追加到切片的行不一定构成完整结果集;是否允许返回部分数据,要由业务协议明确决定,不能仅凭 Scan 成功判断。

rows.Err 为 nil 是否说明每一列都正确?

不完全说明。它主要覆盖迭代过程;列数不匹配或转换失败通常由当前行的 Scan 返回,仍需保留 Scan 判断。

只使用 defer rows.Close 够不够?

对常见只读查询,循环后检查 Err 是核心。若驱动或业务涉及写入、批量提交或特殊关闭语义,再显式检查 Close 的返回值。

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