Migration changing uuids from byte to hex format in db

This commit is contained in:
rand00 2022-05-09 21:13:32 +02:00 committed by Reynir Björnsson
parent 9c3a4002af
commit a45b373019
3 changed files with 51 additions and 2 deletions

View file

@ -178,6 +178,7 @@ let () =
actions (module M20210712c); actions (module M20210712c);
[ f20210910 ]; [ f20210910 ];
actions (module M20211105); actions (module M20211105);
actions (module M20220509);
]) ])
|> Cmd.eval |> Cmd.eval
|> exit |> exit

View file

@ -0,0 +1,48 @@
let new_version = 16L and old_version = 15L
and identifier = "2022-05-09"
and migrate_doc = "switch uuid encoding to hex"
and rollback_doc = "switch uuid encoding back to binary"
let old_uuid_rep =
let encode uuid = Ok (Uuidm.to_bytes uuid) in
let decode s =
Uuidm.of_bytes s
|> Option.to_result ~none:"failed to decode uuid"
in
Caqti_type.custom ~encode ~decode Caqti_type.string
let uuids_byte_encoded_q =
Caqti_request.collect ~oneshot:true
Caqti_type.unit
(Caqti_type.tup2 (Builder_db.Rep.id (`build : [`build])) old_uuid_rep)
"SELECT id, uuid FROM build"
let uuids_hex_encoded_q =
Caqti_request.collect ~oneshot:true
Caqti_type.unit
(Caqti_type.tup2 (Builder_db.Rep.id (`build : [`build])) Builder_db.Rep.uuid)
"SELECT id, uuid FROM build"
let migrate_q =
Caqti_request.exec ~oneshot:true
(Caqti_type.tup2 (Builder_db.Rep.id (`build : [`build])) Builder_db.Rep.uuid)
"UPDATE build SET uuid = $2 WHERE id = $1"
let rollback_q =
Caqti_request.exec ~oneshot:true
(Caqti_type.tup2 (Builder_db.Rep.id (`build : [`build])) old_uuid_rep)
"UPDATE build SET uuid = $2 WHERE id = $1"
let migrate _datadir (module Db : Caqti_blocking.CONNECTION) =
let open Grej.Infix in
Grej.check_version ~user_version:old_version (module Db) >>= fun () ->
Db.collect_list uuids_byte_encoded_q () >>= fun old_uuids ->
Grej.list_iter_result (Db.exec migrate_q) old_uuids >>= fun () ->
Db.exec (Grej.set_version new_version) ()
let rollback _datadir (module Db : Caqti_blocking.CONNECTION) =
let open Grej.Infix in
Grej.check_version ~user_version:new_version (module Db) >>= fun () ->
Db.collect_list uuids_hex_encoded_q () >>= fun new_uuids ->
Grej.list_iter_result (Db.exec rollback_q) new_uuids >>= fun () ->
Db.exec (Grej.set_version old_version) ()

View file

@ -36,9 +36,9 @@ type file = {
} }
let uuid = let uuid =
let encode uuid = Ok (Uuidm.to_bytes uuid) in let encode uuid = Ok (Uuidm.to_string uuid) in
let decode s = let decode s =
Uuidm.of_bytes s Uuidm.of_string s
|> Option.to_result ~none:"failed to decode uuid" |> Option.to_result ~none:"failed to decode uuid"
in in
Caqti_type.custom ~encode ~decode Caqti_type.string Caqti_type.custom ~encode ~decode Caqti_type.string