db

Documentation

Index

• func Diff[T any](a, b T) []string
• func Equal[T any](a, b T) bool
• func PkName(model any) (name string, err error)
• func UpdateDiff[T any](db *Db, prev, curr T) (columns []string, err error)
• type Db
  • func New(opt Options) *Db
  • func (o *Db) Close()
  • func (o *Db) Count(model any) (int, error)
  • func (o *Db) Delete(model any, fn func(*bun.DeleteQuery)) error
  • func (o *Db) DeleteAll(model any) error
  • func (o *Db) Exec(query string, arg ...any) error
  • func (o *Db) Exists(model any, fn func(*bun.SelectQuery)) (bool, error)
  • func (o *Db) ExistsPk(model any) (bool, error)
  • func (o *Db) Format(query string, arg ...any) string
  • func (o *Db) GetIfExists(model any, fn func(*bun.SelectQuery)) (bool, error)
  • func (o *Db) GetIfExistsPk(model any) (bool, error)
  • func (o *Db) Insert(model any) error
  • func (o *Db) Ok() bool
  • func (o *Db) Ping() bool
  • func (o *Db) Select(model any, fn func(*bun.SelectQuery)) error
  • func (o *Db) SelectAll(model any) error
  • func (o *Db) SelectIn(model any, ids any) error
  • func (o *Db) Truncate(model any) error
  • func (o *Db) Update(model any, fn func(*bun.UpdateQuery)) error
  • func (o *Db) UpdateAll(model any) error
  • func (o *Db) UpdateIn(model any, ids any) error
  • func (o *Db) Upsert(model any) error
  • func (o *Db) Wait(timeout time.Duration) bool
• type Options
• type Updater
  • func NewUpdater[T any](db *Db, v T) *Updater[T]
  • func (o *Updater[T]) Equal(v T) bool
  • func (o *Updater[T]) Last() T
  • func (o *Updater[T]) Update(v T) (columns []string, err error)

Functions

func Diff

func Diff[T any](a, b T) []string

func Equal

func Equal[T any](a, b T) bool

func PkName

func PkName(model any) (name string, err error)

func UpdateDiff

func UpdateDiff[T any](db *Db, prev, curr T) (columns []string, err error)

Types

type Db

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

func New

func New(opt Options) *Db

func (*Db) Close

func (o *Db) Close()

func (*Db) Count

func (o *Db) Count(model any) (int, error)

func (*Db) Delete

func (o *Db) Delete(model any, fn func(*bun.DeleteQuery)) error

func (*Db) DeleteAll

func (o *Db) DeleteAll(model any) error

func (*Db) Exec

func (o *Db) Exec(query string, arg ...any) error

func (*Db) Exists

func (o *Db) Exists(model any, fn func(*bun.SelectQuery)) (bool, error)

func (*Db) ExistsPk

func (o *Db) ExistsPk(model any) (bool, error)

func (*Db) Format

func (o *Db) Format(query string, arg ...any) string

func (*Db) GetIfExists

func (o *Db) GetIfExists(model any, fn func(*bun.SelectQuery)) (bool, error)

func (*Db) GetIfExistsPk

func (o *Db) GetIfExistsPk(model any) (bool, error)

func (*Db) Insert

func (o *Db) Insert(model any) error

func (*Db) Ok

func (o *Db) Ok() bool

func (*Db) Ping

func (o *Db) Ping() bool

func (*Db) Select

func (o *Db) Select(model any, fn func(*bun.SelectQuery)) error

func (*Db) SelectAll

func (o *Db) SelectAll(model any) error

func (*Db) SelectIn

func (o *Db) SelectIn(model any, ids any) error

func (*Db) Truncate

func (o *Db) Truncate(model any) error

func (*Db) Update

func (o *Db) Update(model any, fn func(*bun.UpdateQuery)) error

func (*Db) UpdateAll

func (o *Db) UpdateAll(model any) error

func (*Db) UpdateIn

func (o *Db) UpdateIn(model any, ids any) error

func (*Db) Upsert

func (o *Db) Upsert(model any) error

func (*Db) Wait

func (o *Db) Wait(timeout time.Duration) bool

type Options

type Options struct {
	User          string
	Pass          string
	Host          string
	Name          string
	Timeout       time.Duration
	MaxConnFactor float32
	MinOpenConns  int
	Strict        bool
	Insecure      bool
	LogErrors     bool
	LogQueries    bool
}

type Updater

type Updater[T any] struct {
	// contains filtered or unexported fields
}

func NewUpdater

func NewUpdater[T any](db *Db, v T) *Updater[T]

func (*Updater[T]) Equal

func (o *Updater[T]) Equal(v T) bool

func (*Updater[T]) Last

func (o *Updater[T]) Last() T

func (*Updater[T]) Update

func (o *Updater[T]) Update(v T) (columns []string, err error)