sqlz

Documentation

Index

• Variables
• func MustBeginTx(ctx context.Context, db SQLTxBeginner, opts *sql.TxOptions) *sql.Tx
• func ScanRows(rows SQLRows, structTag string, destPointer interface{}) error
• type Queryer
  • func NewDB(db SQLQueryer) Queryer
• type SQLExecuter
• type SQLQueryer
• type SQLRows
• type SQLTxBeginner

Variables

var (
	ErrMustBePointer        = errors.New("sql: must be pointer")
	ErrMustNotNil           = errors.New("sql: must not nil")
	ErrDataTypeNotSupported = errors.New("sql: data type not supported")
)

Functions

func MustBeginTx

func MustBeginTx(ctx context.Context, db SQLTxBeginner, opts *sql.TxOptions) *sql.Tx

func ScanRows

func ScanRows(rows SQLRows, structTag string, destPointer interface{}) error

Types

type Queryer

type Queryer interface {
	QueryStructSliceContext(ctx context.Context, structTag string, destStructSlicePointer interface{}, query string, args ...any) error
	QueryStructContext(ctx context.Context, structTag string, destStructPointer interface{}, query string, args ...any) error
}

func NewDB

func NewDB(db SQLQueryer) Queryer

type SQLExecuter

type SQLExecuter interface {
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
}

type SQLQueryer

type SQLQueryer interface {
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
}

type SQLRows

type SQLRows interface {
	Close() error
	Columns() ([]string, error)
	Next() bool
	Scan(...interface{}) error
	Err() error
}

type SQLTxBeginner

type SQLTxBeginner interface {
	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
}