merchant

Merchant backend to process payments, run by merchants
Log | Files | Refs | Submodules | README | LICENSE

pg_select_category.c (3221B)


      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 backenddb/pg_select_category.c
     18  * @brief Implementation of the select_category function for Postgres
     19  * @author Christian Grothoff
     20  */
     21 #include "platform.h"
     22 #include <taler/taler_error_codes.h>
     23 #include <taler/taler_dbevents.h>
     24 #include <taler/taler_pq_lib.h>
     25 #include "pg_select_category.h"
     26 #include "pg_helper.h"
     27 
     28 
     29 enum GNUNET_DB_QueryStatus
     30 TMH_PG_select_category (
     31   void *cls,
     32   const char *instance_id,
     33   uint64_t category_id,
     34   struct TALER_MERCHANTDB_CategoryDetails *cd,
     35   size_t *num_products,
     36   char **products)
     37 {
     38   struct PostgresClosure *pg = cls;
     39   struct GNUNET_PQ_QueryParam params[] = {
     40     GNUNET_PQ_query_param_string (instance_id),
     41     GNUNET_PQ_query_param_uint64 (&category_id),
     42     GNUNET_PQ_query_param_end
     43   };
     44 
     45   if (NULL == cd)
     46   {
     47     struct GNUNET_PQ_ResultSpec rs_null[] = {
     48       GNUNET_PQ_result_spec_end
     49     };
     50 
     51     check_connection (pg);
     52     return GNUNET_PQ_eval_prepared_singleton_select (
     53       pg->conn,
     54       "select_category",
     55       params,
     56       rs_null);
     57   }
     58   else
     59   {
     60     struct GNUNET_PQ_ResultSpec rs[] = {
     61       GNUNET_PQ_result_spec_string ("category_name",
     62                                     &cd->category_name),
     63       TALER_PQ_result_spec_json ("category_name_i18n",
     64                                  &cd->category_name_i18n),
     65       GNUNET_PQ_result_spec_array_string (pg->conn,
     66                                           "products",
     67                                           num_products,
     68                                           products),
     69       GNUNET_PQ_result_spec_end
     70     };
     71 
     72     PREPARE (pg,
     73              "select_category",
     74              "SELECT"
     75              " category_name"
     76              ",category_name_i18n::TEXT"
     77              ",t.product_array AS products"
     78              " FROM merchant_categories mc"
     79              " JOIN merchant_instances inst"
     80              "   USING (merchant_serial)"
     81              ",LATERAL ("
     82              "   SELECT ARRAY ("
     83              "     SELECT "
     84              "         mi.product_id AS product_id"
     85              "       FROM merchant_product_categories mpc"
     86              "       JOIN merchant_inventory mi"
     87              "          USING (product_serial)"
     88              "      WHERE mpc.category_serial = mc.category_serial"
     89              "   ) AS product_array"
     90              " ) t"
     91              " WHERE inst.merchant_id=$1"
     92              "   AND mc.category_serial=$2");
     93     check_connection (pg);
     94     return GNUNET_PQ_eval_prepared_singleton_select (
     95       pg->conn,
     96       "select_category",
     97       params,
     98       rs);
     99   }
    100 }