summaryrefslogtreecommitdiff
path: root/src/auditordb/pg_get_emergency_by_count.c
diff options
context:
space:
mode:
authorCedric Zwahlen <cedric.zwahlen@students.bfh.ch>2024-04-16 18:54:24 +0200
committerCedric Zwahlen <cedric.zwahlen@students.bfh.ch>2024-04-19 20:47:34 +0200
commitba725b627efe5d5a6b4131898c7ee643fce85380 (patch)
tree01aad63c0e7a12f37e026fc64d1fc8f839fda5ce /src/auditordb/pg_get_emergency_by_count.c
parent962bcbc6a6bd10f3bbe80766278c36b02f53c7e4 (diff)
downloadexchange-ba725b627efe5d5a6b4131898c7ee643fce85380.tar.gz
exchange-ba725b627efe5d5a6b4131898c7ee643fce85380.tar.bz2
exchange-ba725b627efe5d5a6b4131898c7ee643fce85380.zip
Fix various CRUD bugs
Diffstat (limited to 'src/auditordb/pg_get_emergency_by_count.c')
-rw-r--r--src/auditordb/pg_get_emergency_by_count.c52
1 files changed, 27 insertions, 25 deletions
diff --git a/src/auditordb/pg_get_emergency_by_count.c b/src/auditordb/pg_get_emergency_by_count.c
index b056683c1..589ca31e0 100644
--- a/src/auditordb/pg_get_emergency_by_count.c
+++ b/src/auditordb/pg_get_emergency_by_count.c
@@ -108,14 +108,14 @@ TAH_PG_get_emergency_by_count (
TALER_AUDITORDB_EmergenciesByCountCallback cb,
void *cb_cls)
{
-
+ uint64_t plimit = (uint64_t) ((limit < 0) ? -limit : limit);
struct PostgresClosure *pg = cls;
- struct GNUNET_PQ_QueryParam params[] = {
- GNUNET_PQ_query_param_uint64 (&offset),
- GNUNET_PQ_query_param_bool (return_suppressed),
- GNUNET_PQ_query_param_int64 (&limit),
- GNUNET_PQ_query_param_end
- };
+ struct GNUNET_PQ_QueryParam params[] = {
+ GNUNET_PQ_query_param_uint64 (&offset),
+ GNUNET_PQ_query_param_bool (return_suppressed),
+ GNUNET_PQ_query_param_uint64 (&plimit),
+ GNUNET_PQ_query_param_end
+ };
struct EmergencyByCountContext dcc = {
.cb = cb,
.cb_cls = cb_cls,
@@ -140,25 +140,27 @@ TAH_PG_get_emergency_by_count (
" ORDER BY row_id DESC"
" LIMIT $3"
);
- PREPARE (pg,
- "auditor_emergency_by_count_get_asc",
- "SELECT"
- " row_id"
- ",denompub_h"
- ",num_issued"
- ",num_known"
- ",risk"
- ",start"
- ",deposit_end"
- ",value"
- " FROM auditor_emergency"
- " WHERE (row_id > $1)"
- " AND ($2 OR suppressed is false)"
- " ORDER BY row_id ASC"
- " LIMIT $3"
- );
+ PREPARE (pg,
+ "auditor_emergency_by_count_get_asc",
+ "SELECT"
+ " row_id"
+ ",denompub_h"
+ ",num_issued"
+ ",num_known"
+ ",risk"
+ ",start"
+ ",deposit_end"
+ ",value"
+ " FROM auditor_emergency"
+ " WHERE (row_id > $1)"
+ " AND ($2 OR suppressed is false)"
+ " ORDER BY row_id ASC"
+ " LIMIT $3"
+ );
qs = GNUNET_PQ_eval_prepared_multi_select (pg->conn,
- (limit > 0) ? "auditor_emergency_by_count_get_asc" : "auditor_emergency_by_count_get_desc",
+ (limit > 0) ?
+ "auditor_emergency_by_count_get_asc"
+ : "auditor_emergency_by_count_get_desc",
params,
&emergency_by_count_cb,
&dcc);