Versions in this module Expand all Collapse all v1 v1.0.0 Mar 21, 2023 Changes in this version + var Cache kvs.KeyValueStore + var ErrTxRollbacked = errors.New("Nested transaction already rollbacked") + var LogErrNoRows bool + var LogQueriesThreshold time.Duration + func MustPing(db *sql.DB) + func SetCache(store kvs.KeyValueStore) + type Connection interface + Begin func() (*Tx, error) + Call func(sproc string, args ...interface{}) *dat.CallBuilder + DeleteFrom func(table string) *dat.DeleteBuilder + Exec func(cmd string, args ...interface{}) (*dat.Result, error) + ExecBuilder func(b dat.Builder) error + ExecMulti func(commands ...*dat.Expression) (int, error) + Insect func(table string) *dat.InsectBuilder + InsertInto func(table string) *dat.InsertBuilder + SQL func(sql string, args ...interface{}) *dat.RawBuilder + Select func(columns ...string) *dat.SelectBuilder + SelectDoc func(columns ...string) *dat.SelectDocBuilder + Update func(table string) *dat.UpdateBuilder + Upsert func(table string) *dat.UpsertBuilder + type DB struct + DB *sqlx.DB + Version int64 + func NewDB(db *sql.DB, driverName string) *DB + func NewDBFromSqlx(dbx *sqlx.DB) *DB + func NewDBFromString(driver string, connectionString string) *DB + func (db *DB) Begin() (*Tx, error) + func (db *DB) MustCreateMetaTable() + func (db *DB) MustRegisterFunction(name string, version string, body string) + type Execer struct + func NewExecer(database database, builder dat.Builder) *Execer + func (ex *Execer) Cache(id string, ttl time.Duration, invalidate bool) dat.Execer + func (ex *Execer) Cancel() error + func (ex *Execer) Exec() (*dat.Result, error) + func (ex *Execer) Interpolate() (string, []interface{}, error) + func (ex *Execer) QueryJSON() ([]byte, error) + func (ex *Execer) QueryObject(dest interface{}) error + func (ex *Execer) QueryScalar(destinations ...interface{}) error + func (ex *Execer) QuerySlice(dest interface{}) error + func (ex *Execer) QueryStruct(dest interface{}) error + func (ex *Execer) QueryStructs(dest interface{}) error + func (ex *Execer) Queryx() (*sqlx.Rows, error) + func (ex *Execer) Timeout(timeout time.Duration) dat.Execer + type Queryable struct + func WrapSqlxExt(e sqlx.Ext) *Queryable + func (q *Queryable) Call(sproc string, args ...interface{}) *dat.CallBuilder + func (q *Queryable) DeleteFrom(table string) *dat.DeleteBuilder + func (q *Queryable) Exec(cmd string, args ...interface{}) (*dat.Result, error) + func (q *Queryable) ExecBuilder(b dat.Builder) error + func (q *Queryable) ExecMulti(commands ...*dat.Expression) (int, error) + func (q *Queryable) Insect(table string) *dat.InsectBuilder + func (q *Queryable) InsertInto(table string) *dat.InsertBuilder + func (q *Queryable) SQL(sql string, args ...interface{}) *dat.RawBuilder + func (q *Queryable) Select(columns ...string) *dat.SelectBuilder + func (q *Queryable) SelectDoc(columns ...string) *dat.SelectDocBuilder + func (q *Queryable) Update(table string) *dat.UpdateBuilder + func (q *Queryable) Upsert(table string) *dat.UpsertBuilder + type Tx struct + IsRollbacked bool + func WrapSqlxTx(tx *sqlx.Tx) *Tx + func (tx *Tx) AutoCommit() error + func (tx *Tx) AutoRollback() error + func (tx *Tx) Begin() (*Tx, error) + func (tx *Tx) Commit() error + func (tx *Tx) Rollback() error + func (tx *Tx) Select(columns ...string) *dat.SelectBuilder