db

Jul 18, 2020

Changes in this version

+ var ErrBulkEnded = errors.New("no more data to copy")

+ var ErrNoTransaction = errors.New("no transaction in context, please wrap with DoAtomic()")

+ func Bulk(ctx context.Context, feeder func(*sql.Stmt) error, schema, table string, ...) error

May 18, 2020

Changes in this version

+ func Get(ctx context.Context, db *sql.DB, scanner func(*sql.Row) error, query string, ...) error

+ func List(ctx context.Context, db *sql.DB, scanner func(*sql.Rows) error, query string, ...) error

May 16, 2020

Changes in this version

+ func DoAtomic(ctx context.Context, db *sql.DB, action func(context.Context) error) error

Apr 27, 2020

Changes in this version

+ func ReadTx(ctx context.Context) *sql.Tx

Apr 26, 2020

Changes in this version

+ func StoreTx(ctx context.Context, tx *sql.Tx) context.Context

Apr 26, 2020

Changes in this version

+ var SQLTimeout = time.Second * 5

+ func Create(db *sql.DB, tx *sql.Tx, query string, args ...interface{}) (newID uint64, err error)

+ func Exec(db *sql.DB, tx *sql.Tx, query string, args ...interface{}) (err error)

+ func GetRow(db *sql.DB, query string, args ...interface{}) *sql.Row

+ type RowScanner interface

+ Scan func(...interface{}) error

Apr 26, 2020

Changes in this version

+ func CreateWithTimeout(db *sql.DB, tx *sql.Tx, sqlTimeout time.Duration, query string, ...) (newID uint64, err error)

+ func ExecWithTimeout(db *sql.DB, tx *sql.Tx, sqlTimeout time.Duration, query string, ...) (err error)

Dec 22, 2019

Changes in this version

+ var ErrNoHost = errors.New("no host for database connection")

Oct 31, 2019

Changes in this version

+ func EndTx(tx *sql.Tx, err error) error

+ func GetTx(db *sql.DB, tx *sql.Tx) (*sql.Tx, error)

+ func New(config Config) (*sql.DB, error)

+ func Ping(db *sql.DB) bool

+ func RowsClose(rows *sql.Rows, err error) error

+ type Config struct

+ func Flags(fs *flag.FlagSet, prefix string) Config

+ type WhereInUint []uint

+ func (a WhereInUint) Value() (driver.Value, error)