goqux

Documentation

Index

• type Database
  • func NewDb(db *sql.DB) *Database
  • func (db *Database) InTx(txFunc func(tx *Tx) error) (err error)
  • func (db *Database) InTxContext(ctx context.Context, opts *sql.TxOptions, txFunc func(tx *Tx) error) (err error)
• type GoquLoggerAdapter
  • func (x *GoquLoggerAdapter) Printf(format string, v ...interface{})
• type Tx

Types

type Database

type Database struct {
	Goqu *goqu.Database
	// contains filtered or unexported fields
}

DB 数据库扩展

func NewDb

func NewDb(db *sql.DB) *Database

NewDb 新建

func (*Database) InTx

func (db *Database) InTx(txFunc func(tx *Tx) error) (err error)

InTx ref: https://stackoverflow.com/questions/16184238/database-sql-tx-detecting-commit-or-rollback

func (*Database) InTxContext

func (db *Database) InTxContext(ctx context.Context, opts *sql.TxOptions, txFunc func(tx *Tx) error) (err error)

InTxContext 运行在一个事务上下文

type GoquLoggerAdapter

type GoquLoggerAdapter struct {
}

func (*GoquLoggerAdapter) Printf

func (x *GoquLoggerAdapter) Printf(format string, v ...interface{})

type Tx

type Tx struct {
	Tx     *sql.Tx
	GoquTx *goqu.TxDatabase
}

Tx 事务扩展