runner

Jul 26, 2016

Changes in this version

+ var LogErrNoRows bool

type Execer

+ func (ex *Execer) Cancel() error

+ func (ex *Execer) Interpolate() (string, []interface{}, error)

+ func (ex *Execer) Timeout(timeout time.Duration) dat.Execer

Jul 15, 2015

Changes in this version

+ func MustPing(db *sql.DB)

type DB

+ Version int64

Jun 26, 2015

Changes in this version

+ var Cache kvs.KeyValueStore

+ var ErrTxRollbacked = errors.New("Nested transaction already rollbacked")

+ var LogQueriesThreshold time.Duration

+ 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

+ 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) Exec() (*dat.Result, 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)

+ 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