mysql

package

v0.1.1 Latest Latest Go to latest Published: Oct 13, 2022 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitee.com/natas-public/beego-utils

Links

Open Source Insights

Documentation ¶

Overview ¶

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

@DESC 数据库相关基础操作
@AUTH Neo
@DATE 2022-03-14
@CHANGE LOGS
DATE CHANGER DETAIL *****************************************************************************

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

@DESC 数据库实体Entity操作
@AUTH Neo
@DATE 2022-03-14
@CHANGE LOGS
DATE CHANGER DETAIL *****************************************************************************

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

@DESC 功能函数定义
@AUTH Neo
@DATE 2022-03-14
@CHANGE LOGS
DATE CHANGER DETAIL *****************************************************************************

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 ¶

func Begin(om orm.Ormer) (orm.TxOrmer, error)
func Commit(tx orm.TxOrmer) error
func GetModels() *map[string]*ModelInfo
func MySQLClientLaunch()
func RegisterEntityWithPrefix(prefix string, models ...any)
func Rollback(tx orm.TxOrmer) error
func RunSyncDB(afterSync AfterSyncFunc, initData InitDataFunc)
func SetQueryOrder(qs orm.QuerySeter, order map[string]bool) orm.QuerySeter
type AfterSyncFunc
type DBConfig
type Dao
- func (*Dao) Delete(entity any) AppCode
- func (*Dao) Insert(entity any) AppCode
- func (*Dao) InsertMulti(bulk int, entities any) AppCode
- func (*Dao) PageQuery(query IPageQuery, entity any, entities any) (AppCode, *PageInfo)
- func (*Dao) Read(entity any) (AppCode, any)
- func (*Dao) ReadByFilter(filter IFilter, entity any) (AppCode, any)
- func (*Dao) Update(entity any) AppCode
type FieldInfo
- func GetModelByField(mName, fName string) *FieldInfo
type Fielder
type FilterDateRange
type FilterFloat64Range
type FilterInt64Range
type IFilter
type IPageQuery
type InitDataFunc
type ModelBase
type ModelBaseAuto
type ModelInfo
type PageInfo
- func QueryPage(qs orm.QuerySeter, pageSize int64, queryRet any) (*PageInfo, error)
type PageQuery
type TagInfo

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Begin ¶ added in v0.0.6

func Begin(om orm.Ormer) (orm.TxOrmer, error)

Begin ******************************************************************************

@DESC Beego ORM事务Begin，增加错误日志处理
@PARAMS om orm.Ormer ORM对象
@RETURN orm.TxOrmer 启动事务的ORM对象
@AUTH Neo
@DATE 2022-03-14
@CHANGE LOGS
DATE CHANGER DETAIL *****************************************************************************

func Commit ¶ added in v0.0.6

func Commit(tx orm.TxOrmer) error

Commit ******************************************************************************

@DESC Beego ORM事务Commit，增加错误日志处理
@PARAMS tx orm.TxOrmer 启动事务的ORM对象
@RETURN
@AUTH Neo
@DATE 2022-03-14
@CHANGE LOGS
DATE CHANGER DETAIL *****************************************************************************

func GetModels ¶ added in v0.0.16

func GetModels() *map[string]*ModelInfo

GetModels ******************************************************************************

@DESC 获取全部缓存模型信息
@PARAMS
@RETURN *map[string]*ModelInfo 缓存模型信息
@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 RegisterEntityWithPrefix ¶ added in v0.1.0

func RegisterEntityWithPrefix(prefix string, models ...any)

RegisterEntityWithPrefix ******************************************************************************

@DESC 注册模型
@PARAMS prefix string 数据库表名前缀
models any 结构体对象
@RETURN
@AUTH Neo
@DATE 2022-03-14
@CHANGE LOGS
DATE CHANGER DETAIL *****************************************************************************

func Rollback ¶ added in v0.0.6

func Rollback(tx orm.TxOrmer) error

Rollback ******************************************************************************

@DESC Beego ORM事务Rollback，增加错误日志处理
@PARAMS tx orm.TxOrmer 启动事务的ORM对象
@RETURN
@AUTH Neo
@DATE 2022-03-14
@CHANGE LOGS
DATE CHANGER DETAIL *****************************************************************************

func RunSyncDB ¶

