pgstmt

README

pgstmt

DSL SQL Builder

Experiment DO NOT use in production

Documentation

Index

• Variables
• func All(v interface{}) interface{}
• func Any(v interface{}) interface{}
• func Arg(v interface{}) interface{}
• func NotArg(v interface{}) interface{}
• type Cond
• type CondMode
• type DeleteStatement
• type Distinct
• type InsertStatement
• type Join
• type OnConflict
• type OrderBy
• type Result
  • func Delete(f func(b DeleteStatement)) *Result
  • func Insert(f func(b InsertStatement)) *Result
  • func Select(f func(b SelectStatement)) *Result
  • func Update(f func(b UpdateStatement)) *Result
  • func (r *Result) Exec(f func(string, ...interface{}) (sql.Result, error)) (sql.Result, error)
  • func (r *Result) ExecContext(ctx context.Context, ...) (sql.Result, error)
  • func (r *Result) ExecWith(ctx context.Context) (sql.Result, error)
  • func (r *Result) IterWith(ctx context.Context, iter pgsql.Iterator) error
  • func (r *Result) Query(f func(string, ...interface{}) (*sql.Rows, error)) (*sql.Rows, error)
  • func (r *Result) QueryContext(ctx context.Context, ...) (*sql.Rows, error)
  • func (r *Result) QueryRow(f func(string, ...interface{}) *sql.Row) *sql.Row
  • func (r *Result) QueryRowContext(ctx context.Context, f func(context.Context, string, ...interface{}) *sql.Row) *sql.Row
  • func (r *Result) QueryRowWith(ctx context.Context) *sql.Row
  • func (r *Result) QueryWith(ctx context.Context) (*sql.Rows, error)
  • func (r *Result) SQL() (query string, args interface{})
• type SelectStatement
• type Set
• type UpdateStatement
• type Values

Variables

var Default interface{} = defaultValue{}

Default use for insert default value

Functions

func All

func All(v interface{}) interface{}

All marks value as all($?)

func Any

func Any(v interface{}) interface{}

Any marks value as any($?)

func Arg

func Arg(v interface{}) interface{}

Arg marks value as argument to replace with $? when build query

func NotArg

func NotArg(v interface{}) interface{}

NotArg marks value as non-argument

Types

type Cond

type Cond interface {
	Op(field, op string, value interface{})
	OpRaw(field, op string, rawValue interface{})
	Eq(field string, value interface{})
	EqRaw(field string, rawValue interface{})
	Ne(field string, value interface{})
	NeRaw(field string, rawValue interface{})
	Lt(field string, value interface{})
	LtRaw(field string, rawValue interface{})
	Le(field string, value interface{})
	LeRaw(field string, rawValue interface{})
	Gt(field string, value interface{})
	GtRaw(field string, rawValue interface{})
	Ge(field string, value interface{})
	GeRaw(field string, rawValue interface{})
	Like(field string, value interface{})
	LikeRaw(field string, rawValue interface{})
	ILike(field string, value interface{})
	ILikeRaw(field string, rawValue interface{})
	In(field string, value ...interface{})
	InRaw(field string, value ...interface{})
	InSelect(field string, f func(b SelectStatement))
	NotIn(field string, value ...interface{})
	NotInRaw(field string, value ...interface{})
	IsNull(field string)
	IsNotNull(field string)
	Raw(sql string)
	And(f func(b Cond))
	Or(f func(b Cond))
	Mode() CondMode
}

Cond is the condition builder

type CondMode

type CondMode interface {
	And()
	Or()
}

type DeleteStatement

type DeleteStatement interface {
	From(table string)
	Where(f func(b Cond))
	Returning(col ...string)
}

type Distinct

type Distinct interface {
	On(col ...string)
}

type InsertStatement

type InsertStatement interface {
	Into(table string)
	Columns(col ...string)
	OverridingSystemValue()
	OverridingUserValue()
	DefaultValues()
	Value(value ...interface{})
	Values(values ...interface{})
	Select(f func(b SelectStatement))
	OnConflict(target ...string) OnConflict
	OnConflictOnConstraint(constraintName string) OnConflict
	Returning(col ...string)
}

InsertStatement is the insert statement builder

type Join

