bsq

Jun 18, 2023

Changes in this version

+ func CamelToSnake(name string) string

+ func ColP(sql ...any) any

+ func DefaultNameMap() func(string) string

+ func EachColumn(def TableDef, do func(*Column, *reflect.StructField) error) error

+ func EachTable(do func(TableDef) error) error

+ func FullJoinEq(from, to ColumnRef) any

+ func IndexedVars(fmt string) func() BindVars

+ func InitSchema(schema string, opts *InitOpts, tables ...TableDef) error

+ func LeftJoinEq(from, to ColumnRef) any

+ func NamedVars(fmt string) func() BindVars

+ func Out(sql ...any) any

+ func PGe(col ColumnRef) any

+ func PGt(col ColumnRef) any

+ func PLe(col ColumnRef) any

+ func PLt(col ColumnRef) any

+ func PNe(col ColumnRef) any

+ func PositionalVars(sym string) func() BindVars

+ func RightJoinEq(from, to ColumnRef) any

+ type BindVars interface

+ Param func(name string, col *Column) (string, error)

+ ParamColumns func() []*Column

type Column

+ func (c *Column) AName() string

+ func (c *Column) ColumnRef() *Column

+ func (c *Column) In(t TableDef) ColumnRef

+ func (c *Column) Index() int

+ func (c *Column) QName() string

+ type ColumnRef interface

+ AName func() string

+ ColumnRef func() *Column

+ QName func() string

+ Table func() TableDef

+ type Columns []*Column

+ func (cs Columns) Defn(add []any) []any

+ type CreateDialect interface

+ DefCreate func(idColumn *Column, cols ...*Column) *Query

+ QueryCreate func(db sqlize.Querier, q *Query, args ...any) (id int64, err error)

type Delete

+ Key Columns

+ func (del Delete) Defn() []any

type Dialect

+ func DefaultSQL(bv func() BindVars, quote map[string]string) Dialect

+ NewContext func() DialectCtx

+ Parameter func(ctx DialectCtx, key string, col *Column) (string, error)

+ Quote func(name string) string

+ type DialectCtx interface

+ Close func()

+ OutColumns func() []*Column

+ ParamColumns func() []*Column

+ WriteContext func() *WriteCtx

+ type ExplicitMap struct

+ func NewExplicitMap(mapping map[string]string, fallback func(string) string) *ExplicitMap

+ func (m ExplicitMap) Map(name string) string

+ func (m ExplicitMap) With(mapping map[string]string) ExplicitMap

+ type IndexBindVars struct

+ func NewIndexBindVars(format string) *IndexBindVars

+ func (bv *IndexBindVars) Param(key string, c *Column) (string, error)

+ func (bv *IndexBindVars) ParamColumns() []*Column

type InitOpts

+ ColNameMap func(fieldname string) (columname string)

+ ForceSchema bool

type Insert

+ Table TableDef

+ func (ins Insert) Defn() []any

+ type L struct

+ Elems []any

+ End string

+ Sep string

+ Start string

+ func Ls(es ...any) L

+ type NameBindVars struct

+ func NewNamedBindVars(format string) *NameBindVars

+ func (bv *NameBindVars) Param(key string, c *Column) (string, error)

+ func (bv *NameBindVars) ParamColumns() []*Column

+ type PositionBindVars struct

+ Symbol string

+ func (bv *PositionBindVars) Param(_ string, c *Column) (string, error)

+ func (bv *PositionBindVars) ParamColumns() []*Column

+ type Prunable int

+ const PruneDefn

+ const PruneString

+ const PruneTabs

+ type Queries struct

+ func NewQueries(sub ...*Queries) *Queries

+ func (qs *Queries) Add(q *Query) *Query

+ func (qs *Queries) ForEach(clear bool, do func(*Query) error) error

+ func (qs *Queries) Init(clear bool, d Dialect) error

+ func (qs *Queries) MustAdd(q *Query, err error) *Query

+ func (qs *Queries) Prepare(clear bool, db *sql.DB, initWith Dialect) error

type Query

+ func DefCreateQuery(d Dialect, idColumn *Column, cols ...*Column) (*Query, error)

+ func DefQuery(defn ...any) *Query

+ func DefUpsertQuery(d Dialect, ups Upsert) (*Query, error)

+ func NewCreateQuery(d Dialect, idColumn *Column, cols ...*Column) (*Query, error)

+ func NewQueryPrep(db *sql.DB, d Dialect, defn ...any) (*Query, error)

+ func NewQueryPrepContext(ctx context.Context, db *sql.DB, d Dialect, defn ...any) (*Query, error)

+ func NewUpsertQuery(d Dialect, ups Upsert) (*Query, error)

