sharding

Nov 22, 2023

Changes in this version

+ const PKMySQLSequence

type ShardingMigrator

+ func (m ShardingMigrator) BuildIndexOptions(opts []schema.IndexOption, stmt *gorm.Statement) (results []interface{})

Aug 8, 2022

Changes in this version

+ var ErrInsertDiffSuffix = errors.New("can not insert different suffix table in one query ")

+ var ShardingIgnoreStoreKey = "sharding_ignore"

type ShardingMigrator

+ func (m ShardingMigrator) DropTable(dst ...interface{}) error

Apr 22, 2022

Changes in this version

type Config

+ ShardingSuffixs func() (suffixs []string)

+ type ShardingDialector struct

+ func NewShardingDialector(d gorm.Dialector, s *Sharding) ShardingDialector

+ func (d ShardingDialector) Migrator(db *gorm.DB) gorm.Migrator

+ type ShardingMigrator struct

+ func (m ShardingMigrator) AutoMigrate(dst ...interface{}) error

Jan 25, 2022

Changes in this version

+ const PKCustom

+ const PKPGSequence

+ const PKSnowflake

type Config

+ NumberOfShards uint

+ PrimaryKeyGenerator int

+ PrimaryKeyGeneratorFn func(tableIdx int64) int64

Jan 21, 2022

Changes in this version

type Config

+ DoubleWrite bool

Jan 19, 2022

Changes in this version

+ var ErrInvalidID = errors.New("invalid id format")

+ var ErrMissingShardingKey = errors.New("sharding key or id required, and use operator =")

+ type Config struct

+ EnableFullTable bool

+ PrimaryKeyGenerate func(tableIdx int64) int64

+ ShardingAlgorithm func(columnValue interface{}) (suffix string, err error)

+ ShardingAlgorithmByPrimaryKey func(id int64) (suffix string)

+ ShardingKey string

+ type ConnPool struct

+ func (pool *ConnPool) BeginTx(ctx context.Context, opt *sql.TxOptions) (gorm.ConnPool, error)

+ func (pool *ConnPool) Commit() error

+ func (pool *ConnPool) Ping() error

+ func (pool *ConnPool) Rollback() error

+ func (pool *ConnPool) String() string

+ func (pool ConnPool) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (pool ConnPool) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)

+ func (pool ConnPool) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (pool ConnPool) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

+ type Sharding struct

+ ConnPool *ConnPool

+ func Register(config Config, tables ...interface{}) *Sharding

+ func (s *Sharding) Initialize(db *gorm.DB) error

+ func (s *Sharding) LastQuery() string

+ func (s *Sharding) Name() string

+ func (s *Sharding) Register(config Config, tables ...interface{}) *Sharding