blob: 684809128cca2e2768df01e4864e221c8351050c (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
let default_batch = 50
type cursor_batch = {
cursor_id : string;
rows : Tuple.materialized list;
has_more : bool;
}
type exec_result =
| Batch of cursor_batch
| Closed of Sublanguage_types.transition_delta
module Make (NT : Nt.S) = struct
module DrlExec = Drl.Executor.Make (NT)
type error =
| ParseError of string
| QueryError of DrlExec.error
| CursorError of string
let sexp_of_error e =
let open Sexplib.Sexp in
match e with
| ParseError s -> List [ Atom "parse-error"; Atom s ]
| QueryError e -> DrlExec.sexp_of_error e
| CursorError s -> List [ Atom "cursor-error"; Atom s ]
let ( let* ) = Result.bind
let execute (ctx : Sublanguage_context.t) (stmt : Ast.statement) :
(exec_result, error) result =
ignore default_batch;
match stmt with
| Ast.Begin _ ->
Error (CursorError "cursors not yet implemented")
| Ast.Fetch _ ->
Error (CursorError "cursors not yet implemented")
| Ast.Close _ ->
let* () = Ok () in
Ok (Closed ctx.branch#multigroups)
end
module Memory = Make (Nt.Memory)
|
