gormPool

Documentation

Index

• Variables
• 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
• type MySqlSetting
• type PostgresConnection
• type PostgresPool
  • func NewPostgresPool(dbSetting *DbSetting) *PostgresPool
  • func (receiver *PostgresPool) Close() error
  • func (receiver *PostgresPool) GetConn() *gorm.DB
• type PostgresSetting
• type SqlServerConnection
• type SqlServerPool
  • func NewSqlServerPool(dbSetting *DbSetting) *SqlServerPool
  • func (receiver *SqlServerPool) Close() error
  • func (receiver *SqlServerPool) GetConn() *gorm.DB
• type SqlServerSetting

Variables

var (
	MySqlDsnFormat = "%s:%s@tcp(%s:%d)/%s?charset=%s&parseTime=True&loc=Local"
)

var (
	PostgresDsnFormat = "host=%s user=%s password=%s dbname=%s port=%d sslmode=%s TimeZone=%s"
)

var (
	SqlServerDsnFormat = "sqlserver://%s:%s@%s:?%d?database=%s"
)

Types

type Common

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

type DbSetting

type DbSetting struct {
	Common    *Common           `yaml:"common"`
	MySql     *MySqlSetting     `yaml:"mysql"`
	Postgres  *PostgresSetting  `yaml:"postgres"`
	SqlServer *SqlServerSetting `yaml:"sqlServer"`
}

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 获取主数据库链接

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"`
}

type PostgresConnection

type PostgresConnection struct {
	Username string `yaml:"username"`
	Password string `yaml:"password"`
	Host     string `yaml:"host"`
	Port     uint16 `yaml:"port"`
	Database string `yaml:"database"`
	TimeZone string `yaml:"timezone"`
	SslMode  string `yaml:"sslmode"`
}

type PostgresPool

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

func NewPostgresPool

func NewPostgresPool(dbSetting *DbSetting) *PostgresPool

NewPostgresPool 创建mysql链接池对象

func (*PostgresPool) Close

func (receiver *PostgresPool) Close() error

Close 关闭数据库链接

func (*PostgresPool) GetConn

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

GetMain 获取主数据库链接

type PostgresSetting

type PostgresSetting struct {
	MaxOpenConns int                 `yaml:"maxOpenConns"`
	MaxIdleConns int                 `yaml:"maxIdleConns"`
	MaxLifetime  int                 `yaml:"maxLifetime"`
	MaxIdleTime  int                 `yaml:"maxIdleTime"`
	Main         *PostgresConnection `yaml:"main"`
}

type SqlServerConnection

type SqlServerConnection struct {
	Username string `yaml:"username"`
	Password string `yaml:"password"`
	Host     string `yaml:"host"`
	Port     uint16 `yaml:"port"`
	Database string `yaml:"database"`
}

type SqlServerPool

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

func NewSqlServerPool

func NewSqlServerPool(dbSetting *DbSetting) *SqlServerPool

NewSqlServerPool 创建mysql链接池对象

func (*SqlServerPool) Close

func (receiver *SqlServerPool) Close() error

Close 关闭数据库链接

func (*SqlServerPool) GetConn

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

GetMain 获取主数据库链接

type SqlServerSetting

type SqlServerSetting struct {
	MaxOpenConns int                  `yaml:"maxOpenConns"`
	MaxIdleConns int                  `yaml:"maxIdleConns"`
	MaxLifetime  int                  `yaml:"maxLifetime"`
	MaxIdleTime  int                  `yaml:"maxIdleTime"`
	Main         *SqlServerConnection `yaml:"main"`
}