今天我将给大家带来一篇《如何在很短的间隔/同时进行多个查询》，主要内容是讲解等等，感兴趣的朋友可以收藏或者有更好的建议在评论提出，我都会认真看的！大家一起进步，一起学习！

问题内容
嘿，我收到一条错误消息：来自 pgx 的 conn busy

我不知道如何解决这个问题。这是我的功能：

func (r *proverbRepo) SelectPendingProverbs(table string) (proverbs []domain.Proverb, err error) {
    query := fmt.Sprintf("SELECT id, proverb literal FROM %s", table)
    rows, err := r.Db.Query(context.Background(), query)
    defer rows.Close()

    if err != nil {
        return
    }

    for rows.Next() {
        var prov domain.Proverb
        if err = rows.Scan(&prov.ID, &prov.Literal); err != nil {
            return
        }
        proverbs = append(proverbs, prov)
    }
    return
}
r.db 是 pgx.connect(context.background(), os.getenv("psql_url"))

我在很短的时间内从两个单独的前端请求获取两个不同的表。

第一个请求通过，另一个请求返回 conn busy 错误消息。

我真的不知道要寻找什么，有人可以帮助我吗？

解决方案

pgx.connect() 返回一个不能同时使用的 pgx.conn。这是该类型的 Godocs 的状态：

conn 是 postgresql 连接句柄。并发使用并不安全。使用连接池来管理多个 goroutine 对多个数据库连接的访问​​。

因此，如果您将 pgx.connect() 替换为 GitHub.com/jackc/pgx/pgxpool 中的 pgxpool.connect() ，应该没问题。

pgx 返回的 r.db 。 connect(context.background(), os.getenv("psql_url")) 如果类型为 *pgx.conn 并且表示非并发安全的单个连接。通常，您希望使用连接池来为您处理并发并允许重用打开的连接。 要使用连接池，请将 import github.com/jackc/pgx/v4 替换为 github.com/jackc/pgx/v4/pgxpool 并使用 pgxpool.connect() 而不是 pgx.connect() 连接，并且 api 将是一样的：

r.pool := pgxpool.connect(context.background(), os.getenv("psql_url"))
r.pool.query(context.background(), query)
...
如果在任何给定点您需要使用单个连接来访问某些较低级别的功能，您可以安全地获取并发安全连接，如下所示：

conn, err := r.Pool.Acquire(context.Background())
if err != nil {
    fmt.Fprintln(os.Stderr, "Error acquiring connection:", err)
    os.Exit(1)
}
defer conn.Release()
...
好了，本文到此结束，带大家了解了《如何在很短的间隔/同时进行多个查询》。