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 = errors.New("记录已存在")
	ErrDBRecordNotExist = errors.New("记录不存在")
)

Functions

func CheckExist

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

func CheckHasOnlyOne

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

func Count

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

func Delete

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

func DeleteEntity

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

func ExecuteRawSql

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

func ExecuteRawSqlTemplate

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

func Insert

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

func InsertBatch

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

func InsertEntity

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

func IsErrorDBRecordHasExist

func IsErrorDBRecordHasExist(err error) bool

func IsErrorDBRecordNotExist

func IsErrorDBRecordNotExist(err error) bool

func Query

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

func QueryOne

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

func Transaction

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

func Update

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

func UpdateEntity

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

Types

type Executor

type Executor interface {
	ExecuteRawSql(sql string, values ...any) ([]sql.Result, error)
	ExecuteRawSqlTemplate(sql string, template map[string]any, values ...any) ([]sql.Result, error)
}