txengine

Nov 26, 2024

Changes in this version

+ func RunTransaction(ctx context.Context, dbName string, ...) (err error)

+ func RunTransactionWithLock(ctx context.Context, dbName string, lock string, durationInSec int, ...) (err error)

Nov 25, 2024

Changes in this version

+ func StartTx(ctx context.Context, tx *sql.Tx, ...) (err error)

+ type Tx sql.Tx

+ func WithTx(tx *sql.Tx) *Tx

+ func (o *Tx) Exec(ctx context.Context, query string, params ...any) (sql.Result, error)

+ func (o *Tx) QueryInt(ctx context.Context, query string, params ...any) (result int, err error)

+ type TypedTx sql.Tx

+ func WithTypedTx[T any](tx *sql.Tx) *TypedTx[T]

+ func (o *TypedTx[T]) Find(ctx context.Context, tableName string, where coredb.WhereQuery) ([]*T, error)

+ func (o *TypedTx[T]) FindOne(ctx context.Context, tableName string, where coredb.WhereQuery) (*T, error)

+ func (o *TypedTx[T]) Query(ctx context.Context, query string, params ...any) (result []*T, err error)