连接关闭时插入postgresql

各位小伙伴们，大家好呀！看看今天我又给各位带来了什么文章？本文标题是《连接关闭时插入postgresql》，很明显是关于Golang的文章哈哈哈，其中内容主要会涉及到等等，如果能帮到你，觉得很不错的话，欢迎各位多多点评和分享！

我尝试将用户插入 postgres 数据库并获取三个参数以供进一步处理，但总是收到错误“conn close”：

package db

import (
    "context"
    "os"

    "github.com/jackc/pgx/v4"
)

const (
    insertsql = "insert into users (name, email, created, status, role, password, activation_code) values ($1, $2, $3, $4, $5, $6, $7) returning name, email, activation_code;"
)

type userrepository struct {
    connect *pgx.conn
}

func newuserrepository(c *pgx.conn) domain.userrepository {
    return &userrepository{
        connect: c,
    }
}

func (r *userrepository) save(u *domain.user) (string, string, string, *resterrors.resterr) {
    var name, email, activation_code string
    if r.connect == nil {
        os.exit(1)
    }
    if err := r.connect.queryrow(context.background(), insertsql, u.name, u.email, u.created, u.status, u.role, u.password, u.activationcode).scan(&name, &email, &activation_code); err != nil {
        logger.error("error saving user to the database: " + err.error())
        return "", "", "", resterrors.newintenalservererror(resterrors.db_error)
    }
    return name, email, activation_code, nil
}

connect 在创建存储库时插入 application.go

repository := db.newuserrepository(postgresql.connect)
userhandler := controller.newuserhandler(service.newuserservice(repository))

connect 在 postgresql 包中全局声明

package postgresql

import (
    "context"
    "fmt"
    "net/url"

    "github.com/jackc/pgx/v4"
)
var (
    Connect *pgx.Conn
    username = "postgres"
    password = "***********" 
    host     = "127.0.0.1"
    port     = "5432"
    dbName   = "test"
)

func init() {
    //prepare URL to connect to database
    var err error
    datasourceName := fmt.Sprintf("postgres://%s:%s@%s:%s/%s", username, password, host, port, dbName)
    Connect, err = pgx.Connect(context.Background(), datasourceName)
    if err != nil {
        logger.Error("unable to connect to database: " + err.Error())
        panic(fmt.Errorf("unable to connect to database: %w", err))
      }
    logger.Info("successsfully connected to postgres database")
      // to close DB connection
    defer Connect.Close(context.Background())
}

可能有什么问题吗？

正确答案

单个数据库连接不是并发安全的，并且没有重新建立连接的机制。您的问题可能是并发访问中断了连接，或者由于其他原因关闭了连接。

您需要一个数据库连接池，以便它可以为并发操作创建新连接（对 net/http 服务器的请求并发处理连接）。来自https://pkg.go.dev/github.com/jackc/pgx/v4#hdr-Connection_Pool：

使用 pgxpool 应该会获得更好的结果 - 请参阅 https://pkg.go.dev/github.com/jackc/pgx/[email protected]/pgxpool#hdr-Establishing_a_Connection

到这里，我们也就讲完了《连接关闭时插入postgresql》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！