aboutsummaryrefslogtreecommitdiffstats
path: root/lib/ddl/executor.ml
diff options
context:
space:
mode:
Diffstat (limited to 'lib/ddl/executor.ml')
-rw-r--r--lib/ddl/executor.ml81
1 files changed, 0 insertions, 81 deletions
diff --git a/lib/ddl/executor.ml b/lib/ddl/executor.ml
deleted file mode 100644
index c16ff1f..0000000
--- a/lib/ddl/executor.ml
+++ /dev/null
@@ -1,81 +0,0 @@
-module Make (NT : Nt.S) = struct
- module Error = struct
- open Condition
-
- (* TODO: more structure *)
- let relation_not_found name =
- condition "relation-not-found" "Relation not found" ("name" |=| of_string name)
-
- let multigroup_not_found name =
- condition "multigroup-not-found" "Multigroup not found" ("name" |=| of_string name)
- end
-
- let ( let* ) = Result.bind
- let parse_fqn (s : string) : (Qualified_name.t, Condition.t) result = Qualified_name.try_parse s
-
- let lookup_mg (ctx : Sublanguage_context.t) (mg_name : string) :
- (Management.Multigroup.multigroup, Condition.t) result =
- match ctx.branch#mg_of mg_name with
- | Some mg -> Ok mg
- | None -> Error (Error.multigroup_not_found mg_name)
-
- let convert_cardinality : Ast.cardinality_spec -> Conventions.Cardinality.t = function
- | Ast.Finite n -> Conventions.Cardinality.Finite n
- | Ast.AlephZero -> Conventions.Cardinality.AlephZero
- | Ast.Continuum -> Conventions.Cardinality.Continuum
- | Ast.ConstrainedFinite -> Conventions.Cardinality.ConstrainedFinite
-
- (* Every relation-touching statement names exactly one mg via its FQN
- prefix. The executor parses the FQN, resolves the mg in the branch
- cache, advances it through NT, and returns a single-element delta. *)
- let execute (ctx : Sublanguage_context.t) (stmt : Ast.statement) :
- (Sublanguage_types.transition_delta * string, Condition.t) result =
- let bh = ctx.write_handle in
- let branch_name = ctx.branch#name in
- match stmt with
- | Ast.CreateMultigroup name -> (
- ctx.branch#add_multigroup ~name;
- match ctx.branch#mg_of name with
- | Some mg -> Ok ([name, mg], "Multigroup created: " ^ name)
- | None -> Error (Error.multigroup_not_found name) )
- | Ast.CreateRelation {name; schema= schema_pairs} ->
- let* fqn = parse_fqn name in
- let* mg = lookup_mg ctx fqn.mg in
- let schema =
- List.fold_left (fun s (attr, dom) -> Schema.add attr dom s) Schema.empty schema_pairs
- in
- let* _bh, new_mg = NT.create_relation bh mg ~branch_name ~name:fqn.name ~schema in
- ctx.branch#set_mg ~name:fqn.mg new_mg;
- Ok ([fqn.mg, new_mg], "Relation created: " ^ name)
- | Ast.RetractRelation name ->
- let* fqn = parse_fqn name in
- let* mg = lookup_mg ctx fqn.mg in
- let* _bh, new_mg = NT.retract_relation bh mg ~name:fqn.name in
- ctx.branch#set_mg ~name:fqn.mg new_mg;
- Ok ([fqn.mg, new_mg], "Relation retracted: " ^ name)
- | Ast.ClearRelation name -> (
- let* fqn = parse_fqn name in
- let* mg = lookup_mg ctx fqn.mg in
- match mg#get_relation fqn.name with
- | None -> Error (Error.relation_not_found name)
- | Some rel ->
- let* _bh, new_mg =
- NT.clear_relation bh mg ~branch_name ~mg_name:fqn.mg (rel :> Relation.relation)
- in
- ctx.branch#set_mg ~name:fqn.mg new_mg;
- Ok ([fqn.mg, new_mg], "Relation cleared: " ^ name) )
- | Ast.RegisterDomain {name; cardinality} ->
- let* fqn = parse_fqn name in
- let* mg = lookup_mg ctx fqn.mg in
- let domain : Relation.domain =
- new Relation.domain
- ~name:fqn.name
- ~generator:(fun _ -> Generator.Error "not enumerable via DDL")
- ~membership_criteria:(fun _ -> true)
- ~cardinality:(convert_cardinality cardinality) ~schema:Schema.empty ~provenance:None
- ~lineage:None ~constraints:None
- in
- let* _bh, new_mg = NT.register_domain bh mg domain in
- ctx.branch#set_mg ~name:fqn.mg new_mg;
- Ok ([fqn.mg, new_mg], "Domain registered: " ^ name)
-end