我收到一條錯誤消息：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錯誤消息。我真的不知道要尋找什么，有人可以幫助我嗎？
2 回答
忽然笑
TA貢獻1806條經驗 獲得超5個贊
pgx.Connect()返回pgx.Conn不能同時使用的a。這是此類godocs的說明：
Conn 是 PostgreSQL 連接句柄。并發使用并不安全。使用連接池來管理多個 goroutine 對多個數據庫連接的訪問。
所以如果你pgx.Connect()用pgxpool.Connect()from替換github.com/jackc/pgx/pgxpool你應該沒問題。
慕尼黑8549860
TA貢獻1818條經驗 獲得超11個贊
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()
...
- 2 回答
- 0 關注
- 233 瀏覽
添加回答
舉報
0/150
提交
取消