database

Documentation

Index

• func GetRun()
• type Configure
  • func NewConfigure(dsn string, maxIdleConns, maxOpenConns, connMaxIdleTime, connMaxLifetime int, ...) Configure
• type DBConfig
  • func (e *DBConfig) Init(config *gorm.Config, open func(string) gorm.Dialector) (*gorm.DB, error)
• type DBInfo
• type DBModel
  • func NewDBModel(info *DBInfo) *DBModel
  • func (m *DBModel) ConnectDB(db string) error
  • func (m *DBModel) GeRows() string
• type DBResolverConfig
  • func (e *DBResolverConfig) Init(register *dbresolver.DBResolver, open func(string) gorm.Dialector) *dbresolver.DBResolver
• type ResolverConfigure
  • func NewResolverConfigure(sources, replicas []string, policy string, tables []string) ResolverConfigure

Functions

func GetRun

func GetRun()

Types

type Configure

type Configure interface {
	Init(*gorm.Config, func(string) gorm.Dialector) (*gorm.DB, error)
}

func NewConfigure

func NewConfigure(
	dsn string,
	maxIdleConns,
	maxOpenConns,
	connMaxIdleTime,
	connMaxLifetime int,
	registers []ResolverConfigure) Configure

NewConfigure 初始化 Configure

type DBConfig

type DBConfig struct {
	// contains filtered or unexported fields
}

func (*DBConfig) Init

func (e *DBConfig) Init(config *gorm.Config, open func(string) gorm.Dialector) (*gorm.DB, error)

Init 获取db，⚠️注意：读写分离只能配置一组

type DBInfo

type DBInfo struct {
	DBType   string
	Host     string
	UserName string
	Password string
	Charset  string
}

type DBModel

type DBModel struct {
	DBEngine *sql.DB
	DBInfo   *DBInfo
}

func NewDBModel

func NewDBModel(info *DBInfo) *DBModel

func (*DBModel) ConnectDB

func (m *DBModel) ConnectDB(db string) error

func (*DBModel) GeRows

func (m *DBModel) GeRows() string

type DBResolverConfig

type DBResolverConfig struct {
	// contains filtered or unexported fields
}

func (*DBResolverConfig) Init

func (e *DBResolverConfig) Init(
	register *dbresolver.DBResolver,
	open func(string) gorm.Dialector) *dbresolver.DBResolver

type ResolverConfigure

type ResolverConfigure interface {
	Init(*dbresolver.DBResolver, func(string) gorm.Dialector) *dbresolver.DBResolver
}

func NewResolverConfigure

func NewResolverConfigure(sources, replicas []string, policy string, tables []string) ResolverConfigure

NewResolverConfigure 初始化 ResolverConfigure