1 /*************************************************
2 * Exim - an Internet mail transport agent *
3 *************************************************/
5 /* Copyright (c) The Exim Maintainers 2020 - 2022 */
6 /* Copyright (c) University of Cambridge 1995 - 2018 */
7 /* See the file NOTICE for conditions of use and distribution. */
8 /* SPDX-License-Identifier: GPL-2.0-or-later */
12 #include "lf_functions.h"
16 /*************************************************
17 * Call SQL server(s) to run an actual query *
18 *************************************************/
20 /* All the SQL lookups are of the same form, with a list of servers to try
21 until one can be accessed. It is now also possible to provide the server data
22 as part of the query. This function manages server selection and looping; each
23 lookup has its own function for actually performing the lookup.
26 name the lookup name, e.g. "MySQL"
27 optionname the name of the servers option, e.g. "mysql_servers"
28 optserverlist the value of the servers option
30 result where to pass back the result
31 errmsg where to pass back an error message
32 do_cache to be set zero if data is changed
33 func the lookup function to call
35 Returns: the return from the lookup function, or DEFER
39 lf_sqlperform(const uschar *name, const uschar *optionname,
40 const uschar *optserverlist, const uschar *query,
41 uschar **result, uschar **errmsg, uint *do_cache, const uschar * opts,
42 int(*fn)(const uschar *, uschar *, uschar **, uschar **, BOOL *, uint *, const uschar *))
46 BOOL defer_break = FALSE;
48 DEBUG(D_lookup) debug_printf_indent("%s query: \"%s\" opts '%s'\n", name, query, opts);
50 /* Handle queries that do have server information at the start. */
52 if (Ustrncmp(query, "servers", 7) == 0)
56 const uschar *qserverlist;
63 *errmsg = string_sprintf("missing = after \"servers\" in %s lookup", name);
71 *errmsg = string_sprintf("missing ; after \"servers=\" in %s lookup",
78 *errmsg = string_sprintf("\"servers=\" defines no servers in \"%s\"",
83 qserverlist = string_sprintf("%.*s", (int)(ss - s), s);
85 while ((qserver = string_nextinlist(&qserverlist, &qsep, NULL, 0)))
87 if (Ustrchr(qserver, '/'))
91 int len = Ustrlen(qserver);
92 const uschar * serverlist = optserverlist;
94 for (int sep = 0; server = string_nextinlist(&serverlist, &sep, NULL, 0);)
95 if (Ustrncmp(server, qserver, len) == 0 && server[len] == '/')
100 *errmsg = string_sprintf("%s server \"%s\" not found in %s", name,
101 qserver, optionname);
106 if (is_tainted(server))
108 *errmsg = string_sprintf("%s server \"%s\" is tainted", name, server);
112 rc = (*fn)(ss+1, server, result, errmsg, &defer_break, do_cache, opts);
113 if (rc != DEFER || defer_break) return rc;
117 /* Handle queries that do not have server information at the start. */
121 const uschar * serverlist = NULL;
123 /* If options are present, scan for a server definition. Default to
124 the "optserverlist" srgument. */
129 for (int sep = ','; ele = string_nextinlist(&opts, &sep, NULL, 0); )
130 if (Ustrncmp(ele, "servers=", 8) == 0)
131 { serverlist = ele + 8; break; }
135 serverlist = optserverlist;
137 *errmsg = string_sprintf("no %s servers defined (%s option)", name,
140 for (int d = 0; (server = string_nextinlist(&serverlist, &d, NULL, 0)); )
142 /* If not a full spec assume from options; scan main list for matching
145 if (!Ustrchr(server, '/'))
147 int len = Ustrlen(server);
148 const uschar * slist = optserverlist;
150 for (int sep = 0; ele = string_nextinlist(&slist, &sep, NULL, 0); )
151 if (Ustrncmp(ele, server, len) == 0 && ele[len] == '/')
155 *errmsg = string_sprintf("%s server \"%s\" not found in %s", name,
162 if (is_tainted(server))
164 *errmsg = string_sprintf("%s server \"%s\" is tainted", name, server);
168 rc = (*fn)(query, server, result, errmsg, &defer_break, do_cache, opts);
169 if (rc != DEFER || defer_break) return rc;
176 /* End of lf_sqlperform.c */