edb

package
v1.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 4, 2023 License: MIT Imports: 11 Imported by: 0

Documentation

Overview

Package edb 数据库操作

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LIMIT

func LIMIT(Page interface{}, PerPage interface{}) string

LIMIT 用于拼接LIMIT语句,返回拼接后的LIMIT语句 Page 第几页 PerPage 每页多少条

func OrderBY

func OrderBY(参数 ...interface{}) string

OrderBY 接收任意参数组合 用于拼接ORDER BY语句,返回拼接后的ORDER BY语句 调用方式 OrderBY("id", "desc", "title", "desc")

Types

type DatabaseOperator

type DatabaseOperator interface {
	Connect(string) error                                 // 返回连接数据库时可能出现的错误 中文函数名: 连接数据库
	Query(string) ([]map[string]interface{}, error)       // 接收查询语句作为参数,返回查询结果的列表和可能出现的错误 中文函数名: 查询
	Insert(string, map[string]interface{}) (int64, error) // 接收插入语句和待插入数据作为参数,返回插入操作对应的id值和可能出现的错误 中文函数名: 插入
	Update(string, map[string]interface{}) (int64, error) // 接收更新语句作为参数,返回更新操作对应的行数和可能出现的错误 中文函数名: 更新
	Delete(string, map[string]interface{}) (int64, error) // 接收删除语句作为参数,返回删除操作对应的行数和可能出现的错误 中文函数名: 删除
	Count(string, map[string]interface{}) (int64, error)  // 接收查询语句作为参数,返回查询结果的数量和可能出现的错误 中文函数名: 总数
	BeginTransaction() error                              // 返回开始事务时可能出现的错误 中文函数名: 开始事务
	CommitTransaction() error                             // 返回提交事务时可能出现的错误 中文函数名: 提交事务
	RollbackTransaction() error                           // 返回回滚事务时可能出现的错误 中文函数名: 回滚事务
	QueryWithPagination(string, int, int) ([]map[string]interface{}, error)
}

type H

type H map[string]any

H 简化map[string]interface{}的写法 edb.H{"name": "张三", "age": 18} 用起来方便一点

type MySQLQueryBuilder

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

func NewMySQLQueryBuilder

func NewMySQLQueryBuilder() *MySQLQueryBuilder

func NewMySQL查询构建器

func NewMySQL查询构建器(db *Mysql数据库操作类) *MySQLQueryBuilder

func (*MySQLQueryBuilder) Count

func (qb *MySQLQueryBuilder) Count() (int64, error)

func (*MySQLQueryBuilder) Delete added in v1.2.1

func (qb *MySQLQueryBuilder) Delete() (int64, error)

func (*MySQLQueryBuilder) First added in v1.2.1

func (qb *MySQLQueryBuilder) First() (map[string]interface{}, error)

func (*MySQLQueryBuilder) From

func (qb *MySQLQueryBuilder) From(table string) *MySQLQueryBuilder

func (*MySQLQueryBuilder) Get added in v1.2.1

func (qb *MySQLQueryBuilder) Get() ([]map[string]interface{}, error)

func (*MySQLQueryBuilder) GetInt added in v1.2.1

func (qb *MySQLQueryBuilder) GetInt() (int64, error)

func (*MySQLQueryBuilder) Insert added in v1.2.1

func (qb *MySQLQueryBuilder) Insert(data map[string]interface{}) (int64, error)

func (*MySQLQueryBuilder) Limit

func (qb *MySQLQueryBuilder) Limit(offset, limit int64) *MySQLQueryBuilder

func (*MySQLQueryBuilder) OrWhere added in v1.2.1

func (qb *MySQLQueryBuilder) OrWhere(column string, operator string, value interface{}) *MySQLQueryBuilder

func (*MySQLQueryBuilder) OrderBy

func (qb *MySQLQueryBuilder) OrderBy(cols ...string) *MySQLQueryBuilder

func (*MySQLQueryBuilder) Paginate added in v1.2.1

func (qb *MySQLQueryBuilder) Paginate(total int64, current_pages int64) *MySQLQueryBuilder

func (*MySQLQueryBuilder) Select

func (qb *MySQLQueryBuilder) Select(cols ...string) *MySQLQueryBuilder

func (*MySQLQueryBuilder) ToSQL

func (qb *MySQLQueryBuilder) ToSQL() (string, []interface{})

func (*MySQLQueryBuilder) Update added in v1.2.1

func (qb *MySQLQueryBuilder) Update(data map[string]interface{}) (int64, error)

func (*MySQLQueryBuilder) Where

func (qb *MySQLQueryBuilder) Where(column string, operator string, value interface{}) *MySQLQueryBuilder

type Mysql数据库操作类

type Mysql数据库操作类 struct {
	// contains filtered or unexported fields
}

func NewMysql数据库操作类