func RunSyncDB(afterSync 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 ¶ added in v0.0.3

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 Dao ¶ added in v0.1.0

type Dao struct {
}

Dao ******************************************************************************

@DESC 数据库基础操作封装定义
@AUTH Neo
@DATE 2022-03-14
@CHANGE LOGS
DATE CHANGER DETAIL *****************************************************************************

func (*Dao) Delete ¶ added in v0.1.0

func (*Dao) Delete(entity any) AppCode

Delete ******************************************************************************

@DESC 删除数据基础操作
@PARAMS entity any 对象实体
@RETURN AppCode 状态码
@AUTH Neo
@DATE 2022-03-14
@CHANGE LOGS
DATE CHANGER DETAIL *****************************************************************************

func (*Dao) Insert ¶ added in v0.1.0

func (*Dao) Insert(entity any) AppCode

Insert ******************************************************************************

@DESC 插入数据基础操作
@PARAMS entity any 对象实体
@RETURN AppCode 状态码
@AUTH Neo
@DATE 2022-03-14
@CHANGE LOGS
DATE CHANGER DETAIL *****************************************************************************

func (*Dao) InsertMulti ¶ added in v0.1.0

func (*Dao) InsertMulti(bulk int, entities any) AppCode

InsertMulti ******************************************************************************

@DESC 批量插入数据基础操作
@PARAMS bulk int 数据长
entities any 对象实体
@RETURN AppCode 状态码
@AUTH Neo
@DATE 2022-03-14
@CHANGE LOGS
DATE CHANGER DETAIL *****************************************************************************

func (*Dao) PageQuery ¶ added in v0.1.0

func (*Dao) PageQuery(query IPageQuery, entity any, entities any) (AppCode, *PageInfo)

PageQuery ******************************************************************************

@DESC 分页读取数据基础操作
@PARAMS query IPageQuery 分页查询信息接口
entity any 对象实体
entities any 对象实体（用于返回查询结果）
@RETURN AppCode 状态码
*PageInfo 分页信息
@AUTH Neo
@DATE 2022-03-14
@CHANGE LOGS
DATE CHANGER DETAIL *****************************************************************************

func (*Dao) Read ¶ added in v0.1.0

func (*Dao) Read(entity any) (AppCode, any)

Read ******************************************************************************

@DESC 读取数据基础操作
@PARAMS entity any 对象实体
@RETURN AppCode 状态码
any 数据对象实体
@AUTH Neo
@DATE 2022-03-14
@CHANGE LOGS
DATE CHANGER DETAIL *****************************************************************************

func (*Dao) ReadByFilter ¶ added in v0.1.0

func (*Dao) ReadByFilter(filter IFilter, entity any) (AppCode, any)

ReadByFilter ******************************************************************************

@DESC 根据筛选条件读取数据基础操作
@PARAMS filter IFilter 筛选条件接口
entity any 对象实体
@RETURN AppCode 状态码
any 数据对象实体
@AUTH Neo
@DATE 2022-03-14
@CHANGE LOGS
DATE CHANGER DETAIL *****************************************************************************

func (*Dao) Update ¶ added in v0.1.0

func (*Dao) Update(entity any) AppCode

Update ******************************************************************************

@DESC 更新数据基础操作
@PARAMS entity any 对象实体
@RETURN AppCode 状态码
@AUTH Neo
@DATE 2022-03-14
@CHANGE LOGS
DATE CHANGER DETAIL *****************************************************************************

type FieldInfo ¶ added in v0.0.16

type FieldInfo struct {
	JsonTag TagInfo
	OrmTag  TagInfo
	NeoTag  TagInfo
}

func GetModelByField ¶ added in v0.0.16

func GetModelByField(mName, fName string) *FieldInfo

GetModelByField ******************************************************************************

@DESC 根据模型名及字段名缓存模型信息
@PARAMS mName string 模型名
fName string 字段名
@RETURN *FieldInfo 缓存模型字段信息
@AUTH Neo
@DATE 2022-03-14
@CHANGE LOGS
DATE CHANGER DETAIL *****************************************************************************

type Fielder ¶ added in v0.0.16

type Fielder interface {
	String() string
	FieldType() int
	SetRaw(any) error
	RawValue() any
}

Fielder define field info

type FilterDateRange ¶ added in v0.0.3

type FilterDateRange struct {
	Min *ntime.MTime
	Max *ntime.MTime
}

type FilterFloat64Range ¶ added in v0.0.3

type FilterFloat64Range struct {
	Min *float64
	Max *float64
}

type FilterInt64Range ¶ added in v0.0.3

type FilterInt64Range struct {
	Min *int64
	Max *int64
}

type IFilter ¶ added in v0.1.0

type IFilter interface {
	GetQuerySeter(qs orm.QuerySeter) orm.QuerySeter
}

type IPageQuery ¶ added in v0.1.0

type IPageQuery interface {
	GetPageQuery() PageQuery
	GetFilter() any
}

type InitDataFunc ¶

type InitDataFunc func()

type ModelBase ¶ added in v0.0.3

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.MTime `` /* 135-byte string literal not displayed */
	CreateUser string      `json:"createUser"   orm:"null;column(create_user);size(32);description(创建者ID)"`
	UpdateTime ntime.MTime `` /* 131-byte string literal not displayed */
	UpdateUser string      `json:"updateUser"   orm:"null;column(update_user);size(32);description(更新者ID)"`
}

type ModelBaseAuto ¶ added in v0.0.14

type ModelBaseAuto struct {
	ID         int32       `json:"id"         orm:"column(id);pk;auto;description(系统ID)"`
	Remark     string      `json:"remark"     orm:"null;column(remark);size(500);description(备注信息)"`
	CreateTime ntime.MTime `` /* 134-byte string literal not displayed */
	CreateUser string      `json:"createUser" orm:"null;column(create_user);size(32);description(创建者ID)"`
	UpdateTime ntime.MTime `` /* 129-byte string literal not displayed */
	UpdateUser string      `json:"updateUser" orm:"null;column(update_user);size(32);description(更新者ID)"`
}

type ModelInfo ¶ added in v0.0.16

type ModelInfo struct {
	TName      string
	FieldInfos map[string]*FieldInfo
}

type PageInfo ¶ added in v0.0.3

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 ¶ added in v0.0.3

func QueryPage(qs orm.QuerySeter, pageSize int64, queryRet any) (*PageInfo, error)

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

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

type PageQuery ¶ added in v0.0.3

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

type TagInfo ¶ added in v0.0.16

type TagInfo struct {
	Attrs map[string]bool
	Tags  map[string]string
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL