sqlite

package
v0.20.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 12, 2023 License: MIT Imports: 19 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Delete

func Delete(queryMods ...bob.Mod[*dialect.DeleteQuery]) bob.BaseQuery[*dialect.DeleteQuery]

func F

func F(name string, args ...any) *dialect.Function

F creates a function expression with the given name and args

SQL: generate_series(1, 3)
Go: psql.F("generate_series", 1, 3)

func Insert

func Insert(queryMods ...bob.Mod[*dialect.InsertQuery]) bob.BaseQuery[*dialect.InsertQuery]

func RawQuery

func RawQuery(q string, args ...any) bob.BaseQuery[expr.Clause]

func Select

func Select(queryMods ...bob.Mod[*dialect.SelectQuery]) bob.BaseQuery[*dialect.SelectQuery]

func Update

func Update(queryMods ...bob.Mod[*dialect.UpdateQuery]) bob.BaseQuery[*dialect.UpdateQuery]

func UseSchema added in v0.15.0

func UseSchema(ctx context.Context, schema string) context.Context

UseSchema modifies a context to add a schema that will be used when a tablle/view was generated with an empty schema

Types

type Expression added in v0.2.0

type Expression = dialect.Expression

func And

func And(args ...bob.Expression) Expression

SQL: a AND b AND c Go: psql.And("a", "b", "c")

func Arg

func Arg(args ...any) Expression

SQL: $1, $2, $3 Go: psql.Args("a", "b", "c")

func ArgGroup added in v0.15.0

func ArgGroup(args ...any) Expression

SQL: ($1, $2, $3) Go: psql.ArgGroup("a", "b", "c")

func Concat

func Concat(args ...bob.Expression) Expression

SQL: a || b || c Go: psql.Concat("a", "b", "c")

func Group

func Group(exps ...bob.Expression) Expression

SQL: (a, b) Go: psql.Group("a", "b")

func Not

func Not(exp bob.Expression) Expression

SQL: NOT true Go: psql.Not("true")

func Or

func Or(args ...bob.Expression) Expression

SQL: a OR b OR c Go: psql.Or("a", "b", "c")

func Placeholder

func Placeholder(n uint) Expression

SQL: $1, $2, $3 Go: psql.Placeholder(3)

func Quote

func Quote(ss ...string) Expression

SQL: "table"."column" Go: psql.Quote("table", "column")

func Raw

func Raw(query string, args ...any) Expression

SQL: where a = $1 Go: psql.Raw("where a = ?", "something")

func S

func S(s string) Expression

S creates a string literal SQL: 'a string' Go: psql.S("a string")

type Filterable added in v0.15.0

type Filterable interface {
	AppendWhere(...any)
}

type Loader added in v0.15.0

Loader builds a query mod that makes an extra query after the object is retrieved it can be used to prevent N+1 queries by loading relationships in batches

type PreloadOption added in v0.15.0

type PreloadOption = internal.PreloadOption[*dialect.SelectQuery]

Modifies preloading relationships

func PreloadExcept added in v0.20.0

func PreloadExcept(cols ...string) PreloadOption

func PreloadOnly added in v0.20.0

func PreloadOnly(cols ...string) PreloadOption

func PreloadWhere added in v0.20.0

func PreloadWhere(f ...func(from, to string) []bob.Expression) PreloadOption

type PreloadSettings added in v0.19.0

type PreloadSettings = internal.PreloadSettings[*dialect.SelectQuery]

Settings for preloading relationships

type Preloader added in v0.15.0

type Preloader = internal.Preloader[*dialect.SelectQuery]

Preloader builds a query mod that modifies the original query to retrieve related fields while it can be used as a queryMod, it does not have any direct effect. if using manually, the ApplyPreload method should be called with the query's context AFTER other mods have been applied

func Preload added in v0.15.0

func Preload[T any, Ts ~[]T](rel orm.Relationship, cols []string, opts ...PreloadOption) Preloader

type Table added in v0.15.0

type Table[T any, Tslice ~[]T, Tset any] struct {
	*View[T, Tslice]

	BeforeInsertHooks orm.Hooks[Tset]
	AfterInsertHooks  orm.Hooks[T]

	BeforeUpsertHooks orm.Hooks[Tset]
	AfterUpsertHooks  orm.Hooks[T]

	BeforeUpdateHooks orm.Hooks[T]
	AfterUpdateHooks  orm.Hooks[T]

	BeforeDeleteHooks orm.Hooks[T]
	AfterDeleteHooks  orm.Hooks[T]
	// contains filtered or unexported fields
}

The table contains extract information from the struct and contains caches ???

func NewTable added in v0.15.0

func NewTable[T any, Tset any](schema, tableName string) *Table[T, []T, Tset]

