dbs

Documentation

Index

• Variables
• type Batch
  • func NewBatch(db *sql.DB, n int) *Batch
  • func (this *Batch) Add(query string, args ...any)
  • func (this *Batch) Close()
  • func (this *Batch) EnableStat(b bool)
  • func (this *Batch) Exec()
  • func (this *Batch) OnFail(callback func(err error))
• type DB
  • func NewDB(rawDB *sql.DB) *DB
  • func (this *DB) Begin() (*sql.Tx, error)
  • func (this *DB) Close() error
  • func (this *DB) EnableStat(b bool)
  • func (this *DB) Exec(query string, args ...interface{}) (sql.Result, error)
  • func (this *DB) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
  • func (this *DB) Prepare(query string) (*Stmt, error)
  • func (this *DB) Query(query string, args ...interface{}) (*sql.Rows, error)
  • func (this *DB) QueryRow(query string, args ...interface{}) *sql.Row
  • func (this *DB) RawDB() *sql.DB
• type QueryLabel
  • func NewQueryLabel(manager *QueryStatManager, query string) *QueryLabel
  • func (this *QueryLabel) End()
• type QueryStat
  • func NewQueryStat(query string) *QueryStat
  • func (this *QueryStat) AddCost(cost float64)
• type QueryStatManager
  • func NewQueryStatManager() *QueryStatManager
  • func (this *QueryStatManager) AddCost(query string, cost float64)
  • func (this *QueryStatManager) AddQuery(query string) *QueryLabel
  • func (this *QueryStatManager) TopN(n int) []*QueryStat
• type Stmt
  • func NewStmt(rawStmt *sql.Stmt, query string) *Stmt
  • func (this *Stmt) Close() error
  • func (this *Stmt) EnableStat()
  • func (this *Stmt) Exec(args ...interface{}) (sql.Result, error)
  • func (this *Stmt) ExecContext(ctx context.Context, args ...interface{}) (sql.Result, error)
  • func (this *Stmt) Query(args ...interface{}) (*sql.Rows, error)
  • func (this *Stmt) QueryContext(ctx context.Context, args ...interface{}) (*sql.Rows, error)
  • func (this *Stmt) QueryRow(args ...interface{}) *sql.Row
  • func (this *Stmt) QueryRowContext(ctx context.Context, args ...interface{}) *sql.Row

Variables

var SharedQueryStatManager = NewQueryStatManager()

Types

type Batch

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

func NewBatch

func NewBatch(db *sql.DB, n int) *Batch

func (*Batch) Add

func (this *Batch) Add(query string, args ...any)

func (*Batch) Close

func (this *Batch) Close()

func (*Batch) EnableStat

func (this *Batch) EnableStat(b bool)

func (*Batch) Exec

func (this *Batch) Exec()

func (*Batch) OnFail

func (this *Batch) OnFail(callback func(err error))

type DB

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

func NewDB

func NewDB(rawDB *sql.DB) *DB

func (*DB) Begin

func (this *DB) Begin() (*sql.Tx, error)

func (*DB) Close

func (this *DB) Close() error

func (*DB) EnableStat

func (this *DB) EnableStat(b bool)

func (*DB) Exec

func (this *DB) Exec(query string, args ...interface{}) (sql.Result, error)

func (*DB) ExecContext

func (this *DB) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func (*DB) Prepare

func (this *DB) Prepare(query string) (*Stmt, error)

func (*DB) Query

func (this *DB) Query(query string, args ...interface{}) (*sql.Rows, error)

func (*DB) QueryRow

func (this *DB) QueryRow(query string, args ...interface{}) *sql.Row

func (*DB) RawDB

func (this *DB) RawDB() *sql.DB

type QueryLabel

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

func NewQueryLabel

func NewQueryLabel(manager *QueryStatManager, query string) *QueryLabel

func (*QueryLabel) End

func (this *QueryLabel) End()

type QueryStat

type QueryStat struct {
	Query   string
	CostMin float64
	CostMax float64

	CostTotal float64
	Calls     int64
}

func NewQueryStat

func NewQueryStat(query string) *QueryStat

func (*QueryStat) AddCost

func (this *QueryStat) AddCost(cost float64)

type QueryStatManager

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

func NewQueryStatManager

func NewQueryStatManager() *QueryStatManager

func (*QueryStatManager) AddCost

func (this *QueryStatManager) AddCost(query string, cost float64)

func (*QueryStatManager) AddQuery

func (this *QueryStatManager) AddQuery(query string) *QueryLabel

func (*QueryStatManager) TopN

func (this *QueryStatManager) TopN(n int) []*QueryStat

type Stmt

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

func NewStmt

func NewStmt(rawStmt *sql.Stmt, query string) *Stmt

func (*Stmt) Close

func (this *Stmt) Close() error

func (*Stmt) EnableStat

func (this *Stmt) EnableStat()

func (*Stmt) Exec

func (this *Stmt) Exec(args ...interface{}) (sql.Result, error)

func (*Stmt) ExecContext

func (this *Stmt) ExecContext(ctx context.Context, args ...interface{}) (sql.Result, error)

func (*Stmt) Query

func (this *Stmt) Query(args ...interface{}) (*sql.Rows, error)

func (*Stmt) QueryContext

func (this *Stmt) QueryContext(ctx context.Context, args ...interface{}) (*sql.Rows, error)

func (*Stmt) QueryRow

func (this *Stmt) QueryRow(args ...interface{}) *sql.Row

func (*Stmt) QueryRowContext

func (this *Stmt) QueryRowContext(ctx context.Context, args ...interface{}) *sql.Row