go_dbutil_mysql

package module

v0.0.0-...-b1da310 Latest Latest Go to latest Published: Dec 9, 2019 License: MIT Imports: 9 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

github.com/chengli1988/go-dbutil-mysql

README ¶

go-dbutil-mysql

注意

本项目属于练手项目！

依赖第三方库

1、https://github.com/go-sql-driver/mysql v1.4.1

Documentation ¶

Index ¶

Constants
func InitPool(driverName string, username string, password string, ip string, port string, ...)
type BaseDB
type BatchEngine
- func NewBatchEngine(models []ModelInterface, db *BaseDB) *BatchEngine
- func (engine *BatchEngine) InsertMany() error
- func (engine *BatchEngine) ReplaceMany() error
type CommonModel
type Engine
- func NewEngine(model ModelInterface, db *BaseDB) *Engine
type ModelInterface
type MysqlDB
type SqlFactory

Constants ¶

View Source

const (
	COMMON_CREATEID   = "create_id"
	COMMON_CREATETIME = "create_time"
	COMMON_UPDATEID   = "update_id"
	COMMON_UPDATETIME = "update_time"
)

数据库公共字段常量常量名：表名_字段

View Source

const MYSQL_DRIVERNAME = "mysql"

Variables ¶

This section is empty.

Functions ¶

func InitPool ¶

func InitPool(driverName string, username string, password string, ip string, port string, dbname string, charset string)

Types ¶

type BaseDB ¶

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

func (*BaseDB) DoTransaction ¶

func (baseDB *BaseDB) DoTransaction(dbOperates func() error) (bool, error)

func (*BaseDB) SelectBySql ¶

func (baseDB *BaseDB) SelectBySql(selectSql string, params ...interface{}) ([]map[string]interface{}, error)

func (*BaseDB) SelectCountBySql ¶

func (baseDB *BaseDB) SelectCountBySql(countSql string, params ...interface{}) (int, error)

func (*BaseDB) SelectOneBySql ¶

func (baseDB *BaseDB) SelectOneBySql(selectSql string, params ...interface{}) (map[string]interface{}, error)

type BatchEngine ¶

type BatchEngine struct {
	Engine
	// contains filtered or unexported fields
}

func NewBatchEngine ¶

func NewBatchEngine(models []ModelInterface, db *BaseDB) *BatchEngine

func (*BatchEngine) InsertMany ¶

func (engine *BatchEngine) InsertMany() error

批量新增

func (*BatchEngine) ReplaceMany ¶

func (engine *BatchEngine) ReplaceMany() error

type CommonModel ¶

type CommonModel struct {
	CreateId   string `json:"createId" db:"create_id"`
	CreateTime string `json:"createTime" db:"create_time"`
	UpdateId   string `json:"updateId" db:"update_id"`
	UpdateTime string `json:"updateTime" db:"update_time"`
}

公共字段

type Engine ¶

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

func NewEngine ¶

func NewEngine(model ModelInterface, db *BaseDB) *Engine

func (*Engine) Delete ¶

func (engine *Engine) Delete() (int, error)

删除

func (*Engine) Distinct ¶

func (engine *Engine) Distinct() *Engine

去重

func (*Engine) Fields ¶

func (engine *Engine) Fields(dbFields ...string) *Engine

查询字段

func (*Engine) IgnoreFields ¶

func (engine *Engine) IgnoreFields(ignoreDbFields ...string) *Engine

忽略字段

func (*Engine) Insert ¶

func (engine *Engine) Insert() error

新增

func (*Engine) Limit ¶

func (engine *Engine) Limit(currentPage int, pageSize int) *Engine

func (*Engine) OrderByAsc ¶

func (engine *Engine) OrderByAsc(dbFields ...string) *Engine

func (*Engine) OrderByDesc ¶

func (engine *Engine) OrderByDesc(dbFields ...string) *Engine

func (*Engine) SelectAll ¶

func (engine *Engine) SelectAll() ([]map[string]interface{}, error)

根据条件查询所有记录

func (*Engine) SelectOne ¶

func (engine *Engine) SelectOne() (map[string]interface{}, error)

根据条件查询一行记录

func (*Engine) SelectPage ¶

func (engine *Engine) SelectPage() ([]map[string]interface{}, int, error)

根据条件分页查询

func (*Engine) Update ¶

func (engine *Engine) Update() (int, error)

更新

func (*Engine) WhereEqs ¶

func (engine *Engine) WhereEqs(dbFields ...string) *Engine

等于条件

func (*Engine) WhereGes ¶

func (engine *Engine) WhereGes(dbFields ...string) *Engine

func (*Engine) WhereGts ¶

func (engine *Engine) WhereGts(dbFields ...string) *Engine

func (*Engine) WhereIns ¶

func (engine *Engine) WhereIns(dbFields ...string) *Engine

func (*Engine) WhereLeftLikes ¶

func (engine *Engine) WhereLeftLikes(dbFields ...string) *Engine

func (*Engine) WhereLes ¶

func (engine *Engine) WhereLes(dbFields ...string) *Engine

func (*Engine) WhereLikes ¶

func (engine *Engine) WhereLikes(dbFields ...string) *Engine

func (*Engine) WhereLts ¶

func (engine *Engine) WhereLts(dbFields ...string) *Engine

func (*Engine) WhereNes ¶

func (engine *Engine) WhereNes(dbFields ...string) *Engine

func (*Engine) WhereRightLikes ¶

func (engine *Engine) WhereRightLikes(dbFields ...string) *Engine

type ModelInterface ¶

type ModelInterface interface {
	// 返回数据库表名
	GetTableName() string
}

实体接口

type MysqlDB ¶

type MysqlDB struct {
}

type SqlFactory ¶

type SqlFactory interface {
	// contains filtered or unexported methods
}

Source Files ¶

View all Source files

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