Module `Granary_sql.Plan`Source

Physical query-plan IR.

The planner (Planner) lowers a bound Ast.stmt into an op tree, which the executor (Exec) walks to produce rows. Plan expressions (expr) differ from Ast.expr in that column references are resolved to integer ordinals. Every type is exposed concretely because the planner constructs and the executor matches on the full structure.

Sourcemodule Cat = Granary_catalog.Catalog

Sourcetype binop =

| Eq
| Ne
| Lt
| Le
| Gt
| Ge
| Add
| Sub
| Mul
| Div
| And
| Or
| Concat
| Mod
| Bit_and
| Bit_or
| Lshift
| Rshift
| Like
| Glob

Sourcetype expr =

| P_lit of Ast.literal
| P_col of int
(*
column ordinal
*)
| P_binop of binop * expr * expr
| P_not of expr
| P_is_null of expr
| P_is_not_null of expr
| P_neg of expr
| P_bitnot of expr
| P_between of expr * expr * expr
| P_in of expr * expr list
| P_func of Ast.scalar_func * expr list
| P_param of int
(*
0-indexed positional parameter
*)
| P_subquery of Ast.stmt
| P_exists of Ast.stmt
| P_in_select of expr * Ast.stmt
| P_case of {
1. scrutinee : expr option;
2. branches : (expr * expr) list;
3. else_ : expr option;
}
| P_cast of expr * Ast.ty
| P_excluded_col of int
(*
Column reference into the proposed INSERT excluded row.
*)
| P_window_slot of int
(*
Window function slot reference — substituted to P_col(n_input_cols+i) by planner.
*)
| P_collate of expr * Ast.collation

Sourcetype window_plan_item = {

func : Ast.window_func;
args : expr list;
partition_by : expr list;
order_by : (expr * [ `Asc | `Desc ] * [ `Nulls_first | `Nulls_last ]) list;
frame : Ast.frame_spec option;

}

Sourcetype snippet_spec = {

col_idx : int;
start_tag : string;
end_tag : string;
ellipsis : string;
n_tokens : int;

}

Sourcetype op =

