如何在很短的时间间隔内/同时进行多个查询
How to make multiple query in a very short interval / simultaneously
嘿,我收到一条错误消息: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"))
我在很短的时间内从两个独立的前端请求中获取两个不同的 table。
第一个请求通过,另一个 returns conn busy
错误消息。
我真的不知道要找什么,有人能帮我吗?
pgx.Connect()
returns一个pgx.Conn
不能同时使用。这就是这种类型的 godocs 状态:
Conn is a PostgreSQL connection handle. It is not safe for concurrent usage. Use a connection pool to manage access to multiple database connections from multiple goroutines.
因此,如果您将 pgx.Connect()
替换为 github.com/jackc/pgx/pgxpool
中的 pgxpool.Connect()
,您应该没问题。
如果类型为 *pgx.Conn
,则 pgx.Connect(context.Background(), os.Getenv("PSQL_URL"))
返回的 r.Db
表示并发不安全的单个连接。通常,您希望使用连接池来为您处理并发并允许重用打开的连接。
要使用连接池,请将 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)
...
如果在任何给定点您需要使用单个连接来访问某些 lower-level 功能,您可以安全地获取并发安全连接,如下所示:
conn, err := r.Pool.Acquire(context.Background())
if err != nil {
fmt.Fprintln(os.Stderr, "Error acquiring connection:", err)
os.Exit(1)
}
defer conn.Release()
...
嘿,我收到一条错误消息: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"))
我在很短的时间内从两个独立的前端请求中获取两个不同的 table。
第一个请求通过,另一个 returns conn busy
错误消息。
我真的不知道要找什么,有人能帮我吗?
pgx.Connect()
returns一个pgx.Conn
不能同时使用。这就是这种类型的 godocs 状态:
Conn is a PostgreSQL connection handle. It is not safe for concurrent usage. Use a connection pool to manage access to multiple database connections from multiple goroutines.
因此,如果您将 pgx.Connect()
替换为 github.com/jackc/pgx/pgxpool
中的 pgxpool.Connect()
,您应该没问题。
如果类型为 *pgx.Conn
,则 pgx.Connect(context.Background(), os.Getenv("PSQL_URL"))
返回的 r.Db
表示并发不安全的单个连接。通常,您希望使用连接池来为您处理并发并允许重用打开的连接。
要使用连接池,请将 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)
...
如果在任何给定点您需要使用单个连接来访问某些 lower-level 功能,您可以安全地获取并发安全连接,如下所示:
conn, err := r.Pool.Acquire(context.Background())
if err != nil {
fmt.Fprintln(os.Stderr, "Error acquiring connection:", err)
os.Exit(1)
}
defer conn.Release()
...