X-Git-Url: https://vcs.fsf.org/?a=blobdiff_plain;f=src%2Fsrc%2Flookups%2Fsqlite.c;h=4bf616052dfe37ef63e696edd0afc0a4c329152a;hb=17ccbda62e05f6ed59a27791643be4b94f7fcdbd;hp=bb024b50ebd98d4897ccdb89fa4c0a614b1e2d08;hpb=31480e424d1ac61f5d3a86d7913e5bd78c7d4d9b;p=exim.git diff --git a/src/src/lookups/sqlite.c b/src/src/lookups/sqlite.c index bb024b50e..4bf616052 100644 --- a/src/src/lookups/sqlite.c +++ b/src/src/lookups/sqlite.c @@ -1,19 +1,13 @@ -/* $Cambridge: exim/src/src/lookups/sqlite.c,v 1.2 2005/08/08 10:48:27 ph10 Exp $ */ - /************************************************* * Exim - an Internet mail transport agent * *************************************************/ -/* Copyright (c) University of Cambridge 1995 - 2005 */ +/* Copyright (c) University of Cambridge 1995 - 2018 */ /* See the file NOTICE for conditions of use and distribution. */ #include "../exim.h" #include "lf_functions.h" -#include "sqlite.h" -#ifndef LOOKUP_SQLITE -static void dummy(int x) { dummy(x-1); } -#else #include @@ -23,13 +17,13 @@ static void dummy(int x) { dummy(x-1); } /* See local README for interface description. */ -void * +static void * sqlite_open(uschar *filename, uschar **errmsg) { sqlite3 *db = NULL; int ret; -ret = sqlite3_open((char *)filename, &db); +ret = sqlite3_open(CS filename, &db); if (ret != 0) { *errmsg = (void *)sqlite3_errmsg(db); @@ -47,61 +41,51 @@ return db; /* See local README for interface description. */ -struct strbuf { - uschar *string; - int size; - int len; -}; - -static int sqlite_callback(void *arg, int argc, char **argv, char **azColName) +static int +sqlite_callback(void *arg, int argc, char **argv, char **azColName) { -struct strbuf *res = arg; -int i; +gstring * res = *(gstring **)arg; /* For second and subsequent results, insert \n */ -if (res->string != NULL) - res->string = string_cat(res->string, &res->size, &res->len, US"\n", 1); +if (res) + res = string_catn(res, US"\n", 1); if (argc > 1) { /* For multiple fields, include the field name too */ - for (i = 0; i < argc; i++) + for (int i = 0; i < argc; i++) { uschar *value = US((argv[i] != NULL)? argv[i]:""); - res->string = lf_quote(US azColName[i], value, Ustrlen(value), res->string, - &res->size, &res->len); + res = lf_quote(US azColName[i], value, Ustrlen(value), res); } } else - { - res->string = string_append(res->string, &res->size, &res->len, 1, - (argv[0] != NULL)? argv[0]:""); - } + res = string_cat(res, argv[0] ? US argv[0] : US ""); -res->string[res->len] = 0; +*(gstring **)arg = res; return 0; } -int -sqlite_find(void *handle, uschar *filename, uschar *query, int length, - uschar **result, uschar **errmsg, BOOL *do_cache) +static int +sqlite_find(void *handle, uschar *filename, const uschar *query, int length, + uschar **result, uschar **errmsg, uint *do_cache) { int ret; -struct strbuf res = { NULL, 0, 0 }; +gstring * res = NULL; -ret = sqlite3_exec(handle, (char *)query, sqlite_callback, &res, (char **)errmsg); +ret = sqlite3_exec(handle, CS query, sqlite_callback, &res, (char **)errmsg); if (ret != SQLITE_OK) { debug_printf("sqlite3_exec failed: %s\n", *errmsg); return FAIL; } -if (res.string == NULL) *do_cache = FALSE; +if (!res) *do_cache = 0; -*result = res.string; +*result = string_from_gstring(res); return OK; } @@ -113,7 +97,7 @@ return OK; /* See local README for interface description. */ -void sqlite_close(void *handle) +static void sqlite_close(void *handle) { sqlite3_close(handle); } @@ -134,7 +118,7 @@ Arguments: Returns: the processed string or NULL for a bad option */ -uschar * +static uschar * sqlite_quote(uschar *s, uschar *opt) { register int c; @@ -159,6 +143,44 @@ while ((c = *s++) != 0) return quoted; } -#endif /* LOOKUP_SQLITE */ + + +/************************************************* +* Version reporting entry point * +*************************************************/ + +/* See local README for interface description. */ + +#include "../version.h" + +void +sqlite_version_report(FILE *f) +{ +fprintf(f, "Library version: SQLite: Compile: %s\n" + " Runtime: %s\n", + SQLITE_VERSION, sqlite3_libversion()); +#ifdef DYNLOOKUP +fprintf(f, " Exim version %s\n", EXIM_VERSION_STR); +#endif +} + +static lookup_info _lookup_info = { + US"sqlite", /* lookup name */ + lookup_absfilequery, /* query-style lookup, starts with file name */ + sqlite_open, /* open function */ + NULL, /* no check function */ + sqlite_find, /* find function */ + sqlite_close, /* close function */ + NULL, /* no tidy function */ + sqlite_quote, /* quoting function */ + sqlite_version_report /* version reporting */ +}; + +#ifdef DYNLOOKUP +#define sqlite_lookup_module_info _lookup_module_info +#endif + +static lookup_info *_lookup_list[] = { &_lookup_info }; +lookup_module_info sqlite_lookup_module_info = { LOOKUP_MODULE_INFO_MAGIC, _lookup_list, 1 }; /* End of lookups/sqlite.c */