store

Documentation

Index

• func DeleteTx(ctx context.Context, tx *sqlx.Tx, table string, id ...int64) error
• func DeleteWhereTx(ctx context.Context, tx *sqlx.Tx, table string, where string, ...) error
• func InsertTx(ctx context.Context, tx *sqlx.Tx, table string, data map[string]interface{}) (int64, error)
• func IsNotFound(err error) bool
• func UpdateTx(ctx context.Context, tx *sqlx.Tx, table string, id int64, ...) error
• func UpdateWhereTx(ctx context.Context, tx *sqlx.Tx, table string, data map[string]interface{}, ...) error
• type MySQL
  • func NewMySQL(addr, user, password, database string) (*MySQL, error)
  • func (m *MySQL) Connect(ctx context.Context) (*sqlx.DB, error)
  • func (m *MySQL) Delete(ctx context.Context, table string, id ...int64) error
  • func (m *MySQL) DeleteWhere(ctx context.Context, table string, where string, args ...interface{}) error
  • func (m *MySQL) Exec(ctx context.Context, statement string, args ...interface{}) (sql.Result, error)
  • func (m *MySQL) Get(ctx context.Context, data interface{}, query string, args ...interface{}) error
  • func (m *MySQL) Gets(ctx context.Context, data interface{}, query string, args ...interface{}) error
  • func (m *MySQL) Insert(ctx context.Context, table string, data map[string]interface{}) (int64, error)
  • func (m *MySQL) Tx(ctx context.Context, f func(ctx context.Context, tx *sqlx.Tx) error) error
  • func (m *MySQL) Update(ctx context.Context, table string, id int64, data map[string]interface{}) error
  • func (m *MySQL) UpdateWhere(ctx context.Context, table string, data map[string]interface{}, where string, ...) error

Functions

func DeleteTx

func DeleteTx(ctx context.Context, tx *sqlx.Tx, table string, id ...int64) error

DeleteTx 使用主键 ID 删除数据

func DeleteWhereTx

func DeleteWhereTx(ctx context.Context, tx *sqlx.Tx, table string, where string, args ...interface{}) error

DeleteWhereTx 通过　where 条件来删除数据

func InsertTx

func InsertTx(ctx context.Context, tx *sqlx.Tx, table string, data map[string]interface{}) (int64, error)

InsertTx 使用事务向 MySQL 中插入一条数据

func IsNotFound

func IsNotFound(err error) bool

IsNotFound 判断查询错误是否是 未找到错误

func UpdateTx

func UpdateTx(ctx context.Context, tx *sqlx.Tx, table string, id int64, data map[string]interface{}) error

UpdateTx 使用主键 ID 更新一条记录

func UpdateWhereTx

func UpdateWhereTx(ctx context.Context, tx *sqlx.Tx, table string, data map[string]interface{}, where string, args ...interface{}) error

UpdateWhereTx 使用自定义条件跟新数据

Types

type MySQL

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

MySQL 是使用 mysql 对 Storage 接口的实现

func NewMySQL

func NewMySQL(addr, user, password, database string) (*MySQL, error)

NewMySQL create a new mysql storage

func (*MySQL) Connect

func (m *MySQL) Connect(ctx context.Context) (*sqlx.DB, error)

Connect 建立 mysql 链接, 并返回 *sqlx.DB

func (*MySQL) Delete

func (m *MySQL) Delete(ctx context.Context, table string, id ...int64) error

Delete 使用主键 ID 删除数据

func (*MySQL) DeleteWhere

func (m *MySQL) DeleteWhere(ctx context.Context, table string, where string, args ...interface{}) error

DeleteWhere 通过　where 条件来删除数据

func (*MySQL) Exec

func (m *MySQL) Exec(ctx context.Context, statement string, args ...interface{}) (sql.Result, error)

Exec 执行语句

func (*MySQL) Get

func (m *MySQL) Get(ctx context.Context, data interface{}, query string, args ...interface{}) error

Get 查询一条数据, 要求 data 必须是一个具体的结构,而不是切片

func (*MySQL) Gets

func (m *MySQL) Gets(ctx context.Context, data interface{}, query string, args ...interface{}) error

Gets 查询一组数据, 要求 data 是一个切片结构

func (*MySQL) Insert

func (m *MySQL) Insert(ctx context.Context, table string, data map[string]interface{}) (int64, error)

Insert 向 MySQL 中插入一条数据

func (*MySQL) Tx

func (m *MySQL) Tx(ctx context.Context, f func(ctx context.Context, tx *sqlx.Tx) error) error

Tx 执行一个事务

func (*MySQL) Update

func (m *MySQL) Update(ctx context.Context, table string, id int64, data map[string]interface{}) error

Update 使用主键 ID 更新一条记录

func (*MySQL) UpdateWhere

func (m *MySQL) UpdateWhere(ctx context.Context, table string, data map[string]interface{}, where string, args ...interface{}) error

UpdateWhere 使用自定义条件跟新数据