使用Go PGX库操作PostgreSQL查询时报conn is busy错误如何解决

API 探路者

2026-10-1

问题分析

连接未释放：你通过postgre.client.Acquire()从连接池获取连接后，没有调用Release()方法归还连接，会导致连接持续被占用，池资源耗尽后直接引发连接相关错误。
核心逻辑错误：pgx.Row对象会绑定当前使用的数据库连接，你在还未调用Scan()读取Row中的数据时，就提前提交了事务，事务结束后对应的连接会直接归还到连接池，后续你对返回的Row执行读取操作时，该连接已经可能被其他逻辑占用，就会抛出conn is busy错误。
错误处理遗漏：Acquire()方法返回的错误没有判断，如果获取连接失败，client变量为nil，后续调用client.BeginTx会直接触发空指针panic。
不必要的事务开销：只读查询不需要显式开启事务，pgx默认会为单次查询启用隐式事务，可减少冗余逻辑。

修复方案

推荐的做法是在read方法内完成数据读取，直接返回业务对象而非原始的pgx.Row，避免连接资源泄漏，示例代码如下：

// 示例为读取用户场景，可根据实际业务调整返回值
func (postgre *PostgreClient) readUser(query string) (*User, error) {
    // pgxpool的QueryRow会自动获取和归还连接，不需要手动Acquire
    row := postgre.client.QueryRow(context.TODO(), query)
    
    var u User
    err := row.Scan(&u.ID, &u.Name) // 方法内直接完成Scan读取数据
    if err != nil {
        return nil, err
    }
    return &u, nil
}

如果你确实需要保留返回pgx.Row的设计，必须将连接、事务的生命周期和Row的生命周期绑定，这种场景下需要调用方负责在读完数据后释放资源，该写法容易出现资源泄漏，不优先推荐：

func (postgre *PostgreClient) read(query string) (pgx.Row, func(), error) {
    client, err := postgre.client.Acquire(context.TODO())
    if err != nil {
        return nil, nil, err
    }
    transaction, err := client.BeginTx(context.TODO(), pgx.TxOptions{})
    if err != nil {
        client.Release()
        return nil, nil, err
    }

    rows := transaction.QueryRow(context.TODO(), query)
    // 释放函数交给调用方，在Scan完成后调用
    cleanup := func() {
        _ = transaction.Rollback(context.TODO())
        client.Release()
    }
    return rows, cleanup, nil
}

// 调用方使用示例
row, cleanup, err := pgClient.read("select * from users where id = 1")
defer cleanup()
// 先执行Scan，再触发cleanup释放资源
err = row.Scan(&id, &name)

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