dba

Aug 6, 2026

Changes in this version

+ const O

+ type Formatter func(idx int) string

type Node

+ Text string

type RenderCtx

+ Bind func(v any) error

+ Render func(n Node) error

type SQL

+ func (d *SQL) Formatter(formatter Formatter) *SQL

+ func (d *SQL) GetMap() (map[string]any, bool, error)

+ func (d *SQL) ListMap() ([]map[string]any, error)

Aug 4, 2026

Changes in this version

+ type LogFunc func(ctx context.Context, begin time.Time, query string, args []any, err error)

+ func NewLogger(logger *slog.Logger, slowThreshold time.Duration, doClean bool) LogFunc

type SQL

+ func (d *SQL) SetLogger(fn LogFunc) *SQL

Aug 2, 2026

Changes in this version

type RenderCtx

+ Resolve func(key string) (any, error)

Aug 2, 2026

Changes in this version

+ type Pipe func(ctx RenderCtx, v any) error

+ type RenderCtx interface

+ AddParam func(v any)

+ QuoteIdent func(s string)

+ WriteString func(s string)

type SQL

+ func (d *SQL) RegisterMacro(prefix byte, pipe string) *SQL

+ func (d *SQL) RegisterPipe(name string, fn Pipe) *SQL

Aug 2, 2026

Changes in this version

+ type Arg interface

+ WriteTo func(w ArgWriter) error

+ func ExpandOrNull[T any](v []T) Arg

+ func Expand[T any](v []T) Arg

+ func Null() Arg

+ func Raw(s string) Arg

+ type ArgWriter interface

+ AddParam func(v any)

+ WriteString func(s string)

Aug 2, 2026

Changes in this version

+ func ColumnsAndValues(model any, omitempty bool) ([]string, []any, error)

Aug 2, 2026

Changes in this version

+ const F

+ const I

+ func AnsiQuoter(s string) string

+ func DollarFormat(idx int) string

+ func GroupBy[T any, K comparable](slice []T, fn func(T) K) map[K][]T

+ func IndexBy[T any, K comparable](slice []T, fn func(T) K) (map[K]T, error)

+ func IsOk(v any) bool

+ func Map[T any, R any](slice []T, fn func(T) R) []R

+ func MySQLQuoter(s string) string

+ func Page[T any](q *SQL, page, size int) ([]T, int64, error)

+ func QmarkFormat(_ int) string

+ func Scalar[T any](d *SQL) (T, bool, error)

+ func ToKeyValue(model any, omitempty bool) ([]string, []any, error)

+ type BeforeCreate interface

+ BeforeCreate func() error

+ type BeforeUpdate interface

+ BeforeUpdate func() error

+ type Dao struct

+ func NewDao[T any](q *SQL, table string) *Dao[T]

+ func (d *Dao[T]) All() ([]T, error)

+ func (d *Dao[T]) Batch(entities []T) (int64, error)

+ func (d *Dao[T]) Count(where string, args ...any) (int64, error)

+ func (d *Dao[T]) CountAll() (int64, error)

+ func (d *Dao[T]) Create(data any) (int64, error)

+ func (d *Dao[T]) Delete(where string, args ...any) (int64, error)

+ func (d *Dao[T]) Exists(where string, args ...any) (bool, error)

+ func (d *Dao[T]) Get(where string, args ...any) (*T, error)

+ func (d *Dao[T]) GetByID(id any) (*T, error)

+ func (d *Dao[T]) List(where string, args ...any) ([]T, error)

+ func (d *Dao[T]) PK(pk string) *Dao[T]

+ func (d *Dao[T]) Page(page, size int, where string, args ...any) ([]T, int64, error)

+ func (d *Dao[T]) RawBatch(entities []T) *SQL

+ func (d *Dao[T]) RawCreate(data any) *SQL

+ func (d *Dao[T]) RawSelect(where string, args ...any) *SQL

+ func (d *Dao[T]) SQL() *SQL

+ func (d *Dao[T]) Table(table string) *Dao[T]

+ func (d *Dao[T]) Update(data any, where string, args ...any) (int64, error)

+ func (d *Dao[T]) Vars(alias string) map[string]Node

+ func (d *Dao[T]) WithCtx(ctx context.Context) *Dao[T]

+ func (d *Dao[T]) WithTx(tx *SQL) *Dao[T]

+ type ExecFunc func(ctx context.Context, query string, args []any) (any, error)

+ type Formater func(idx int) string

+ type H = map[string]any

+ type Hook func(next ExecFunc) ExecFunc

+ func LogHook(logger *slog.Logger, slowThreshold time.Duration, cleanSpec bool) Hook

+ type Node struct

+ Args []any

+ RawSQL string

+ type Quoter func(string) string

+ type SQL struct

+ func NewFromSqlx(db *sqlx.DB) *SQL

+ func Open(driver, dsn string) (*SQL, error)

+ func (d *SQL) Add(query string, args ...any) *SQL

+ func (d *SQL) AddIf(cond bool, query string, args ...any) *SQL

+ func (d *SQL) Batch(rows [][]any) *SQL

+ func (d *SQL) BatchInsert(table string, entities []any) *SQL

+ func (d *SQL) Begin() (*SQL, error)

+ func (d *SQL) Close() error

+ func (d *SQL) Commit() error

+ func (d *SQL) Delete(table string, where string, args ...any) *SQL

+ func (d *SQL) Error() error

+ func (d *SQL) Exec() (sql.Result, error)

+ func (d *SQL) Formater(formatter Formater) *SQL

+ func (d *SQL) Get(dest any) (found bool, err error)

+ func (d *SQL) Insert(table string, data any) *SQL

+ func (d *SQL) List(dest interface{}) error

+ func (d *SQL) Pool() *sqlx.DB

+ func (d *SQL) Quoter(quoter Quoter) *SQL

+ func (d *SQL) Rollback() error

+ func (d *SQL) Rows() (*sqlx.Rows, error)

+ func (d *SQL) Select(table string, where string, args ...any) *SQL

+ func (d *SQL) ToSQL() (string, []any, error)

+ func (d *SQL) Transaction(fn func(*SQL) error) error

+ func (d *SQL) Unsafe() *SQL

+ func (d *SQL) Update(table string, data any, where string, args ...any) *SQL

+ func (d *SQL) Use(mw ...Hook) *SQL

+ func (d *SQL) Var(key string, query string, args ...any) *SQL

+ func (d *SQL) Vars(vars map[string]Node) *SQL

+ func (d *SQL) WithCtx(ctx context.Context) *SQL

+ type SQLExpr struct

+ Args []any

+ Sql string

+ func Expr(sql string, args ...any) SQLExpr

+ type TableDef struct

+ func Table(table, alias string) *TableDef

+ func (t *TableDef) Alias(alias string) *TableDef

+ func (t *TableDef) Build() map[string]Node

+ func (t *TableDef) Fields(fields ...string) *TableDef

+ func (t *TableDef) Struct(model any) *TableDef