diff options
| author | Christian Grothoff <christian@grothoff.org> | 2024-08-29 06:48:31 +0200 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2024-08-29 06:48:31 +0200 |
| commit | 2d3e7e86dba75c881dc15a9c76f221e312dd84df (patch) | |
| tree | 5ded35c4e3db7ecc462d16cf5920ffa2c459d812 /src/exchangedb | |
| parent | ce9de215f728e7734aed98b30c9d41629984848a (diff) | |
-actually call new stored procedure
Diffstat (limited to 'src/exchangedb')
| -rw-r--r-- | src/exchangedb/pg_select_aggregations_above_serial.c | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/exchangedb/pg_select_aggregations_above_serial.c b/src/exchangedb/pg_select_aggregations_above_serial.c index e65e3740b..56f99b022 100644 --- a/src/exchangedb/pg_select_aggregations_above_serial.c +++ b/src/exchangedb/pg_select_aggregations_above_serial.c @@ -75,7 +75,7 @@ aggregation_serial_helper_cb (void *cls, uint64_t batch_deposit_serial_id; struct TALER_Amount amount; struct GNUNET_PQ_ResultSpec rs[] = { - TALER_PQ_RESULT_SPEC_AMOUNT ("amount", + TALER_PQ_RESULT_SPEC_AMOUNT ("total_amount", &amount), GNUNET_PQ_result_spec_uint64 ("aggregation_serial_id", &tracking_rowid), @@ -128,9 +128,8 @@ TEH_PG_select_aggregations_above_serial ( "SELECT" " aggregation_serial_id" ",batch_deposit_serial_id" - " FROM aggregation_tracking" - " WHERE aggregation_serial_id>=$1" - " ORDER BY aggregation_serial_id ASC;"); + ",total_amount" + " FROM exchange_do_select_aggregations_above_serial($1);"); qs = GNUNET_PQ_eval_prepared_multi_select (pg->conn, "select_aggregations_above_serial", params, |