octobe

Feb 18, 2022

Changes in this version

+ type TxScheme struct

+ func (scheme *TxScheme) Commit() error

+ func (scheme *TxScheme) Rollback() error

+ func (scheme *TxScheme) Segment(query string) *Segment

+ func (scheme *TxScheme) WatchRollback(cb func() error) error

Mar 14, 2021

Changes in this version

+ var ErrNeedInput = errors.New("insert method require at least one argument")

+ type Option interface

+ Type func() string

+ func SuppressError(err error) Option

Jan 26, 2021

Changes in this version

+ var ErrUsed = errors.New("this query has already executed")

+ type Handler func(scheme Scheme) error

+ type Octobe struct

+ DB *sql.DB

+ func New(db *sql.DB) Octobe

+ func (ob Octobe) Begin(ctx context.Context) (scheme Scheme)

+ func (ob Octobe) BeginTx(ctx context.Context, opts ...*sql.TxOptions) (scheme Scheme, err error)

+ func (ob Octobe) WatchTransaction(ctx context.Context, cb func(scheme Scheme) error, opts ...*sql.TxOptions) error

+ type Scheme struct

+ func (scheme *Scheme) Segment(query string) *Segment

+ func (scheme Scheme) Commit() error

+ func (scheme Scheme) Handle(handler Handler) error

+ func (scheme Scheme) Rollback() error

+ func (scheme Scheme) WatchRollback(cb func() error)

+ type Segment struct

+ func (segment *Segment) Arguments(args ...interface{})

+ func (segment *Segment) Exec() error

+ func (segment *Segment) Insert(dest ...interface{}) error

+ func (segment *Segment) Query(cb func(*sql.Rows) error) error

+ func (segment *Segment) QueryRow(dest ...interface{}) error