Go语言使用PostgreSQL预编译语句导致连接耗尽问题求助

核心原因 #

你的UPDATE语句误用了QueryRow且未处理结果集，导致数据库连接被持续占用。QueryRow适用于带返回结果的SQL操作（比如带RETURNING的INSERT/UPDATE、SELECT），而你的UPDATE没有RETURNING子句，调用QueryRow后会生成一个未关闭的空结果集，PostgreSQL会维持连接处于idle状态直到结果集被释放，最终耗尽max_connections限制。

而INSERT语句正常是因为你在执行时必然调用了Scan读取RETURNING的itemid，结果集被关闭后连接会自动放回连接池。

解决方案 #

1. 用Exec替代QueryRow执行无返回结果的UPDATE #

修改UpdateStatus函数，使用Exec执行UPDATE语句——它专门用于无返回结果的SQL操作，执行完成后立即释放连接回池：

func (ipg *ItemPG) UpdateStatus(itemid int64, status string) error {
    _, err := ipg.preparedStatements[UpdateStatus].Exec(status, itemid)
    if err != nil {
        return errors.Wrapf(err, "cannot update item status item: %d - status: %s", itemid, status)
    }
    return nil
}

2. 优化数据库连接池配置 #

Go的database/sql默认连接池配置无法应对高并发场景，需手动调整参数避免连接泄漏或过度占用：

// 初始化db实例后设置连接池参数
db.SetMaxOpenConns(20) // 最大打开连接数，根据服务器硬件配置调整
db.SetMaxIdleConns(10) // 最大空闲连接数，建议小于等于最大打开连接数
db.SetConnMaxLifetime(time.Hour) // 连接最长存活时间，避免长期idle的连接失效

3. 统一管理预编译语句生命周期 #

预编译语句（*sql.Stmt）由连接池自动管理，无需每次使用后关闭。只需在程序退出或资源清理阶段统一关闭所有预编译语句即可：

// 清理资源时调用
func (ipg *ItemPG) ClosePreparedStatements() {
    for _, stmt := range ipg.preparedStatements {
        _ = stmt.Close()
    }
}

验证 #

修改后，执行UPDATE语句的连接会立即放回连接池，不会持续处于idle状态，同时保留预编译语句的复用优势，避免重复创建的额外开销。

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