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

Update queries for better network load in sharded setup

Browse Source
This commit is contained in:
Marco Boss 2022-04-06 14:21:57 +02:00
commit fe2a15c558
No known key found for this signature in database
GPG Key ID: 89A3EC33C625C3DF
2 changed files with 160 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/exchangedb/exchange-0001-part.sql
View File

@ -1466,17 +1466,33 @@ END IF;
-- Obtain KYC status based on the last wire transfer into -- Obtain KYC status based on the last wire transfer into
-- this reserve. FIXME: likely not adequate for reserves that got P2P transfers! -- this reserve. FIXME: likely not adequate for reserves that got P2P transfers!
SELECT -- SELECT
kyc_ok -- kyc_ok
,wire_target_serial_id -- ,wire_target_serial_id
INTO -- INTO
kycok -- kycok
,account_uuid -- ,account_uuid
FROM reserves_in -- FROM reserves_in
JOIN wire_targets ON (wire_source_h_payto = wire_target_h_payto) -- JOIN wire_targets ON (wire_source_h_payto = wire_target_h_payto)
WHERE reserve_pub=rpub -- WHERE reserve_pub=rpub
LIMIT 1; -- limit 1 should not be required (without p2p transfers) -- LIMIT 1; -- limit 1 should not be required (without p2p transfers)
WITH reserves_in AS materialized (
SELECT wire_source_h_payto
FROM reserves_in WHERE
reserve_pub=rpub
)
SELECT
kyc_ok
,wire_target_serial_id
INTO
kycok
,account_uuid
FROM wire_targets
WHERE wire_target_h_payto = (
SELECT wire_source_h_payto
FROM reserves_in
);
END $$; END $$;

136
src/exchangedb/plugin_exchangedb_postgres.c
View File

