如何在很短的间隔/同时进行多个查询

Question

我收到一条错误消息：conn busy来自 pgx

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

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错误消息。

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

Answer 1

pgx.Connect()返回pgx.Conn不能同时使用的a。这是此类godocs的说明：Conn 是 PostgreSQL 连接句柄。并发使用并不安全。使用连接池来管理多个 goroutine 对多个数据库连接的访问。所以如果你pgx.Connect()用pgxpool.Connect()from替换github.com/jackc/pgx/pgxpool你应该没问题。

Answer 2

ifr.Db返回的pgx.Connect(context.Background(), os.Getenv("PSQL_URL"))if 类型为*pgx.Connand 表示单个连接，该连接不是并发安全的。通常，您希望使用连接池来为您处理并发并允许重用打开的连接。要使用连接池，请替换import github.com/jackc/pgx/v4withgithub.com/jackc/pgx/v4/pgxpool并使用 connect withpgxpool.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()...