taler/exchange
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

update of batch 2 test

Browse Source
This commit is contained in:
Joseph 2022-12-21 07:28:46 -05:00
parent b90d25ecfc
commit 2030d64910
No known key found for this signature in database
GPG Key ID: E709789D3076B5CC
1 changed files with 25 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
src/exchangedb/exchange_do_batch2_reserves_in_insert.sql
View File

@ -46,20 +46,12 @@ LANGUAGE plpgsql
AS $$ AS $$
DECLARE DECLARE
curs_reserve_exist REFCURSOR; curs_reserve_exist REFCURSOR;
-- FOR SELECT reserve_pub
-- FROM reserves
-- WHERE in_reserve_pub = reserves.reserve_pub
-- OR in2_reserve_pub = reserves.reserve_pub;
DECLARE DECLARE
curs_transaction_exist CURSOR curs_transaction_exist refcursor;
FOR SELECT reserve_pub
FROM reserves_in
WHERE in_reserve_pub = reserves_in.reserve_pub
OR in2_reserve_pub = reserves_in.reserve_pub;
DECLARE DECLARE
i RECORD; i RECORD;
DECLARE
r RECORD;
BEGIN BEGIN
--SIMPLE INSERT ON CONFLICT DO NOTHING --SIMPLE INSERT ON CONFLICT DO NOTHING
transaction_duplicate=FALSE; transaction_duplicate=FALSE;
@ -138,6 +130,8 @@ BEGIN
PERFORM pg_notify(in_notify, NULL); PERFORM pg_notify(in_notify, NULL);
PERFORM pg_notify(in2_notify, NULL); PERFORM pg_notify(in2_notify, NULL);
OPEN curs_transaction_exist FOR
WITH reserve_in_exist AS (
INSERT INTO reserves_in INSERT INTO reserves_in
(reserve_pub (reserve_pub
,wire_reference ,wire_reference
@ -161,33 +155,34 @@ BEGIN
,in2_exchange_account_name ,in2_exchange_account_name
,in2_wire_source_h_payto ,in2_wire_source_h_payto
,in_expiration_date) ,in_expiration_date)
ON CONFLICT DO NOTHING; ON CONFLICT DO NOTHING
RETURNING reserve_pub)
SELECT * FROM reserve_in_exist;
FETCH FROM curs_transaction_exist INTO r;
IF FOUND IF FOUND
THEN THEN
transaction_duplicate = FALSE; /*HAPPY PATH THERE IS NO DUPLICATE TRANS AND NEW RESERVE*/ IF in_reserve_pub = r.reserve_pub
transaction_duplicate2 = FALSE; THEN
RETURN; transaction_duplicate = TRUE;
ELSE END IF;
FOR l IN curs_transaction_exist IF in2_reserve_pub = i.reserve_pub
LOOP THEN
IF in_reserve_pub = l.reserve_pub transaction_duplicate = TRUE;
END IF;
FETCH FROM curs_transaction_exist INTO r;
IF FOUND
THEN
IF in_reserve_pub = r.reserve_pub
THEN THEN
transaction_duplicate = TRUE; transaction_duplicate = TRUE;
END IF; END IF;
IF in2_reserve_pub = i.reserve_pub
IF in2_reserve_pub = l.reserve_pub
THEN THEN
transaction_duplicate2 = TRUE; transaction_duplicate = TRUE;
END IF; END IF;
END IF;
IF transaction_duplicate AND transaction_duplicate2
THEN
RETURN;
END IF;
END LOOP;
END IF; END IF;
CLOSE curs_reserve_exist;
CLOSE curs_transaction_exist; CLOSE curs_transaction_exist;
RETURN; RETURN;
END $$; END $$;