gormPool

Documentation

Index

• type Common
• type DbSetting
  • func NewDbSetting(path string) *DbSetting
• type Dsn
• type MySqlConnection
• type MySqlPool
  • func NewMySqlPool(dbSetting *DbSetting) *MySqlPool
  • func (receiver *MySqlPool) Close() error
  • func (receiver *MySqlPool) GetConn() *gorm.DB
  • func (receiver *MySqlPool) GetRws() *gorm.DB
• type MySqlSetting

Types

type Common

type Common struct {
	Driver string `yaml:"driver"`
}

type DbSetting

type DbSetting struct {
	Common *Common       `yaml:"common"`
	MySql  *MySqlSetting `yaml:"mysql"`
}

func NewDbSetting

func NewDbSetting(path string) *DbSetting

NewDbSetting 初始化

type Dsn

type Dsn struct {
	Name    string
	Content string
}

type MySqlConnection

type MySqlConnection struct {
	Username  string `yaml:"username"`
	Password  string `yaml:"password"`
	Host      string `yaml:"host"`
	Port      uint16 `yaml:"port"`
	Database  string `yaml:"database"`
	Charset   string `yaml:"charset"`
	Collation string `yaml:"collation"`
}

type MySqlPool

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

func NewMySqlPool

func NewMySqlPool(dbSetting *DbSetting) *MySqlPool

NewMySqlPool 创建mysql链接池对象

func (*MySqlPool) Close

func (receiver *MySqlPool) Close() error

Close 关闭数据库链接

func (*MySqlPool) GetConn

func (receiver *MySqlPool) GetConn() *gorm.DB

GetMain 获取主数据库链接

func (*MySqlPool) GetRws

func (receiver *MySqlPool) GetRws() *gorm.DB

GetRws 获取带有读写分离的数据库链接

type MySqlSetting

type MySqlSetting struct {
	MaxOpenConns int                         `yaml:"maxOpenConns"`
	MaxIdleConns int                         `yaml:"maxIdleConns"`
	MaxLifetime  int                         `yaml:"maxLifetime"`
	MaxIdleTime  int                         `yaml:"maxIdleTime"`
	Rws          bool                        `yaml:"rws"`
	Main         *MySqlConnection            `yaml:"main"`
	Sources      map[string]*MySqlConnection `yaml:"sources"`
	Replicas     map[string]*MySqlConnection `yaml:"replicas"`
}