| Op_create_table of {
1. name : string;
2. columns : Granary_encoding.Row.column list;
3. uniq_idxs : (string * string list * Cat.idx_origin) list;
4. if_not_exists : bool;
5. fk_constraints : (string list * string * string list * Granary_catalog.Catalog.fk_action * Granary_catalog.Catalog.fk_action * bool) list;
  (*
  (local_cols, parent_table, parent_cols, on_delete, on_update, deferrable)
  *)
6. without_rowid : bool;
7. autoincrement : bool;
  (*
  #299: INTEGER PRIMARY KEY AUTOINCREMENT.
  *)
}
| Op_col_create_table of {
1. name : string;
2. columns : Granary_encoding.Row.column list;
3. if_not_exists : bool;
}
(*
DDL: CREATE TABLE name (...) USING COLUMNSTORE. Registers the table in the catalog with Columnar storage.
*)
| Op_insert of {
1. table_meta : Cat.table_meta;
2. ordinals : int list;
3. values : expr list list;
4. on_conflict : Ast.conflict_action option;
5. returning : expr list;
6. upsert_update : (string list * (int * expr) list) option;
}
| Op_insert_select of {
1. table_meta : Cat.table_meta;
2. ordinals : int list;
3. source : op;
4. on_conflict : Ast.conflict_action option;
}
| Op_seq_scan of {
1. table_meta : Cat.table_meta;
}
| Op_filter of {
1. pred : expr;
2. child : op;
}
| Op_project of {
1. ordinals : int list;
2. child : op;
}
| Op_expr_project of {
1. exprs : (expr * string option) list;
2. child : op;
}
| Op_sort of {
1. keys : (expr * [ `Asc | `Desc ] * [ `Nulls_first | `Nulls_last ]) list;
2. child : op;
}
| Op_limit of {
1. limit : int;
2. offset : int;
3. child : op;
}
| Op_create_index of {
1. name : string;
2. table : string;
3. tree_id : int;
  (*
  table's tree_id
  *)
4. col_sqls : string list;
  (*
  col name (plain) or expr SQL (expression)
  *)
5. col_expr_flags : bool list;
  (*
  true = expression index column, false = plain column
  *)
6. where_expr : expr option;
7. where_sql : string option;
8. unique : bool;
9. columns : Granary_encoding.Row.column list;
  (*
  columns of the target table — needed for row decoding during index population
  *)
10. if_not_exists : bool;
}
| Op_index_lookup of {
1. table_tree : int;
  (*
  table's tree_id
  *)
2. idx_tree : int;
  (*
  index tree_id
  *)
3. col_idx : int;
  (*
  column ordinal for encoding
  *)
4. col_type : Granary_encoding.Row.ty;
5. lookup_val : expr;
  (*
  value to look up
  *)
6. table_meta : Cat.table_meta;
  (*
  for row decoding
  *)
}
| Op_rowid_lookup of {
1. table_meta : Cat.table_meta;
2. lookup_val : expr;
  (*
  #243 (T1): point lookup on an INTEGER PRIMARY KEY rowid alias — a single table-tree seek by the integer key, no index.
  *)
}
| Op_col_seq_scan of {
1. table_meta : Cat.table_meta;
}
(*
Scan a columnar table; emits one Row.t per stored row.
*)
| Op_update of {
1. table_meta : Cat.table_meta;
2. assignments : (int * expr) list;
  (*
  (col_ordinal, new_value_expr)
  *)
3. where : expr option;
4. order : (expr * [ `Asc | `Desc ] * [ `Nulls_first | `Nulls_last ]) list;
5. limit : int option;
6. offset : int option;
7. indexes : Cat.index_info list;
8. returning : expr list;
}
| Op_delete of {
1. table_meta : Cat.table_meta;
2. where : expr option;
3. order : (expr * [ `Asc | `Desc ] * [ `Nulls_first | `Nulls_last ]) list;
4. limit : int option;
5. offset : int option;
6. indexes : Cat.index_info list;
7. returning : expr list;
}
| Op_drop_table of {
1. table_meta : Cat.table_meta;
2. indexes : Cat.index_info list;
}
| Op_drop_index of {
1. idx_info : Cat.index_info;
}
| Op_nested_loop_join of {
1. left : op;
  (*
  left input (any op stream)
  *)
2. right_meta : Cat.table_meta;
  (*
  right table for row decode
  *)
3. idx_tree : int;
  (*
  right-side index tree id
  *)
4. right_col_idx : int;
  (*
  join col ordinal IN RIGHT TABLE
  *)
5. left_col_idx : int;
  (*
  join col ordinal in the LEFT row
  *)
6. join_kind : [ `Inner | `Left ];
7. right_col_offset : int;
  (*
  = n_left_cols
  *)
8. n_right_cols : int;
}
| Op_hash_join of {
1. left : op;
2. right : op;
3. left_key : int;
  (*
  col ordinal in the left row
  *)
4. right_key : int;
  (*
  col ordinal in the right row
  *)
5. join_kind : [ `Inner | `Left ];
6. right_col_offset : int;
7. n_right_cols : int;
}
| Op_aggregate of {
1. child : op;
2. group_cols : int list;
  (*
  column ordinals in the CHILD row. [] = one big group.
  *)
3. aggs : agg_spec list;
4. having : expr option;
  (*
  evaluated on the OUTPUT row of Op_aggregate; output row = group_col0; group_col1; ...; agg1; agg2; ....
  *)
5. proj : proj_item list;
  (*
  projection over the aggregate output row. Maps to the final row emitted to downstream operators.
  *)
6. windows : window_plan_item list;
  (*
  Post-aggregate window functions; for plain GROUP BY.
  *)
}
| Op_alter_table of {
1. table_meta : Cat.table_meta;
2. action : Ast.alter_action;
}
| Op_begin
| Op_commit
| Op_rollback
| Op_savepoint of string
| Op_release of string
| Op_rollback_to of string
| Op_create_fts_table of {
1. name : string;
2. columns : string list;
}
| Op_fts_insert of {
1. fts_meta : Cat.fts_table_meta;
2. col_names : string list;
3. col_values : expr list;
4. rowid_value : expr option;
  (*
  #330: explicit rowid from the column list
  *)
}
| Op_fts_delete of {
1. fts_meta : Cat.fts_table_meta;
2. where : expr option;
}
| Op_fts_seq_scan of {
1. fts_meta : Cat.fts_table_meta;
2. where : expr option;
}
| Op_fts_match_scan of {
1. fts_meta : Cat.fts_table_meta;
2. query : Fts_query.t;
3. proj : int list;
4. include_rank : bool;
  (*
  if true, append BM25 score as last projected column
  *)
5. snippets : snippet_spec list;
}
| Op_pragma_rows of {
1. rows : Granary_encoding.Row.t list;
}
| Op_pragma_get_user_version
(*
Read user_version from sys_meta at exec time; returns one row [V_int n].
*)
| Op_pragma_set_user_version of {
1. version : int64;
}
(*
Write user_version to sys_meta; DDL-like, returns 0 rows.
*)
| Op_pragma_integrity_check
(*
Scan all table + index B-trees; return ["ok"] or list of error strings.
*)
| Op_pragma_get_fk
(*
Read fk_enforcement flag from catalog; returns one row [V_int 0|1].
*)
| Op_pragma_set_fk of {
1. on : bool;
}
(*
Write fk_enforcement flag to catalog; DDL-like, returns 0 rows.
*)
| Op_pragma_get_recursive_triggers
(*
Read recursive_triggers flag from catalog; returns one row [V_int 0|1].
*)
| Op_pragma_set_recursive_triggers of {
1. on : bool;
}
(*
Write recursive_triggers flag to catalog; DDL-like, returns 0 rows.
*)
| Op_pragma_get_defer_fk
(*
Read defer_foreign_keys flag from catalog; returns one row [V_int 0|1].
*)
| Op_pragma_set_defer_fk of {
1. on : bool;
}
(*
Write defer_foreign_keys flag to catalog; DDL-like, returns 0 rows.
*)
| Op_pragma_wal_checkpoint
(*
Migrate WAL contents to main DB and reset; no-op outside WAL mode.
*)
| Op_pragma_get_wal_autocheckpoint
(*
Read per-connection auto-checkpoint threshold.
*)
| Op_pragma_set_wal_autocheckpoint of {
1. n : int64;
}
(*
Set per-connection auto-checkpoint threshold (0 disables).
*)
| Op_pragma_get_synchronous
(*
#298 read durability mode
*)
| Op_pragma_set_synchronous of {
1. mode : string;
}
| Op_pragma_get_wal_batch_commits
| Op_pragma_set_wal_batch_commits of {
1. n : int64;
}
| Op_pragma_get_wal_batch_interval_ms
| Op_pragma_set_wal_batch_interval_ms of {
1. n : int64;
}
| Op_vacuum
(*
Compact-rebuild the database file (phase 37 / #120).
*)
| Op_attach of {
1. path : string;
2. schema : string;
}
(*
ATTACH DATABASE 'path' AS schema — phase 40 / #64. Mutates the executing Db.t's attached map; never observed by exec.ml.
*)
| Op_detach of {
1. schema : string;
}
(*
DETACH DATABASE schema — phase 40 / #64.
*)
| Op_database_list
(*
PRAGMA database_list — phase 40 / #64. Yields one row per schema: (seq INT, name TEXT, file TEXT).
*)
| Op_active_database_get
(*
PRAGMA active_database — phase 40 / #64.
*)
| Op_active_database_set of {
1. schema : string;
}
(*
PRAGMA active_database = schema — phase 40 / #64. Subsequent non-routing statements route through t.attached under schema.
*)
| Op_distinct of {
1. child : op;
}
| Op_union of {
1. all : bool;
2. left : op;
3. right : op;
}
| Op_intersect of {
1. left : op;
2. right : op;
}
| Op_except of {
1. left : op;
2. right : op;
}
| Op_const_select of {
1. exprs : (expr * string option) list;
}
| Op_window of {
1. child : op;
2. windows : window_plan_item list;
3. n_input_cols : int;
}
| Op_with_cte of {
1. cte_name : string;
2. def : op;
3. query : op;
4. recursive : bool;
}
| Op_cte_scan of {
1. cte_name : string;
2. n_cols : int;
}
| Op_create_view of {
1. name : string;
2. query : Ast.stmt;
}
| Op_create_reactive_view of {
1. name : string;
2. query : Ast.stmt;
3. refresh : Ast.refresh_mode;
}
| Op_drop_view of {
1. name : string;
}
| Op_create_trigger of {
1. name : string;
2. timing : Ast.trigger_timing;
3. event : Ast.trigger_event;
4. table : string;
5. when_ : Ast.expr option;
6. body : Ast.stmt list;
}
| Op_drop_trigger of {
1. name : string;
}
| Op_sqlite_master
(*
Virtual scan that reconstructs sqlite_master rows from catalog metadata.
*)
| Op_sqlite_sequence
(*
#312: virtual scan over AUTOINCREMENT counters (name, seq).
*)
| Op_seq_set of {
1. table : string;
2. seq : int64;
}
(*
#312.1: writable sqlite_sequence SET/INSERT -> set table's next_rowid.
*)
| Op_seq_reset of {
1. table : string option;
}
(*
#312.1: writable sqlite_sequence DELETE -> reset table's next_rowid; None (bare DELETE, no WHERE) resets every AUTOINCREMENT counter.
*)
| Op_no_op
(*
No-op plan node produced by IF EXISTS DROP when object not found.
*)
| Op_changes
(*
Returns rows affected by last DML. Intercepted in db.ml query — not exec.ml.
*)
| Op_last_insert_rowid
(*
Returns rowid of last INSERT. Intercepted in db.ml query — not exec.ml.
*)
| Op_total_changes
(*
Returns total rows affected since the connection was opened. Intercepted in db.ml query — not exec.ml.
*)
| Op_explain of {
1. analyze : bool;
2. inner : op;
}

Sourceand proj_item =

| PI_group_col of int
(*
project the i-th GROUP BY column (index into group_cols)
*)
| PI_agg_slot of int
(*
project the k-th aggregate result
*)
| PI_window_slot of int
(*
project the j-th post-aggregate window function result
*)

Sourceand agg_spec = {

func : Ast.agg_func;
col_ord : int option;
(*
None means COUNT-star
*)

}

Install

dune-project
Dependency

Authors

Maintainers

Sources

doc/granary.sql/Granary_sql/Plan/index.html

Module `Granary_sql.Plan`Source

package granary

Install

dune-project Dependency

Authors

Maintainers

Sources

doc/granary.sql/Granary_sql/Plan/index.html

Module Granary_sql.PlanSource

dune-project
Dependency

Module `Granary_sql.Plan`Source