pgx 用于 Go：完整指南及示例

pgx 简介：强大的 Go 语言 PostgreSQL 驱动程序

pgx（PostgreSQL eXtended）库是一个现代、高性能的驱动程序和工具集，用于从 Go 编程语言操作 PostgreSQL。与标准包 database/sql 不同，pgx 提供对 PostgreSQL 协议的直接访问，从而带来显著的性能提升，并允许访问数据库的独特功能，例如 LISTEN/NOTIFY、COPY 协议、数组和复合类型操作等等。

为什么要使用 pgx 而不是标准 database/sql？首先，由于消除了不必要的抽象层，pgx 的运行速度提高了 30-50%。其次，它支持 PostgreSQL 12+（及更新版本）的所有现代功能。第三，pgx 提供了丰富的 API 用于管理连接、连接池、预编译语句和事务。最后，pgx 通过一个特殊的适配器与 database/sql 完全兼容，允许在已使用标准接口的项目中使用它。

安装 pgx

在 Go 项目中安装 pgx 使用标准命令 go get。要操作 PostgreSQL，您需要安装 pgx 主包以及可能的附加模块：

# 安装 pgx v5 主包（推荐版本）\ngo get github.com/jackc/pgx/v5\n\n# 安装用于连接池的包\ngo get github.com/jackc/pgx/v5/pgxpool\n\n# 安装用于与 database/sql 兼容的适配器\ngo get github.com/jackc/pgx/v5/stdlib

执行这些命令后，您就可以在 Go 文件中导入 pgx。请确保您已安装 Go 1.18 或更高版本，因为 pgx v5 使用了泛型。

快速入门：首次连接到 PostgreSQL

让我们编写一个最简单的程序，连接到 PostgreSQL 数据库并执行查询。假设您的 PostgreSQL 运行在 localhost:5432，数据库名为 testdb，用户名为 testuser，密码为 testpass。

package main\n\nimport (\n    "context"\n    "fmt"\n    "log"\n    "os"\n\n    "github.com/jackc/pgx/v5"\n)\n\nfunc main() {\n    // 连接字符串\n    connStr := "postgres://testuser:testpass@localhost:5432/testdb"\n\n    // 建立连接\n    conn, err := pgx.Connect(context.Background(), connStr)\n    if err != nil {\n        log.Fatalf("无法连接到数据库：%v", err)\n    }\n    defer conn.Close(context.Background())\n\n    // 执行简单查询\n    var greeting string\n    err = conn.QueryRow(context.Background(), "SELECT 'Hello, PostgreSQL!'").Scan(&greeting)\n    if err != nil {\n        log.Fatalf("执行查询时出错：%v", err)\n    }\n\n    fmt.Println(greeting)\n}

这段代码建立连接，执行查询并输出结果。请注意使用了 context.Background()——这是在 Go 中传递上下文的标准方式，允许控制超时和操作取消。

pgx 的主要方法和函数

让我们来看看 pgx 库中最重要的方法和函数。对于每个方法，我们将提供描述、参数和一个可运行的代码示例。

1. pgx.Connect — 建立连接

功能： 创建一个到 PostgreSQL 的新连接。这是开始使用数据库的主要方式。

参数：

\n
• ctx context.Context — 用于管理连接生命周期的上下文
\n
• connString string — URI 或 DSN 格式的连接字符串
\n

返回值： (*pgx.Conn, error)

示例：

conn, err := pgx.Connect(context.Background(), "postgres://user:pass@localhost:5432/mydb")\nif err != nil {\n    log.