Method Query

pgxpool/pool.go:747–760

Query acquires a connection and executes a query that returns [pgx.Rows]. Arguments should be referenced positionally from the SQL string as $1, $2, etc. See [pgx.Rows] documentation to close the returned [pgx.Rows] and return the acquired connection to the [Pool]. If there is an error, the returne

(ctx context.Context, sql string, args ...any)

// [pgx.QueryResultFormatsByOID] may be used as the first args to control exactly how the query is executed. This is rarely
// needed. See the documentation for those types for details.
func (p *Pool) Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error) {
	c, err := p.Acquire(ctx)
	if err != nil {
		return errRows{err: err}, err
	}

	rows, err := c.Query(ctx, sql, args...)
	if err != nil {
		c.Release()
		return errRows{err: err}, err
	}

	return c.getPoolRows(rows), nil
}

// QueryRow acquires a connection and executes a query that is expected
// to return at most one row ([pgx.Row]). Errors are deferred until [pgx.Row]'s