@ -749,6 +749,7 @@ prepare_statements (struct PostgresClosure *pg)
for a reserve */ for a reserve */
GNUNET_PQ_make_prepare ( GNUNET_PQ_make_prepare (
"reserves_in_get_transactions", "reserves_in_get_transactions",
/*
"SELECT" "SELECT"
" wire_reference" " wire_reference"
",credit_val" ",credit_val"
@ -759,6 +760,24 @@ prepare_statements (struct PostgresClosure *pg)
" JOIN wire_targets" " JOIN wire_targets"
" ON (wire_source_h_payto = wire_target_h_payto)" " ON (wire_source_h_payto = wire_target_h_payto)"
" WHERE reserve_pub=$1;", " WHERE reserve_pub=$1;",
*/
"WITH ri AS MATERIALIZED ( "
" SELECT * "
" FROM reserves_in "
" WHERE reserve_pub = $1 "
") "
"SELECT "
" wire_reference "
" ,credit_val "
" ,credit_frac "
" ,execution_date "
" ,payto_uri AS sender_account_details "
"FROM wire_targets "
"JOIN ri "
" ON (wire_target_h_payto = wire_source_h_payto) "
"WHERE wire_target_h_payto = ( "
" SELECT wire_source_h_payto FROM ri "
"); ",
1), 1),
/* Used in #postgres_do_withdraw() to store /* Used in #postgres_do_withdraw() to store
the signature of a blinded coin with the blinded coin's the signature of a blinded coin with the blinded coin's
@ -879,6 +898,7 @@ prepare_statements (struct PostgresClosure *pg)
demonstrate double-spending) */ demonstrate double-spending) */
GNUNET_PQ_make_prepare ( GNUNET_PQ_make_prepare (
"get_reserves_out", "get_reserves_out",
/*
"SELECT" "SELECT"
" ro.h_blind_ev" " ro.h_blind_ev"
",denom.denom_pub_hash" ",denom.denom_pub_hash"
@ -897,6 +917,30 @@ prepare_statements (struct PostgresClosure *pg)
" JOIN denominations denom" " JOIN denominations denom"
" ON (ro.denominations_serial = denom.denominations_serial)" " ON (ro.denominations_serial = denom.denominations_serial)"
" WHERE res.reserve_pub=$1;", " WHERE res.reserve_pub=$1;",
*/
"WITH robr AS MATERIALIZED ( "
" SELECT h_blind_ev "
" FROM reserves_out_by_reserve "
" WHERE reserve_uuid= ( "
" SELECT reserve_uuid "
" FROM reserves "
" WHERE reserve_pub = $1 "
" ) "
") SELECT "
" ro.h_blind_ev "
" ,denom.denom_pub_hash "
" ,ro.denom_sig "
" ,ro.reserve_sig "
" ,ro.execution_date "
" ,ro.amount_with_fee_val "
" ,ro.amount_with_fee_frac "
" ,denom.fee_withdraw_val "
" ,denom.fee_withdraw_frac "
"FROM robr "
"JOIN reserves_out ro "
" ON (ro.h_blind_ev = robr.h_blind_ev) "
"JOIN denominations denom "
" ON (ro.denominations_serial = denom.denominations_serial); ",
1), 1),
/* Used in #postgres_select_withdrawals_above_serial_id() */ /* Used in #postgres_select_withdrawals_above_serial_id() */
@ -1040,7 +1084,7 @@ prepare_statements (struct PostgresClosure *pg)
high-level information about a melt operation */ high-level information about a melt operation */
GNUNET_PQ_make_prepare ( GNUNET_PQ_make_prepare (
"get_melt", "get_melt",
"SELECT" /* "SELECT"
" denoms.denom_pub_hash" " denoms.denom_pub_hash"
",denoms.fee_refresh_val" ",denoms.fee_refresh_val"
",denoms.fee_refresh_frac" ",denoms.fee_refresh_frac"
@ -1056,7 +1100,33 @@ prepare_statements (struct PostgresClosure *pg)
" ON (old_coin_pub = kc.coin_pub)" " ON (old_coin_pub = kc.coin_pub)"
" JOIN denominations denoms" " JOIN denominations denoms"
" ON (kc.denominations_serial = denoms.denominations_serial)" " ON (kc.denominations_serial = denoms.denominations_serial)"
" WHERE rc=$1;", " WHERE rc=$1;", */
"WITH rc AS MATERIALIZED ( "
" SELECT"
" * FROM refresh_commitments"
" WHERE rc=$1"
")"
"SELECT"
" denoms.denom_pub_hash"
",denoms.fee_refresh_val"
",denoms.fee_refresh_frac"
",rc.old_coin_pub"
",rc.old_coin_sig"
",kc.age_commitment_hash"
",amount_with_fee_val"
",amount_with_fee_frac"
",noreveal_index"
",melt_serial_id "
"FROM ("
" SELECT"
" * "
" FROM known_coins"
" WHERE coin_pub=(SELECT old_coin_pub from rc)"
") kc "
"JOIN rc"
" ON (kc.coin_pub=rc.old_coin_pub) "
"JOIN denominations denoms"
" USING (denominations_serial);",
1), 1),
/* Used in #postgres_select_refreshes_above_serial_id() to fetch /* Used in #postgres_select_refreshes_above_serial_id() to fetch
refresh session with id '\geq' the given parameter */ refresh session with id '\geq' the given parameter */
@ -1889,6 +1959,7 @@ prepare_statements (struct PostgresClosure *pg)
BEGIN; SET LOCAL join_collapse_limit=1; query; COMMIT; */ BEGIN; SET LOCAL join_collapse_limit=1; query; COMMIT; */
GNUNET_PQ_make_prepare ( GNUNET_PQ_make_prepare (
"recoup_by_reserve", "recoup_by_reserve",
/*
"SELECT" "SELECT"
" recoup.coin_pub" " recoup.coin_pub"
",recoup.coin_sig" ",recoup.coin_sig"
@ -1913,6 +1984,42 @@ prepare_statements (struct PostgresClosure *pg)
" ON (reserves_out_by_reserve.h_blind_ev = reserves_out.h_blind_ev))" " ON (reserves_out_by_reserve.h_blind_ev = reserves_out.h_blind_ev))"
" ON (recoup_by_reserve.reserve_out_serial_id = reserves_out.reserve_out_serial_id)" " ON (recoup_by_reserve.reserve_out_serial_id = reserves_out.reserve_out_serial_id)"
" WHERE reserves.reserve_pub=$1);", " WHERE reserves.reserve_pub=$1);",
*/
"WITH res AS MATERIALIZED ( "
" SELECT * "
" FROM reserves "
" WHERE reserve_pub = $1 "
"), "
"coin_pub AS MATERIALIZED ( "
" SELECT coin_pub "
" FROM recoup_by_reserve "
" JOIN (reserves_out "
" JOIN ( "
" SELECT * "
" FROM reserves_out_by_reserve "
" WHERE reserves_out_by_reserve.reserve_uuid = ( "
" SELECT reserve_uuid FROM res "
" ) "
" ) reserves_out_by_reserve "
" ON (reserves_out_by_reserve.h_blind_ev = reserves_out.h_blind_ev)) "
" ON (recoup_by_reserve.reserve_out_serial_id = reserves_out.reserve_out_serial_id) "
") "
"SELECT recoup.coin_pub "
" ,recoup.coin_sig "
" ,recoup.coin_blind "
" ,recoup.amount_val "
" ,recoup.amount_frac "
" ,recoup.recoup_timestamp "
" ,denominations.denom_pub_hash "
" ,known_coins.denom_sig "
"FROM denominations "
" JOIN (known_coins "
" JOIN recoup "
" ON (recoup.coin_pub = known_coins.coin_pub)) "
" ON (known_coins.denominations_serial = denominations.denominations_serial) "
"WHERE recoup.coin_pub = ( "
" SELECT coin_pub FROM coin_pub "
"); ",
1), 1),
/* Used in #postgres_get_coin_transactions() to obtain recoup transactions /* Used in #postgres_get_coin_transactions() to obtain recoup transactions
affecting old coins of refreshed coins */ affecting old coins of refreshed coins */
@ -1959,6 +2066,7 @@ prepare_statements (struct PostgresClosure *pg)
/* Used in #postgres_get_expired_reserves() */ /* Used in #postgres_get_expired_reserves() */
GNUNET_PQ_make_prepare ( GNUNET_PQ_make_prepare (
"get_expired_reserves", "get_expired_reserves",
/*
"SELECT" "SELECT"
" expiration_date" " expiration_date"
",payto_uri AS account_details" ",payto_uri AS account_details"
@ -1975,6 +2083,30 @@ prepare_statements (struct PostgresClosure *pg)
" OR current_balance_frac != 0)" " OR current_balance_frac != 0)"
" ORDER BY expiration_date ASC" " ORDER BY expiration_date ASC"
" LIMIT 1;", " LIMIT 1;",
*/
"WITH ed AS MATERIALIZED ( "
" SELECT * "
" FROM reserves "
" WHERE expiration_date <= $1 "
" AND (current_balance_val != 0 OR current_balance_frac != 0) "
" ORDER BY expiration_date ASC "
" LIMIT 1 "
") "
"SELECT "
" ed.expiration_date "
" ,payto_uri AS account_details "
" ,ed.reserve_pub "
" ,current_balance_val "
" ,current_balance_frac "
"FROM ( "
" SELECT "
" * "
" FROM reserves_in "
" WHERE reserve_pub = ( "
" SELECT reserve_pub FROM ed) "
" ) ri "
"JOIN wire_targets wt ON (ri.wire_source_h_payto = wt.wire_target_h_payto) "
"JOIN ed ON (ri.reserve_pub = ed.reserve_pub); ",
1), 1),
/* Used in #postgres_get_coin_transactions() to obtain recoup transactions /* Used in #postgres_get_coin_transactions() to obtain recoup transactions
for a coin */ for a coin */