pgxutil

type FieldFilter interface {
	Filter(fieldExpr string) string
}

type FieldUpdate interface {
	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 QueryArg interface {
	// contains filtered or unexported methods
}

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

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