database

Documentation

Index

• Variables
• func CheckExist(executor Executor, executeParams *sql.CheckExistExecuteParams) (bool, error)
• func CheckHasOnlyOne(executor Executor, executeParams *sql.CheckHasOnlyOneExecuteParams) (bool, error)
• func Count(executor Executor, executeParams *sql.CountExecuteParams) (int64, error)
• func Delete(executor Executor, executeParams *sql.DeleteExecuteParams) error
• func DeleteEntity(executor Executor, tableName string, e any) error
• func ExecuteRawSql(executor Executor, sql string, args ...any) ([]sql.Result, error)
• func ExecuteRawSqlTemplate(executor Executor, sql string, executeParams map[string]any, args ...any) ([]sql.Result, error)
• func Insert(executor Executor, executeParams *sql.InsertExecuteParams) error
• func InsertBatch(executor Executor, executeParams *sql.InsertBatchExecuteParams) error
• func InsertEntity(executor Executor, tableName string, es any) error
• func IsErrorDBRecordHasExist(err error) bool
• func IsErrorDBRecordNotExist(err error) bool
• func Query(executor Executor, executeParams *sql.QueryExecuteParams) ([]sql.Result, int64, error)
• func QueryOne(executor Executor, executeParams *sql.QueryOneExecuteParams) (sql.Result, error)
• func Transaction(executor Executor, txFunc func(tx Executor) error) error
• func Update(executor Executor, executeParams *sql.UpdateExecuteParams) error
• func UpdateEntity(executor Executor, tableName string, e any) error
• type Executor

Variables

var (
	// ErrDBRecordHasExist 数据库记录已存在
	ErrDBRecordHasExist = errors.New("记录已存在")

	// ErrDBRecordNotExist 数据库记录不存在
	ErrDBRecordNotExist = errors.New("记录不存在")
)

Functions

func CheckExist

func CheckExist(executor Executor, executeParams *sql.CheckExistExecuteParams) (bool, error)

CheckExist 数据存在性检查 参数: - executor: 数据库基础设施接口 - executeParams: 数据存在性检查参数 返回值: - 是否存在 - 错误

func CheckHasOnlyOne

func CheckHasOnlyOne(executor Executor, executeParams *sql.CheckHasOnlyOneExecuteParams) (bool, error)

CheckHasOnlyOne 数据唯一性检查 参数: - executor: 数据库基础设施接口 - executeParams: 数据唯一性检查参数 返回值: - 是否唯一 - 错误

func Count

func Count(executor Executor, executeParams *sql.CountExecuteParams) (int64, error)

Count 数据计数 参数: - executor: 数据库基础设施接口 - executeParams: 数据计数参数 返回值: - 数量 - 错误

func Delete

func Delete(executor Executor, executeParams *sql.DeleteExecuteParams) error

Delete 删除数据 参数: - executor: 数据库基础设施接口 - executeParams: 删除数据参数 返回值: - 错误

func DeleteEntity

func DeleteEntity(executor Executor, tableName string, e any) error

DeleteEntity 通过结构删除数据 参数: - executor: 数据库基础设施接口 - tableName: 表名 - e: 结构，结构字段需要使用sqlmapping标注 返回值: - 错误

func ExecuteRawSql

func ExecuteRawSql(executor Executor, sql string, args ...any) ([]sql.Result, error)

ExecuteRawSql SQL执行接口 参数: - executor: 数据库基础设施接口 - sql: SQL语句，可以使用预编译，需要填充的值用?占位 - args: 预编译填充值 返回值: - SQL执行结果 - 错误

func ExecuteRawSqlTemplate

func ExecuteRawSqlTemplate(executor Executor, sql string, executeParams map[string]any, args ...any) ([]sql.Result, error)

ExecuteRawSqlTemplate SQL模板执行接口 参数: - executor: 数据库基础设施接口 - sql: SQL语句模板，可以使用预编译，需要填充的值用?占位，可以使用Go模板构造SQL语句 - template: 渲染SQL语句模板的模板参数 - args: 预编译填充值 返回值: - SQL执行结果 - 错误

func Insert

func Insert(executor Executor, executeParams *sql.InsertExecuteParams) error

Insert 插入数据 参数: - executor: 数据库基础设施接口 - executeParams: 插入数据参数 返回值: - 错误

func InsertBatch

func InsertBatch(executor Executor, executeParams *sql.InsertBatchExecuteParams) error

InsertBatch 批量插入数据 参数: - executor: 数据库基础设施接口 - executeParams: 批量插入数据参数 返回值: - 错误

func InsertEntity

func InsertEntity(executor Executor, tableName string, es any) error

InsertEntity 通过结构插入数据 参数: - executor: 数据库基础设施接口 - tableName: 表名 - es: 结构或结构slice(批量插入)，结构字段需要使用sqlmapping标注 返回值: - 错误

func IsErrorDBRecordHasExist

func IsErrorDBRecordHasExist(err error) bool

IsErrorDBRecordHasExist 检查错误是否是数据库记录已存在错误 参数: - err: 错误 返回值: - 是否是数据库记录已存在错误

func IsErrorDBRecordNotExist

func IsErrorDBRecordNotExist(err error) bool

IsErrorDBRecordNotExist 检查错误是否是数据库记录不存在错误 参数: - err: 错误 返回值: - 是否是数据库记录不存在错误

func Query

func Query(executor Executor, executeParams *sql.QueryExecuteParams) ([]sql.Result, int64, error)

Query 查询数据 参数: - executor: 数据库基础设施接口 - executeParams: 查询数据参数 返回值: - 查询结果 - 总数 - 错误

func QueryOne

func QueryOne(executor Executor, executeParams *sql.QueryOneExecuteParams) (sql.Result, error)

QueryOne 查询单条数据 参数: - executor: 数据库基础设施接口 - executeParams: 查询单条数据参数 返回值: - 查询结果 - 错误

func Transaction

func Transaction(executor Executor, txFunc func(tx Executor) error) error

Transaction 执行事务 参数: - executor: 数据库基础设施接口 - txFunc: 事务函数 返回值: - 错误

func Update

func Update(executor Executor, executeParams *sql.UpdateExecuteParams) error

Update 更新数据 参数: - executor: 数据库基础设施接口 - executeParams: 更新数据参数 返回值: - 错误

func UpdateEntity

func UpdateEntity(executor Executor, tableName string, e any) error

UpdateEntity 通过结构更新数据 参数: - executor: 数据库基础设施接口 - tableName: 表名 - e: 结构，结构字段需要使用sqlmapping标注 返回值: - 错误

Types

type Executor

type Executor interface {
	// ExecuteRawSql SQL执行接口
	// 参数:
	// - sql: SQL语句，可以使用预编译，需要填充的值用?占位
	// - values: 预编译填充值
	// 返回值:
	// - SQL执行结果
	// - 错误
	ExecuteRawSql(sql string, args ...any) ([]sql.Result, error)

	// ExecuteRawSqlTemplate SQL模板执行接口
	// 参数:
	// - sql: SQL语句模板，可以使用预编译，需要填充的值用?占位，可以使用Go模板构造SQL语句
	// - template: 渲染SQL语句模板的模板参数
	// - values: 预编译填充值
	// 返回值:
	// - SQL执行结果
	// - 错误
	ExecuteRawSqlTemplate(sql string, template map[string]any, args ...any) ([]sql.Result, error)
}

Executor 数据库基础设施接口