sharding

Jul 13, 2022

Changes in this version

type Mysql

+ func (m *Mysql) FetchAllByWhere(key interface{}, table string, where *ds.Where, t interface{}) ([]interface{}, error)

+ func (m *Mysql) FetchPage(key interface{}, table string, where map[string]interface{}, t interface{}, ...) ([]interface{}, error)

+ func (m *Mysql) FetchPageByWhere(key interface{}, table string, where *ds.Where, t interface{}, ...) ([]interface{}, error)

Aug 18, 2021

Changes in this version

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

+ type Mysql struct

+ func NewMysql(isMaster bool) *Mysql

+ func (m *Mysql) AddSharding(key interface{}) *Mysql

+ func (m *Mysql) BatchInsert(key interface{}, batch *ds.Batch) (int64, error)

+ func (m *Mysql) Begin() error

+ func (m *Mysql) Commit() error

+ func (m *Mysql) Delete(key interface{}, del *ds.Delete) (int64, error)

+ func (m *Mysql) Exec(key interface{}, statement string) error

+ func (m *Mysql) FetchAll(key interface{}, table string, where map[string]interface{}, t interface{}) ([]interface{}, error)

+ func (m *Mysql) FetchRow(key interface{}, table string, where map[string]interface{}, t interface{}) (interface{}, error)

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

+ func (m *Mysql) GetShardingKey(key interface{}) int

+ func (m *Mysql) Insert(key interface{}, insert *ds.Insert) (int64, error)

+ func (m *Mysql) Query(key interface{}, query string, t interface{}, args ...interface{}) ([]interface{}, error)

+ func (m *Mysql) RollBack() error

+ func (m *Mysql) Update(key interface{}, update *ds.Update) (int64, error)