如何在 Go 中的 HTTP Goroutine 之间共享 MySQL 连接？

如何在 HTTP Goroutine 之间共享 MySQL 连接？

Go 中，database/sql 包简化了 HTTP Goroutines 之间数据库连接的共享。通过创建连接池，它自动管理数据库连接的打开和关闭。

sql.Open(...) 函数返回一个连接池句柄，而不仅仅是单个连接。当池完全利用时，database/sql 包会处理打开新连接。

要在提供的代码示例中共享数据库连接，请在 main() 函数中实例化数据库连接并将其分配给全局变量以便于 HTTP 处理程序对其进行访问。

var db *sql.DB // Global variable for sharing between main and HTTP handler

然后，在 main() 函数中，使用 sql.Open(...) 初始化连接池。 SetMaxIdleConns(...) 配置池中的空闲连接数。 Ping() 调用可确保在需要时建立连接。

func main() {
    var err error
    db, err = sql.Open("mysql", "root@unix(/tmp/mysql.sock)/mydb") // This opens a connection pool
    if err != nil {
        log.Fatalf("Error on initializing database connection: %s", err.Error())
    }

    db.SetMaxIdleConns(100)

    err = db.Ping() // This actually opens a connection if necessary
    if err != nil {
        log.Fatalf("Error on opening database connection: %s", err.Error())
    }
}

在 HomeHandler HTTP 处理程序中，使用全局 db 变量来执行查询。

func HomeHandler(w http.ResponseWriter, r *http.Request) {
    var msg string
    err := db.QueryRow("SELECT msg FROM hello WHERE page=?", "home").Scan(&msg)
    if err != nil {
        fmt.Fprintf(w, "Database Error!")
    } else {
        fmt.Fprintf(w, msg)
    }
}

按照以下步骤操作通过这种方法，数据库连接可以在 HTTP goroutine 之间高效共享，而不需要手动打开和关闭连接。

以上是如何在 Go 中的 HTTP Goroutine 之间共享 MySQL 连接？的详细内容。更多信息请关注PHP中文网其他相关文章！