主页 / coding / 问题 / 76986363
Accepted
clarkk
Asked: 2023-08-27 17:04:46 +0800 CST

如何将 jackc/pgx 与连接池、上下文、准备好的语句等一起使用

  • 772

我仍然不是 golang 专家，仍在学习中。这也是我第一次接触postgresql

import "github.com/jackc/pgx/v5/pgxpool"

const DB = "postgres://postgres:xxx@localhost:5432/mydb?pool_min_conns=1&pool_max_conns=5&pool_max_conn_idle_time=30s"

dbpool, err := pgxpool.New(context.Background(), DB)
if err != nil {
    log.Fatal("Unable to create connection pool: "+err.Error())
}
defer dbpool.Close()

1. 如何从池中获取连接并使用准备好的语句，其中将 SQL 和 SQL 值作为两个单独的参数传递？

来自 PHP，以前从未使用过数据库池。

2. 如何确保从池中拉出连接时是“新鲜”的，并且不会继续执行先前未完成的事务（回滚/提交）？

3. 将连接释放回池时也是如此。如果上下文被取消或者请求失败，它会自动回滚吗？

4. 请求数据库时如何使用goroutines？是否可以在同一事务中进行并行选择查询，或者所有查询都必须是串行的？我想所有写入查询都必须是串行的？

postgresql

1 个回答

  1. Best Answer
    1. 如何从池中获取连接并使用准备好的语句，其中将 SQL 和 SQL 值作为两个单独的参数传递？

    一般来说你不会。该池负责连接的管理（获取和释放）以及准备语句的管理（创建和缓存）。

    Acquire但是，如果您想保持控制，则可以使用该方法或其任何相关方法从池中显式获取连接。

    类似地，如果您想手动创建并重用准备好的语句（例如，您需要在紧密循环内执行相同的查询，但您不想依赖池对准备好的语句的缓存），那么您可以使用获取的连接的Conn方法返回*pgx.Conn连接的表示形式，并且有一个名为 的方法Prepare。

    1. 如何确保从池中拉出连接时是“新鲜的”，并且不会继续之前未完成的事务（回滚/提交）？

    池的 Acquire 方法返回可用连接。根据定义，正在使用的连接（即未释放的连接）不可用，并且不会由 Acquire 方法返回。

    1. 当您将连接释放回池时也是如此。如果上下文被取消或者请求失败，它会自动回滚吗？

    释放回池中的连接所持有的资源，如果不空闲，将被销毁。关于事务提交/回滚，它们都不会被自动调用，文档明确指出：“必须在返回的事务上调用 Commit 或 Rollback 来最终确定事务块”。

    1. 请求数据库时如何使用goroutines？是否可以在同一事务中进行并行选择查询，或者所有查询都必须是串行的？我想所有写入查询都必须是串行的？

    游泳池可以安全地同时使用。然而，同时使用pgxpool.Conn也不安全。pgxpool.Tx

    例子：

    Begin不支持自动回滚或自动提交，您自己必须按照文档所述，调用Rollback或Commit来“最终确定事务块”。

    func f(ctx context.Context, pool *pgxpool.Pool) (err error) {
    tx, err := pool.Begin(ctx)
    if err != nil {
        return err
    }
    defer func() {
        if err != nil {
            tx.Rollback(ctx)
        } else {
            tx.Commit(ctx)
        }
    }()

    _, err := tx.Exec(ctx, "insert into users (email) values ($1)", "[email protected]")
    if err != nil {
        return err
    }

    var id int
    row := tx.QueryRow(ctx, "select id from users where email = $1", "[email protected]")
    if err := row.Scan(&id); err != nil {
        return err
    }

    // NOTE: the above is just an example, if you need the auto
    // generated id of an inserted record, please use the RETURNING
    // clause supported by PostgreSQL.
    return nil
}

    BeginFunc但是，如果您想要 pgxRollback或Commit交易，您可以使用。

    func f(ctx context.Context, pool *pgxpool.Pool) (err error) {
    return pool.BeginFunc(ctx, func(tx pgx.Tx) error {
        _, err := tx.Exec(ctx, "insert into users (email) values ($1)", "[email protected]")
        if err != nil {
            return err
        }

        var id int
        row := tx.QueryRow(ctx, "select id from users where email = $1", "[email protected]")
        if err := row.Scan(&id); err != nil {
            return err
        }

        // NOTE: the above is just an example, if you need the auto
        // generated id of an inserted record, please use the RETURNING
        // clause supported by PostgreSQL.
        return nil
    })
}
    • 2

相关问题