2 This file is part of GNUnet
3 Copyright (C) 2016 GNUnet e.V.
5 GNUnet is free software; you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published
7 by the Free Software Foundation; either version 3, or (at your
8 option) any later version.
10 GNUnet is distributed in the hope that it will be useful, but
11 WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 General Public License for more details.
15 You should have received a copy of the GNU General Public License
16 along with GNUnet; see the file COPYING. If not, write to the
17 Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
18 Boston, MA 02110-1301, USA.
22 * @brief library to help with access to a MySQL database
23 * @author Christian Grothoff
26 #include <mysql/mysql.h>
27 #include "gnunet_my_lib.h"
32 * Run a prepared SELECT statement.
34 * @param mc mysql context
35 * @param sh handle to SELECT statment
36 * @param params parameters to the statement
40 GNUNET_MY_exec_prepared (struct GNUNET_MYSQL_Context *mc,
41 struct GNUNET_MYSQL_StatementHandle *sh,
42 const struct GNUNET_MY_QueryParam *params)
44 const struct GNUNET_MY_QueryParam *p;
50 for (i=0;NULL != params[i].conv;i++)
51 num += params[i].num_params;
53 MYSQL_BIND qbind[num];
56 memset(qbind, 0, sizeof(qbind));
58 for (i=0;NULL != (p = ¶ms[i])->conv;i++)
69 stmt = GNUNET_MYSQL_statement_get_stmt (mc, sh);
70 if (mysql_stmt_bind_param (stmt,
73 GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, "mysql",
74 _("`%s' failed at %s:%d with error: %s\n"),
75 "mysql_stmt_bind_param", __FILE__, __LINE__,
76 mysql_stmt_error (stmt));
77 GNUNET_MYSQL_statements_invalidate (mc);
81 if (mysql_stmt_execute (stmt))
83 GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, "mysql",
84 _("`%s' failed at %s:%d with error: %s\n"),
85 "mysql_stmt_execute", __FILE__, __LINE__,
86 mysql_stmt_error (stmt));
87 GNUNET_MYSQL_statements_invalidate (mc);
94 * Extract results from a query result according
95 * to the given specification. If colums are NULL,
96 * the destination is not modified, and #GNUNET_NO is returned
100 * @param row, the row from the result to extract
101 * @param result specificatio to extract for
103 #GNUNET_YES if all results could be extracted
104 #GNUNET_NO if at least one result was NULL
105 #GNUNET_SYSERR if a result was invalid
108 GNUNET_MY_extract_result (MYSQL_BIND * result,
109 struct GNUNET_MY_QueryParam *qp,
110 struct GNUNET_MY_ResultSpec *rs,
114 int had_null = GNUNET_NO;
117 for(i = 0 ; NULL != rs[i].conv ; i++)
119 struct GNUNET_MY_ResultSpec *spec;
122 ret = spec->conv(spec->conv_cls,
126 if(ret == GNUNET_SYSERR){
127 //GNUNET_MY_cleanup_result(rs);
128 return GNUNET_SYSERR;
131 if(spec->result_size != NULL)
132 *spec->result_size = spec->dst_size;
135 if(GNUNET_YES == had_null)