blob: 5fadc6d6877f05d3effa5dd4041f1995cd859943 (
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
|
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)
module Error = struct
open Condition
(* TODO: more structure *)
let cursor_error msg = condition "cursor-error" msg empty
end
let ( let* ) = Result.bind
let execute (ctx : Sublanguage_context.t) (stmt : Ast.statement) :
(exec_result, Condition.t) result =
ignore default_batch;
match stmt with
| Ast.Begin _ -> Error (Error.cursor_error "cursors not yet implemented")
| Ast.Fetch _ -> Error (Error.cursor_error "cursors not yet implemented")
| Ast.Close _ ->
let* () = Ok () in
Ok (Closed ctx.branch#multigroups)
end
module Memory = Make (Nt.Memory)
|
