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

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

通常不需要.池负责管理连接(获取和释放)以及管理准备好的语句(创建和缓存).

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

同样，如果您想要手动创建和重用预准备语句(例如，您需要在紧密循环中执行相同的查询，但您不想依赖池对预准备语句的缓存)，则可以使用获取的Connection的Conn方法，该方法返回连接的*pgx.Conn表示形式，该方法有一个名为Prepare的方法.

2. 如何确保当您从池中拉出连接时是"新的"，并且您不会继续处理先前未完成的事务(回滚/提交)？

池的获取方法返回available个连接.根据定义，正在使用的连接(即未释放的连接)是不可用的，Acquire方法不会返回这些连接.

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

释放回池的连接所持有的资源(如果不是空闲的话)将是destroyed.关于事务提交/回滚，都不会自动调用，documentation明确表示:"Commit or Rollback must be called on the returned transaction to finalize the transaction block."

4. 在请求数据库时如何使用Goroutines？是否可以在同一事务中进行并行SELECT查询，或者所有查询都必须是连续的吗？我猜所有的写入查询都必须是连续的？

池子可以安全地同时使用.然而，同时使用pgxpool.Conn或pgxpool.Tx都不安全.

Example:

Begin不支持自动回滚或自动提交，如documentation所述，您自己必须调用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)", "c@em.com")
    if err != nil {
        return err
    }

    var id int
    row := tx.QueryRow(ctx, "select id from users where email = $1", "c@em.com")
    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
}

然而，如果您希望PGx为您的交易使用Rollback或Commit，您可以使用BeginFunc.

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)", "c@em.com")
        if err != nil {
            return err
        }

        var id int
        row := tx.QueryRow(ctx, "select id from users where email = $1", "c@em.com")
        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
    })
}