diff options
author | Joseph <Joseph.xu@efrei.net> | 2023-01-05 09:22:16 -0500 |
---|---|---|
committer | Joseph <Joseph.xu@efrei.net> | 2023-01-05 09:22:16 -0500 |
commit | 043c46c59d62abcafef5c37fb97c66995e6b3859 (patch) | |
tree | f121671c6db0f942c7dbf6e5da273e04282bf1b4 /src/exchangedb/exchange_do_batch2_reserves_in_insert.sql | |
parent | d805c54052a4684a7312e05186169fb66c35668b (diff) | |
download | exchange-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.sql | 32 |
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); |