Pgxpool 在扫描时返回“池已关闭”错误

目前golang学习网上已经有很多关于Golang的文章了，自己在初次阅读这些文章中，也见识到了很多学习思路；那么本文《Pgxpool 在扫描时返回“池已关闭”错误》，也希望能帮助到大家，如果阅读完后真的对你学习Golang有帮助，欢迎动动手指，评论留言并分享~

我正在尝试在新的 go 应用程序中实现 pgxpool。尝试扫描结构后，我不断收到“池已关闭”错误。

连接后，pgx 记录器给了我这个。我认为 pgxpool 应该保持开放。

{"level":"info","msg":"关闭连接","pid":5499,"time":"2022-02-24t16:36:33+10:30"}

这是我的路由器代码

func router() http.handler {

    var err error

    config, err := pgxpool.parseconfig(os.getenv("database_url"))

    if err != nil {
        log.fatalln(err)
    }

    log.println(os.getenv("database_url"))

    logruslogger := &logrus.logger{
        out:          os.stderr,
        formatter:    new(logrus.jsonformatter),
        hooks:        make(logrus.levelhooks),
        level:        logrus.infolevel,
        exitfunc:     os.exit,
        reportcaller: false,
    }

    config.connconfig.logger = newlogger(logruslogger)

    db, err := pgxpool.connectconfig(context.background(), config)

    if err != nil {
        log.fatalln(err)
    }

    defer db.close()

--- minio connection

rs := newappresource(db, mc)

然后，在辅助文件中我设置资源

type appresource struct {
   db *pgxpool.pool
   mc *minio.client
}

// newappresource function to pass global var
func newappresource(db *pgxpool.pool, mc *minio.client) *appresource {
    return &appresource{
        db: db,
        mc: mc,
    }
}

此代码末尾发生“池已关闭”错误

func (rs *appResource) login(w http.ResponseWriter, r *http.Request) {

    var user User
    var login Login

    d := json.NewDecoder(r.Body)
    d.DisallowUnknownFields() // catch unwanted fields

    err := d.Decode(&login)
    if err != nil {
        http.Error(w, err.Error(), http.StatusBadRequest)
        return
    }

    if err != nil {
        fmt.Println("can't decode JSON", err)
    }

    if login.Email == "" {
        log.Println("empty email")
        return
    }

    log.Println(login.Email)

    log.Println(login.Password)

    if login.Password == "" {
        log.Println("empty password")
        return
    }

    // optional extra check
    if d.More() {
        http.Error(w, "extraneous data after JSON object", http.StatusBadRequest)
        return
    }

    sqlStatement := "SELECT user_id, password FROM users WHERE active = 'true' AND email = ?"

    row := rs.db.QueryRow(context.Background(), sqlStatement, login.Email)

    err = row.Scan(&user.UserId, &user.Password)

    if err == sql.ErrNoRows {
        log.Println("user not found")
        http.Error(w, err.Error(), http.StatusUnauthorized)
        return
    }

    if err != nil {
        log.Println(err)
        http.Error(w, err.Error(), http.StatusInternalServerError)
        return
    }

正确答案

您似乎正在执行以下操作：

func router() http.Handler {
   db, err := pgxpool.ConnectConfig(context.Background(), config)
   if err != nil {
       log.Fatalln(err)
   }
   defer db.Close()

   return appResource{db: db}
}

问题在于，当函数 router() 结束时，defer db.close() 运行，并且这是在实际使用返回的 pgxpool.pool 之前（返回的 http.handler 将在稍后使用 http 时使用）请求已处理）。尝试使用关闭的 pgxpool.pool 会导致您看到的错误。

最简单的解决方案是简单地删除 defer db.close() 但是您也可以考虑调用 db.close() 作为干净关闭过程的一部分（只要您正在处理请求，它就需要保持打开状态） ）。

您正在使用 pgxpool，它与标准库不同；但我相信 standard library docs 中给出的建议适用于此：

很少需要关闭数据库。

理论要掌握，实操不能落！以上关于《Pgxpool 在扫描时返回“池已关闭”错误》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！