dbutil

Documentation

Index

• func BulkQuery[T any](ctx context.Context, db BulkQueryer, query string, structs []T) error
• func BulkSQL[T any](db BulkQueryer, sql string, structs []T) (string, []any, error)
• func IsUniqueViolation(err error) bool
• func QueryErrorWrapf(cause error, sql string, sqlArgs []any, message string, msgArgs ...any) error
• func QueryErrorf(sql string, sqlArgs []any, message string, msgArgs ...any) error
• func ScanAllJSON[V any](rows *sql.Rows, s []V) ([]V, error)
• func ScanAllMap[K comparable, V any](rows *sql.Rows, m map[K]V) error
• func ScanAllSlice[V any](rows *sql.Rows, s []V) ([]V, error)
• func ScanAndValidateJSON(rows *sql.Rows, destination any) error
• func ScanJSON(rows *sql.Rows, destination any) error
• func ToValidUTF8(s string) string
• type BulkQueryer
• type QueryError
  • func AsQueryError(err error) *QueryError
  • func (e *QueryError) Error() string
  • func (e *QueryError) Query() (string, []any)
  • func (e *QueryError) Unwrap() error

Functions

func BulkQuery

func BulkQuery[T any](ctx context.Context, db BulkQueryer, query string, structs []T) error

BulkQuery runs the query as a bulk operation with the given structs

func BulkSQL

func BulkSQL[T any](db BulkQueryer, sql string, structs []T) (string, []any, error)

BulkSQL takes a query which uses VALUES with struct bindings and rewrites it as a bulk operation. It returns the new SQL query and the args to pass to it.

func IsUniqueViolation

func IsUniqueViolation(err error) bool

IsUniqueViolation returns true if the given error is a violation of unique constraint

func QueryErrorWrapf

func QueryErrorWrapf(cause error, sql string, sqlArgs []any, message string, msgArgs ...any) error

func QueryErrorf

func QueryErrorf(sql string, sqlArgs []any, message string, msgArgs ...any) error

func ScanAllJSON

func ScanAllJSON[V any](rows *sql.Rows, s []V) ([]V, error)

ScanAllJSON scans all rows as a single column containing JSON that be unmarshalled into instances of V.

func ScanAllMap

func ScanAllMap[K comparable, V any](rows *sql.Rows, m map[K]V) error

ScanAllMap scans a key and value from each two column row into the given map

func ScanAllSlice

func ScanAllSlice[V any](rows *sql.Rows, s []V) ([]V, error)

ScanAllSlice scans all rows as a single value and returns them in the given slice.

func ScanAndValidateJSON

func ScanAndValidateJSON(rows *sql.Rows, destination any) error

ScanAndValidateJSON scans a row which is JSON into a destination struct and validates it

func ScanJSON

func ScanJSON(rows *sql.Rows, destination any) error

ScanJSON scans a row which is JSON into a destination struct

func ToValidUTF8

func ToValidUTF8(s string) string

ToValidUTF8 replaces invalid UTF-8 sequences with � characters and also strips NULL characters, which whilst being valid UTF-8, can't be saved to PostgreSQL.

Types

type BulkQueryer

type BulkQueryer interface {
	Rebind(query string) string
	QueryxContext(ctx context.Context, query string, args ...any) (*sqlx.Rows, error)
}

BulkQueryer is the DB/TX functionality needed for these bulk operations

type QueryError

type QueryError struct {
	// contains filtered or unexported fields
}

QueryError is an error type for failed SQL queries

func AsQueryError

func AsQueryError(err error) *QueryError

func (*QueryError) Error

func (e *QueryError) Error() string

func (*QueryError) Query

func (e *QueryError) Query() (string, []any)

func (*QueryError) Unwrap

func (e *QueryError) Unwrap() error