dbs

Documentation

Index

• Constants
• Variables
• func IsClosedErr(err error) bool
• type Batch
  • func NewBatch(db *DB, n int) *Batch
  • func (this *Batch) Add(query string, args ...any)
  • 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, dsn string) *DB
  • func OpenReader(dsn string) (*DB, error)
  • func OpenWriter(dsn string) (*DB, error)
  • func (this *DB) Begin() (*sql.Tx, error)
  • func (this *DB) BeginUpdating() bool
  • func (this *DB) Close() error
  • func (this *DB) EnableStat(b bool)
  • func (this *DB) EndUpdating()
  • func (this *DB) Exec(query string, args ...any) (sql.Result, error)
  • func (this *DB) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
  • func (this *DB) Prepare(query string) (*Stmt, error)
  • func (this *DB) Query(query string, args ...any) (*sql.Rows, error)
  • func (this *DB) QueryRow(query string, args ...any) *sql.Row
  • func (this *DB) RawDB() *sql.DB
  • func (this *DB) SetMaxOpenConns(n int)
• 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(db *DB, rawStmt *sql.Stmt, query string) *Stmt
  • func (this *Stmt) Close() error
  • func (this *Stmt) EnableStat()
  • func (this *Stmt) Exec(args ...any) (result sql.Result, err error)
  • func (this *Stmt) ExecContext(ctx context.Context, args ...any) (result sql.Result, err error)
  • func (this *Stmt) Query(args ...any) (*sql.Rows, error)
  • func (this *Stmt) QueryContext(ctx context.Context, args ...any) (*sql.Rows, error)
  • func (this *Stmt) QueryRow(args ...any) *sql.Row
  • func (this *Stmt) QueryRowContext(ctx context.Context, args ...any) *sql.Row

Constants

const (
	SyncMode = "OFF"
)

Variables

var SharedQueryStatManager = NewQueryStatManager()

Functions

func IsClosedErr

func IsClosedErr(err error) bool

Types

type Batch

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

func NewBatch

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

func (*Batch) Add

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

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, dsn string) *DB

func OpenReader

func OpenReader(dsn string) (*DB, error)

func OpenWriter

func OpenWriter(dsn string) (*DB, error)

func (*DB) Begin

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

func (*DB) BeginUpdating

func (this *DB) BeginUpdating() bool

func (*DB) Close

func (this *DB) Close() error

Close the database

func (*DB) EnableStat

func (this *DB) EnableStat(b bool)

func (*DB) EndUpdating

func (this *DB) EndUpdating()

func (*DB) Exec

func (this *DB) Exec(query string, args ...any) (sql.Result, error)

func (*DB) ExecContext

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

func (*DB) Prepare

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

func (*DB) Query

func (this *DB) Query(query string, args ...any) (*sql.Rows, error)

func (*DB) QueryRow

func (this *DB) QueryRow(query string, args ...any) *sql.Row

func (*DB) RawDB

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

func (*DB) SetMaxOpenConns

func (this *DB) SetMaxOpenConns(n int)

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(db *DB, 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 ...any) (result sql.Result, err error)

func (*Stmt) ExecContext

func (this *Stmt) ExecContext(ctx context.Context, args ...any) (result sql.Result, err error)

func (*Stmt) Query

func (this *Stmt) Query(args ...any) (*sql.Rows, error)

func (*Stmt) QueryContext

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

func (*Stmt) QueryRow

func (this *Stmt) QueryRow(args ...any) *sql.Row

func (*Stmt) QueryRowContext

func (this *Stmt) QueryRowContext(ctx context.Context, args ...any) *sql.Row