eMysql

Documentation

Index

• Variables
• func GetConnect(name string) *gorm.DB
• func GetConnectByConf(conf MultipleConf) (*gorm.DB, error)
• func Init(c map[string]MultipleConf)
• type Conf
  • func (c *Conf) DSN() string
• type EGorm
  • func (ctl *EGorm) GDB() *gorm.DB
• type GormConfigOption
  • func WithIgnoreRecordNotFound(isIgnore bool) GormConfigOption
  • func WithName(name string) GormConfigOption
  • func WithSlowThreshold(duration time.Duration) GormConfigOption
• type MultipleConf
  • func (m *MultipleConf) ConfToGormDialector() (sourcesDialector, replicasDialector []gorm.Dialector)

Variables

var ErrNoInit = errors.New("eMysql: please initialize with eMysql.Init()")

Functions

func GetConnect

func GetConnect(name string) *gorm.DB

func GetConnectByConf

func GetConnectByConf(conf MultipleConf) (*gorm.DB, error)

GetConnectByConf 获取gorm连接

func Init

func Init(c map[string]MultipleConf)

Types

type Conf

type Conf struct {
	Host     string
	Port     int
	Database string
	User     string
	Password string
	Params   string
}

func (*Conf) DSN

func (c *Conf) DSN() string

type EGorm

type EGorm struct {
	ConfName string
}

EGorm 在结构体引入组合并赋值ConfName，即可通过GDB()获取gorm连接 Example

type User struct {
	 EGorm
}

var user = User{EGorm{ConfName: "localhost"}}

func (u *User) GetUser(id int64) error {
	 u.GDB().Where("id = ?", id).First()
}

func (*EGorm) GDB

func (ctl *EGorm) GDB() *gorm.DB

GDB 获取DB连接

type GormConfigOption

type GormConfigOption func(conf *logConf)

func WithIgnoreRecordNotFound

func WithIgnoreRecordNotFound(isIgnore bool) GormConfigOption

WithIgnoreRecordNotFound 是否忽略notFound错误，默认为 false

func WithName

func WithName(name string) GormConfigOption

WithName 慢日志名，默认为 mysql

func WithSlowThreshold

func WithSlowThreshold(duration time.Duration) GormConfigOption

WithSlowThreshold 慢日志时间阈值，默认为 100毫秒

type MultipleConf

type MultipleConf struct {
	Sources  []Conf // 写库
	Replicas []Conf // 读库
}

MultipleConf 读写分离配置

func (*MultipleConf) ConfToGormDialector

func (m *MultipleConf) ConfToGormDialector() (sourcesDialector, replicasDialector []gorm.Dialector)

ConfToGormDialector 处理配置为gorm配置 @param conf 配置列表 @return sourcesDSN 写库dsn列表 @return replicasDSN 读库dsn列表