type Join interface {
	On(f func(b Cond))
	Using(col ...string)
}

type OnConflict

type OnConflict interface {
	DoNothing()
	DoUpdate(f func(b UpdateStatement))
}

type OrderBy

type OrderBy interface {
	Asc() OrderBy
	Desc() OrderBy
	NullsFirst() OrderBy
	NullsLast() OrderBy
}

type Result

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

func Delete

func Delete(f func(b DeleteStatement)) *Result

Delete builds delete statement

func Insert

func Insert(f func(b InsertStatement)) *Result

Insert builds insert statement

func Select

func Select(f func(b SelectStatement)) *Result

Select builds select statement

func Update

func Update(f func(b UpdateStatement)) *Result

Update builds update statement

func (*Result) Exec

func (r *Result) Exec(f func(string, ...interface{}) (sql.Result, error)) (sql.Result, error)

func (*Result) ExecContext

func (r *Result) ExecContext(ctx context.Context, f func(context.Context, string, ...interface{}) (sql.Result, error)) (sql.Result, error)

func (*Result) ExecWith

func (r *Result) ExecWith(ctx context.Context) (sql.Result, error)

func (*Result) IterWith

func (r *Result) IterWith(ctx context.Context, iter pgsql.Iterator) error

func (*Result) Query

func (r *Result) Query(f func(string, ...interface{}) (*sql.Rows, error)) (*sql.Rows, error)

func (*Result) QueryContext

func (r *Result) QueryContext(ctx context.Context, f func(context.Context, string, ...interface{}) (*sql.Rows, error)) (*sql.Rows, error)

func (*Result) QueryRow

func (r *Result) QueryRow(f func(string, ...interface{}) *sql.Row) *sql.Row

func (*Result) QueryRowContext

func (r *Result) QueryRowContext(ctx context.Context, f func(context.Context, string, ...interface{}) *sql.Row) *sql.Row

func (*Result) QueryRowWith

func (r *Result) QueryRowWith(ctx context.Context) *sql.Row

func (*Result) QueryWith

func (r *Result) QueryWith(ctx context.Context) (*sql.Rows, error)

func (*Result) SQL

func (r *Result) SQL() (query string, args interface{})

type SelectStatement

type SelectStatement interface {
	Distinct() Distinct
	Columns(col ...interface{})
	ColumnSelect(f func(b SelectStatement), as string)
	From(table ...string)
	FromSelect(f func(b SelectStatement), as string)
	FromValues(f func(b Values), as string)
	Join(table string) Join
	InnerJoin(table string) Join
	FullOuterJoin(table string) Join
	LeftJoin(table string) Join
	RightJoin(table string) Join
	JoinSelect(f func(b SelectStatement), as string) Join
	InnerJoinSelect(f func(b SelectStatement), as string) Join
	FullOuterJoinSelect(f func(b SelectStatement), as string) Join
	LeftJoinSelect(f func(b SelectStatement), as string) Join
	RightJoinSelect(f func(b SelectStatement), as string) Join
	JoinLateralSelect(f func(b SelectStatement), as string) Join
	InnerJoinLateralSelect(f func(b SelectStatement), as string) Join
	FullOuterJoinLateralSelect(f func(b SelectStatement), as string) Join
	LeftJoinLateralSelect(f func(b SelectStatement), as string) Join
	RightJoinLateralSelect(f func(b SelectStatement), as string) Join
	Where(f func(b Cond))
	GroupBy(col ...string)
	Having(f func(b Cond))
	OrderBy(col string) OrderBy
	Limit(n int64)
	Offset(n int64)
}

SelectStatement is the select statement builder

type Set

type Set interface {
	To(value ...interface{})
	ToRaw(rawValue ...interface{})
	Select(f func(b SelectStatement))
}

type UpdateStatement

type UpdateStatement interface {
	Table(table string)
	Set(col ...string) Set
	From(table ...string)
	Join(table string) Join
	InnerJoin(table string) Join
	FullOuterJoin(table string) Join
	LeftJoin(table string) Join
	RightJoin(table string) Join
	Where(f func(b Cond))
	WhereCurrentOf(cursor string)
	Returning(col ...string)
}

type Values

type Values interface {
	Value(value ...interface{})
	Values(values ...interface{})
}