sqlite

type Partition struct {
	// Name is the file's path, which keeps it stable across requests and
	// unique within the set.
	Name   string
	DSN    string
	Labels map[string]string
}

type PartitionSet struct {
	// Files lists the partitions explicitly. Exclusive with Glob.
	Files []string `json:"files,omitempty"`

	// Glob matches the partitions, with ** for any depth.
	Glob string `json:"glob,omitempty"`

	// Labels is a regular expression over each partition's path whose named
	// groups become constant columns of that partition's rows, such as
	// `dt=(?P<dt>[0-9-]+)`. Every partition must match it. An exact-value filter
	// on a label column skips the partitions it excludes without opening them.
	Labels string `json:"labels,omitempty"`

	// Immutable opens every partition with immutable=1: SQLite then skips all
	// locking, which is only correct for sealed files nothing writes again.
	Immutable bool `json:"immutable,omitempty"`

	// Concurrency bounds the partitions read at once; zero means 8.
	Concurrency int `json:"concurrency,omitempty"`
}

type SQLMember struct {
	// Name identifies the member in the cursor and breaks ties between members
	// holding rows with equal keys, so it must be stable across requests.
	Name   string
	Client *sql.DB
	// Labels become constant columns of every row this member returns, so
	// filters, order and projections can address them like stored columns.
	Labels map[string]string
}

type SQLMergeRequest struct {
	Driver  string
	Members []SQLMember
	// Read is the request every member runs. Its Position is the merged
	// cursor: the per-member positions travel in Position.State under
	// query.ProviderStateKey.
	Read SQLPageRequest
	// Concurrency bounds the members read at once; zero means 8.
	Concurrency int
}

type SQLOptions struct {
	// Type overrides the connection driver type (postgres, mysql, sql_server, clickhouse, sqlite).
	Type string `json:"type,omitempty"`

	// URL is an inline DSN used when no stored connection is referenced.
	URL string `json:"url,omitempty"`

	// Database overrides the database from the hydrated connection URL.
	Database string `json:"database,omitempty"`

	// Partitions reads the query over several SQLite files sharing a schema
	// and merges their rows. Exclusive with a connection and URL.
	Partitions *PartitionSet `json:"partitions,omitempty"`
}

type SQLPageRequest struct {
	// Connection names the connection client is, for the SQL statement tap.
	Connection       string
	Query            string
	QueryArgs        []any
	QueryIdentifiers []string
	Filters          []query.ColumnFilterValue
	Order            query.Order
	Position         query.CursorPosition
	Page             query.PageRequest
	Diagnostics      *query.ProviderDiagnostics
}

type SQLPageResult struct {
	Rows        []query.Row
	ColumnTypes []*sql.ColumnType
	Total       *query.Total
	HasMore     bool
}