dbkit

Oct 11, 2020

Changes in this version

+ type BetweenOption struct

+ func Between(column string, minValue, maxValue interface{}) *BetweenOption

+ func (f *BetweenOption) CompileDelete(base sq.DeleteBuilder) (sq.DeleteBuilder, error)

+ func (f *BetweenOption) CompileSelect(base sq.SelectBuilder) (sq.SelectBuilder, error)

+ func (f *BetweenOption) CompileUpdate(base sq.UpdateBuilder) (sq.UpdateBuilder, error)

Jun 14, 2020

Changes in this version

+ type CompileDeleteFn func(sq.DeleteBuilder) (sq.DeleteBuilder, error)

+ type CompileSelectFn func(sq.SelectBuilder) (sq.SelectBuilder, error)

+ type CompileUpdateFn func(sq.UpdateBuilder) (sq.UpdateBuilder, error)

type DeleteOption

+ func NewDeleteOption(fn CompileDeleteFn) DeleteOption

+ type DeleteTestCase struct

+ Builder sq.DeleteBuilder

+ Expected string

+ ExpectedArgs []interface{}

+ ExpectedErr string

+ TestName string

+ func (tt *DeleteTestCase) Execute(t *testing.T)

type SelectOption

+ func NewSelectOption(fn CompileSelectFn) SelectOption

+ type SelectTestCase struct

+ Builder sq.SelectBuilder

+ Expected string

+ ExpectedArgs []interface{}

+ ExpectedErr string

+ TestName string

+ func (tt *SelectTestCase) Execute(t *testing.T)

type UpdateOption

+ func NewUpdateOption(fn CompileUpdateFn) UpdateOption

+ type UpdateTestCase struct

+ Builder sq.UpdateBuilder

+ Expected string

+ ExpectedArgs []interface{}

+ ExpectedErr string

+ TestName string

+ func (tt *UpdateTestCase) Execute(t *testing.T)

May 25, 2020

Changes in this version

+ type DeleteOption interface

+ CompileDelete func(sq.DeleteBuilder) (sq.DeleteBuilder, error)

+ type EqualOption struct

+ func (f *EqualOption) CompileDelete(base sq.DeleteBuilder) (sq.DeleteBuilder, error)

+ func (f *EqualOption) CompileSelect(base sq.SelectBuilder) (sq.SelectBuilder, error)

+ func (f *EqualOption) CompileUpdate(base sq.UpdateBuilder) (sq.UpdateBuilder, error)

+ type LikeOption struct

+ func (l *LikeOption) CompileSelect(base sq.SelectBuilder) (sq.SelectBuilder, error)

+ type PaginationOption struct

+ func (p *PaginationOption) CompileSelect(base sq.SelectBuilder) (sq.SelectBuilder, error)

+ type SelectOption interface

+ CompileSelect func(sq.SelectBuilder) (sq.SelectBuilder, error)

+ type SortOption struct

+ func (s *SortOption) CompileSelect(base sq.SelectBuilder) (sq.SelectBuilder, error)

+ type UpdateOption interface

+ CompileUpdate func(sq.UpdateBuilder) (sq.UpdateBuilder, error)

May 3, 2020

Changes in this version

+ func CompileOpts(builder sq.SelectBuilder, opts ...FindOption) (err error)

Mar 20, 2020

Changes in this version

+ type Transactional struct

+ func (t *Transactional) CancelMe(ctx context.Context, err error) error

+ func (t *Transactional) CommitMe(ctx *context.Context) func() error

Feb 27, 2020

Changes in this version

+ type CacheStore struct

+ func NewCacheStore(client *redis.Client) *CacheStore

+ func (c *CacheStore) Retrieve(ctx context.Context, key string, target interface{}, ...) (err error)

+ func (c *CacheStore) WithExpiration(expiration time.Duration) *CacheStore

type FindOption

+ String func() string

Feb 10, 2020

Changes in this version

+ type FindOption interface

+ CompileQuery func(sq.SelectBuilder) (sq.SelectBuilder, error)

+ func Pagination(offset, limit uint64) FindOption

+ func PaginationWithRange(start, end uint64) FindOption

+ func Sort(column string, orderBy OrderBy) FindOption

+ type FindOptionImpl struct

+ func CreateFindOption() *FindOptionImpl

+ func (f *FindOptionImpl) CompileQuery(base sq.SelectBuilder) (compiled sq.SelectBuilder, err error)

+ func (f *FindOptionImpl) With(option ...FindOption) *FindOptionImpl

+ type OrderBy int

+ const Asc

+ const Desc

+ func (o OrderBy) String() string

+ type WhereCondition FindOption

+ func Equal(column string, cond string) WhereCondition

+ func Like(column, condition string) WhereCondition

Dec 24, 2019

Changes in this version

+ const TxoKey

+ func CtxWithTxo(parent context.Context) context.Context

+ func ErrCtx(ctx context.Context) error

+ func GetCache(client *redis.Client, key string, val interface{}) (err error)

+ func SetCache(client *redis.Client, key string, val interface{}, exp time.Duration) error

+ func SetErrCtx(ctx context.Context, err error) error

+ func SetTxCtx(ctx context.Context, tx sq.BaseRunner) error

+ func TxCtx(ctx context.Context, t sq.BaseRunner) sq.BaseRunner

+ type JSON json.RawMessage

+ func (j *JSON) MarshalJSON() ([]byte, error)

+ func (j *JSON) Scan(src interface{}) error

+ func (j *JSON) UnmarshalJSON(data []byte) error

+ func (j JSON) Value() (driver.Value, error)

+ type Txo struct