+ func (q *Query) Init(d Dialect) error

+ func (q *Query) OutCols() []*Column

+ func (q *Query) ParamCols() []*Column

+ func (q *Query) Prune(p Prunable)

+ func (q *Query) Stmt() *sql.Stmt

+ func (q *Query) String() string

type Select

+ func (sel Select) Defn() []any

type Table

+ func (t *Table) As(alias string) TableDef

+ func (t *Table) QName() string

+ func (t *Table) TableDef() *Table

+ type TableDef interface

+ Alias func() string

+ TableDef func() *Table

type Update

+ func (upd Update) Defn() []any

type Upsert

+ func (ups *Upsert) Complete() error

+ type UpsertDialect interface

+ DefUpsert func(defn Upsert) *Query

+ type WriteCtx struct

+ func (c *WriteCtx) OutColumns() []*Column

+ func (c *WriteCtx) WriteContext() *WriteCtx

Dec 15, 2022

Changes in this version

type Column

+ func (col *Column) DefIdx() int

+ type EntityMap struct

+ func (m *EntityMap[E]) Both(col *Column, tofrom func(E) any)

+ func (m *EntityMap[E]) ToFrom(col *Column, toSQL, fromSQL func(E) any)

+ func (m EntityMap[E]) FromMaps(out []Columner) (from []func(E) any, err error)

+ func (m EntityMap[E]) ToMaps(in []Columner) (to []func(E) any, err error)

+ type Repo struct

+ func NewRepo(d Dialect, idColumn *Column, cfg *sqlize.RepoConfig, emap EntityMap[E]) (*Repo[E, ID], error)

+ func (r *Repo[E, ID]) Create(q sqlize.Querier, entity E) (E, error)

+ func (r *Repo[E, ID]) Delete(q sqlize.Querier, entity E) error

+ func (r *Repo[E, ID]) Read(q sqlize.Querier, id ID, reuse E) (E, error)

+ func (r *Repo[E, ID]) Update(q sqlize.Querier, entity E) error

Sep 18, 2022

Changes in this version

type Query

+ func (defn *Query) Error() error

+ type RepoBase struct

+ QueryCreate *Query

+ QueryDelete *Query

+ QueryRead *Query

+ QueryUpdate *Query

+ func NewRepoBase(d Dialect, idColumn *Column, cfg *sqlize.RepoConfig) (*RepoBase, error)

Apr 18, 2022

Changes in this version

+ func QueryCreate(db sqlize.Querier, q *Query, args ...interface{}) (id int64, err error)

+ func QueryCreateNamed(db sqlize.Querier, q *Query, args ...sql.NamedArg) (id int64, err error)

type Dialect

+ CreateSQL func(tbl *Table, idCol Columner, setCols []Columner) []interface{}

+ QueryCreate func(db sqlize.Querier, query string, args ...interface{}) (id int64, err error)

+ UpsertSQL func(tbl *Table, conflict, set []Columner) []interface{}

type Query

+ func NewQuery(d Dialect, flags WriteFlag, defn ...interface{}) Query

+ func (defn *Query) Defn() []interface{}

+ func (defn *Query) Flags() WriteFlag

+ func (qdefn *Query) Bind(params ...sql.NamedArg) []interface{}

+ func (qdefn *Query) Dialect() Dialect

+ func (qdefn *Query) Exec(db sqlize.Querier, args ...interface{}) (sql.Result, error)

+ func (qdefn *Query) ExecContext(ctx context.Context, db sqlize.Querier, args ...interface{}) (sql.Result, error)

+ func (qdefn *Query) ExecNamed(db sqlize.Querier, args ...sql.NamedArg) (sql.Result, error)

+ func (qdefn *Query) ExecNamedContext(ctx context.Context, db sqlize.Querier, args ...sql.NamedArg) (sql.Result, error)

+ func (qdefn *Query) MustSQL() string

+ func (qdefn *Query) Prepare(db sqlize.Querier) (*sql.Stmt, error)

+ func (qdefn *Query) PrepareContext(ctx context.Context, db sqlize.Querier) (*sql.Stmt, error)

+ func (qdefn *Query) Query(db sqlize.Querier, args ...interface{}) (*sql.Rows, error)

+ func (qdefn *Query) QueryContext(ctx context.Context, db sqlize.Querier, args ...interface{}) (*sql.Rows, error)

+ func (qdefn *Query) QueryNamed(db sqlize.Querier, args ...sql.NamedArg) (*sql.Rows, error)

+ func (qdefn *Query) QueryNamedContext(ctx context.Context, db sqlize.Querier, args ...sql.NamedArg) (*sql.Rows, error)

