aboutsummaryrefslogtreecommitdiff
path: root/src/exchangedb/exchange_do_batch2_reserves_in_insert.sql
diff options
context:
space:
mode:
authorJoseph <Joseph.xu@efrei.net>2023-01-05 09:22:16 -0500
committerJoseph <Joseph.xu@efrei.net>2023-01-05 09:22:16 -0500
commit043c46c59d62abcafef5c37fb97c66995e6b3859 (patch)
treef121671c6db0f942c7dbf6e5da273e04282bf1b4 /src/exchangedb/exchange_do_batch2_reserves_in_insert.sql
parentd805c54052a4684a7312e05186169fb66c35668b (diff)
downloadexchange-043c46c59d62abcafef5c37fb97c66995e6b3859.tar.xz
modifications applied to batch test...
Diffstat (limited to 'src/exchangedb/exchange_do_batch2_reserves_in_insert.sql')
-rw-r--r--src/exchangedb/exchange_do_batch2_reserves_in_insert.sql32
1 files changed, 13 insertions, 19 deletions
diff --git a/src/exchangedb/exchange_do_batch2_reserves_in_insert.sql b/src/exchangedb/exchange_do_batch2_reserves_in_insert.sql
index d1cc10415..bda644eca 100644
--- a/src/exchangedb/exchange_do_batch2_reserves_in_insert.sql
+++ b/src/exchangedb/exchange_do_batch2_reserves_in_insert.sql
@@ -52,6 +52,8 @@ DECLARE
i RECORD;
DECLARE
r RECORD;
+DECLARE
+ k INT8;
BEGIN
--SIMPLE INSERT ON CONFLICT DO NOTHING
transaction_duplicate=TRUE;
@@ -60,6 +62,7 @@ BEGIN
out_reserve_found2 = TRUE;
ruuid=0;
ruuid2=0;
+ k=0;
INSERT INTO wire_targets
(wire_target_h_payto
,payto_uri)
@@ -92,35 +95,26 @@ BEGIN
ON CONFLICT DO NOTHING
RETURNING reserve_uuid,reserve_pub)
SELECT * FROM reserve_changes;
-
- FETCH FROM curs_reserve_exist INTO i;
- IF FOUND
- THEN
- IF in_reserve_pub = i.reserve_pub
- THEN
- out_reserve_found = FALSE;
- ruuid = i.reserve_uuid;
- END IF;
- IF in2_reserve_pub = i.reserve_pub
- THEN
- out_reserve_found2 = FALSE;
- ruuid2 = i.reserve_uuid;
- END IF;
+ WHILE k < 2 LOOP
FETCH FROM curs_reserve_exist INTO i;
IF FOUND
THEN
IF in_reserve_pub = i.reserve_pub
THEN
- out_reserve_found = FALSE;
ruuid = i.reserve_uuid;
+ IF in_reserve_pub <> in2_reserve_pub
+ THEN
+ out_reserve_found = FALSE;
+ END IF;
END IF;
IF in2_reserve_pub = i.reserve_pub
THEN
- out_reserve_found2 = FALSE;
- ruuid2 = i.reserve_uuid;
- END IF;
+ out_reserve_found2 = FALSE;
+ ruuid2 = i.reserve_uuid;
+ END IF;
END IF;
- END IF;
+ k=k+1;
+ END LOOP;
CLOSE curs_reserve_exist;
PERFORM pg_notify(in_notify, NULL);