嘿,我收到一条错误消息: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.Dbpgx.Connect(context.Background(), os.Getenv("PSQL_URL"))
我要在很短的间隔内从两个单独的前端请求中获取两个不同的表。

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

我真的不知道要寻找什么,有人会帮我吗?

最佳答案

pgx.Connect()返回不能同时使用的pgx.Conn。这是此类型的godocs的状态:



因此,如果将pgx.Connect()替换为pgxpool.Connect()中的github.com/jackc/pgx/pgxpool,则应该没问题。

关于go - 如何在很短的间隔内/同时进行多个查询,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/58597639/

10-10 16:46