func NewTablex added in v0.15.0

func NewTablex[T any, Tslice ~[]T, Tset any](schema, tableName string) *Table[T, Tslice, Tset]

func (*Table[T, Tslice, Tset]) Delete added in v0.15.0

func (t *Table[T, Tslice, Tset]) Delete(ctx context.Context, exec bob.Executor, row T) (int64, error)

Deletes the given model if columns is nil, every column is deleted

func (*Table[T, Tslice, Tset]) DeleteMany added in v0.15.0

func (t *Table[T, Tslice, Tset]) DeleteMany(ctx context.Context, exec bob.Executor, rows ...T) (int64, error)

Deletes the given models if columns is nil, every column is deleted

func (*Table[T, Tslice, Tset]) Insert added in v0.15.0

func (t *Table[T, Tslice, Tset]) Insert(ctx context.Context, exec bob.Executor, row Tset) (T, error)

Insert inserts a row into the table with only the set columns in Tset

func (*Table[T, Tslice, Tset]) InsertMany added in v0.15.0

func (t *Table[T, Tslice, Tset]) InsertMany(ctx context.Context, exec bob.Executor, rows ...Tset) (Tslice, error)

Insert inserts a row into the table with only the set columns in Tset

func (*Table[T, Tslice, Tset]) Query added in v0.15.0

func (t *Table[T, Tslice, Tset]) Query(ctx context.Context, exec bob.Executor, queryMods ...bob.Mod[*dialect.SelectQuery]) *TableQuery[T, Tslice, Tset]

Adds table name et al

func (*Table[T, Tslice, Tset]) Update added in v0.15.0

func (t *Table[T, Tslice, Tset]) Update(ctx context.Context, exec bob.Executor, row T, cols ...string) (int64, error)

Updates the given model if columns is nil, every non-primary-key column is updated NOTE: values from the DB are not refreshed into the model

func (*Table[T, Tslice, Tset]) UpdateMany added in v0.15.0

func (t *Table[T, Tslice, Tset]) UpdateMany(ctx context.Context, exec bob.Executor, vals Tset, rows ...T) (int64, error)

Updates the given models if columns is nil, every column is updated NOTE: values from the DB are not refreshed into the models

func (*Table[T, Tslice, Tset]) Upsert added in v0.15.0

func (t *Table[T, Tslice, Tset]) Upsert(ctx context.Context, exec bob.Executor, updateOnConflict bool, conflictCols, updateCols []string, row Tset) (T, error)

Uses the setional columns to know what to insert If conflictCols is nil, it uses the primary key columns If updateCols is nil, it updates all the columns set in Tset if no column is set in Tset (i.e. INSERT DEFAULT VALUES), then it upserts all NonPK columns

func (*Table[T, Tslice, Tset]) UpsertMany added in v0.15.0

func (t *Table[T, Tslice, Tset]) UpsertMany(ctx context.Context, exec bob.Executor, updateOnConflict bool, conflictCols, updateCols []string, rows ...Tset) (Tslice, error)

Uses the setional columns to know what to insert If conflictCols is nil, it uses the primary key columns If updateCols is nil, it updates all the columns set in Tset if no column is set in Tset (i.e. INSERT DEFAULT VALUES), then it upserts all NonPK columns

type TableQuery added in v0.15.0

type TableQuery[T any, Ts ~[]T, Tset any] struct {
	ViewQuery[T, Ts]
	// contains filtered or unexported fields
}

func (*TableQuery[T, Tslice, Tset]) DeleteAll added in v0.15.0

func (t *TableQuery[T, Tslice, Tset]) DeleteAll() (int64, error)

DeleteAll deletes all rows matched by the current query NOTE: Hooks cannot be run since the values are never retrieved

func (*TableQuery[T, Tslice, Tset]) UpdateAll added in v0.15.0

func (t *TableQuery[T, Tslice, Tset]) UpdateAll(vals Tset) (int64, error)

UpdateAll updates all rows matched by the current query NOTE: Hooks cannot be run since the values are never retrieved

type View added in v0.15.0

type View[T any, Tslice ~[]T] struct {
	AfterSelectHooks orm.Hooks[T]
	// contains filtered or unexported fields
}

func NewView added in v0.15.0

func NewView[T any](schema, tableName string) *View[T, []T]

func NewViewx added in v0.15.0

func NewViewx[T any, Tslice ~[]T](schema, tableName string) *View[T, Tslice]

func (*View[T, Tslice]) Columns added in v0.15.0

func (v *View[T, Tslice]) Columns() orm.Columns

Returns a column list

func (*View[T, Tslice]) Name added in v0.15.0

func (v *View[T, Tslice]) Name(ctx context.Context) Expression

func (*View[T, Tslice]) NameAs added in v0.15.0

