Go rowslife 出错时怎么查连接泄漏

Go 里看到连接数持续升高、请求偶发卡住时，问题经常不在 SQL 语句，而在 database/sql.Rows 的生命周期没有走完。最小修复是：查询成功后立刻安排 rows.Close()，遍历结束再检查 rows.Err()；如果中途 Scan 失败或业务提前返回，也必须经过同一条回收路径。

先确认 Rows 的真实生命周期

QueryContext 返回的是结果集对象，不是已经取完的数据。Rows.Next 负责把游标推进到下一行，随后才能调用 Scan；当 Next 返回 false 时，可能是自然结束，也可能是驱动在迭代过程中报错。因此只写一个循环还不够。

rows, err := db.QueryContext(ctx, query, userID)
if err != nil {
    return err // 查询没有拿到结果集时，不要再调用 rows 的方法
}
defer rows.Close() // 先登记回收，覆盖后续 Scan 失败和提前返回

for rows.Next() {
    if err := rows.Scan(&id, &name); err != nil {
        return err // defer 会关闭仍未消费完的结果集
    }
}
if err := rows.Err(); err != nil {
    return err // 区分自然结束与迭代/驱动错误
}
return nil

自然结束时，标准库可能已经隐式关闭 Rows，但显式 Close 仍然值得保留：它让提前返回路径明确可见，而且 Close 是幂等的。对读查询而言，循环后检查 Err 是识别网络中断、驱动读取失败等问题的关键。

把连接泄漏定位到退出路径

先不要把所有“连接不够用”都归因于连接泄漏。sql.DB 是连接池，DB.Stats() 可以提供线索：InUse 长时间偏高，且 WaitCount 继续增长，说明调用方占用连接的时间过长；如果请求刚结束仍不回落，就要沿着 Rows 和事务的退出路径查。

stats := db.Stats()
log.Printf("db stats: in_use=%d idle=%d wait_count=%d", stats.InUse, stats.Idle, stats.WaitCount) // 只记录池状态线索

rows, err := db.QueryContext(ctx, query)
if err != nil {
    return err // QueryContext 失败时没有可关闭的 Rows
}
defer func() {
    if closeErr := rows.Close(); closeErr != nil {
        log.Printf("close rows: %v", closeErr) // 记录关闭阶段的驱动错误
    }
}()

诊断时重点找三类代码：把 rows 放进循环后才 defer 的代码、错误分支直接 return 的代码，以及开启事务后只关闭 Rows 却没有提交或回滚的代码。第三类不属于 Rows 单独泄漏，但同样会长期占用连接，外在症状很像。

修复提前返回和扫描失败

最稳妥的结构是“拿到 Rows 立即登记 Close，循环内只处理当前行，循环后集中处理 Err”。如果业务只需要前几行，也不要依赖调用者记得收尾；让拥有 Rows 的函数负责关闭它。若使用 QueryContext，还应把请求的取消信号传入上下文，让底层查询在请求结束后有机会停止。

需要特别注意 Scan 错误：它发生在 Next 返回 true 之后，不能用 Rows.Err() 代替处理。可以把扫描错误立即返回，同时依靠前面登记的 defer rows.Close() 释放结果集。若是多结果集，还要继续处理或明确关闭后再检查 Err，不要只看第一组数据。

用检查清单做反向验证

反向验证应看一段时间内的趋势，而不是只采样一次。让查询分别走完整结果、空结果、Scan 失败和 context 取消四条路径；如果每条路径都能返回，且连接池占用回落，才说明 Rows 的资源边界真正闭合。

常见问题

Rows.Next 返回 false 就一定没有错误吗？

不一定。它既表示没有下一行，也可能表示读取阶段出错，必须调用 Rows.Err() 判断。

已经遍历到末尾，还需要 rows.Close 吗？

标准库在没有更多结果集时会自动关闭，但显式关闭能覆盖提前返回和多结果集场景，且调用是幂等的。

调大 MaxOpenConns 能解决连接泄漏吗？

不能。它只能延后池耗尽；应先修复 Rows、事务或长时间未结束的查询，再根据真实并发量调整池参数。