如何在 Go 中高效地重用 Postgres 连接进行行插入？

在 Go 中重用 Postgres 数据库连接进行行插入

简介

在 Go 中管理 Postgres 连接时，至关重要有效利用连接以避免性能瓶颈和不必要的资源消耗。在本文中，我们将探讨如何使用 sql.DB 池有效地重用单个 Postgres 数据库连接来进行行插入。

问题：打开多个连接

提供的代码打开了与数据库的多个连接，耗尽了连接池并导致插入操作失败。出现这种情况是因为 db.QueryRow() 方法在执行查询后未正确释放连接。

理解 sql.DB

sql.DB 是一个连接自动管理和重用连接的池。它仅在需要时创建新连接，最多达到数据库服务器定义的限制。

问题：缺少扫描调用

在代码中， db.QueryRow( ) 的使用无需对返回的 *Row 值调用 Scan 方法。在底层，*Row 持有一个连接，该连接在调用 Scan 时释放。如果不调用 Scan，连接将保持打开状态，从而导致连接堆积和性能问题。

解决方案：正确处理 *Row

要解决此问题，可以选择以下任一方法如果不需要查询结果，则使用 E​​xec，或者对返回的 *Row 调用 Scan 来释放关联的

更新的代码

以下更新的代码使用 Scan 正确释放连接：

sqlStatement := `
    INSERT INTO heartbeat ("Legend", "Status", "TimeStamp")
    VALUES (, , )
`

row := db.QueryRow(sqlStatement, Legend, Status, TimeStamp)

var result int
if err := row.Scan(&result); err != nil {
    log.Fatal("Error scanning query result:", err)
}

或者，您可以使用 Exec，如果查询不返回任何结果：

sqlStatement := `
    INSERT INTO heartbeat ("Legend", "Status", "TimeStamp")
    VALUES (, , )
`

if _, err := db.Exec(sqlStatement, Legend, Status, TimeStamp); err != nil {
    log.Fatal("Error executing query:", err)
}

通过正确处理 *Row 并释放连接，您可以确保有效使用数据库连接，提高性能和可靠性。

以上是如何在 Go 中高效地重用 Postgres 连接进行行插入？的详细内容。更多信息请关注PHP中文网其他相关文章！