Line data Source code
1 : /* 2 : This file is part of TALER 3 : Copyright (C) 2022 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 exchangedb/pg_create_tables.c 18 : * @brief Implementation of the create_tables function for Postgres 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_create_tables.h" 26 : #include "pg_helper.h" 27 : 28 : 29 : enum GNUNET_GenericReturnValue 30 57 : TEH_PG_create_tables (void *cls, 31 : bool support_partitions, 32 : uint32_t num_partitions) 33 : { 34 57 : struct PostgresClosure *pg = cls; 35 : struct GNUNET_PQ_Context *conn; 36 : enum GNUNET_GenericReturnValue ret; 37 57 : struct GNUNET_PQ_QueryParam params[] = { 38 : support_partitions 39 0 : ? GNUNET_PQ_query_param_uint32 (&num_partitions) 40 57 : : GNUNET_PQ_query_param_null (), 41 : GNUNET_PQ_query_param_end 42 : }; 43 57 : struct GNUNET_PQ_ExecuteStatement es[] = { 44 57 : GNUNET_PQ_make_try_execute ("SET search_path TO exchange;"), 45 : GNUNET_PQ_EXECUTE_STATEMENT_END 46 : }; 47 : 48 57 : conn = GNUNET_PQ_connect_with_cfg (pg->cfg, 49 : "exchangedb-postgres", 50 : "exchange-", 51 : es, 52 : NULL); 53 57 : if (NULL == conn) 54 0 : return GNUNET_SYSERR; 55 57 : ret = GNUNET_PQ_exec_sql (conn, 56 : "procedures"); 57 57 : GNUNET_break (GNUNET_OK == ret); 58 57 : if (GNUNET_OK == ret) 59 : { 60 : struct GNUNET_PQ_Context *tconn; 61 : 62 57 : tconn = pg->conn; 63 57 : pg->prep_gen++; 64 57 : pg->conn = conn; 65 57 : PREPARE (pg, 66 : "create_tables", 67 : "SELECT" 68 : " exchange_do_create_tables" 69 : " ($1::INTEGER);"); 70 57 : pg->conn = tconn; 71 57 : if (0 > 72 57 : GNUNET_PQ_eval_prepared_non_select (conn, 73 : "create_tables", 74 : params)) 75 : { 76 0 : GNUNET_break (0); 77 0 : ret = GNUNET_SYSERR; 78 : } 79 : } 80 57 : GNUNET_PQ_disconnect (conn); 81 57 : return ret; 82 : }