mysqlmodule

Documentation

Overview

Package mysqlmodule @Title mysql模块 @Description mysql模块 @Author yr 2024/7/25 下午3:12 @Update yr 2024/7/25 下午3:12

Index

• func RegisterTable(dst ...interface{})
• type Callback
• type Conf
• type MysqlModule
  • func NewMysqlModule() *MysqlModule
  • func (m *MysqlModule) ExecuteFun(f Callback, args ...interface{}) (interface{}, error)
  • func (m *MysqlModule) ExecuteTransaction(funs ...TransactionCallback) error
  • func (m *MysqlModule) GetClient() *gorm.DB
  • func (m *MysqlModule) InitConn(conf *Conf, id int32)
  • func (m *MysqlModule) OnInit() error
• type TransactionCallback

Functions

func RegisterTable

func RegisterTable(dst ...interface{})

Types

type Callback

type Callback func(tx *gorm.DB, args ...interface{}) (interface{}, error)

type Conf

type Conf struct {
	UserName           string        `binding:"required"` // 数据库用户名
	Passwd             string        `binding:"required"` // 数据库密码
	Net                string        `binding:"required"` // 连接方式
	Addr               string        `binding:"required"` // 数据库地址
	DBNamePrefix       string        `binding:"required"` // 使用的数据库名的前缀,真正的名字是 DBNamePrefix + "_" + nodeID
	TimeZone           string        `binding:"required"` // 时区
	Timeout            time.Duration `binding:""`         // 连接超时时间
	ReadTimeout        time.Duration `binding:""`         // 读取超时时间
	WriteTimeout       time.Duration `binding:""`         // 写超时时间
	SetConnMaxIdleTime time.Duration `binding:""`         // 连接最大空闲时间
	SetConnMaxLifetime time.Duration `binding:""`         // 连接最大生命周期
	SetMaxIdleConns    int           `binding:""`         // 最大空闲连接数
	SetMaxOpenConns    int           `binding:""`         // 最大打开连接数
}

type MysqlModule

type MysqlModule struct {
	core.Module
	// contains filtered or unexported fields
}

func NewMysqlModule

func NewMysqlModule() *MysqlModule

func (*MysqlModule) ExecuteFun

func (m *MysqlModule) ExecuteFun(f Callback, args ...interface{}) (interface{}, error)

func (*MysqlModule) ExecuteTransaction

func (m *MysqlModule) ExecuteTransaction(funs ...TransactionCallback) error

func (*MysqlModule) GetClient

func (m *MysqlModule) GetClient() *gorm.DB

func (*MysqlModule) InitConn

func (m *MysqlModule) InitConn(conf *Conf, id int32)

InitConn 初始化连接

func (*MysqlModule) OnInit

func (m *MysqlModule) OnInit() error

type TransactionCallback

type TransactionCallback func(tx *gorm.DB) error