dbq

Jul 15, 2020

Changes in this version

+ func FlattenArgs(args ...interface{}) []interface

May 31, 2020

Changes in this version

+ type ScanFaster interface

+ ScanFast func() []interface{}

May 29, 2020

Changes in this version

+ func MustQs(ctx context.Context, db interface{}, query string, ConcreteStruct interface{}, ...) interface

+ func Qs(ctx context.Context, db interface{}, query string, ConcreteStruct interface{}, ...) (out interface{}, rErr error)

type Options

+ func (o *Options) MustQ(ctx context.Context, db interface{}, query string, args ...interface{}) interface{}

+ func (o *Options) MustQs(ctx context.Context, db interface{}, query string, ConcreteStruct interface{}, ...) interface{}

+ func (o *Options) Q(ctx context.Context, db interface{}, query string, args ...interface{}) (out interface{}, rErr error)

+ func (o *Options) Qs(ctx context.Context, db interface{}, query string, ConcreteStruct interface{}, ...) (out interface{}, rErr error)

Apr 2, 2020

Changes in this version

+ func ConstantDelayRetryPolicy(interval time.Duration, retryAttempts ...uint64) backoff.BackOff

+ func ExponentialRetryPolicy(maxElapsedTime time.Duration, retryAttempts ...uint64) backoff.BackOff

+ func INSERTStmt(tableName string, columns []string, rows int, dbtype ...Database) string

+ func Tx(ctx context.Context, db interface{}, ...) error

+ type BeginTxer interface

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

+ type EFn func(ctx context.Context, query string, options *Options, args ...interface{}) (sql.Result, error)

type Options

+ RetryPolicy backoff.BackOff

+ type QFn func(ctx context.Context, query string, options *Options, args ...interface{}) (interface{}, error)

+ type TxCommit func() error

Jan 26, 2020

Changes in this version

+ var SingleResult = &Options

+ func E(ctx context.Context, db ExecContexter, query string, options *Options, ...) (sql.Result, error)

+ func INSERT(tableName string, columns []string, rows int, dbtype ...Database) string

+ func MustE(ctx context.Context, db ExecContexter, query string, options *Options, ...) sql.Result

+ func MustQ(ctx context.Context, db interface{}, query string, options *Options, ...) interface

+ func Ph(columnsN, rows int, incr int, dbtype ...Database) string

+ func Q(ctx context.Context, db interface{}, query string, options *Options, ...) (out interface{}, rErr error)

+ func Struct(strct interface{}, tagName ...string) []interface

+ type Database int

+ const MySQL

+ const PostgreSQL

+ type ExecContexter interface

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

+ type Options struct

+ ConcreteStruct interface{}

+ ConcurrentPostUnmarshal bool

+ DecoderConfig *StructorConfig

+ PostFetch func(ctx context.Context) error

+ RawResults bool

+ SingleResult bool

+ type PostUnmarshaler interface

+ PostUnmarshal func(ctx context.Context, row, count int) error

+ type QueryContexter interface

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

+ type SQLBasic interface

+ type StructorConfig struct

+ DecodeHook mapstructure.DecodeHookFunc

+ WeaklyTypedInput bool

+ func StdTimeConversionConfig(dbtype ...Database) *StructorConfig