首页 > 解决方案 > goroutine 中的 pgx 报告连接繁忙

问题描述

我的应用程序pgx用于在 goroutine 中运行数据库查询。但是,我收到连接繁忙错误。有没有办法拥有一个 goroutine

func writeDb(dbconn *pgx.Conn) {
   sqlWritePost := `QUERY_HERE`
   _, err := dbconn.Exec(context.Background(), sqlWritePost, v.Url, v.Content, v.StrippedContent, v.Posthash)
   if err != nil {
       fmt.Println(err)
       os.Exit(1)
    }
}

func main() {

   var dbconn *pgx.Conn
   dbconn, err := pgx.Connect(context.Background(), os.Getenv("database_string"))
   if err != nil {
       fmt.Println(err)
       os.Exit(1)
   }
   ...
   go writeDb(dbconn)
   ...

}

我收到错误conn busy。有没有办法构造我的代码以避免这个问题?谢谢!

标签: postgresqlgo

解决方案


推荐阅读