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 SelectMap[ROW any, K comparable, V any](ctx context.Context, db bun.IDB, qfn func(*bun.SelectQuery) *bun.SelectQuery, ...) (map[K]V, error)
• func SelectMapRaw[ROW any, K comparable, V any](ctx context.Context, db bun.IDB, q string, args []any, ...) (map[K]V, error)
• func SelectOne[T any](ctx context.Context, db bun.IDB, q string, args []any) (T, error)
• func SelectPage[ROW any](ctx context.Context, db bun.IDB, p sdsql.Page, ...) (*sdsql.PagingResult[ROW], error)
• func Tx(ctx context.Context, db bun.IDB, action func(context.Context, bun.Tx) error, ...) error
• func TxFor[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, postProcs ...sdsql.RowsProc[ROW]) (ROW, error)

func SelectFirstRaw

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

func SelectMany

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

func SelectManyAndCount

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

func SelectManyRaw

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

func SelectMap

func SelectMap[ROW any, K comparable, V any](ctx context.Context, db bun.IDB, qfn func(*bun.SelectQuery) *bun.SelectQuery, transform func(ROW) (K, V), postProcs ...sdsql.RowsProc[ROW]) (map[K]V, error)

func SelectMapRaw

func SelectMapRaw[ROW any, K comparable, V any](ctx context.Context, db bun.IDB, q string, args []any, transform func(ROW) (K, V), postProcs ...sdsql.RowsProc[ROW]) (map[K]V, error)

func SelectOne

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

func SelectPage

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

func Tx

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

func TxFor

func TxFor[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"`
}