sharding

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]) BatchInsertCtx(ctx context.Context, key any, batch *ds.Batch) (int64, error)

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

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

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

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

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

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

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

func (m *Mysql[T]) FetchAllByWhere(key any, table string, where ds.WhereInterface, model T) ([]T, 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]) FetchPage(key any, table string, where meta.Where, model T, page, pageSize int, orders ...string) (*meta.Page[T], error)

func (m *Mysql[T]) FetchPageBySelect(key any, sel *ds.Select, model T) (*meta.Page[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]) FetchPageByWhere(key any, table string, where ds.WhereInterface, model T, page, pageSize int, orders ...string) (*meta.Page[T], error)

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

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

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

func (m *Mysql[T]) FetchRowCtx(ctx context.Context, key any, table string, where meta.Where, model 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]) InsertCtx(ctx context.Context, key any, insert *ds.Insert) (int64, error)

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

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

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

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

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

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

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

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

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

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

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

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

func (t *Tx) Commit()

func (t *Tx) IsCompleted() bool

func (t *Tx) Reset()

func (t *Tx) Rollback()