5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * Copyright (C) 2002 Stichting NLnet, Netherlands, stichting@nlnet.nl.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * Permission to use, copy, modify, and distribute this software for any
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * purpose with or without fee is hereby granted, provided that the
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * above copyright notice and this permission notice appear in all
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * THE SOFTWARE IS PROVIDED "AS IS" AND STICHTING NLNET
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE INCLUDING ALL
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * STICHTING NLNET BE LIABLE FOR ANY SPECIAL, DIRECT, INDIRECT, OR
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * USE OR PERFORMANCE OF THIS SOFTWARE.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * The development of Dynamically Loadable Zones (DLZ) for BIND 9 was
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * conceived and contributed by Rob Butler.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * Permission to use, copy, modify, and distribute this software for any
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * purpose with or without fee is hereby granted, provided that the
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * above copyright notice and this permission notice appear in all
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * THE SOFTWARE IS PROVIDED "AS IS" AND ROB BUTLER
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE INCLUDING ALL
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * ROB BUTLER BE LIABLE FOR ANY SPECIAL, DIRECT, INDIRECT, OR
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * USE OR PERFORMANCE OF THIS SOFTWARE.
02d54949f0f1db4729e14c3322b207f58d2578a4Mark Andrews * Copyright (C) 1999-2001, 2013, 2016 Internet Systems Consortium, Inc. ("ISC")
02d54949f0f1db4729e14c3322b207f58d2578a4Mark Andrews * This Source Code Form is subject to the terms of the Mozilla Public
02d54949f0f1db4729e14c3322b207f58d2578a4Mark Andrews * License, v. 2.0. If a copy of the MPL was not distributed with this
02d54949f0f1db4729e14c3322b207f58d2578a4Mark Andrews * file, You can obtain one at http://mozilla.org/MPL/2.0/.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * This provides the externally loadable MySQL DLZ module, without
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * update support
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * Structure to hold everthing needed by this "instance" of the MySQL
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * module remember, the module code is only loaded once, but may have
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * many separate instances.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunttypedef struct {
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* Helper functions from the dlz_dlopen driver */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt/* forward references */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Huntb9_add_helper(mysql_instance_t *db, const char *helper_name, void *ptr);
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * Private methods
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* release DB connection */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* destroy DB instance */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * Properly cleans up a list of database instances.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * This function is only used when the module is compiled for
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * multithreaded operation.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* release memory for the list structure */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * Loops through the list of DB instances, attempting to lock
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * on the mutex. If successful, the DBI is reserved for use
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * and the thread can perform queries against the database.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * If the lock fails, the next one in the list is tried.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * looping continues until a lock is obtained, or until
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * the list has been searched dbc_search_limit times.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * This function is only used when the module is compiled for
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * multithreaded operation.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* get top of list */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* loop through list */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* try to lock on the mutex */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt return (dbi); /* success, return the DBI for use. */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* not successful, keep trying */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* check to see if we have gone to the top of the list. */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module unable to find available connection "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt#endif /* PTHREADS */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * Allocates memory for a new string, and then constructs the new
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * string by "escaping" the input string. The new string is
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * safe to be used in queries. This is necessary because we cannot
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * be sure of what types of strings are passed to us, and we don't
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * want special characters in the string causing problems.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Huntstatic char *
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Huntmysqldrv_escape_string(MYSQL *mysql, const char *instr) {
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt mysql_real_escape_string(mysql, outstr, instr, len);
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * This function is the real core of the module. Zone, record
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * and client strings are passed in (or NULL is passed if the
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * string is not available). The type of query we want to run
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * is indicated by the query flag, and the dbdata object is passed
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * passed in to. dbdata really holds a single database instance.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * The function will construct and run the query, hopefully getting
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * a result set.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Huntmysql_get_resultset(const char *zone, const char *record,
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt mysql_instance_t *db = (mysql_instance_t *)dbdata;
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt unsigned int i = 0;
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt unsigned int j = 0;
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* find an available DBI from the list */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt#else /* PTHREADS */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * only 1 DBI - no need to lock instance lock either
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * only 1 thread in the whole process, no possible contention.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt#endif /* PTHREADS */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* what type of query are we going to run? */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "No query specified for findzone. "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "Findzone requires a query");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "No query specified for lookup. "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "Lookup requires a query");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "Incorrect query flag passed to "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "mysql_get_resultset");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt dbi->zone = mysqldrv_escape_string((MYSQL *) dbi->dbconn,
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt dbi->record = mysqldrv_escape_string((MYSQL *) dbi->dbconn,
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt dbi->client = mysqldrv_escape_string((MYSQL *) dbi->dbconn,
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * what type of query are we going to run? this time we build
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * the actual query to run.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt querystring = build_querystring(dbi->authority_q);
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt querystring = build_querystring(dbi->countzone_q);
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "Incorrect query flag passed to "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "mysql_get_resultset");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* output the full query string when debugging */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt db->log(ISC_LOG_DEBUG(1), "\nQuery String: %s\n", querystring);
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* attempt query up to 3 times. */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt for (i = 0; i < 3; i++) {
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt qres = mysql_query((MYSQL *) dbi->dbconn, querystring);
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt for (j = 0; j < 4; j++)
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* release the lock so another thread can use this dbi */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * The processing of result sets for lookup and authority are
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * exactly the same. So that functionality has been moved
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * into this function to minimize code.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Huntmysql_process_rs(mysql_instance_t *db, dns_sdlzlookup_t *lookup,
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt unsigned int j;
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt fields = mysql_num_fields(rs); /* how many columns in result set */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt row = mysql_fetch_row(rs); /* get a row from the result set */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * one column in rs, it's the data field. use
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * default type of A record, and default TTL
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt result = db->putrr(lookup, "a", 86400, safeGet(row[0]));
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * two columns, data field, and data type.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * use default TTL of 86400.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt result = db->putrr(lookup, safeGet(row[0]), 86400,
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * three columns, all data no defaults.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * convert text to int, make sure it worked
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module ttl must be "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "a postive number");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * more than 3 fields, concatenate the last
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * ones together. figure out how long to make
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * allocate string memory, allow for NULL to
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * term string
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module unable to allocate "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "memory for temporary string");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module ttl must be "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "a postive number");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * DLZ methods
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt/*% determine if the zone is supported by (in) the database */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt mysql_instance_t *db = (mysql_instance_t *)dbdata;
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt result = mysql_get_resultset(name, NULL, NULL, FINDZONE, dbdata, &rs);
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module unable to return "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "result set for findzone query");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * if we returned any rows, the zone is supported.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt mysql_get_resultset(name, NULL, NULL, COUNTZONE, dbdata, NULL);
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt/*% Determine if the client is allowed to perform a zone transfer */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Huntdlz_allowzonexfr(void *dbdata, const char *name, const char *client) {
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt mysql_instance_t *db = (mysql_instance_t *)dbdata;
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* first check if the zone is supported by the database. */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt result = dlz_findzonedb(dbdata, name, NULL, NULL);
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * if we get to this point we know the zone is supported by
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * the database the only questions now are is the zone
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * transfer is allowed for this client and did the config file
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * have an allow zone xfr query.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt result = mysql_get_resultset(name, NULL, client, ALLOWXFR,
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module unable to return "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "result set for allow xfr query");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * count how many rows in result set; if we returned any,
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * zone xfr is allowed.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * If the client is allowed to perform a zone transfer, the next order of
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * business is to get all the nodes in the zone, so bind can respond to the
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Huntdlz_allnodes(const char *zone, void *dbdata, dns_sdlzallnodes_t *allnodes) {
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt mysql_instance_t *db = (mysql_instance_t *)dbdata;
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt unsigned int j;
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt result = mysql_get_resultset(zone, NULL, NULL, ALLNODES, dbdata, &rs);
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* if we didn't get a result set, log an err msg. */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module unable to return "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "result set for all nodes query");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt fields = mysql_num_fields(rs); /* how many columns in result set */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt row = mysql_fetch_row(rs); /* get a row from the result set */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module too few fields returned "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "by all nodes query");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module ttl must be "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "a postive number");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt result = db->putnamedrr(allnodes, safeGet(row[2]),
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * more than 4 fields, concatenate the last
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * ones together.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module unable to allocate "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "memory for temporary string");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt result = db->putnamedrr(allnodes, safeGet(row[2]),
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * If the lookup function does not return SOA or NS records for the zone,
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * use this function to get that information for named.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Huntdlz_authority(const char *zone, void *dbdata, dns_sdlzlookup_t *lookup) {
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt mysql_instance_t *db = (mysql_instance_t *)dbdata;
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt result = mysql_get_resultset(zone, NULL, NULL, AUTHORITY, dbdata, &rs);
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module unable to return "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "result set for authority query");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * lookup and authority result sets are processed in the same
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * manner: mysql_process_rs does the job for both functions.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt/*% If zone is supported, lookup up a (or multiple) record(s) in it */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt mysql_instance_t *db = (mysql_instance_t *)dbdata;
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt result = mysql_get_resultset(zone, name, NULL, LOOKUP, dbdata, &rs);
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* if we didn't get a result set, log an err msg. */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module unable to return "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "result set for lookup query");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * lookup and authority result sets are processed in the same
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * manner: mysql_process_rs does the job for both functions.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * Create an instance of the module.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Huntdlz_create(const char *dlzname, unsigned int argc, char *argv[],
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt void **dbdata, ...)
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt#endif /* PTHREADS */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* allocate memory for MySQL instance */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* Fill in the helper functions */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt while ((helper_name = va_arg(ap, const char*)) != NULL)
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt b9_add_helper(mysql, helper_name, va_arg(ap, void*));
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* if debugging, let user know we are multithreaded. */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt mysql->log(ISC_LOG_DEBUG(1), "MySQL module running multithreaded");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt#else /* PTHREADS */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* if debugging, let user know we are single threaded. */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt mysql->log(ISC_LOG_DEBUG(1), "MySQL module running single threaded");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt#endif /* PTHREADS */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* verify we have at least 4 arg's passed to the module */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module requires "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "at least 4 command line args.");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* no more than 8 arg's should be passed to the module */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module cannot accept "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "more than 7 command line args.");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* get db name - required */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt mysql->dbname = get_parameter_value(argv[1], "dbname=");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module requires a dbname parameter.");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* get db port. Not required, but must be > 0 if specified */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "Mysql module: port "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "must be a positive number.");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt mysql->host = get_parameter_value(argv[1], "host=");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt mysql->user = get_parameter_value(argv[1], "user=");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt mysql->pass = get_parameter_value(argv[1], "pass=");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt mysql->socket = get_parameter_value(argv[1], "socket=");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* multithreaded build can have multiple DB connections */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL database connection count "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "must be positive.");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* allocate memory for database connection list */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* initialize DB connection list */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * create the appropriate number of database instances (DBI)
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * append each new DBI to the end of the list
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt for (i = 0; i < dbcount; i++) {
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt#endif /* PTHREADS */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt result = build_dbinstance(argv[5], argv[6], argv[4],
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt result = build_dbinstance(argv[5], argv[6], argv[4],
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module could not create "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "database instance object.");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* when multithreaded, build a list of DBI's */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * when single threaded, hold onto the one connection
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* create and set db connection */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module could not allocate "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "memory for database connection");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* enable automatic reconnection. */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt if (mysql_options((MYSQL *) dbi->dbconn, MYSQL_OPT_RECONNECT,
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module failed to set "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MYSQL_OPT_RECONNECT option, continuing");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL connection failed: %s",
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "MySQL module failed to create "
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt "database connection after 4 attempts");
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* set DBI = null for next loop through. */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt#endif /* PTHREADS */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * Destroy the module.
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt mysql_instance_t *db = (mysql_instance_t *)dbdata;
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt /* cleanup the list of DBI's */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt#else /* PTHREADS */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt#endif /* PTHREADS */
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * Return the version of the API
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Hunt * Register a helper function from the bind9 dlz_dlopen driver
5ba1d3dcc5739a1f77ec2875b276b163a42ef1e8Evan Huntb9_add_helper(mysql_instance_t *db, const char *helper_name, void *ptr) {