2 This file is part of GNUnet
3 Copyright (C) 2016 Inria & 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 Christophe Genevey
24 * @author Christian Grothoff
27 #include <mysql/mysql.h>
28 #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
38 #GNUNET_YES if we can prepare all statement
39 #GNUNET_SYSERR if we can't prepare all statement
42 GNUNET_MY_exec_prepared (struct GNUNET_MYSQL_Context *mc,
43 struct GNUNET_MYSQL_StatementHandle *sh,
44 struct GNUNET_MY_QueryParam *params)
46 const struct GNUNET_MY_QueryParam *p;
52 for (i=0;NULL != params[i].conv;i++)
53 num += params[i].num_params;
55 MYSQL_BIND qbind[num];
58 memset (qbind, 0, sizeof(qbind));
60 for (i=0;NULL != (p = ¶ms[i])->conv;i++)
67 GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
68 "Conversion for MySQL query failed at offset %u\n",
74 stmt = GNUNET_MYSQL_statement_get_stmt (sh);
75 if (mysql_stmt_bind_param (stmt,
78 GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR,
80 _("`%s' failed at %s:%d with error: %s\n"),
81 "mysql_stmt_bind_param",
83 mysql_stmt_error (stmt));
84 GNUNET_MYSQL_statements_invalidate (mc);
88 if (mysql_stmt_execute (stmt))
90 GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR,
92 _("`%s' failed at %s:%d with error: %s\n"),
93 "mysql_stmt_execute", __FILE__, __LINE__,
94 mysql_stmt_error (stmt));
95 GNUNET_MYSQL_statements_invalidate (mc);
98 GNUNET_MY_cleanup_query (params,
106 * Free all memory that was allocated in @a qp during
107 * #GNUNET_MY_exec_prepared().
109 * @param qp query specification to clean up
110 * @param qbind array of parameter to clean up
113 GNUNET_MY_cleanup_query (struct GNUNET_MY_QueryParam *qp,
118 for (i=0; NULL != qp[i].conv ;i++)
119 if (NULL != qp[i].cleaner)
120 qp[i].cleaner (qp[i].conv_cls,
126 * Extract results from a query result according to the given
127 * specification. Always fetches the next row.
129 * @param sh statement that returned results
130 * @param rs specification to extract for
132 * #GNUNET_YES if all results could be extracted
133 * #GNUNET_NO if there is no more data in the result set
134 * #GNUNET_SYSERR if a result was invalid
137 GNUNET_MY_extract_result (struct GNUNET_MYSQL_StatementHandle *sh,
138 struct GNUNET_MY_ResultSpec *rs)
140 unsigned int num_fields;
145 stmt = GNUNET_MYSQL_statement_get_stmt (sh);
149 return GNUNET_SYSERR;
153 mysql_stmt_free_result (stmt);
158 for (i=0;NULL != rs[i].pre_conv;i++)
159 num_fields += rs[i].num_fields;
161 if (mysql_stmt_field_count (stmt) != num_fields)
163 GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
164 "Number of fields missmatch between SQL result and result specification\n");
165 return GNUNET_SYSERR;
169 MYSQL_BIND result[num_fields];
170 unsigned int field_off;
172 memset (result, 0, sizeof (MYSQL_BIND) * num_fields);
174 for (i=0;NULL != rs[i].pre_conv;i++)
176 struct GNUNET_MY_ResultSpec *rp = &rs[i];
179 rp->pre_conv (rp->conv_cls,
186 GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
187 "Pre-conversion for MySQL result failed at offset %u\n",
189 return GNUNET_SYSERR;
191 field_off += rp->num_fields;
194 if (mysql_stmt_bind_result (stmt, result))
196 GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR,
198 _("%s failed at %s:%d with error: %s\n"),
199 "mysql_stmt_bind_result",
201 mysql_stmt_error (stmt));
202 return GNUNET_SYSERR;
204 #if TEST_OPTIMIZATION
205 (void) mysql_stmt_store_result (stmt);
207 ret = mysql_stmt_fetch (stmt);
208 if (MYSQL_NO_DATA == ret)
210 mysql_stmt_free_result (stmt);
215 GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR,
217 _("%s failed at %s:%d with error: %s\n"),
220 mysql_stmt_error (stmt));
221 GNUNET_MY_cleanup_result (rs);
222 mysql_stmt_free_result (stmt);
223 return GNUNET_SYSERR;
226 for (i=0;NULL != rs[i].post_conv;i++)
228 struct GNUNET_MY_ResultSpec *rp = &rs[i];
230 if (NULL != rp->post_conv)
232 rp->post_conv (rp->conv_cls,
238 GNUNET_log (GNUNET_ERROR_TYPE_INFO,
239 "Post-conversion for MySQL result failed at offset %u\n",
241 mysql_stmt_free_result (stmt);
242 GNUNET_MY_cleanup_result (rs);
243 return GNUNET_SYSERR;
245 field_off += rp->num_fields;
253 * Free all memory that was allocated in @a rs during
254 * #GNUNET_MY_extract_result().
256 * @param rs result specification to clean up
259 GNUNET_MY_cleanup_result (struct GNUNET_MY_ResultSpec *rs)
263 for (i=0;NULL != rs[i].post_conv;i++)
264 if (NULL != rs[i].cleaner)
265 rs[i].cleaner (rs[i].conv_cls,