ql

Jan 23, 2024

Changes in this version

type StringArray

+ func (s *StringArray) Value() (driver.Value, error)

Jan 2, 2024

Changes in this version

+ func ContextWithoutTx(ctx context.Context) context.Context

Dec 22, 2023

Changes in this version

+ func TryTxFromContext(ctx TxContext) *sqlx.Tx

Dec 11, 2023

Changes in this version

type TxContext

+ func TxContextFromContext(ctx context.Context) TxContext

Feb 20, 2023

Changes in this version

+ func ExecNamedAffected(ctx TxContext, stmt string, args any) (int, error)

Feb 13, 2023

Changes in this version

+ type StringArray []string

+ func NewStringArray(value []string) StringArray

+ func (s *StringArray) Scan(src any) error

type TxContext

+ func WithCancel(parent TxContext) (TxContext, context.CancelFunc)

+ func WithDeadline(parent TxContext, deadline time.Time) (TxContext, context.CancelFunc)

+ func WithTimeout(parent TxContext, timeout time.Duration) (TxContext, context.CancelFunc)

+ func WithValue(parent TxContext, key any, value any) TxContext

+ CommitAndChain func() error

Nov 22, 2022

Changes in this version

+ func InNewTransactionWithResult(ctx context.Context, db TxStarter, fun func(ctx TxContext) (R, error)) (R, error)

Nov 22, 2022

Changes in this version

+ func InAnyTransactionWithResult(ctx context.Context, db TxStarter, fun func(ctx TxContext) (R, error)) (R, error)

+ func InExistingTransactionWithResult(ctx context.Context, fun func(ctx TxContext) (R, error)) (R, error)

Nov 22, 2022

Changes in this version

+ func ExecNamed(ctx TxContext, stmt string, args any) error

Nov 1, 2022

Changes in this version

+ var ErrNoTransaction = errors.New("no transaction in context")

+ var ErrTransactionExistInContext = errors.New("transaction exists in context")

+ func Exec(ctx TxContext, stmt string, args ...interface{}) error

+ func ExecAffected(ctx TxContext, stmt string, args ...interface{}) (int, error)

+ func FirstOrNil(ctx TxContext, query string, args ...interface{}) (*T, error)

+ func Get(ctx TxContext, query string, args ...interface{}) (*T, error)

+ func InAnyTransaction(ctx context.Context, db TxStarter, fun func(ctx TxContext) (R, error)) (R, error)

+ func InExistingTransaction(ctx context.Context, fun func(ctx TxContext) (R, error)) (R, error)

+ func InNewTransaction(ctx context.Context, db TxStarter, fun func(ctx TxContext) (R, error)) (R, error)

+ func NoRollback(err error) error

+ func Select(ctx TxContext, query string, args ...interface{}) ([]T, error)

+ type Action func()

+ type Hooks interface

+ OnCommit func(action Action)

+ type QueryIter struct

+ func Iter(ctx TxContext, query string, args ...interface{}) (*QueryIter[T], error)

+ func (q *QueryIter[T]) Close() error

+ func (q *QueryIter[T]) ForEach(consumer func(row T) error) error

+ func (q *QueryIter[T]) HasNext() bool

+ func (q *QueryIter[T]) Next() (T, error)

+ type Tx interface

+ type TxContext interface

+ WithContext func(ctx context.Context) TxContext

+ type TxStarter interface

+ BeginTxx func(ctx context.Context, opts *sql.TxOptions) (*sqlx.Tx, error)