2 This file is part of GNUnet
3 Copyright (C) 2016, 2018 GNUnet e.V.
5 GNUnet is free software: you can redistribute it and/or modify it
6 under the terms of the GNU Affero General Public License as published
7 by the Free Software Foundation, either version 3 of the License,
8 or (at your 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 Affero General Public License for more details.
15 You should have received a copy of the GNU Affero General Public License
16 along with this program. If not, see <http://www.gnu.org/licenses/>.
20 * @brief library to help with access to a MySQL database
21 * @author Christophe Genevey
22 * @author Christian Grothoff
25 #include <mysql/mysql.h>
26 #include "gnunet_my_lib.h"
30 * Run a prepared SELECT statement.
32 * @param mc mysql context
33 * @param sh handle to SELECT statment
34 * @param params parameters to the statement
36 #GNUNET_YES if we can prepare all statement
37 #GNUNET_SYSERR if we can't prepare all statement
40 GNUNET_MY_exec_prepared (struct GNUNET_MYSQL_Context *mc,
41 struct GNUNET_MYSQL_StatementHandle *sh,
42 struct GNUNET_MY_QueryParam *params)
44 const struct GNUNET_MY_QueryParam *p;
49 for (unsigned int i=0;NULL != params[i].conv;i++)
50 num += params[i].num_params;
52 MYSQL_BIND qbind[num];
59 for (unsigned int i=0;NULL != (p = ¶ms[i])->conv;i++)
66 GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
67 "Conversion for MySQL query failed at offset %u\n",
73 stmt = GNUNET_MYSQL_statement_get_stmt (sh);
74 if (mysql_stmt_bind_param (stmt,
77 GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR,
79 _("`%s' failed at %s:%d with error: %s\n"),
80 "mysql_stmt_bind_param",
82 mysql_stmt_error (stmt));
83 GNUNET_MYSQL_statements_invalidate (mc);
87 if (mysql_stmt_execute (stmt))
89 GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR,
91 _("`%s' failed at %s:%d with error: %s\n"),
92 "mysql_stmt_execute", __FILE__, __LINE__,
93 mysql_stmt_error (stmt));
94 GNUNET_MYSQL_statements_invalidate (mc);
97 GNUNET_MY_cleanup_query (params,
105 * Free all memory that was allocated in @a qp during
106 * #GNUNET_MY_exec_prepared().
108 * @param qp query specification to clean up
109 * @param qbind array of parameter to clean up
112 GNUNET_MY_cleanup_query (struct GNUNET_MY_QueryParam *qp,
115 for (unsigned int i=0; NULL != qp[i].conv ;i++)
116 if (NULL != qp[i].cleaner)
117 qp[i].cleaner (qp[i].conv_cls,
123 * Extract results from a query result according to the given
124 * specification. Always fetches the next row.
126 * @param sh statement that returned results
127 * @param rs specification to extract for
129 * #GNUNET_YES if all results could be extracted
130 * #GNUNET_NO if there is no more data in the result set
131 * #GNUNET_SYSERR if a result was invalid
134 GNUNET_MY_extract_result (struct GNUNET_MYSQL_StatementHandle *sh,
135 struct GNUNET_MY_ResultSpec *rs)
137 unsigned int num_fields;
141 stmt = GNUNET_MYSQL_statement_get_stmt (sh);
145 return GNUNET_SYSERR;
149 mysql_stmt_free_result (stmt);
154 for (unsigned int i=0;NULL != rs[i].pre_conv;i++)
155 num_fields += rs[i].num_fields;
157 if (mysql_stmt_field_count (stmt) != num_fields)
159 GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
160 "Number of fields missmatch between SQL result and result specification\n");
161 return GNUNET_SYSERR;
165 MYSQL_BIND result[num_fields];
166 unsigned int field_off;
168 memset (result, 0, sizeof (MYSQL_BIND) * num_fields);
170 for (unsigned int i=0;NULL != rs[i].pre_conv;i++)
172 struct GNUNET_MY_ResultSpec *rp = &rs[i];
175 rp->pre_conv (rp->conv_cls,
182 GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
183 "Pre-conversion for MySQL result failed at offset %u\n",
185 return GNUNET_SYSERR;
187 field_off += rp->num_fields;
190 if (mysql_stmt_bind_result (stmt, result))
192 GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR,
194 _("%s failed at %s:%d with error: %s\n"),
195 "mysql_stmt_bind_result",
197 mysql_stmt_error (stmt));
198 return GNUNET_SYSERR;
200 #if TEST_OPTIMIZATION
201 (void) mysql_stmt_store_result (stmt);
203 ret = mysql_stmt_fetch (stmt);
204 if (MYSQL_NO_DATA == ret)
206 mysql_stmt_free_result (stmt);
211 GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR,
213 _("%s failed at %s:%d with error: %s\n"),
216 mysql_stmt_error (stmt));
217 GNUNET_MY_cleanup_result (rs);
218 mysql_stmt_free_result (stmt);
219 return GNUNET_SYSERR;
222 for (unsigned int i=0;NULL != rs[i].post_conv;i++)
224 struct GNUNET_MY_ResultSpec *rp = &rs[i];
226 if (NULL != rp->post_conv)
228 rp->post_conv (rp->conv_cls,
234 GNUNET_log (GNUNET_ERROR_TYPE_INFO,
235 "Post-conversion for MySQL result failed at offset %u\n",
237 mysql_stmt_free_result (stmt);
238 GNUNET_MY_cleanup_result (rs);
239 return GNUNET_SYSERR;
241 field_off += rp->num_fields;
249 * Free all memory that was allocated in @a rs during
250 * #GNUNET_MY_extract_result().
252 * @param rs result specification to clean up
255 GNUNET_MY_cleanup_result (struct GNUNET_MY_ResultSpec *rs)
257 for (unsigned int i=0;NULL != rs[i].post_conv;i++)
258 if (NULL != rs[i].cleaner)
259 rs[i].cleaner (rs[i].conv_cls,