123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144 |
- /*
- This file is part of GNUnet
- Copyright (C) 2017 GNUnet e.V.
- GNUnet is free software: you can redistribute it and/or modify it
- under the terms of the GNU Affero General Public License as published
- by the Free Software Foundation, either version 3 of the License,
- or (at your option) any later version.
- GNUnet is distributed in the hope that it will be useful, but
- WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- Affero General Public License for more details.
- You should have received a copy of the GNU Affero General Public License
- along with this program. If not, see <http://www.gnu.org/licenses/>.
- SPDX-License-Identifier: AGPL3.0-or-later
- */
- /**
- * @file sq/sq.c
- * @brief helper functions for Sqlite3 DB interactions
- * @author Christian Grothoff
- */
- #include "platform.h"
- #include "gnunet_sq_lib.h"
- /**
- * Execute a prepared statement.
- *
- * @param db_conn database connection
- * @param params parameters to the statement
- * @return #GNUNET_OK on success, #GNUNET_SYSERR on error
- */
- int
- GNUNET_SQ_bind (sqlite3_stmt *stmt,
- const struct GNUNET_SQ_QueryParam *params)
- {
- unsigned int j;
- j = 1;
- for (unsigned int i = 0; NULL != params[i].conv; i++)
- {
- if (GNUNET_OK !=
- params[i].conv (params[i].conv_cls,
- params[i].data,
- params[i].size,
- stmt,
- j))
- {
- GNUNET_log_from (GNUNET_ERROR_TYPE_WARNING,
- "sq",
- _ ("Failure to bind %u-th SQL parameter\n"),
- i);
- if (SQLITE_OK !=
- sqlite3_reset (stmt))
- {
- GNUNET_log_from (GNUNET_ERROR_TYPE_WARNING,
- "sq",
- _ ("Failure in sqlite3_reset (!)\n"));
- return GNUNET_SYSERR;
- }
- }
- GNUNET_assert (0 != params[i].num_params);
- j += params[i].num_params;
- }
- return GNUNET_OK;
- }
- /**
- * Extract results from a query result according to the given specification.
- *
- * @param result result to process
- * @param[in,out] rs result specification to extract for
- * @return
- * #GNUNET_OK if all results could be extracted
- * #GNUNET_SYSERR if a result was invalid (non-existing field)
- */
- int
- GNUNET_SQ_extract_result (sqlite3_stmt *result,
- struct GNUNET_SQ_ResultSpec *rs)
- {
- unsigned int j = 0;
- for (unsigned int i = 0; NULL != rs[i].conv; i++)
- {
- if (NULL == rs[i].result_size)
- rs[i].result_size = &rs[i].dst_size;
- if (GNUNET_OK !=
- rs[i].conv (rs[i].cls,
- result,
- j,
- rs[i].result_size,
- rs[i].dst))
- {
- for (unsigned int k = 0; k < i; k++)
- if (NULL != rs[k].cleaner)
- rs[k].cleaner (rs[k].cls);
- return GNUNET_SYSERR;
- }
- GNUNET_assert (0 != rs[i].num_params);
- j += rs[i].num_params;
- }
- return GNUNET_OK;
- }
- /**
- * Free all memory that was allocated in @a rs during
- * #GNUNET_SQ_extract_result().
- *
- * @param rs reult specification to clean up
- */
- void
- GNUNET_SQ_cleanup_result (struct GNUNET_SQ_ResultSpec *rs)
- {
- for (unsigned int i = 0; NULL != rs[i].conv; i++)
- if (NULL != rs[i].cleaner)
- rs[i].cleaner (rs[i].cls);
- }
- /**
- * Reset @a stmt and log error.
- *
- * @param dbh database handle
- * @param stmt statement to reset
- */
- void
- GNUNET_SQ_reset (sqlite3 *dbh,
- sqlite3_stmt *stmt)
- {
- if (SQLITE_OK !=
- sqlite3_reset (stmt))
- GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK,
- "sqlite",
- _ ("Failed to reset sqlite statement with error: %s\n"),
- sqlite3_errmsg (dbh));
- }
- /* end of sq.c */
|