+ func (qdefn *Query) QueryRow(db sqlize.Querier, args ...interface{}) *sql.Row

+ func (qdefn *Query) QueryRowContext(ctx context.Context, db sqlize.Querier, args ...interface{}) *sql.Row

+ func (qdefn *Query) QueryRowNamed(db sqlize.Querier, args ...sql.NamedArg) *sql.Row

+ func (qdefn *Query) QueryRowNamedContext(ctx context.Context, db sqlize.Querier, args ...sql.NamedArg) *sql.Row

+ func (qdefn *Query) SQL() (string, error)

+ func (qdefn Query) With(d Dialect, flags WriteFlag) Query

+ func (qdefn Query) WithDialect(d Dialect) Query

+ func (qdefn Query) WithFlags(flags WriteFlag) Query

Sep 18, 2021

Changes in this version

+ var DefaultDialect = StdSQL(PositionalParams("?"))

+ func AddDialect(name string, d Dialect) error

+ func CreateArgs(db sqlize.SQL, q *QueryDefn, args ...interface{}) (id int64, err error)

+ func CreateNamedArgs(db sqlize.SQL, q *QueryDefn, args ...sql.NamedArg) (id int64, err error)

+ func ForEachDefn(do func(Tabler) (done bool)) bool

+ func InitDefns(schema string, opts *InitOpts, tableDefns ...Tabler) error

+ func MustAddDialect(name string, d Dialect)

+ func MustInitDefns(schema string, opts *InitOpts, tableDefns ...Tabler)

+ func MustSQLString(d Dialect, flags WriteFlag, stmt ...interface{}) (string, interface{})

+ func QuoteKeywords(keywords []string, defn string) (escaped string)

+ func SQLString(d Dialect, flags WriteFlag, stmt ...interface{}) (string, interface{}, error)

+ func UpsertOnConflict(tbl *Table, conflict, set []Columner) []interface

+ func VisitDefn(tdefn Tabler, v DefnVisitor) error

+ func WriteSQL(wr io.Writer, d Dialect, flags WriteFlag, stmt ...interface{}) (params interface{}, err error)

+ type ArgMap = func([]sql.NamedArg) []interface

+ type CRUD struct

+ CreateQuery QueryDefn

+ DeleteQuery QueryDefn

+ ReadQuery QueryDefn

+ UpdateQuery QueryDefn

+ func NewCRUD(d Dialect, id Columner) *CRUD

+ func (crud *CRUD) Create(db sqlize.SQL, args ...interface{}) (id int64, err error)

+ func (crud *CRUD) CreateNamed(db sqlize.SQL, args ...sql.NamedArg) (id int64, err error)

+ func (crud *CRUD) Delete(db sqlize.SQL, id interface{}) (sql.Result, error)

+ func (crud *CRUD) Read(db sqlize.SQL, id interface{}) *sql.Row

+ func (crud *CRUD) Update(db sqlize.SQL, id interface{}, args ...interface{}) (sql.Result, error)

+ func (crud *CRUD) UpdateNamed(db sqlize.SQL, id interface{}, args ...sql.NamedArg) (sql.Result, error)

+ type Column struct

+ Name string

+ func (col *Column) ColumnDefn() *Column

+ func (col *Column) Q(qualifier string) Columner

+ func (col Column) Table() Tabler

+ func (col Column) WriteTo(w io.Writer, ctx *writeContext) error

+ type Columner interface

+ ColumnDefn func() *Column

+ Q func(qualifier string) Columner

+ Table func() Tabler

+ func Cols(cs ...Columner) []Columner

+ func ColsOf(t Tabler, exclude ...Columner) []Columner

+ type Create struct

+ IDColumn Columner

+ Set []Columner

+ func (cre Create) WriteTo(w io.Writer, ctx *writeContext) error

+ type DefnVisitor interface

+ Column func(c *Column, field *reflect.StructField) error

+ Table func(defn Tabler) error

+ type Delete struct

+ EqColumns []Columner

+ From *Table

+ func (del Delete) WriteTo(w io.Writer, ctx *writeContext) error

+ type Dialect interface

+ Create func(db sqlize.SQL, query string, args ...interface{}) (id int64, err error)

+ CreateStatement func(tbl *Table, idCol Columner, setCols []Columner) []interface{}

+ QuoteName func(defn string) (escaped string)

+ UpsertStatement func(tbl *Table, conflict, set []Columner) []interface{}

+ func GetDialect(name string) Dialect

+ func StdSQL(pn ParamNamer) Dialect

+ type IndexedParams string

+ func (_ IndexedParams) ArgMapper(ctx interface{}) func([]sql.NamedArg) []interface{}

