diff options
Diffstat (limited to 'lib/relation.ml')
| -rw-r--r-- | lib/relation.ml | 58 |
1 files changed, 2 insertions, 56 deletions
diff --git a/lib/relation.ml b/lib/relation.ml index d27f2e2..c01c761 100644 --- a/lib/relation.ml +++ b/lib/relation.ml @@ -1,66 +1,12 @@ -module Protocol = struct - open Protocol_conv_xml - open Sexplib0.Sexp_conv - - type tuple = string list - [@@deriving sexp, protocol ~driver:(module Xml_light)] - - type relation = { - attribute_name : string; - attribute_type : string; - tuples : tuple; - } - [@@deriving sexp, protocol ~driver:(module Xml_light)] - - type facts = relation list - [@@deriving sexp, protocol ~driver:(module Xml_light)] -end - -(* -let test_write_and_retrieve() = - let open Disk in - let stream: Executor.history = [{state = Executor._EMPTY_SHA_HASH_; files = Executor.StringMap.empty}] in - let locations: Executor.locations = Executor.StringMap.empty in - let open Extensions.Result in - let command_write1: Command.t = - {kind = Command.WRITE; timestamp = 10.0; hash = ""; content = "Daisy"; filename = "user/first-name"} in - let+ ((stream, locations), Command.ComputedHash handle) = Command.commit_and_perform stream locations command_write1 in - let command_write2: Command.t = - {kind = Command.WRITE; timestamp = 10.0; hash = ""; content = "Blossom"; filename = "user/last-name"} in - let command_write3: Command.t = - {kind = Command.WRITE; timestamp = 10.0; hash = ""; content = "Minnie"; filename = "user/first-name"} in - let+ ((stream, locations), Command.ComputedHash _handle) = Command.commit_and_perform stream locations command_write2 in - let+ ((stream, locations), Command.ComputedHash handle) = Command.commit_and_perform stream locations command_write3 in - let command_write4: Command.t = - {kind = Command.WRITE; timestamp = 10.0; hash = ""; content = "Mouse"; filename = "user/last-name"} in - let+ ((stream, locations), Command.ComputedHash _handle) = Command.commit_and_perform stream locations command_write4 in - let command_write5: Command.t = - {kind = Command.WRITE; timestamp = 10.0; hash = ""; content = "Billie"; filename = "user/first-name"} in - let+ ((stream, locations), Command.ComputedHash handle) = Command.commit_and_perform stream locations command_write5 in - let command_write6: Command.t = - {kind = Command.WRITE; timestamp = 10.0; hash = ""; content = "Beans"; filename = "user/last-name"} in - let+ ((stream, locations), Command.ComputedHash _handle) = Command.commit_and_perform stream locations command_write6 in - let command_read1: Command.t = {kind = Command.READ; timestamp = 0.0; hash = ""; content = ""; filename = "user/first-name"} in - let+ (_, Command.Read first_name) = Command.commit_and_perform (List.tl stream) locations command_read1 in - let command_read2: Command.t = {kind = Command.READ; timestamp = 0.0; hash = ""; content = ""; filename = "user/last-name"} in - let+ (_, Command.Read last_name) = Command.commit_and_perform (List.tl stream) locations command_read2 in - (* List.iter (fun a -> print_endline a) (List.map Bytes.to_string first_name); *) - (* List.iter (fun a -> print_endline a) (List.map Bytes.to_string last_name); *) - let relation_result: Protocol.relation list = - [{attribute_name = "user/first-name"; attribute_type = "string"; tuples = List.map Bytes.to_string first_name}; - {attribute_name = "user/last-name"; attribute_type = "string"; tuples = List.map Bytes.to_string last_name}] in - Ok (Xml.to_string (Protocol.facts_to_xml_light relation_result)) - (* (Sexp.to_string (Protocol.sexp_of_t )) *) - [@@warning "-8-27"] (* Suppress pattern match incomplete warnings *) -*) - let write_and_retrieve () = let open Disk in + let schema = Executor.StringMap.empty |> Executor.StringMap.add "user" [("first_name", Executor.Text); ("last_name", Executor.Text)] in let commit : Executor.commit = { state = Executor._EMPTY_SHA_HASH_; files = Executor.StringMap.empty; references = Executor.StringMap.empty; + schema } in let locations : Executor.locations = Executor.StringMap.empty in |