sql

Oct 10, 2026

Changes in this version

+ var ErrNoColumn = errors.New("column does not exist")

Oct 9, 2026

Changes in this version

type Driver

+ Dialect func() string

Sep 28, 2026

Changes in this version

+ type DefaultSorted interface

+ DefaultSort func() []string

type View

+ func NewView(base fromTable, joins ...fromOptions) *View

+ func (v *View) Column(name string, expr string) *View

Sep 19, 2026

Changes in this version

+ func InTransaction(ctx context.Context, db Db, do func(ctx context.Context) error) (err error)

+ func NewTransaction(db Db) *transaction

Sep 1, 2026

Changes in this version

+ var ErrArgumentsMismatch = errors.New("number of placeholders does not match number of arguments")

+ var ErrBadRequest = errors.New("bad request")

+ var ErrCannotCommitTransaction = errors.New("unable to commit a transaction")

+ var ErrCannotConnectDb = errors.New("unable to connect to a db")

+ var ErrCannotCreateSavepoint = errors.New("unable to create a savepoint")

+ var ErrCannotReleaseSavepoint = errors.New("unable to release a savepoint")

+ var ErrCannotRollbackSavepoint = errors.New("unable to rollback a savepoint")

+ var ErrCannotRollbackTransaction = errors.New("unable to rollback a transaction")

+ var ErrCannotStartTx = errors.New("unable to start a transaction")

+ var ErrConflict = errors.New("duplicate key value violates unique constraint")

+ var ErrDeadlock = errors.New("deadlock")

+ var ErrExprBuilderNotImplemented = errors.New("expression builder is not defined")

+ var ErrInternal = errors.New("internal error")

+ var ErrNoRows = errors.New("no rows in result set")

+ var ErrNoTransactionInContext = errors.New("no started transaction in context")

+ var ErrQueryFailed = errors.New("query failed")

+ var ErrUnsupportedQueryMode = errors.New("unsupported query mode")

+ var Expr = Plain

+ func Delete() *deleteQuery

+ func FromError(err error) (*e, bool)

+ func Insert(fields ...string) *insertQuery

+ func Join(f fromMain, condition string) fromOptions

+ func JoinCsv(v []string) *string

+ func LeftJoin(f fromMain, condition string) fromOptions

+ func NewContextWithTransaction(ctx context.Context, connection Db) (_ context.Context, commit func() error, rollback func() error, _ error)

+ func NewError(err error) error

+ func NewRepository[Model any, _ ScannableModel[Model]](connection Db, opts ...repositoryOption) (*repository[Model], error)

+ func NewStorage[Model any, scan ScannableModel[Model]](connection Db, from *from, opts ...repositoryOption) (*storage[Model], error)

+ func Plain(query string, params ...any) *plainBuilder

+ func Query(q SelectQuery, alias string) fromQuery

+ func RightJoin(f fromMain, condition string) fromOptions

+ func Select(fields ...string) *selectQuery

+ func SplitCsv(v *string) []string

+ func Table(table string) fromTable

+ func Update(values map[string]any) *updateQuery

+ func WithExtraMapping(mapping map[string]string) repositoryOption

+ type BuildOption func(*builderCfg) error

+ func WithMappings(mappings map[string]string) BuildOption

+ type Builder interface

+ Build func(driver Driver, opts ...BuildOption) (string, []any, error)

+ type CountBuilder interface

+ type CountQuery interface

+ From func(main fromMain, opts ...fromOptions) CountQuery

+ Returning func(fields ...string) CountQuery

+ Where func(query criteria.Expression) CountQuery

+ func Count() CountQuery

+ type Db interface

+ Begin func(ctx context.Context) (Tx, error)

+ Connect func(ctx context.Context) (Db, error)

+ DbSql func() (*dbSql.DB, error)

+ Driver func() Driver

+ func NewDb(driver, dsn string) (Db, error)

+ type DeleteBuilder interface

+ type DeleteQuery interface

+ From func(main fromTable, opts ...fromOptions) DeleteQuery

+ Where func(query criteria.Expression) DeleteQuery

+ type Driver interface

+ Conflict func(conflict string, updates []string) string

+ Field func(field string, operation string, value any, params *[]any) (string, *[]any, error)

