mysql

Documentation

Overview

Package mysql ******************************************************************************

• @DESC 数据查询公共操作
• @AUTH Neo
• @DATE 2022-03-14
• @CHANGE LOGS
• DATE CHANGER DETAIL *****************************************************************************

Package mysql ******************************************************************************

• @DESC 连接MySQL数据库操作
• @AUTH Neo
• @DATE 2022-03-14
• @CHANGE LOGS
• DATE CHANGER DETAIL *****************************************************************************

Index

• Constants
• func GetPagesInfo(tName string, curPage int64, pageSize int64, conditions string) (int64, int64, orm.RawSeter, error)
• func MySQLClientLaunch()
• func RunSyncDB(afterSyncs []AfterSyncFunc, initData InitDataFunc)
• func SetQueryOrder(qs orm.QuerySeter, order map[string]bool) orm.QuerySeter
• type AfterSyncFunc
• type DBConfig
• type FilterDateRange
• type FilterFloat64Range
• type FilterInt64Range
• type InitDataFunc
• type ModelBase
• type PageInfo
  • func QueryPage(qs orm.QuerySeter, pageSize int64, queryRet interface{}) (*PageInfo, error)
• type PageQuery

Constants

const (
	SqlalterTimeTemplate       = "ALTER TABLE `%s` MODIFY COLUMN `%s` timestamp(3) DEFAULT current_timestamp(3) NULL COMMENT '%s';"
	SqlalterCreatetimeTemplate = "ALTER TABLE `%s` MODIFY COLUMN `create_time` timestamp(3) DEFAULT current_timestamp(3) NULL COMMENT '创建时间';"
	SqlalterUpdatetimeTemplate = "" /* 146-byte string literal not displayed */
)

Functions

func GetPagesInfo

func GetPagesInfo(tName string, curPage int64, pageSize int64, conditions string) (int64, int64, orm.RawSeter, error)

GetPagesInfo ******************************************************************************

• @DESC 组装用于分页查询的RawSeter
• @PARAMS
• tName string 表名
• curPage int64 当前页数
• pageSize int64 每页记录数
• condition string 拼接好的WHERE条件语句
• @RETURN
• int64 总记录数
• int64 总页数
• orm.RawSeter ORM查询器
• @AUTH Neo
• @DATE 2022-03-14
• @CHANGE LOGS
• DATE CHANGER DETAIL *****************************************************************************

func MySQLClientLaunch

func MySQLClientLaunch()

MySQLClientLaunch ******************************************************************************

• @DESC 启动创建MySQL数据库连接，读取配置文件中指定的信息，连接数据库
• @PARAMS
• @RETURN
• @AUTH Neo
• @DATE 2022-03-14
• @CHANGE LOGS
• DATE CHANGER DETAIL *****************************************************************************

func RunSyncDB

func RunSyncDB(afterSyncs []AfterSyncFunc, initData InitDataFunc)

RunSyncDB ******************************************************************************

• @DESC 根据各Model定义，创建数据库表并初始化数据
• @PARAMS afterSyncs []AfterSyncFunc 数据库表自动创建后的修补操作
• initData InitDataFunc 数据初始化函数
• @RETURN
• @AUTH Neo
• @DATE 2022-03-14
• @CHANGE LOGS
• DATE CHANGER DETAIL *****************************************************************************

func SetQueryOrder

func SetQueryOrder(qs orm.QuerySeter, order map[string]bool) orm.QuerySeter

SetQueryOrder ******************************************************************************

• @DESC 查询器中设置排序标记
• @PARAMS
• qs orm.QuerySeter ORM查询器
• order map[string]bool 排序表
• @RETURN
• orm.QuerySeter ORM查询器
• @AUTH Neo
• @DATE 2022-03-14
• @CHANGE LOGS
• DATE CHANGER DETAIL *****************************************************************************

Types

type AfterSyncFunc

type AfterSyncFunc func()

type DBConfig

type DBConfig struct {
	Alias    string
	User     string
	Password string
	Host     string
	Database string
	Charset  string
	Loc      string
	Debug    bool
	Force    bool
	Verbose  bool
	Mock     bool
	MaxIdle  int
	MaxConn  int
}

type FilterDateRange

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

type FilterFloat64Range

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

type FilterInt64Range

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

type InitDataFunc

type InitDataFunc func()

type ModelBase

type ModelBase struct {
	ID         string      `json:"id"         orm:"column(id);pk;size(32);description(系统ID)"`
	Remark     string      `json:"remark"     orm:"null;column(remark);size(500);description(备注信息)"`
	CreateTime ntime.NTime `json:"createTime" orm:"column(create_time);type(datetime);description(创建时间)"`
	CreateUser string      `json:"createUser" orm:"null;column(create_user);size(32);description(创建者ID)"`
	UpdateTime ntime.NTime `json:"updateTime" orm:"column(update_time);type(datetime);description(更新时间)"`
	UpdateUser string      `json:"updateUser" orm:"null;column(update_user);size(32);description(更新者ID)"`
}

type PageInfo

type PageInfo struct {
	Total    int64 `json:"total"`
	Page     int64 `json:"page"`
	PageSize int64 `json:"pageSize"`
	Pages    int64 `json:"pages"`
	Count    int64 `json:"count"`
}

func QueryPage

func QueryPage(qs orm.QuerySeter, pageSize int64, queryRet interface{}) (*PageInfo, error)

QueryPage ******************************************************************************

• @DESC 查询分页数据
• @PARAMS
• qs orm.QuerySeter ORM查询器
• pageSize int64 每页记录数
• queryRet interface{} 查询结果集
• @RETURN
• *PageInfo 分页信息
• @AUTH Neo
• @DATE 2022-03-14
• @CHANGE LOGS
• DATE CHANGER DETAIL *****************************************************************************

type PageQuery

type PageQuery struct {
	Page     int64           `json:"page"`
	PageSize int64           `json:"pageSize"`
	Order    map[string]bool `json:"order"`
}