当前位置：首页 > 文章列表 > Golang > Go教程 > Go database/sql 如何处理 Rows.Close 错误：事务提交前的资源回收顺序

Go database/sql 如何处理 Rows.Close 错误：事务提交前的资源回收顺序

来源：17golang原创 2026-08-29 12:04:58 0浏览收藏

线上批量导入偶尔出现“事务已经提交，但结果不完整”的告警，排查时很容易只盯着 rows.Err()，却漏掉 Rows.Close 返回的错误。对 database/sql 来说，读取结束、关闭结果集和提交事务是三个不同的检查点；把它们揉成一个 defer，就可能在提交后才发现连接或驱动层的问题。

在事务内查询时，应先确认 rows.Err()，再显式处理 rows.Close()，两个检查都通过后才调用 Commit；任一点失败，都走 Rollback。

要点速览

rows.Next() 返回 false 不等于查询完整成功，还要看 rows.Err()。
rows.Close() 负责释放结果集资源，也可能返回错误，不能只写成无视返回值的 defer。
事务提交前检查读取错误和关闭错误，失败分支统一回滚。
关闭成功后再提交，提交失败仍要记录并交给上层处理。

为什么 rows.Next 结束后还要检查两次

database/sql.Rows 把结果集读取封装成迭代器。Next 返回 false 可能表示没有下一行，也可能表示读取途中发生了错误；真正的读取结论要由 rows.Err() 给出。另一方面，Close 负责结束结果集，驱动可能在这里完成最后的网络读取或资源释放，因此它和 Err 不是同一个信号。

这也是为什么“循环结束就提交”不够稳：循环只说明迭代动作停了，不说明数据已经完整落地。

把关闭动作放到 Commit 之前

下面的示例以一个事务内的库存同步为背景。查询本身只读取 inventory_delta，真正的写入省略为注释，重点是四个真实节点：QueryContext、rows.Next、rows.Err、rows.Close。

func syncInventory(ctx context.Context, db *sql.DB) error {
    tx, err := db.BeginTx(ctx, nil)
    if err != nil {
        return err
    }

    rows, err := tx.QueryContext(ctx, `
        SELECT sku, delta
        FROM inventory_delta
        WHERE batch_id = ?
        ORDER BY sku`, batchID)
    if err != nil {
        _ = tx.Rollback()
        return err
    }

    for rows.Next() {
        var sku string
        var delta int
        if err := rows.Scan(&sku, &delta); err != nil {
            _ = rows.Close()
            _ = tx.Rollback()
            return err
        }
        // 在事务内写入库存变更。
    }

    if err := rows.Err(); err != nil {
        _ = rows.Close()
        _ = tx.Rollback()
        return err
    }
    if err := rows.Close(); err != nil {
        _ = tx.Rollback()
        return err
    }
    return tx.Commit()
}

示例里没有使用无条件的 defer rows.Close() 来代替显式检查。实际项目可以再加一个兜底关闭，但兜底动作不应掩盖提交前的主检查。