db

Documentation

Index

• func Count[T any](o *Db) (int, error)
• func Delete[T any](o *Db, fn func(*bun.DeleteQuery)) (int64, error)
• func DeleteAll[T any](o *Db) (int64, error)
• 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) Await(timeout time.Duration) time.Duration
  • func (o *Db) Close()
  • func (o *Db) Count(model any) (int, error)
  • func (o *Db) Delete(model any, fn func(*bun.DeleteQuery)) (int64, error)
  • func (o *Db) DeleteAll(model any) (int64, 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) Migrator() *Migrator
  • func (o *Db) NewSelect(model any) *bun.SelectQuery
  • func (o *Db) Ok() bool
  • func (o *Db) Ping() bool
  • func (o *Db) Scan(model any, query string, arg ...any) error
  • 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) SelectPk(model 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) UpdatePk(model any) error
  • func (o *Db) Upsert(model any) error
  • func (o *Db) Wait(timeout time.Duration) bool
• type Migrator
  • func NewMigrator(d *Db) *Migrator
  • func (o *Migrator) Exec(fs fs.FS, lock bool, rollbackLast bool, previewDown bool, repairDown bool) (ok bool)
  • func (o *Migrator) WithAutoDownSql(v bool) *Migrator
  • func (o *Migrator) WithMarkAppliedOnSuccess(v bool) *Migrator
  • func (o *Migrator) WithRollbackLost(v bool) *Migrator
  • func (o *Migrator) WithSaveDownSql(v bool) *Migrator
• 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 Count

func Count[T any](o *Db) (int, error)

func Delete

func Delete[T any](o *Db, fn func(*bun.DeleteQuery)) (int64, error)

func DeleteAll

func DeleteAll[T any](o *Db) (int64, error)

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) Await

func (o *Db) Await(timeout time.Duration) time.Duration

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)) (int64, error)

func (*Db) DeleteAll

func (o *Db) DeleteAll(model any) (int64, 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) Migrator

func (o *Db) Migrator() *Migrator

func (*Db) NewSelect

func (o *Db) NewSelect(model any) *bun.SelectQuery

func (*Db) Ok

func (o *Db) Ok() bool

func (*Db) Ping

func (o *Db) Ping() bool

func (*Db) Scan

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

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) SelectPk

func (o *Db) SelectPk(model 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) UpdatePk

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

func (*Db) Upsert

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

func (*Db) Wait

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

type Migrator

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

func NewMigrator

func NewMigrator(d *Db) *Migrator

func (*Migrator) Exec

func (o *Migrator) Exec(fs fs.FS, lock bool, rollbackLast bool, previewDown bool, repairDown bool) (ok bool)

func (*Migrator) WithAutoDownSql

func (o *Migrator) WithAutoDownSql(v bool) *Migrator

func (*Migrator) WithMarkAppliedOnSuccess

func (o *Migrator) WithMarkAppliedOnSuccess(v bool) *Migrator

func (*Migrator) WithRollbackLost

func (o *Migrator) WithRollbackLost(v bool) *Migrator

func (*Migrator) WithSaveDownSql

func (o *Migrator) WithSaveDownSql(v bool) *Migrator

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
	ReadOnly      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)