Line data Source code
1 : /* 2 : This file is part of TALER 3 : Copyright (C) 2024 Taler Systems SA 4 : 5 : TALER is free software; you can redistribute it and/or modify it under the 6 : terms of the GNU General Public License as published by the Free Software 7 : Foundation; either version 3, or (at your option) any later version. 8 : 9 : TALER is distributed in the hope that it will be useful, but WITHOUT ANY 10 : WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR 11 : A PARTICULAR PURPOSE. See the GNU General Public License for more details. 12 : 13 : You should have received a copy of the GNU General Public License along with 14 : TALER; see the file COPYING. If not, see <http://www.gnu.org/licenses/> 15 : */ 16 : /** 17 : * @file pg_insert_auditor_progress.c 18 : * @brief Low-level (statement-level) Postgres database access for the exchange 19 : * @author Christian Grothoff 20 : */ 21 : #include "platform.h" 22 : #include "taler_error_codes.h" 23 : #include "taler_dbevents.h" 24 : #include "taler_pq_lib.h" 25 : #include "pg_insert_auditor_progress.h" 26 : #include "pg_helper.h" 27 : 28 : 29 : enum GNUNET_DB_QueryStatus 30 506 : TAH_PG_insert_auditor_progress ( 31 : void *cls, 32 : const char *progress_key, 33 : uint64_t progress_offset, 34 : ...) 35 : { 36 506 : struct PostgresClosure *pg = cls; 37 506 : unsigned int cnt = 1; 38 : va_list ap; 39 : 40 506 : va_start (ap, 41 : progress_offset); 42 2155 : while (NULL != va_arg (ap, 43 : const char *)) 44 : { 45 1649 : cnt++; 46 1649 : (void) va_arg (ap, 47 : uint64_t); 48 : } 49 506 : va_end (ap); 50 506 : { 51 506 : const char *keys[cnt]; 52 506 : uint64_t offsets[cnt]; 53 506 : unsigned int off = 1; 54 506 : struct GNUNET_PQ_QueryParam params[] = { 55 506 : GNUNET_PQ_query_param_array_ptrs_string (cnt, 56 : keys, 57 : pg->conn), 58 506 : GNUNET_PQ_query_param_array_uint64 (cnt, 59 : offsets, 60 : pg->conn), 61 : GNUNET_PQ_query_param_end 62 : }; 63 : enum GNUNET_DB_QueryStatus qs; 64 : 65 506 : keys[0] = progress_key; 66 506 : offsets[0] = progress_offset; 67 : 68 506 : va_start (ap, 69 : progress_offset); 70 2155 : while (off < cnt) 71 : { 72 1649 : keys[off] = va_arg (ap, 73 : const char *); 74 1649 : offsets[off] = va_arg (ap, 75 : uint64_t); 76 1649 : off++; 77 : } 78 506 : GNUNET_assert (NULL == va_arg (ap, 79 : const char *)); 80 506 : va_end (ap); 81 : 82 506 : PREPARE (pg, 83 : "auditor_progress_insert", 84 : "INSERT INTO auditor_progress " 85 : "(progress_key" 86 : ",progress_offset" 87 : ") SELECT *" 88 : " FROM UNNEST (CAST($1 AS TEXT[])," 89 : " CAST($2 AS INT8[]))" 90 : " ON CONFLICT DO NOTHING;"); 91 506 : qs = GNUNET_PQ_eval_prepared_non_select (pg->conn, 92 : "auditor_progress_insert", 93 : params); 94 506 : GNUNET_PQ_cleanup_query_params_closures (params); 95 506 : return qs; 96 : } 97 : }