mysqlmodule

Documentation

Overview

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

Index

• type Callback
• type Conf
• type MysqlModule
  • func NewMysqlModule() *MysqlModule
  • func (m *MysqlModule) ApiInitTables(database string, tables ...interface{}) error
  • func (m *MysqlModule) ApiMysqlExecuteFun(f Callback, args ...interface{}) (interface{}, error)
  • func (m *MysqlModule) ApiMysqlExecuteTransaction(funs ...TransactionCallback) error
  • func (m *MysqlModule) GetClient() *gorm.DB
  • func (m *MysqlModule) Init(conf *Conf)
  • func (m *MysqlModule) OnInit() error
• type TransactionCallback

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"` // 数据库地址
	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) ApiInitTables

func (m *MysqlModule) ApiInitTables(database string, tables ...interface{}) error

func (*MysqlModule) ApiMysqlExecuteFun

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

func (*MysqlModule) ApiMysqlExecuteTransaction

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

func (*MysqlModule) GetClient

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

func (*MysqlModule) Init

func (m *MysqlModule) Init(conf *Conf)

Init 初始化连接

func (*MysqlModule) OnInit

func (m *MysqlModule) OnInit() error

type TransactionCallback

type TransactionCallback func(tx *gorm.DB) error