krabdb

Nov 18, 2023

Changes in this version

+ type SwitchableDatabaseConnection struct

+ DatabaseName string

+ func (d *SwitchableDatabaseConnection) Get(f func(db DB) error) error

Dec 5, 2021

Changes in this version

+ func Quote(o interface{}) string

Dec 3, 2021

Changes in this version

+ func Connect(connectionString string) (*sqlx.DB, error)

+ func QuoteIdentStrings(in []string) []string

+ func QuoteIdentWithDots(s string) string

+ type Connection interface

+ Get func(f func(db DB) error) error

+ type DB interface

+ GetDatabase func() *sqlx.DB

+ NewTx func(ctx context.Context, createTransaction bool) (TransactionExecerContext, error)

+ type DefaultConnection struct

+ func (d *DefaultConnection) Get(f func(db DB) error) error

+ type ExecerContext interface

+ ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ type Instance struct

+ func (d *Instance) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (d *Instance) GetDatabase() *sqlx.DB

+ func (d *Instance) NewTx(ctx context.Context, createTransaction bool) (TransactionExecerContext, error)

+ func (d *Instance) QueryContext(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)

+ func (d *Instance) SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ type QueryerContext interface

+ QueryContext func(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)

+ SelectContext func(ctx context.Context, dest interface{}, query string, args ...interface{}) error

Aug 22, 2021

Changes in this version

+ func AdvisoryUnlock(ctx context.Context, q sqlx.QueryerContext, id int64) (bool, error)

+ func TryAdvisoryLock(ctx context.Context, q sqlx.QueryerContext, id int64) (bool, error)

+ type NullTransaction struct

+ func (t *NullTransaction) Commit() error

+ func (t *NullTransaction) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (t *NullTransaction) Rollback() error

+ type Transaction struct

+ func (t *Transaction) Commit() error

+ func (t *Transaction) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (t *Transaction) Rollback() error

+ type TransactionExecerContext interface

+ Commit func() error

+ Rollback func() error

+ func BeginTx(ctx context.Context, db *sqlx.DB) (TransactionExecerContext, error)

+ func NewTx(ctx context.Context, db *sqlx.DB, createTransaction bool) (TransactionExecerContext, error)

+ func NullTx(ctx context.Context, db *sqlx.DB) (TransactionExecerContext, error)

Jul 4, 2021

Changes in this version

+ func QuoteIdent(s string) string

+ func TryAdvisoryXactLock(ctx context.Context, tx *sqlx.Tx, id int64) (bool, error)

+ func WithConnection(f func(db *sqlx.DB) error) error