diff options
Diffstat (limited to 'lib/scl/executor.ml')
| -rw-r--r-- | lib/scl/executor.ml | 18 |
1 files changed, 5 insertions, 13 deletions
diff --git a/lib/scl/executor.ml b/lib/scl/executor.ml index e40fde6..5fadc6d 100644 --- a/lib/scl/executor.ml +++ b/lib/scl/executor.ml @@ -1,20 +1,14 @@ 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 +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 @@ -25,10 +19,8 @@ module Make (NT : Nt.S) = struct (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.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) |