func NewMysql数据库操作类() *Mysql数据库操作类

func (*Mysql数据库操作类) BeginTransaction

func (op *Mysql数据库操作类) BeginTransaction() error

func (*Mysql数据库操作类) CommitTransaction

func (op *Mysql数据库操作类) CommitTransaction() error

func (*Mysql数据库操作类) Connect

func (op *Mysql数据库操作类) Connect(datasourceName string) error

func (*Mysql数据库操作类) Count

func (op *Mysql数据库操作类) Count(queryStr string, args map[string]interface{}) (int64, error)

Count

func (*Mysql数据库操作类) CountRaw

func (op *Mysql数据库操作类) CountRaw(queryStr string, args []interface{}) (int64, error)

CountRaw

func (*Mysql数据库操作类) Delete

func (op *Mysql数据库操作类) Delete(queryStr string, args map[string]interface{}) (int64, error)

func (*Mysql数据库操作类) ExecRaw added in v1.2.1

func (op *Mysql数据库操作类) ExecRaw(queryStr string, args []interface{}) (int64, error)

func (*Mysql数据库操作类) E关闭数据库

func (op *Mysql数据库操作类) E关闭数据库()

E关闭连接

func (*Mysql数据库操作类) E删除

func (op *Mysql数据库操作类) E删除(删除语句 string, 参数 map[string]interface{}) (int64, error)

E删除 用于执行删除操作,返回删除操作对应的行数和可能出现的错误 参数deleteStr是删除语句,参数args是删除语句中的参数,格式为map[string]interface{}{"参数名": 参数值}

func (*Mysql数据库操作类) E回滚事务

func (op *Mysql数据库操作类) E回滚事务() error

E回滚事务 用于回滚事务,返回回滚事务时可能出现的错误

func (*Mysql数据库操作类) E开始事务

func (op *Mysql数据库操作类) E开始事务() error

E开始事务 用于开始事务,返回开始事务时可能出现的错误

func (*Mysql数据库操作类) E提交事务

func (op *Mysql数据库操作类) E提交事务() error

E提交事务 用于提交事务,返回提交事务时可能出现的错误

func (*Mysql数据库操作类) E插入

func (op *Mysql数据库操作类) E插入(插入语句 string, 参数 map[string]interface{}) (int64, error)

E插入 用于执行插入操作,返回插入操作对应的id值和可能出现的错误 参数insertStr是插入语句,参数args是插入语句中的参数,格式为map[string]interface{}{"参数名": 参数值}

func (*Mysql数据库操作类) E更新

func (op *Mysql数据库操作类) E更新(更新语句 string, 参数 map[string]interface{}) (int64, error)

E更新 用于执行更新操作,返回更新操作对应的行数和可能出现的错误 参数updateStr是更新语句,参数args是更新语句中的参数,格式为map[string]interface{}{"参数名": 参数值}

func (*Mysql数据库操作类) E查询

func (op *Mysql数据库操作类) E查询(查询语句 string, 参数 map[string]interface{}) ([]map[string]interface{}, error)

E查询 用于执行查询操作,返回查询结果的列表和可能出现的错误 参数queryStr是查询语句,参数args是查询语句中的参数,格式为map[string]interface{}{"参数名": 参数值}

func (*Mysql数据库操作类) E连接数据库

func (op *Mysql数据库操作类) E连接数据库(数据库连接信息 string) error

E连接数据库 用于连接数据库,返回连接数据库时可能出现的错误 参数datasourceName是数据库连接信息,格式为"用户名:密码@tcp(IP:端口)/数据库名?charset=utf8"

func (*Mysql数据库操作类) GetAllTableName added in v1.2.2

func (op *Mysql数据库操作类) GetAllTableName() ([]string, error)

func (*Mysql数据库操作类) GetTableInfo added in v1.2.2

func (op *Mysql数据库操作类) GetTableInfo(table string) (*orderedmap.OrderedMap[string, map[string]interface{}], error)

func (*Mysql数据库操作类) Insert

func (op *Mysql数据库操作类) Insert(queryStr string, args map[string]interface{}) (int64, error)

func (*Mysql数据库操作类) Query

func (op *Mysql数据库操作类) Query(queryStr string, args map[string]interface{}) ([]map[string]interface{}, error)

func (*Mysql数据库操作类) QueryRaw

func (op *Mysql数据库操作类) QueryRaw(queryStr string, args []interface{}) ([]map[string]interface{}, error)

QueryRaw 是使用 ? 占位符的

func (*Mysql数据库操作类) RollbackTransaction

func (op *Mysql数据库操作类) RollbackTransaction() error

func (*Mysql数据库操作类) Update

func (op *Mysql数据库操作类) Update(queryStr string, args map[string]interface{}) (int64, error)

Jump to

Keyboard shortcuts

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