diff options
| author | Joseph <Joseph.xu@efrei.net> | 2022-11-25 06:09:20 -0500 |
|---|---|---|
| committer | Joseph <Joseph.xu@efrei.net> | 2022-12-06 08:09:45 -0500 |
| commit | 6e3d1bdc91254a5bd57d58e5280e20813211157b (patch) | |
| tree | 6b9a7cb73af409a57130f216acfea18199a329e5 /src/exchangedb/pg_get_link_data.c | |
| parent | b6476ac881cfd3bde41c88b94f6a7538acf76f9c (diff) | |
| download | exchange-6e3d1bdc91254a5bd57d58e5280e20813211157b.tar.gz exchange-6e3d1bdc91254a5bd57d58e5280e20813211157b.tar.bz2 exchange-6e3d1bdc91254a5bd57d58e5280e20813211157b.zip | |
some modifications for batch test
Diffstat (limited to 'src/exchangedb/pg_get_link_data.c')
| -rw-r--r-- | src/exchangedb/pg_get_link_data.c | 68 |
1 files changed, 49 insertions, 19 deletions
diff --git a/src/exchangedb/pg_get_link_data.c b/src/exchangedb/pg_get_link_data.c index 930862890..f15bf35a2 100644 --- a/src/exchangedb/pg_get_link_data.c +++ b/src/exchangedb/pg_get_link_data.c @@ -178,25 +178,55 @@ TEH_PG_get_link_data (void *cls, enum GNUNET_DB_QueryStatus qs; struct LinkDataContext ldctx; - PREPARE (pg, - "get_link", - "SELECT " - " tp.transfer_pub" - ",denoms.denom_pub" - ",rrc.ev_sig" - ",rrc.ewv" - ",rrc.link_sig" - ",rrc.freshcoin_index" - ",rrc.coin_ev" - " FROM refresh_commitments" - " JOIN refresh_revealed_coins rrc" - " USING (melt_serial_id)" - " JOIN refresh_transfer_keys tp" - " USING (melt_serial_id)" - " JOIN denominations denoms" - " ON (rrc.denominations_serial = denoms.denominations_serial)" - " WHERE old_coin_pub=$1" - " ORDER BY tp.transfer_pub, rrc.freshcoin_index ASC"); + if (NULL == getenv ("NEW_LOGIC")) + { + PREPARE (pg, + "get_link", + "SELECT " + " tp.transfer_pub" + ",denoms.denom_pub" + ",rrc.ev_sig" + ",rrc.ewv" + ",rrc.link_sig" + ",rrc.freshcoin_index" + ",rrc.coin_ev" + " FROM refresh_commitments" + " JOIN refresh_revealed_coins rrc" + " USING (melt_serial_id)" + " JOIN refresh_transfer_keys tp" + " USING (melt_serial_id)" + " JOIN denominations denoms" + " ON (rrc.denominations_serial = denoms.denominations_serial)" + " WHERE old_coin_pub=$1" + " ORDER BY tp.transfer_pub, rrc.freshcoin_index ASC"); + } + + else + { + PREPARE (pg, + "get_link", + "WITH rc AS MATERIALIZED (" + "SELECT" + "* FROM refresh_commitments" + "WHERE old_coin_pub=$1" + ")" + "SELECT " + " tp.transfer_pub" + ",denoms.denom_pub" + ",rrc.ev_sig" + ",rrc.ewv" + ",rrc.link_sig" + ",rrc.freshcoin_index" + ",rrc.coin_ev" + " FROM refresh_revealed_coins rrc" + " USING (melt_serial_id)" + " JOIN refresh_transfer_keys tp" + " USING (melt_serial_id)" + " JOIN denominations denoms" + " USING (denominations_serial)" + " ORDER BY tp.transfer_pub, rrc.freshcoin_index ASC"); + } + ldctx.ldc = ldc; ldctx.ldc_cls = ldc_cls; ldctx.last = NULL; |