+ func (ip IndexedParams) ParamName(p P, ctx interface{}) (string, interface{})

+ type InitDefn struct

+ NameMap func(fieldname string) (columnname string)

+ Schema string

+ func (id *InitDefn) Column(c *Column, f *reflect.StructField) error

+ func (id *InitDefn) Reset()

+ func (id *InitDefn) Table(t Tabler) error

+ type InitOpts struct

+ MustAlias bool

+ NameMap func(fieldname string) (columname string)

+ type Insert struct

+ Columns []Columner

+ func (ins Insert) WriteTo(w io.Writer, ctx *writeContext) error

+ type JoinEq struct

+ From Columner

+ Outer OuterJoin

+ To Columner

+ func (jeq JoinEq) WriteTo(w io.Writer, ctx *writeContext) error

+ type List struct

+ Elems interface{}

+ Post string

+ Pre string

+ Sep string

+ func ColList(cols ...Columner) List

+ func (ls List) WriteTo(w io.Writer, ctx *writeContext) (err error)

+ type NamedParams string

+ func (_ NamedParams) ArgMapper(ctx interface{}) func([]sql.NamedArg) []interface{}

+ func (np NamedParams) ParamName(p P, ctx interface{}) (string, interface{})

+ type OuterJoin string

+ const Full

+ const Left

+ const Right

+ type P string

+ type PEq struct

+ func (ceq PEq) WriteTo(w io.Writer, ctx *writeContext) (err error)

+ type ParamNamer interface

+ ArgMapper func(ctx interface{}) ArgMap

+ ParamName func(p P, ctx interface{}) (string, interface{})

+ type PositionalParams string

+ func (_ PositionalParams) ArgMapper(ctx interface{}) func([]sql.NamedArg) []interface{}

+ func (pp PositionalParams) ParamName(p P, ctx interface{}) (string, interface{})

+ type QueryDefn struct

+ func Query(d Dialect, flags WriteFlag, query ...interface{}) QueryDefn

+ func (qdefn *QueryDefn) Bind(params ...sql.NamedArg) []interface{}

+ func (qdefn *QueryDefn) Dialect() Dialect

+ func (qdefn *QueryDefn) Exec(db sqlize.SQL, args ...interface{}) (sql.Result, error)

+ func (qdefn *QueryDefn) ExecNamed(db sqlize.SQL, args ...sql.NamedArg) (sql.Result, error)

+ func (qdefn *QueryDefn) MustSQL() string

+ func (qdefn *QueryDefn) Prepare(db sqlize.SQL) (*sql.Stmt, error)

+ func (qdefn *QueryDefn) Query(db sqlize.SQL, args ...interface{}) (*sql.Rows, error)

+ func (qdefn *QueryDefn) QueryNamed(db sqlize.SQL, args ...sql.NamedArg) (*sql.Rows, error)

+ func (qdefn *QueryDefn) QueryRow(db sqlize.SQL, args ...interface{}) *sql.Row

+ func (qdefn *QueryDefn) QueryRowNamed(db sqlize.SQL, args ...sql.NamedArg) *sql.Row

+ func (qdefn *QueryDefn) SQL() (string, error)

+ func (qdefn QueryDefn) With(d Dialect, flags WriteFlag) QueryDefn

+ func (qdefn QueryDefn) WithDialect(d Dialect) QueryDefn

+ func (qdefn QueryDefn) WithFlags(flags WriteFlag) QueryDefn

+ type SQLWriterTo interface

+ WriteTo func(w io.Writer, ctx *writeContext) error

+ type Select struct

+ Columns []Columner

+ EqColumns []Columner

+ From Tabler

+ func (sel Select) WriteTo(w io.Writer, ctx *writeContext) error

+ type Table struct

+ DefaultAlias string

+ Name string

+ Schema string

+ func (tbl *Table) Alias(alias string) TableAlias

+ func (tbl *Table) String() string

+ func (tbl *Table) TableData() *Table

+ func (tbl Table) WriteTo(w io.Writer, ctx *writeContext) error

+ type TableAlias struct

+ func (a TableAlias) Q(col Columner) Columner

+ func (a TableAlias) TableData() *Table

+ func (a TableAlias) WriteTo(w io.Writer, ctx *writeContext) error

+ type Tabler interface

+ TableData func() *Table

+ type Update struct

+ EqColumns []Columner

+ Set []Columner

+ func (upd Update) WriteTo(w io.Writer, ctx *writeContext) error

+ type Upsert struct

+ Conflict []Columner

+ Set []Columner

+ func (ups Upsert) WriteTo(w io.Writer, ctx *writeContext) error

+ type WriteFlag uint

+ const Alias

+ const Explicit

+ const Qualify