+ Placeholder func(pos int) string

+ Returning func() bool

+ UpdateAsJoin func() bool

+ type Field string

+ type InsertQuery interface

+ Conflict func(conflict string, excluded ...string) InsertQuery

+ From func(main fromMain, opts ...fromOptions) InsertQuery

+ Into func(table fromTable) InsertQuery

+ Returning func(fields ...string) InsertQuery

+ Values func(values ...any) InsertQuery

+ type Json struct

+ func NewJson[T any](value T) *Json[T]

+ func (f *Json[T]) MarshalJSON() ([]byte, error)

+ func (f *Json[T]) Scan(value any) error

+ func (f *Json[T]) UnmarshalJSON(value []byte) error

+ func (f *Json[T]) Unwrap() T

+ func (f *Json[T]) Value() (driver.Value, error)

+ func (j *Json[T]) ScanText(v pgtype.Text) error

+ func (j Json[T]) TextValue() (pgtype.Text, error)

+ type Mappable interface

+ Mappings func() map[string]string

+ type PoolTracing struct

+ func NewPoolTracing(provider hilton.Provider, db Db) (*PoolTracing, error)

+ func (t *PoolTracing) Close() error

+ type Repository interface

+ Count func(ctx context.Context, query CountBuilder) (int, error)

+ Delete func(ctx context.Context, builder DeleteBuilder) error

+ Get func(ctx context.Context, builder Builder) (*Model, error)

+ Select func(ctx context.Context, builder Builder) ([]*Model, error)

+ type Result interface

+ RowsAffected func() int64

+ type Returnable interface

+ Returns func() []string

+ type Row interface

+ Scan func(dest ...any) error

+ type Rows interface

+ Close func()

+ Err func() error

+ Next func() bool

+ Scan func(dest ...any) error

+ type Scannable interface

+ Scan func() []any

+ type ScannableModel interface

+ type SelectQuery interface

+ From func(main fromMain, opts ...fromOptions) SelectQuery

+ Group func(fields ...string) SelectQuery

+ Page func(page int, count int) SelectQuery

+ Returning func(fields ...string) SelectQuery

+ Sort func(sort ...string) SelectQuery

+ Where func(query criteria.Expression) SelectQuery

+ Window func(window string) SelectQuery

+ type Storage interface

+ Create func(ctx context.Context, model *Model) (*Model, error)

+ Remove func(ctx context.Context, expr criteria.Expression) error

+ Update func(ctx context.Context, model *Model) (*Model, error)

+ type Transactional interface

+ Begin func(ctx context.Context) (childCtx context.Context, commit func() error, rollback func() error, ...)

+ type Tx interface

+ Commit func(ctx context.Context) error

+ Exec func(ctx context.Context, query string, args ...any) (Result, error)

+ Query func(ctx context.Context, query string, args ...any) (Rows, error)

+ QueryRow func(ctx context.Context, query string, args ...any) Row

+ Rollback func(ctx context.Context) error

+ func TransactionFromContext(ctx context.Context) (Tx, error)

+ type UpdateQuery interface

+ From func(opts ...fromOptions) UpdateQuery

+ Returning func(fields ...string) UpdateQuery

+ Table func(table fromTable) UpdateQuery

+ Where func(query criteria.Expression) UpdateQuery

+ type Value any

+ type Valueable interface

+ func Between(field string, from, to any) Valueable

+ func Eq(field string, value any) Valueable

+ func Ge(field string, value any) Valueable

+ func Gt(field string, value any) Valueable

+ func ILike(field string, value any) Valueable

+ func JsonEq(field string, value any) Valueable

+ func JsonIn(field string, value any) Valueable

+ func Le(field string, value any) Valueable

+ func Like(field string, value any) Valueable

+ func Lt(field string, value any) Valueable

+ func Ne(field string, value any) Valueable

+ type Valuer interface

+ Value func() (Value, error)

+ type View interface

+ Count func(ctx context.Context, expr criteria.Expression) (int, error)

+ Find func(ctx context.Context, expr criteria.Expression) ([]*Model, error)

+ Get func(ctx context.Context, expr criteria.Expression) (*Model, error)

+ Repository func() Repository[Model]