db

Documentation

Index

• func WithTx(db DB, f func(tx DB) error) error
• type Base
  • func New(db *sqlx.DB) *Base
  • func (b *Base) DB() DB
  • func (b *Base) WithTx(f func(tx DB) error) error
• type DB

Functions

func WithTx

func WithTx(db DB, f func(tx DB) error) error

Types

type Base

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

Base 基底

func New

func New(db *sqlx.DB) *Base

New 新建

func (*Base) DB

func (b *Base) DB() DB

DB 获取DB

func (*Base) WithTx

func (b *Base) WithTx(f func(tx DB) error) error

WithTx 事务-这种写法必须确定f函数里是否也调用了WithTx，如果不确定，有可能导致事务重复开启，从而出错。所以，在使用唯一一层事务时才使用这个方法 适合在最外层使用

type DB

type DB interface {
	// sqlx的方法
	BindNamed(query string, arg interface{}) (string, []interface{}, error)
	DriverName() string
	Get(dest interface{}, query string, args ...interface{}) error
	GetContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error
	MustExec(query string, args ...interface{}) sql.Result
	MustExecContext(ctx context.Context, query string, args ...interface{}) sql.Result
	NamedExec(query string, arg interface{}) (sql.Result, error)
	NamedExecContext(ctx context.Context, query string, arg interface{}) (sql.Result, error)
	NamedQuery(query string, arg interface{}) (*sqlx.Rows, error)
	PrepareNamed(query string) (*sqlx.NamedStmt, error)
	PrepareNamedContext(ctx context.Context, query string) (*sqlx.NamedStmt, error)
	Preparex(query string) (*sqlx.Stmt, error)
	PreparexContext(ctx context.Context, query string) (*sqlx.Stmt, error)
	QueryRowx(query string, args ...interface{}) *sqlx.Row
	QueryRowxContext(ctx context.Context, query string, args ...interface{}) *sqlx.Row
	Queryx(query string, args ...interface{}) (*sqlx.Rows, error)
	QueryxContext(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)
	Rebind(query string) string
	Select(dest interface{}, query string, args ...interface{}) error
	SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error

	// database/sql的方法
	QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
}

DB 接口