func (v *View[T, Tslice]) NameAs(ctx context.Context) bob.Expression

func (*View[T, Tslice]) Prepare added in v0.15.0

func (v *View[T, Tslice]) Prepare(ctx context.Context, exec bob.Preparer, queryMods ...bob.Mod[*dialect.SelectQuery]) (bob.QueryStmt[T, Tslice], error)

Prepare a statement that will be mapped to the view's type

func (*View[T, Tslice]) PrepareQuery added in v0.15.0

func (v *View[T, Tslice]) PrepareQuery(ctx context.Context, exec bob.Preparer, q bob.Query) (bob.QueryStmt[T, Tslice], error)

Prepare a statement from an existing query that will be mapped to the view's type

func (*View[T, Tslice]) Query added in v0.15.0

func (v *View[T, Tslice]) Query(ctx context.Context, exec bob.Executor, queryMods ...bob.Mod[*dialect.SelectQuery]) *ViewQuery[T, Tslice]

Adds table name et al

type ViewQuery added in v0.15.0

type ViewQuery[T any, Ts ~[]T] struct {
	bob.BaseQuery[*dialect.SelectQuery]
	// contains filtered or unexported fields
}

func (*ViewQuery[T, Tslice]) All added in v0.15.0

func (v *ViewQuery[T, Tslice]) All() (Tslice, error)

All matching rows

func (*ViewQuery[T, Tslice]) Count added in v0.15.0

func (v *ViewQuery[T, Tslice]) Count() (int64, error)

Count the number of matching rows

func (*ViewQuery[T, Tslice]) Cursor added in v0.15.0

func (v *ViewQuery[T, Tslice]) Cursor() (scan.ICursor[T], error)

Cursor to scan through the results

func (*ViewQuery[T, Tslice]) Exists added in v0.15.0

func (v *ViewQuery[T, Tslice]) Exists() (bool, error)

Exists checks if there is any matching row

func (*ViewQuery[T, Tslice]) One added in v0.15.0

func (v *ViewQuery[T, Tslice]) One() (T, error)

First matching row

func (ViewQuery[T, Ts]) WriteQuery added in v0.15.0

func (v ViewQuery[T, Ts]) WriteQuery(w io.Writer, start int) ([]any, error)

it is necessary to override this method to be able to add columns if not set

func (ViewQuery[T, Ts]) WriteSQL added in v0.15.0

func (v ViewQuery[T, Ts]) WriteSQL(w io.Writer, _ bob.Dialect, start int) ([]any, error)

it is necessary to override this method to be able to add columns if not set

type WhereMod added in v0.15.0

type WhereMod[Q Filterable, C any] struct {
	// contains filtered or unexported fields
}

func Where added in v0.15.0

func Where[Q Filterable, C any](name Expression) WhereMod[Q, C]

func (WhereMod[Q, C]) EQ added in v0.15.0

func (w WhereMod[Q, C]) EQ(val C) bob.Mod[Q]

func (WhereMod[Q, C]) GT added in v0.15.0

func (w WhereMod[Q, C]) GT(val C) bob.Mod[Q]

func (WhereMod[Q, C]) GTE added in v0.15.0

func (w WhereMod[Q, C]) GTE(val C) bob.Mod[Q]

func (WhereMod[Q, C]) In added in v0.15.0

func (w WhereMod[Q, C]) In(slice ...C) bob.Mod[Q]

func (WhereMod[Q, C]) LT added in v0.15.0

func (w WhereMod[Q, C]) LT(val C) bob.Mod[Q]

func (WhereMod[Q, C]) LTE added in v0.15.0

func (w WhereMod[Q, C]) LTE(val C) bob.Mod[Q]

func (WhereMod[Q, C]) Like added in v0.19.0

func (w WhereMod[Q, C]) Like(val C) bob.Mod[Q]

func (WhereMod[Q, C]) NE added in v0.15.0

func (w WhereMod[Q, C]) NE(val C) bob.Mod[Q]

func (WhereMod[Q, C]) NotIn added in v0.15.0

func (w WhereMod[Q, C]) NotIn(slice ...C) bob.Mod[Q]

type WhereNullMod added in v0.15.0

type WhereNullMod[Q interface {
	AppendWhere(e ...any)
}, C any] struct {
	WhereMod[Q, C]
}

func WhereNull added in v0.15.0

func WhereNull[Q Filterable, C any](name Expression) WhereNullMod[Q, C]

func (WhereNullMod[Q, C]) IsNotNull added in v0.15.0

func (w WhereNullMod[Q, C]) IsNotNull() bob.Mod[Q]

func (WhereNullMod[Q, C]) IsNull added in v0.15.0

func (w WhereNullMod[Q, C]) IsNull() bob.Mod[Q]

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL