qrypgx

type Backend struct {
	DB *pgx.ConnPool
	mig.Record
	// contains filtered or unexported fields
}

type C interface {
	Query(string, ...interface{}) (*pgx.Rows, error)
	QueryRow(string, ...interface{}) *pgx.Row
	Exec(string, ...interface{}) (pgx.CommandTag, error)
	Prepare(string, string) (*pgx.PreparedStatement, error)
	CopyFrom(pgx.Identifier, []string, pgx.CopyFromSource) (int, error)
}

type Column struct {
	*qry.Task
	Key string
	Job *Job
}

type DB interface {
	Begin() (*pgx.Tx, error)
}

type Job struct {
	Kind
	// Task is the primary subject of this job.
	*qry.Task
	Cols   []Column
	Tabs   []*qry.Task
	Alias  map[*qry.Task]string
	Parent *Job
	// Deps is the list of immediate dependency tasks for this job, except the parent.
	Deps []*qry.Task
}

type Kind uint

type Plan struct {
	*qry.Doc
	Jobs []*Job
}