sharding

Feb 21, 2024

Changes in this version

type Mysql

+ func NewMysqlBy[T itf.ModelInterface](isMaster bool) *Mysql[T]

+ func (m *Mysql[T]) Reset()

+ func (m *Mysql[T]) Set(isMaster bool, tx *Tx)

type Tx

+ func NewTxBy(ctx object.CtxInterface) *Tx

+ func (t *Tx) Reset()

Sep 26, 2023

Changes in this version

type Mysql

+ func (m *Mysql[T]) BatchInsertCtx(ctx context.Context, key any, batch *ds.Batch) (int64, error)

+ func (m *Mysql[T]) CountCtx(ctx context.Context, key any, table string, where ds.WhereInterface) (int64, error)

+ func (m *Mysql[T]) DeleteCtx(ctx context.Context, key any, del *ds.Delete) (int64, error)

+ func (m *Mysql[T]) ExecCtx(ctx context.Context, key any, statement string) error

+ func (m *Mysql[T]) FetchAllByWhereCtx(ctx context.Context, key any, table string, where ds.WhereInterface, model T) ([]T, error)

+ func (m *Mysql[T]) FetchAllCtx(ctx context.Context, key any, table string, where meta.Where, model T) ([]T, error)

+ func (m *Mysql[T]) FetchPageBySelectCtx(ctx context.Context, key any, sel *ds.Select, model T) (*meta.Page[T], error)

+ func (m *Mysql[T]) FetchPageByWhereCtx(ctx context.Context, key any, table string, where ds.WhereInterface, model T, ...) (*meta.Page[T], error)

+ func (m *Mysql[T]) FetchPageCtx(ctx context.Context, key any, table string, where meta.Where, model T, ...) (*meta.Page[T], error)

+ func (m *Mysql[T]) FetchRowCtx(ctx context.Context, key any, table string, where meta.Where, model T) error

+ func (m *Mysql[T]) InsertCtx(ctx context.Context, key any, insert *ds.Insert) (int64, error)

+ func (m *Mysql[T]) LockRowCtx(ctx context.Context, key any, table string, where meta.Where, model T) error

+ func (m *Mysql[T]) QueryCtx(ctx context.Context, key any, query string, model T, args ...any) ([]T, error)

+ func (m *Mysql[T]) TransactionCtx(ctx context.Context, f func(tx *Tx) error, opts *sql.TxOptions) error

+ func (m *Mysql[T]) UpdateCtx(ctx context.Context, key any, update *ds.Update) (int64, error)

Sep 25, 2023

Changes in this version

type Mysql

+ func (m *Mysql[T]) Count(key any, table string, where ds.WhereInterface) (int64, error)

+ func (m *Mysql[T]) FetchPageBySelect(key any, sel *ds.Select, model T) (*meta.Page[T], error)

Sep 4, 2023

Changes in this version

type Mysql

+ func (m *Mysql[T]) LockRow(key any, table string, where meta.Where, model T) error

Jun 9, 2023

Changes in this version

type Mysql

+ func (m *Mysql[T]) SetTx(tx *Tx)

+ func (m *Mysql[T]) Transaction(f func(tx *Tx) error) error

+ type Tx struct

+ func NewTx() *Tx

+ func (t *Tx) Add(id int, tx *db.Tx)

+ func (t *Tx) Commit()

+ func (t *Tx) IsCompleted() bool

+ func (t *Tx) Rollback()

Mar 17, 2023

Changes in this version

+ func Init(mas []config.Mysql, sls []config.Mysql)

+ type Mysql struct

+ func NewMysql(isMaster bool) *Mysql[T]

+ func (m *Mysql[T]) AddSharding(key any) *Mysql[T]

+ func (m *Mysql[T]) BatchInsert(key any, batch *ds.Batch) (int64, error)

+ func (m *Mysql[T]) Begin() error

+ func (m *Mysql[T]) Commit() error

+ func (m *Mysql[T]) Delete(key any, del *ds.Delete) (int64, error)

+ func (m *Mysql[T]) Exec(key any, statement string) error

+ func (m *Mysql[T]) FetchAll(key any, table string, where map[string]any, model T) ([]T, error)

+ func (m *Mysql[T]) FetchAllByWhere(key any, table string, where ds.WhereInterface, model T) ([]T, error)

+ func (m *Mysql[T]) FetchPage(key any, table string, where map[string]any, model T, page, pageSize int) ([]T, error)

+ func (m *Mysql[T]) FetchPageByWhere(key any, table string, where ds.WhereInterface, model T, page, pageSize int) ([]T, error)

+ func (m *Mysql[T]) FetchRow(key any, table string, where map[string]any, model T) (T, error)

+ func (m *Mysql[T]) GetConnection(key int) *db.Mysql[T]

+ func (m *Mysql[T]) GetShardingKey(key any) int

+ func (m *Mysql[T]) Insert(key any, insert *ds.Insert) (int64, error)

+ func (m *Mysql[T]) Query(key any, query string, model T, args ...any) ([]T, error)

+ func (m *Mysql[T]) RollBack() error

+ func (m *Mysql[T]) Update(key any, update *ds.Update) (int64, error)