pgxutil

type CommonArg interface {
	// contains filtered or unexported methods
}

type FieldFilter interface {
	CommonArg
	Filter(fieldExpr string) string
}

type FieldUpdate interface {
	CommonArg
	Update(fieldExpr string) string
}

type IConn interface {
	IQueryable
	Begin() (*pgx.Tx, error)
	BeginEx(ctx context.Context, txOptions *pgx.TxOptions) (*pgx.Tx, error)
}

type IQueryable interface {
	BeginBatch() *pgx.Batch
	CopyFrom(tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int, error)
	CopyFromReader(r io.Reader, sql string) (commandTag pgx.CommandTag, err error)
	CopyToWriter(w io.Writer, sql string, args ...interface{}) (commandTag pgx.CommandTag, err error)

	Exec(sql string, arguments ...interface{}) (commandTag pgx.CommandTag, err error)
	ExecEx(ctx context.Context, sql string, options *pgx.QueryExOptions, arguments ...interface{}) (commandTag pgx.CommandTag, err error)

	Prepare(name, sql string) (*pgx.PreparedStatement, error)
	PrepareEx(ctx context.Context, name, sql string, opts *pgx.PrepareExOptions) (*pgx.PreparedStatement, error)

	Query(sql string, args ...interface{}) (*pgx.Rows, error)
	QueryEx(ctx context.Context, sql string, options *pgx.QueryExOptions, args ...interface{}) (*pgx.Rows, error)

	QueryRow(sql string, args ...interface{}) *pgx.Row
	QueryRowEx(ctx context.Context, sql string, options *pgx.QueryExOptions, args ...interface{}) *pgx.Row
}

type Preparable interface {
	PrepareWith(q IQueryable, name string) (*pgx.PreparedStatement, error)
}

type QC_Exec func(q IQueryable, args ...interface{}) (pgx.CommandTag, error)

type QC_ExecEx func(q IQueryable, ctx context.Context, args ...interface{}) (pgx.CommandTag, error)

type QC_Query func(q IQueryable, args ...interface{}) (*pgx.Rows, error)

type QC_QueryEx func(q IQueryable, ctx context.Context, args ...interface{}) (*pgx.Rows, error)

type QC_QueryRow func(q IQueryable, args ...interface{}) *pgx.Row

type QC_QueryRowEx func(q IQueryable, ctx context.Context, args ...interface{}) *pgx.Row

type QueryArg interface {
	CommonArg
	// contains filtered or unexported methods
}

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

type SqlSelect interface {
	SetExprs(exprs string)
	AddExpr(expr string)
	AddWhere(name string, filter CommonArg) // filter = QueryArg|FieldFilter
	String() string
	PrepareWith(q IQueryable, name string) (*pgx.PreparedStatement, error)
}

type SqlUpdate interface {
	AddUpdate(name string, update CommonArg) // update = QueryArg|FieldUpdate
	AddWhere(name string, filter CommonArg)  // filter = QueryArg|FieldFilter
	String() string
	PrepareWith(q IQueryable, name string) (*pgx.PreparedStatement, error)
}