mirror of
git://git.gnupg.org/gnupg.git
synced 2024-12-23 10:29:58 +01:00
a9e0905342
* agent/cache.c: Fix typos. * agent/call-pinentry.c: Likewise. * agent/call-scd.c: Likewise. * agent/command-ssh.c: Likewise. * agent/command.c: Likewise. * agent/divert-scd.c: Likewise. * agent/findkey.c: Likewise. * agent/gpg-agent.c: Likewise. * agent/w32main.c: Likewise. * common/argparse.c: Likewise. * common/audit.c: Likewise. * common/audit.h: Likewise. * common/convert.c: Likewise. * common/dotlock.c: Likewise. * common/exechelp-posix.c: Likewise. * common/exechelp-w32.c: Likewise. * common/exechelp-w32ce.c: Likewise. * common/exechelp.h: Likewise. * common/helpfile.c: Likewise. * common/i18n.h: Likewise. * common/iobuf.c: Likewise. * common/iobuf.h: Likewise. * common/localename.c: Likewise. * common/logging.c: Likewise. * common/openpgp-oid.c: Likewise. * common/session-env.c: Likewise. * common/sexputil.c: Likewise. * common/sysutils.c: Likewise. * common/t-sexputil.c: Likewise. * common/ttyio.c: Likewise. * common/util.h: Likewise. * dirmngr/cdblib.c: Likewise. * dirmngr/certcache.c: Likewise. * dirmngr/crlcache.c: Likewise. * dirmngr/dirmngr-client.c: Likewise. * dirmngr/dirmngr.c: Likewise. * dirmngr/dirmngr_ldap.c: Likewise. * dirmngr/dns-stuff.c: Likewise. * dirmngr/http.c: Likewise. * dirmngr/ks-engine-hkp.c: Likewise. * dirmngr/ks-engine-ldap.c: Likewise. * dirmngr/ldap-wrapper.c: Likewise. * dirmngr/ldap.c: Likewise. * dirmngr/misc.c: Likewise. * dirmngr/ocsp.c: Likewise. * dirmngr/validate.c: Likewise. * g10/encrypt.c: Likewise. * g10/getkey.c: Likewise. * g10/gpg.c: Likewise. * g10/gpgv.c: Likewise. * g10/import.c: Likewise. * g10/keydb.c: Likewise. * g10/keydb.h: Likewise. * g10/keygen.c: Likewise. * g10/keyid.c: Likewise. * g10/keylist.c: Likewise. * g10/keyring.c: Likewise. * g10/mainproc.c: Likewise. * g10/misc.c: Likewise. * g10/options.h: Likewise. * g10/packet.h: Likewise. * g10/parse-packet.c: Likewise. * g10/pkclist.c: Likewise. * g10/pkglue.c: Likewise. * g10/plaintext.c: Likewise. * g10/server.c: Likewise. * g10/sig-check.c: Likewise. * g10/sqlite.c: Likewise. * g10/tdbio.c: Likewise. * g10/test-stubs.c: Likewise. * g10/tofu.c: Likewise. * g10/trust.c: Likewise. * g10/trustdb.c: Likewise. * g13/create.c: Likewise. * g13/mountinfo.c: Likewise. * kbx/keybox-blob.c: Likewise. * kbx/keybox-file.c: Likewise. * kbx/keybox-init.c: Likewise. * kbx/keybox-search-desc.h: Likewise. * kbx/keybox-search.c: Likewise. * kbx/keybox-update.c: Likewise. * scd/apdu.c: Likewise. * scd/app-openpgp.c: Likewise. * scd/app-p15.c: Likewise. * scd/app.c: Likewise. * scd/ccid-driver.c: Likewise. * scd/command.c: Likewise. * scd/iso7816.c: Likewise. * sm/base64.c: Likewise. * sm/call-agent.c: Likewise. * sm/call-dirmngr.c: Likewise. * sm/certchain.c: Likewise. * sm/gpgsm.c: Likewise. * sm/import.c: Likewise. * sm/keydb.c: Likewise. * sm/minip12.c: Likewise. * sm/qualified.c: Likewise. * sm/server.c: Likewise. * tools/gpg-check-pattern.c: Likewise. * tools/gpgconf-comp.c: Likewise. * tools/gpgkey2ssh.c: Likewise. * tools/gpgparsemail.c: Likewise. * tools/gpgtar.c: Likewise. * tools/rfc822parse.c: Likewise. * tools/symcryptrun.c: Likewise. Signed-off-by: Justus Winter <justus@g10code.com>
253 lines
6.1 KiB
C
253 lines
6.1 KiB
C
/* sqlite.c - SQLite helper functions.
|
|
* Copyright (C) 2015 g10 Code GmbH
|
|
*
|
|
* This file is part of GnuPG.
|
|
*
|
|
* GnuPG is free software; you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation; either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* GnuPG 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 General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program; if not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#include <config.h>
|
|
#include <stdarg.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include <assert.h>
|
|
|
|
#include "gpg.h"
|
|
#include "util.h"
|
|
#include "logging.h"
|
|
|
|
#include "sqlite.h"
|
|
|
|
/* This is a convenience function that combines sqlite3_mprintf and
|
|
sqlite3_exec. */
|
|
int
|
|
sqlite3_exec_printf (sqlite3 *db,
|
|
int (*callback)(void*,int,char**,char**), void *cookie,
|
|
char **errmsg,
|
|
const char *sql, ...)
|
|
{
|
|
va_list ap;
|
|
int rc;
|
|
char *sql2;
|
|
|
|
va_start (ap, sql);
|
|
sql2 = sqlite3_vmprintf (sql, ap);
|
|
va_end (ap);
|
|
|
|
#if 0
|
|
log_debug ("tofo db: executing: '%s'\n", sql2);
|
|
#endif
|
|
|
|
rc = sqlite3_exec (db, sql2, callback, cookie, errmsg);
|
|
|
|
sqlite3_free (sql2);
|
|
|
|
return rc;
|
|
}
|
|
|
|
int
|
|
sqlite3_stepx (sqlite3 *db,
|
|
sqlite3_stmt **stmtp,
|
|
sqlite3_stepx_callback callback,
|
|
void *cookie,
|
|
char **errmsg,
|
|
const char *sql, ...)
|
|
{
|
|
int rc;
|
|
int err = 0;
|
|
sqlite3_stmt *stmt = NULL;
|
|
|
|
va_list va;
|
|
int args;
|
|
enum sqlite_arg_type t;
|
|
int i;
|
|
|
|
int cols;
|
|
/* Names of the columns. We initialize this lazily to avoid the
|
|
overhead in case the query doesn't return any results. */
|
|
const char **azColName = 0;
|
|
int callback_initialized = 0;
|
|
|
|
const char **azVals = 0;
|
|
|
|
callback_initialized = 0;
|
|
|
|
if (stmtp && *stmtp)
|
|
{
|
|
stmt = *stmtp;
|
|
|
|
/* Make sure this statement is associated with the supplied db. */
|
|
assert (db == sqlite3_db_handle (stmt));
|
|
|
|
#if DEBUG_TOFU_CACHE
|
|
prepares_saved ++;
|
|
#endif
|
|
}
|
|
else
|
|
{
|
|
const char *tail = NULL;
|
|
|
|
rc = sqlite3_prepare_v2 (db, sql, -1, &stmt, &tail);
|
|
if (rc)
|
|
log_fatal ("failed to prepare SQL: %s", sql);
|
|
|
|
/* We can only process a single statement. */
|
|
if (tail)
|
|
{
|
|
while (*tail == ' ' || *tail == ';' || *tail == '\n')
|
|
tail ++;
|
|
|
|
if (*tail)
|
|
log_fatal
|
|
("sqlite3_stepx can only process a single SQL statement."
|
|
" Second statement starts with: '%s'\n",
|
|
tail);
|
|
}
|
|
|
|
if (stmtp)
|
|
*stmtp = stmt;
|
|
}
|
|
|
|
#if DEBUG_TOFU_CACHE
|
|
queries ++;
|
|
#endif
|
|
|
|
args = sqlite3_bind_parameter_count (stmt);
|
|
va_start (va, sql);
|
|
if (args)
|
|
{
|
|
for (i = 1; i <= args; i ++)
|
|
{
|
|
t = va_arg (va, enum sqlite_arg_type);
|
|
switch (t)
|
|
{
|
|
case SQLITE_ARG_INT:
|
|
{
|
|
int value = va_arg (va, int);
|
|
err = sqlite3_bind_int (stmt, i, value);
|
|
break;
|
|
}
|
|
case SQLITE_ARG_LONG_LONG:
|
|
{
|
|
long long value = va_arg (va, long long);
|
|
err = sqlite3_bind_int64 (stmt, i, value);
|
|
break;
|
|
}
|
|
case SQLITE_ARG_STRING:
|
|
{
|
|
char *text = va_arg (va, char *);
|
|
err = sqlite3_bind_text (stmt, i, text, -1, SQLITE_STATIC);
|
|
break;
|
|
}
|
|
case SQLITE_ARG_BLOB:
|
|
{
|
|
char *blob = va_arg (va, void *);
|
|
long long length = va_arg (va, long long);
|
|
err = sqlite3_bind_blob (stmt, i, blob, length, SQLITE_STATIC);
|
|
break;
|
|
}
|
|
default:
|
|
/* Internal error. Likely corruption. */
|
|
log_fatal ("Bad value for parameter type %d.\n", t);
|
|
}
|
|
|
|
if (err)
|
|
{
|
|
log_fatal ("Error binding parameter %d\n", i);
|
|
goto out;
|
|
}
|
|
}
|
|
|
|
}
|
|
t = va_arg (va, enum sqlite_arg_type);
|
|
assert (t == SQLITE_ARG_END);
|
|
va_end (va);
|
|
|
|
for (;;)
|
|
{
|
|
rc = sqlite3_step (stmt);
|
|
|
|
if (rc != SQLITE_ROW)
|
|
/* No more data (SQLITE_DONE) or an error occurred. */
|
|
break;
|
|
|
|
if (! callback)
|
|
continue;
|
|
|
|
if (! callback_initialized)
|
|
{
|
|
cols = sqlite3_column_count (stmt);
|
|
azColName = xmalloc (2 * cols * sizeof (const char *) + 1);
|
|
|
|
for (i = 0; i < cols; i ++)
|
|
azColName[i] = sqlite3_column_name (stmt, i);
|
|
|
|
callback_initialized = 1;
|
|
}
|
|
|
|
azVals = &azColName[cols];
|
|
for (i = 0; i < cols; i ++)
|
|
{
|
|
azVals[i] = sqlite3_column_text (stmt, i);
|
|
if (! azVals[i] && sqlite3_column_type (stmt, i) != SQLITE_NULL)
|
|
/* Out of memory. */
|
|
{
|
|
err = SQLITE_NOMEM;
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (callback (cookie, cols, (char **) azVals, (char **) azColName, stmt))
|
|
/* A non-zero result means to abort. */
|
|
{
|
|
err = SQLITE_ABORT;
|
|
break;
|
|
}
|
|
}
|
|
|
|
out:
|
|
xfree (azColName);
|
|
|
|
if (stmtp)
|
|
rc = sqlite3_reset (stmt);
|
|
else
|
|
rc = sqlite3_finalize (stmt);
|
|
if (rc == SQLITE_OK && err)
|
|
/* Local error. */
|
|
{
|
|
rc = err;
|
|
if (errmsg)
|
|
{
|
|
const char *e = sqlite3_errstr (err);
|
|
size_t l = strlen (e) + 1;
|
|
*errmsg = sqlite3_malloc (l);
|
|
if (! *errmsg)
|
|
log_fatal ("Out of memory.\n");
|
|
memcpy (*errmsg, e, l);
|
|
}
|
|
}
|
|
else if (rc != SQLITE_OK && errmsg)
|
|
/* Error reported by sqlite. */
|
|
{
|
|
const char * e = sqlite3_errmsg (db);
|
|
size_t l = strlen (e) + 1;
|
|
*errmsg = sqlite3_malloc (l);
|
|
if (! *errmsg)
|
|
log_fatal ("Out of memory.\n");
|
|
memcpy (*errmsg, e, l);
|
|
}
|
|
|
|
return rc;
|
|
}
|