constructpgx

Documentation

Index

• func AssertRowsAffected(operation string, expectedRows int) func(pgconn.CommandTag) error
• func CollectRows[T any](rows pgx.Rows, err error) ([]T, error)
• func IterateRows[T any](rows pgx.Rows, err error) iter.Seq2[T, error]
• func ScanRow[T any](row pgx.Row, err error) (T, error)

Functions

func AssertRowsAffected

func AssertRowsAffected(operation string, expectedRows int) func(pgconn.CommandTag) error

AssertRowsAffected returns a func that checks if the given operation result affected exactly the expected number of rows.

func CollectRows

func CollectRows[T any](rows pgx.Rows, err error) ([]T, error)

CollectRows collects all rows to the given target type from a ExecutiveQueryBuilder.Query result. It is based on pgx.CollectRows but accepts an additional error for easier use.

func IterateRows

func IterateRows[T any](rows pgx.Rows, err error) iter.Seq2[T, error]

IterateRows returns an iterator over the rows of a database query and scans them to T. If an error occurred initially, while scanning or closing, it returns a single-use iterator with the error. It returns a single-use iterator.

func ScanRow

func ScanRow[T any](row pgx.Row, err error) (T, error)

ScanRow scans a single row to the given target type from a ExecutiveQueryBuilder.QueryRow result.