mysql

Documentation

Index

• Variables
• func Close() error
• func GetDBPool(name string) (*sqlx.DB, error)
• func GetGormPool(name string) (*gorm.DB, error)
• func Init()
• func InitDBPool() error
• func SqlxLogExec(trace *mylog.TraceContext, sqlDB *sqlx.DB, query string, args ...interface{}) (sql.Result, error)
• func SqlxLogGet(trace *mylog.TraceContext, sqlDB *sqlx.DB, dest interface{}, query string, ...) error
• func SqlxLogNamedExec(trace *mylog.TraceContext, sqlDB *sqlx.DB, query string, arg interface{}) (sql.Result, error)
• func SqlxLogNamedQuery(trace *mylog.TraceContext, sqlDB *sqlx.DB, query string, arg interface{}) (*sqlx.Rows, error)
• func SqlxLogQuery(trace *mylog.TraceContext, sqlDB *sqlx.DB, query string, args ...interface{}) (*sql.Rows, error)
• func SqlxLogSelect(trace *mylog.TraceContext, sqlDB *sqlx.DB, dest interface{}, query string, ...) error
• type GormLogger
  • func (logger *GormLogger) LogFormatter(values ...interface{}) (messages map[string]interface{})
  • func (logger *GormLogger) NowFunc() time.Time
  • func (logger *GormLogger) Print(values ...interface{})

Variables

var (
	DBMapPool       map[string]*sqlx.DB
	GORMMapPool     map[string]*gorm.DB
	DBDefaultPool   *sqlx.DB
	GORMDefaultPool *gorm.DB
)

全局变量

Functions

func Close

func Close() error

Close 关闭 DB 连接

func GetDBPool

func GetDBPool(name string) (*sqlx.DB, error)

GetDBPool 获取一个默认连接

func GetGormPool

func GetGormPool(name string) (*gorm.DB, error)

GetGormPool 从连接中获取一个默认连接

func Init

func Init()

Init 初始化 MySQL

func InitDBPool

func InitDBPool() error

InitDBPool 初始化数据库连接池

func SqlxLogExec

func SqlxLogExec(trace *mylog.TraceContext, sqlDB *sqlx.DB, query string,
	args ...interface{}) (sql.Result, error)

SqlxLogExec 执行 sql 并记录日志

func SqlxLogGet

func SqlxLogGet(trace *mylog.TraceContext, sqlDB *sqlx.DB, dest interface{}, query string,
	args ...interface{}) error

SqlxLogGet 单行查询并记录日志

func SqlxLogNamedExec

func SqlxLogNamedExec(trace *mylog.TraceContext, sqlDB *sqlx.DB, query string,
	arg interface{}) (sql.Result, error)

SqlxLogNamedExec 执行 sql 并记录日志

func SqlxLogNamedQuery

func SqlxLogNamedQuery(trace *mylog.TraceContext, sqlDB *sqlx.DB, query string,
	arg interface{}) (*sqlx.Rows, error)

SqlxLogNamedQuery 查询并记录日志

func SqlxLogQuery

func SqlxLogQuery(trace *mylog.TraceContext, sqlDB *sqlx.DB, query string,
	args ...interface{}) (*sql.Rows, error)

SqlxLogQuery 查询并记录日志

func SqlxLogSelect

func SqlxLogSelect(trace *mylog.TraceContext, sqlDB *sqlx.DB, dest interface{}, query string,
	args ...interface{}) error

SqlxLogSelect 多行查询并记录日志

Types

type GormLogger

type GormLogger struct {
	gorm.Logger
	Trace *mylog.TraceContext
}

GormLogger MySQL 日志打印类 Logger default logger

func (*GormLogger) LogFormatter

func (logger *GormLogger) LogFormatter(values ...interface{}) (messages map[string]interface{})

LogFormatter 格式化日志格式

func (*GormLogger) NowFunc

func (logger *GormLogger) NowFunc() time.Time

NowFunc 获取当前时间

func (*GormLogger) Print

func (logger *GormLogger) Print(values ...interface{})

Print 日志输出