postgres

Documentation

Index

• func AppendRowsNonNil[T comparable, S ~[]T](slice S, rows pgx.Rows, fn pgx.RowToFunc[T]) (S, error)
• func CollectRowsNonNil[T comparable](rows pgx.Rows, fn pgx.RowToFunc[T]) ([]T, error)
• func GetTestLogger() *slog.Logger
• type DbCleanup
  • func GetTestPool() (*pgxpool.Pool, DbCleanup)

Functions

func AppendRowsNonNil

func AppendRowsNonNil[T comparable, S ~[]T](slice S, rows pgx.Rows, fn pgx.RowToFunc[T]) (S, error)

AppendRowsNonNil iterates through rows, calling fn for each row, and appending the results into a slice of T if the result is not nil.

This function closes the rows automatically on return.

func CollectRowsNonNil

func CollectRowsNonNil[T comparable](rows pgx.Rows, fn pgx.RowToFunc[T]) ([]T, error)

CollectRowsNonNil iterates through rows, calling fn for each row, and collecting the results into a slice of T if the result is not nil.

This function closes the rows automatically on return.

func GetTestLogger

func GetTestLogger() *slog.Logger

Types

type DbCleanup

type DbCleanup func()

func GetTestPool

func GetTestPool() (*pgxpool.Pool, DbCleanup)