sdbun

Documentation

Overview

Package sdbun bun 扩展包

Index

• Variables
• func Count[ROW any](ctx context.Context, db bun.IDB, qfn func(*bun.SelectQuery) *bun.SelectQuery) (int64, error)
• func Delete[ROW any](ctx context.Context, db bun.IDB, ...) (sdsql.Result, error)
• func Dial(addr Address, opts ...bun.DBOption) (*bun.DB, error)
• func Exists[ROW any](ctx context.Context, db bun.IDB, qfn func(*bun.SelectQuery) *bun.SelectQuery) (bool, error)
• func Insert(ctx context.Context, db bun.IDB, v any, ...) (sdsql.Result, error)
• func LoggerOf(name string) bun.QueryHook
• func PageApplier(p sdsql.Page) func(*bun.SelectQuery) *bun.SelectQuery
• func SelectFirst[ROW any](ctx context.Context, db bun.IDB, qfn func(*bun.SelectQuery) *bun.SelectQuery) (ROW, error)
• func SelectFirstRaw[ROW any](ctx context.Context, db bun.IDB, q string, args []any) (ROW, error)
• func SelectMany[ROW any](ctx context.Context, db bun.IDB, qfn func(*bun.SelectQuery) *bun.SelectQuery) ([]ROW, error)
• func SelectManyAndCount[ROW any](ctx context.Context, db bun.IDB, qfn func(*bun.SelectQuery) *bun.SelectQuery) ([]ROW, int64, error)
• func SelectManyRaw[ROW any](ctx context.Context, db bun.IDB, q string, args []any) ([]ROW, error)
• func SelectOne[T any](ctx context.Context, db bun.IDB, q string, args []any) (T, error)
• func SelectPaging[ROW any](ctx context.Context, db bun.IDB, p sdsql.Page, ...) (*sdsql.PagingResult[ROW], error)
• func Transaction(ctx context.Context, db bun.IDB, action func(context.Context, bun.Tx) error, ...) error
• func TransactionFor[R any](ctx context.Context, db bun.IDB, ...) (R, error)
• func Update(ctx context.Context, db bun.IDB, v any, ...) (sdsql.Result, error)
• type Address

Variables

var (
	ErrIllegalDriver = sderr.Sentinel("illegal driver")
)

Functions

func Count

func Count[ROW any](ctx context.Context, db bun.IDB, qfn func(*bun.SelectQuery) *bun.SelectQuery) (int64, error)

func Delete

func Delete[ROW any](ctx context.Context, db bun.IDB, qfn func(query *bun.DeleteQuery) *bun.DeleteQuery) (sdsql.Result, error)

func Dial

func Dial(addr Address, opts ...bun.DBOption) (*bun.DB, error)

func Exists

func Exists[ROW any](ctx context.Context, db bun.IDB, qfn func(*bun.SelectQuery) *bun.SelectQuery) (bool, error)

func Insert

func Insert(ctx context.Context, db bun.IDB, v any, qfn func(query *bun.InsertQuery) *bun.InsertQuery) (sdsql.Result, error)

func LoggerOf

func LoggerOf(name string) bun.QueryHook

func PageApplier

func PageApplier(p sdsql.Page) func(*bun.SelectQuery) *bun.SelectQuery

func SelectFirst

func SelectFirst[ROW any](ctx context.Context, db bun.IDB, qfn func(*bun.SelectQuery) *bun.SelectQuery) (ROW, error)

func SelectFirstRaw

func SelectFirstRaw[ROW any](ctx context.Context, db bun.IDB, q string, args []any) (ROW, error)

func SelectMany

func SelectMany[ROW any](ctx context.Context, db bun.IDB, qfn func(*bun.SelectQuery) *bun.SelectQuery) ([]ROW, error)

func SelectManyAndCount

func SelectManyAndCount[ROW any](ctx context.Context, db bun.IDB, qfn func(*bun.SelectQuery) *bun.SelectQuery) ([]ROW, int64, error)

func SelectManyRaw

func SelectManyRaw[ROW any](ctx context.Context, db bun.IDB, q string, args []any) ([]ROW, error)

func SelectOne

func SelectOne[T any](ctx context.Context, db bun.IDB, q string, args []any) (T, error)

func SelectPaging

func SelectPaging[ROW any](ctx context.Context, db bun.IDB, p sdsql.Page, qfn func(*bun.SelectQuery) *bun.SelectQuery) (*sdsql.PagingResult[ROW], error)

func Transaction

func Transaction(ctx context.Context, db bun.IDB, action func(context.Context, bun.Tx) error, opts *sql.TxOptions) error

func TransactionFor

func TransactionFor[R any](ctx context.Context, db bun.IDB, action func(context.Context, bun.Tx) (R, error), opts *sql.TxOptions) (R, error)

func Update

func Update(ctx context.Context, db bun.IDB, v any, qfn func(query *bun.UpdateQuery) *bun.UpdateQuery) (sdsql.Result, error)

Types

type Address

type Address struct {
	// common
	Driver string `json:"driver" toml:"driver" yaml:"driver"`
	DSN    string `json:"dsn" toml:"dsn" yaml:"dsn"`
	Logger string `json:"logger" toml:"logger"`

	// options
	ConnMaxLifeTimeMS int64 `json:"conn_max_lifetime" toml:"conn_max_lifetime" yaml:"conn_max_lifetime"`
	ConnMaxIdleTimeMS int64 `json:"conn_max_idle_time" toml:"conn_max_idle_time" yaml:"conn_max_idle_time"`
	MaxIdleConns      int   `json:"max_idle_conns" toml:"max_idle_conns" yaml:"max_idle_conns"`
	MaxOpenConns      int   `json:"max_open_conns" toml:"max_open_conns" yaml:"max_open_conns"`
}