From aae0f0595061ad32960541c532930be0e5af51f2 Mon Sep 17 00:00:00 2001
From: Mateus Cruz <mateuscolvr@gmail.com>
Date: Tue, 6 Feb 2024 00:59:54 -0300
Subject: add lock

---
 lib/query.ml | 9 +++++++++
 1 file changed, 9 insertions(+)

(limited to 'lib/query.ml')

diff --git a/lib/query.ml b/lib/query.ml
index 1fdc2c3..2dab927 100644
--- a/lib/query.ml
+++ b/lib/query.ml
@@ -58,6 +58,14 @@ module Q = struct
         |sql}
         record_out]
   ;;
+
+  let lock =
+    [%rapper
+      execute
+        {sql|
+          SELECT pg_advisory_xact_lock(%int{client_id})
+        |sql}]
+  ;;
 end
 
 let ( let* ) = Result.bind
@@ -80,3 +88,4 @@ let execute_transaction ~client_id ~(op : Operation.transaction_op) conn =
 let find_client id conn = Q.client ~id conn
 let balance client_id conn = Q.balance ~client_id conn
 let transactions client_id conn = Q.transactions ~client_id conn
+let lock client_id conn = Q.lock ~client_id conn
-- 
cgit v1.2.3