app_mysql.c File Reference

MYSQL dialplan application. More...

#include "asterisk.h"
#include <mysql/mysql.h>
#include "asterisk/file.h"
#include "asterisk/logger.h"
#include "asterisk/channel.h"
#include "asterisk/pbx.h"
#include "asterisk/module.h"
#include "asterisk/linkedlists.h"
#include "asterisk/chanvars.h"
#include "asterisk/lock.h"
#include "asterisk/options.h"
#include "asterisk/app.h"
#include "asterisk/config.h"

Include dependency graph for app_mysql.c:

Go to the source code of this file.

Data Structures
struct	ast_MYSQL_id
struct	MYSQLidshead

Macros
#define	AST_MYSQL_ID_CONNID   1
#define	AST_MYSQL_ID_DUMMY   0
#define	AST_MYSQL_ID_FETCHID   3
#define	AST_MYSQL_ID_RESID   2
#define	EXTRA_LOG   0
#define	MYSQL_CONFIG   "app_mysql.conf"
#define	MYSQL_CONFIG_OLD   "mysql.conf"

Enumerations
enum	{ NULLSTRING, NULLVALUE, EMPTYSTRING }

Functions
static int	add_identifier (struct ast_channel *chan, int identifier_type, void *data)
static int	add_identifier_and_set_asterisk_int (struct ast_channel *chan, char *varname, int identifier_type, void *data)
static int	aMYSQL_clear (struct ast_channel *chan, const char *data)
static int	aMYSQL_connect (struct ast_channel *chan, const char *data)
static int	aMYSQL_disconnect (struct ast_channel *chan, const char *data)
static int	aMYSQL_fetch (struct ast_channel *chan, const char *data)
static int	aMYSQL_nextresult (struct ast_channel *chan, const char *data)
static int	aMYSQL_query (struct ast_channel *chan, const char *data)
static int	aMYSQL_set (struct ast_channel *chan, const char *data)
	AST_MODULE_INFO_STANDARD_DEPRECATED (ASTERISK_GPL_KEY, "Simple Mysql Interface")
static int	del_identifier (int identifier, int identifier_type)
static void *	find_identifier (int identifier, int identifier_type)
static int	load_module (void)
	Load the module. More...
static void	mysql_ds_destroy (void *data)
static void	mysql_ds_fixup (void *data, struct ast_channel *oldchan, struct ast_channel *newchan)
static int	MYSQL_exec (struct ast_channel *chan, const char *data)
static int	safe_scan_int (char **data, char *delim, int def)
static int	set_asterisk_int (struct ast_channel *chan, char *varname, int id)
static int	unload_module (void)

Variables
struct MYSQLidshead	_mysql_ids_head
static ast_mutex_t	_mysql_mutex = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }
static const char	app [] = "MYSQL"
struct ast_MYSQL_id *	ast_MYSQL_id
static int	autoclear = 0
static const char	descrip []
static const struct ast_datastore_info	mysql_ds_info
enum { ... }	nullvalue = NULLSTRING
static const char	synopsis [] = "Do several mySQLy things"

Detailed Description

MYSQL dialplan application.

Definition in file app_mysql.c.

Macro Definition Documentation

AST_MYSQL_ID_CONNID

#define AST_MYSQL_ID_CONNID   1

Definition at line 109 of file app_mysql.c.

Referenced by aMYSQL_connect(), aMYSQL_disconnect(), aMYSQL_nextresult(), aMYSQL_query(), mysql_ds_destroy(), and mysql_ds_fixup().

AST_MYSQL_ID_DUMMY

#define AST_MYSQL_ID_DUMMY   0

Definition at line 108 of file app_mysql.c.

AST_MYSQL_ID_FETCHID

#define AST_MYSQL_ID_FETCHID   3

Definition at line 111 of file app_mysql.c.

AST_MYSQL_ID_RESID

#define AST_MYSQL_ID_RESID   2

Definition at line 110 of file app_mysql.c.

Referenced by aMYSQL_clear(), aMYSQL_fetch(), aMYSQL_nextresult(), aMYSQL_query(), mysql_ds_destroy(), and mysql_ds_fixup().

EXTRA_LOG

#define EXTRA_LOG   0

Definition at line 58 of file app_mysql.c.

MYSQL_CONFIG

#define MYSQL_CONFIG   "app_mysql.conf"

Definition at line 106 of file app_mysql.c.

Referenced by load_module().

MYSQL_CONFIG_OLD

#define MYSQL_CONFIG_OLD   "mysql.conf"

Definition at line 107 of file app_mysql.c.

Referenced by load_module().

Enumeration Type Documentation

anonymous enum

anonymous enum

Enumerator
NULLSTRING
NULLVALUE
EMPTYSTRING

Definition at line 60 of file app_mysql.c.

{ NULLSTRING, NULLVALUE, EMPTYSTRING } nullvalue = NULLSTRING;

Function Documentation

add_identifier()

static int add_identifier ( struct ast_channel *  chan, int  identifier_type, void *  data  )

static

Definition at line 211 of file app_mysql.c.

References _mysql_ids_head, AST_LIST_INSERT_HEAD, AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_log, ast_malloc, ast_MYSQL_id::data, ast_MYSQL_id::entries, ast_MYSQL_id::identifier, ast_MYSQL_id::identifier_type, LOG_WARNING, NULL, and ast_MYSQL_id::owner.

Referenced by add_identifier_and_set_asterisk_int().

{
   struct ast_MYSQL_id *i = NULL, *j = NULL;
   struct MYSQLidshead *headp = &_mysql_ids_head;
   int maxidentifier = 0;

   if (AST_LIST_LOCK(headp)) {
      ast_log(LOG_WARNING, "Unable to lock identifiers list\n");
      return -1;
   } else {
      i = ast_malloc(sizeof(*i));
      AST_LIST_TRAVERSE(headp, j, entries) {
         if (j->identifier > maxidentifier) {
            maxidentifier = j->identifier;
         }
      }
      i->identifier = maxidentifier + 1;
      i->identifier_type = identifier_type;
      i->data = data;
      i->owner = chan;
      AST_LIST_INSERT_HEAD(headp, i, entries);
      AST_LIST_UNLOCK(headp);
   }
   return i->identifier;
}

add_identifier_and_set_asterisk_int()

static int add_identifier_and_set_asterisk_int ( struct ast_channel *  chan, char *  varname, int  identifier_type, void *  data  )

static

Definition at line 277 of file app_mysql.c.

References add_identifier(), and set_asterisk_int().

Referenced by aMYSQL_connect(), aMYSQL_nextresult(), and aMYSQL_query().

{
   return set_asterisk_int(chan, varname, add_identifier(chan, identifier_type, data));
}

aMYSQL_clear()

static int aMYSQL_clear ( struct ast_channel *  chan, const char *  data  )

static

Definition at line 525 of file app_mysql.c.

References ast_log, AST_MYSQL_ID_RESID, ast_strdupa, del_identifier(), find_identifier(), id, LOG_WARNING, NULL, parse(), safe_scan_int(), and strsep().

Referenced by MYSQL_exec().

{
   MYSQL_RES *mysqlres;

   int id;
   char *parse = ast_strdupa(data);
   strsep(&parse, " "); /* eat the first token, we already know it :P */
   id = safe_scan_int(&parse, " \n", -1);
   if ((mysqlres = find_identifier(id, AST_MYSQL_ID_RESID)) == NULL) {
      ast_log(LOG_WARNING, "Invalid result identifier %d passed in aMYSQL_clear\n", id);
   } else {
      mysql_free_result(mysqlres);
      del_identifier(id, AST_MYSQL_ID_RESID);
   }

   return 0;
}

aMYSQL_connect()

static int aMYSQL_connect ( struct ast_channel *  chan, const char *  data  )

static

Definition at line 321 of file app_mysql.c.

References add_identifier_and_set_asterisk_int(), args, AST_APP_ARG, AST_DECLARE_APP_ARGS, ast_log, AST_MYSQL_ID_CONNID, AST_NONSTANDARD_APP_ARGS, ast_strdupa, dbcharset, dbhost, dbname, dbpass, dbuser, LOG_WARNING, mysql, NULL, parse(), pbx_builtin_getvar_helper(), and timeout.

Referenced by MYSQL_exec().

{
   AST_DECLARE_APP_ARGS(args,
      AST_APP_ARG(connect);
      AST_APP_ARG(connid);
      AST_APP_ARG(dbhost);
      AST_APP_ARG(dbuser);
      AST_APP_ARG(dbpass);
      AST_APP_ARG(dbname);
      AST_APP_ARG(dbcharset);
   );
   MYSQL *mysql;
   int timeout;
   const char *ctimeout;
   unsigned int port = 0;
   char *port_str;
   char *parse = ast_strdupa(data);

   AST_NONSTANDARD_APP_ARGS(args, parse, ' ');

   if (args.argc < 6) {
      ast_log(LOG_WARNING, "MYSQL_connect is missing some arguments\n");
      return -1;
   }

   if (!(mysql = mysql_init(NULL))) {
      ast_log(LOG_WARNING, "mysql_init returned NULL\n");
      return -1;
   }

   ctimeout = pbx_builtin_getvar_helper(chan, "MYSQL_TIMEOUT");
   if (ctimeout && sscanf(ctimeout, "%30d", &timeout) == 1) {
      mysql_options(mysql, MYSQL_OPT_CONNECT_TIMEOUT, (void *)&timeout);
   }
   if(args.dbcharset && strlen(args.dbcharset) > 2){
      char set_names[255];
      char statement[512];
      snprintf(set_names, sizeof(set_names), "SET NAMES %s", args.dbcharset);
      mysql_real_escape_string(mysql, statement, set_names, sizeof(set_names));
      mysql_options(mysql, MYSQL_INIT_COMMAND, set_names);
      mysql_options(mysql, MYSQL_SET_CHARSET_NAME, args.dbcharset);
   }

   if ((port_str = strchr(args.dbhost, ':'))) {
      *port_str++ = '\0';
      if (sscanf(port_str, "%u", &port) != 1) {
         ast_log(LOG_WARNING, "Invalid port: '%s'\n", port_str);
         port = 0;
      }
   }

   if (!mysql_real_connect(mysql, args.dbhost, args.dbuser, args.dbpass, args.dbname, port, NULL,
#ifdef CLIENT_MULTI_STATEMENTS
         CLIENT_MULTI_STATEMENTS | CLIENT_MULTI_RESULTS
#elif defined(CLIENT_MULTI_QUERIES)
         CLIENT_MULTI_QUERIES
#else
         0
#endif
      )) {
      ast_log(LOG_WARNING, "mysql_real_connect(mysql,%s,%s,dbpass,%s,...) failed(%d): %s\n",
            args.dbhost, args.dbuser, args.dbname, mysql_errno(mysql), mysql_error(mysql));
      return -1;
   }

   add_identifier_and_set_asterisk_int(chan, args.connid, AST_MYSQL_ID_CONNID, mysql);
   return 0;
}

aMYSQL_disconnect()

static int aMYSQL_disconnect ( struct ast_channel *  chan, const char *  data  )

static

Definition at line 543 of file app_mysql.c.

References ast_log, AST_MYSQL_ID_CONNID, ast_strdupa, del_identifier(), find_identifier(), id, LOG_WARNING, mysql, NULL, parse(), safe_scan_int(), and strsep().

Referenced by MYSQL_exec().

{
   MYSQL *mysql;
   int id;
   char *parse = ast_strdupa(data);
   strsep(&parse, " "); /* eat the first token, we already know it :P */

   id = safe_scan_int(&parse, " \n", -1);
   if ((mysql = find_identifier(id, AST_MYSQL_ID_CONNID)) == NULL) {
      ast_log(LOG_WARNING, "Invalid connection identifier %d passed in aMYSQL_disconnect\n", id);
   } else {
      mysql_close(mysql);
      del_identifier(id, AST_MYSQL_ID_CONNID);
   }

   return 0;
}

aMYSQL_fetch()

static int aMYSQL_fetch ( struct ast_channel *  chan, const char *  data  )

static

Definition at line 473 of file app_mysql.c.

References args, AST_APP_ARG, ast_debug, AST_DECLARE_APP_ARGS, ast_log, AST_MYSQL_ID_RESID, AST_NONSTANDARD_APP_ARGS, ast_strdupa, EMPTYSTRING, find_identifier(), LOG_WARNING, NULL, NULLSTRING, nullvalue, parse(), pbx_builtin_setvar_helper(), set_asterisk_int(), and strsep().

Referenced by MYSQL_exec().

{
   MYSQL_RES *mysqlres;
   MYSQL_ROW mysqlrow;
   AST_DECLARE_APP_ARGS(args,
      AST_APP_ARG(fetch);
      AST_APP_ARG(resultvar);
      AST_APP_ARG(fetchid);
      AST_APP_ARG(vars);
   );
   char *s5, *parse;
   int resultid = -1, numFields, j;

   parse = ast_strdupa(data);
   AST_NONSTANDARD_APP_ARGS(args, parse, ' ');
   sscanf(args.fetchid, "%30d", &resultid);

   if (args.resultvar && (resultid >= 0) ) {
      if ((mysqlres = find_identifier(resultid, AST_MYSQL_ID_RESID)) != NULL) {
         /* Grab the next row */
         if ((mysqlrow = mysql_fetch_row(mysqlres)) != NULL) {
            numFields = mysql_num_fields(mysqlres);
            for (j = 0; j < numFields; j++) {
               s5 = strsep(&args.vars, " ");
               if (s5 == NULL) {
                  ast_log(LOG_WARNING, "ast_MYSQL_fetch: More fields (%d) than variables (%d)\n", numFields, j);
                  break;
               }

               pbx_builtin_setvar_helper(chan, s5, mysqlrow[j] ? mysqlrow[j] :
                  nullvalue == NULLSTRING ? "NULL" :
                  nullvalue == EMPTYSTRING ? "" :
                  NULL);
            }
            ast_debug(5, "ast_MYSQL_fetch: numFields=%d\n", numFields);
            set_asterisk_int(chan, args.resultvar, 1); /* try more rows */
         } else {
            ast_debug(5, "ast_MYSQL_fetch : EOF\n");
            set_asterisk_int(chan, args.resultvar, 0); /* no more rows */
         }
         return 0;
      } else {
         set_asterisk_int(chan, args.resultvar, 0);
         ast_log(LOG_WARNING, "aMYSQL_fetch: Invalid result identifier %d passed\n", resultid);
      }
   } else {
      ast_log(LOG_WARNING, "aMYSQL_fetch: missing some arguments\n");
   }

   return -1;
}

aMYSQL_nextresult()

static int aMYSQL_nextresult ( struct ast_channel *  chan, const char *  data  )

static

Definition at line 432 of file app_mysql.c.

References add_identifier_and_set_asterisk_int(), args, AST_APP_ARG, AST_DECLARE_APP_ARGS, ast_log, AST_MYSQL_ID_CONNID, AST_MYSQL_ID_RESID, AST_NONSTANDARD_APP_ARGS, ast_strdupa, find_identifier(), LOG_WARNING, mysql, and parse().

Referenced by MYSQL_exec().

{
   MYSQL       *mysql;
   MYSQL_RES   *mysqlres;
   AST_DECLARE_APP_ARGS(args,
      AST_APP_ARG(nextresult);
      AST_APP_ARG(resultid);
      AST_APP_ARG(connid);
   );
   int connid = -1;
   char *parse = ast_strdupa(data);

   AST_NONSTANDARD_APP_ARGS(args, parse, ' ');
   sscanf(args.connid, "%30d", &connid);

   if (args.argc != 3 || connid <= 0) {
      ast_log(LOG_WARNING, "missing some arguments\n");
      return -1;
   }

   if (!(mysql = find_identifier(connid, AST_MYSQL_ID_CONNID))) {
      ast_log(LOG_WARNING, "Invalid connection identifier %d passed in aMYSQL_query\n", connid);
      return -1;
   }

   if (mysql_more_results(mysql)) {
      mysql_next_result(mysql);
      if ((mysqlres = mysql_store_result(mysql))) {
         add_identifier_and_set_asterisk_int(chan, args.resultid, AST_MYSQL_ID_RESID, mysqlres);
         return 0;
      } else if (!mysql_field_count(mysql)) {
         return 0;
      } else
         ast_log(LOG_WARNING, "mysql_store_result() failed on storing next_result\n");
   } else
      ast_log(LOG_WARNING, "mysql_more_results() result set has no more results\n");

   return 0;
}

aMYSQL_query()

static int aMYSQL_query ( struct ast_channel *  chan, const char *  data  )

static

Definition at line 390 of file app_mysql.c.

References add_identifier_and_set_asterisk_int(), args, AST_APP_ARG, AST_DECLARE_APP_ARGS, ast_log, AST_MYSQL_ID_CONNID, AST_MYSQL_ID_RESID, AST_NONSTANDARD_APP_ARGS, ast_strdupa, find_identifier(), LOG_WARNING, mysql, and parse().

Referenced by MYSQL_exec().

{
   AST_DECLARE_APP_ARGS(args,
      AST_APP_ARG(query);
      AST_APP_ARG(resultid);
      AST_APP_ARG(connid);
      AST_APP_ARG(sql);
   );
   MYSQL       *mysql;
   MYSQL_RES   *mysqlres;
   int connid;
   int mysql_query_res;
   char *parse = ast_strdupa(data);

   AST_NONSTANDARD_APP_ARGS(args, parse, ' ');

   if (args.argc != 4 || (connid = atoi(args.connid)) == 0) {
      ast_log(LOG_WARNING, "missing some arguments\n");
      return -1;
   }

   if (!(mysql = find_identifier(connid, AST_MYSQL_ID_CONNID))) {
      ast_log(LOG_WARNING, "Invalid connection identifier %s passed in aMYSQL_query\n", args.connid);
      return -1;
   }

   if ((mysql_query_res = mysql_query(mysql, args.sql)) != 0) {
      ast_log(LOG_WARNING, "aMYSQL_query: mysql_query failed. Error: %s\n", mysql_error(mysql));
      return -1;
   }

   if ((mysqlres = mysql_store_result(mysql))) {
      add_identifier_and_set_asterisk_int(chan, args.resultid, AST_MYSQL_ID_RESID, mysqlres);
      return 0;
   } else if (!mysql_field_count(mysql)) {
      return 0;
   } else
      ast_log(LOG_WARNING, "mysql_store_result() failed on query %s\n", args.sql);

   return -1;
}

aMYSQL_set()

static int aMYSQL_set ( struct ast_channel *  chan, const char *  data  )

static

Definition at line 295 of file app_mysql.c.

References args, ast_alloca, AST_APP_ARG, AST_DECLARE_APP_ARGS, AST_NONSTANDARD_APP_ARGS, ast_strdupa, parse(), pbx_builtin_setvar_helper(), tmp(), value, and var.

Referenced by MYSQL_exec().

{
   char *var, *tmp, *parse;
   AST_DECLARE_APP_ARGS(args,
      AST_APP_ARG(set);
      AST_APP_ARG(variable);
      AST_APP_ARG(value);
   );

   parse = ast_strdupa(data);
   AST_NONSTANDARD_APP_ARGS(args, parse, ' ');

   if (args.argc == 3) {
      var = ast_alloca(6 + strlen(args.variable) + 1);
      sprintf(var, "MYSQL_%s", args.variable);

      /* Make the parameter case-insensitive */
      for (tmp = var + 6; *tmp; tmp++)
         *tmp = toupper(*tmp);

      pbx_builtin_setvar_helper(chan, var, args.value);
   }
   return 0;
}

AST_MODULE_INFO_STANDARD_DEPRECATED()

AST_MODULE_INFO_STANDARD_DEPRECATED	(	ASTERISK_GPL_KEY	,
		"Simple Mysql Interface"
	)

Referenced by load_module().

del_identifier()

static int del_identifier ( int  identifier, int  identifier_type  )

static

Definition at line 237 of file app_mysql.c.

References _mysql_ids_head, ast_free, AST_LIST_LOCK, AST_LIST_REMOVE, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_log, ast_MYSQL_id::entries, ast_MYSQL_id::identifier, ast_MYSQL_id::identifier_type, and LOG_WARNING.

Referenced by aMYSQL_clear(), and aMYSQL_disconnect().

{
   struct ast_MYSQL_id *i;
   struct MYSQLidshead *headp = &_mysql_ids_head;
   int found = 0;

   if (AST_LIST_LOCK(headp)) {
      ast_log(LOG_WARNING, "Unable to lock identifiers list\n");
   } else {
      AST_LIST_TRAVERSE(headp, i, entries) {
         if ((i->identifier == identifier) &&
             (i->identifier_type == identifier_type)) {
            AST_LIST_REMOVE(headp, i, entries);
            ast_free(i);
            found = 1;
            break;
         }
      }
      AST_LIST_UNLOCK(headp);
   }

   if (found == 0) {
      ast_log(LOG_WARNING, "Could not find identifier %d, identifier_type %d in list to delete\n", identifier, identifier_type);
      return -1;
   } else {
      return 0;
   }
}

find_identifier()

static void* find_identifier ( int  identifier, int  identifier_type  )

static

Definition at line 185 of file app_mysql.c.

References _mysql_ids_head, AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_log, ast_MYSQL_id::data, ast_MYSQL_id::entries, ast_MYSQL_id::identifier, ast_MYSQL_id::identifier_type, LOG_WARNING, and NULL.

Referenced by aMYSQL_clear(), aMYSQL_disconnect(), aMYSQL_fetch(), aMYSQL_nextresult(), and aMYSQL_query().

{
   struct MYSQLidshead *headp = &_mysql_ids_head;
   struct ast_MYSQL_id *i;
   void *res=NULL;
   int found=0;

   if (AST_LIST_LOCK(headp)) {
      ast_log(LOG_WARNING, "Unable to lock identifiers list\n");
   } else {
      AST_LIST_TRAVERSE(headp, i, entries) {
         if ((i->identifier == identifier) && (i->identifier_type == identifier_type)) {
            found = 1;
            res = i->data;
            break;
         }
      }
      if (!found) {
         ast_log(LOG_WARNING, "Identifier %d, identifier_type %d not found in identifier list\n", identifier, identifier_type);
      }
      AST_LIST_UNLOCK(headp);
   }

   return res;
}

load_module()

static int load_module ( void  )

static

Load the module.

Module loading including tests for configuration or dependencies. This function can return AST_MODULE_LOAD_FAILURE, AST_MODULE_LOAD_DECLINE, or AST_MODULE_LOAD_SUCCESS. If a dependency or environment variable fails tests return AST_MODULE_LOAD_FAILURE. If the module can not load the configuration file or other non-critical problem return AST_MODULE_LOAD_DECLINE. On success return AST_MODULE_LOAD_SUCCESS.

Definition at line 633 of file app_mysql.c.

References _mysql_ids_head, app, ast_config_destroy(), ast_config_load, AST_LIST_HEAD_INIT, ast_log, AST_MODULE_INFO_STANDARD_DEPRECATED(), ast_register_application, ast_true(), ast_variable_retrieve(), ASTERISK_GPL_KEY, autoclear, descrip, EMPTYSTRING, LOG_WARNING, MYSQL_CONFIG, MYSQL_CONFIG_OLD, MYSQL_exec(), NULLSTRING, NULLVALUE, nullvalue, and synopsis.

Referenced by load_values_config().

{
   struct MYSQLidshead *headp = &_mysql_ids_head;
   struct ast_flags config_flags = { 0 };
   struct ast_config *cfg = ast_config_load(MYSQL_CONFIG, config_flags);
   const char *temp;

   if (!cfg) {
      /* Backwards compatibility ftw */
      cfg = ast_config_load(MYSQL_CONFIG_OLD, config_flags);
   }

   if (cfg) {
      if ((temp = ast_variable_retrieve(cfg, "general", "nullvalue"))) {
         if (!strcasecmp(temp, "nullstring")) {
            nullvalue = NULLSTRING;
         } else if (!strcasecmp(temp, "emptystring")) {
            nullvalue = EMPTYSTRING;
         } else if (!strcasecmp(temp, "null")) {
            nullvalue = NULLVALUE;
         } else {
            ast_log(LOG_WARNING, "Illegal value for 'nullvalue': '%s' (must be 'nullstring', 'null', or 'emptystring')\n", temp);
         }
      }
      if ((temp = ast_variable_retrieve(cfg, "general", "autoclear")) && ast_true(temp)) {
         autoclear = 1;
      }
      ast_config_destroy(cfg);
   }

   AST_LIST_HEAD_INIT(headp);
   return ast_register_application(app, MYSQL_exec, synopsis, descrip);
}

mysql_ds_destroy()

static void mysql_ds_destroy ( void *  data )

static

Definition at line 134 of file app_mysql.c.

References _mysql_ids_head, ast_free, AST_LIST_LOCK, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_LIST_UNLOCK, ast_log, AST_MYSQL_ID_CONNID, AST_MYSQL_ID_RESID, ast_MYSQL_id::data, ast_MYSQL_id::entries, ast_MYSQL_id::identifier_type, LOG_WARNING, and ast_MYSQL_id::owner.

{
   /* Destroy any IDs owned by the channel */
   struct ast_MYSQL_id *i;
   if (AST_LIST_LOCK(&_mysql_ids_head)) {
      ast_log(LOG_WARNING, "Unable to lock identifiers list\n");
   } else {
      AST_LIST_TRAVERSE_SAFE_BEGIN(&_mysql_ids_head, i, entries) {
         if (i->owner == data) {
            AST_LIST_REMOVE_CURRENT(entries);
            if (i->identifier_type == AST_MYSQL_ID_CONNID) {
               /* Drop connection */
               mysql_close(i->data);
            } else if (i->identifier_type == AST_MYSQL_ID_RESID) {
               /* Drop result */
               mysql_free_result(i->data);
            }
            ast_free(i);
         }
      }
      AST_LIST_TRAVERSE_SAFE_END
      AST_LIST_UNLOCK(&_mysql_ids_head);
   }
}

mysql_ds_fixup()

static void mysql_ds_fixup ( void *  data, struct ast_channel *  oldchan, struct ast_channel *  newchan  )

static

Definition at line 159 of file app_mysql.c.

References _mysql_ids_head, ast_free, AST_LIST_LOCK, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_LIST_UNLOCK, ast_log, AST_MYSQL_ID_CONNID, AST_MYSQL_ID_RESID, ast_MYSQL_id::data, ast_MYSQL_id::entries, ast_MYSQL_id::identifier_type, LOG_WARNING, and ast_MYSQL_id::owner.

{
   /* Destroy any IDs owned by the channel */
   struct ast_MYSQL_id *i;
   if (AST_LIST_LOCK(&_mysql_ids_head)) {
      ast_log(LOG_WARNING, "Unable to lock identifiers list\n");
   } else {
      AST_LIST_TRAVERSE_SAFE_BEGIN(&_mysql_ids_head, i, entries) {
         if (i->owner == data) {
            AST_LIST_REMOVE_CURRENT(entries);
            if (i->identifier_type == AST_MYSQL_ID_CONNID) {
               /* Drop connection */
               mysql_close(i->data);
            } else if (i->identifier_type == AST_MYSQL_ID_RESID) {
               /* Drop result */
               mysql_free_result(i->data);
            }
            ast_free(i);
         }
      }
      AST_LIST_TRAVERSE_SAFE_END
      AST_LIST_UNLOCK(&_mysql_ids_head);
   }
}

MYSQL_exec()

static int MYSQL_exec ( struct ast_channel *  chan, const char *  data  )

static

Definition at line 561 of file app_mysql.c.

References _mysql_mutex, aMYSQL_clear(), aMYSQL_connect(), aMYSQL_disconnect(), aMYSQL_fetch(), aMYSQL_nextresult(), aMYSQL_query(), aMYSQL_set(), ast_channel_datastore_add(), ast_channel_datastore_find(), ast_channel_lock, ast_channel_unlock, ast_datastore_alloc, ast_debug, ast_log, ast_mutex_lock, ast_mutex_unlock, autoclear, ast_datastore::data, LOG_WARNING, NULL, pbx_builtin_setvar_helper(), and result.

Referenced by load_module().

{
   int result;
   char sresult[10];

   ast_debug(5, "MYSQL: data=%s\n", data);

   if (!data) {
      ast_log(LOG_WARNING, "MYSQL requires an argument (see manual)\n");
      return -1;
   }

   result = 0;

   if (autoclear) {
      struct ast_datastore *mysql_store = NULL;

      ast_channel_lock(chan);
      mysql_store = ast_channel_datastore_find(chan, &mysql_ds_info, NULL);
      if (!mysql_store) {
         if (!(mysql_store = ast_datastore_alloc(&mysql_ds_info, NULL))) {
            ast_log(LOG_WARNING, "Unable to allocate new datastore.\n");
         } else {
            mysql_store->data = chan;
            ast_channel_datastore_add(chan, mysql_store);
         }
      }
      ast_channel_unlock(chan);
   }
   ast_mutex_lock(&_mysql_mutex);

   if (strncasecmp("connect", data, strlen("connect")) == 0) {
      result = aMYSQL_connect(chan, data);
   } else if (strncasecmp("query", data, strlen("query")) == 0) {
      result = aMYSQL_query(chan, data);
   } else if (strncasecmp("nextresult", data, strlen("nextresult")) == 0) {
      result = aMYSQL_nextresult(chan, data);
   } else if (strncasecmp("fetch", data, strlen("fetch")) == 0) {
      result = aMYSQL_fetch(chan, data);
   } else if (strncasecmp("clear", data, strlen("clear")) == 0) {
      result = aMYSQL_clear(chan, data);
   } else if (strncasecmp("disconnect", data, strlen("disconnect")) == 0) {
      result = aMYSQL_disconnect(chan, data);
   } else if (strncasecmp("set", data, 3) == 0) {
      result = aMYSQL_set(chan, data);
   } else {
      ast_log(LOG_WARNING, "Unknown argument to MYSQL application : %s\n", data);
      result = -1;
   }

   ast_mutex_unlock(&_mysql_mutex);

   snprintf(sresult, sizeof(sresult), "%d", result);
   pbx_builtin_setvar_helper(chan, "MYSQL_STATUS", sresult);
   return 0;
}

safe_scan_int()

static int safe_scan_int ( char **  data, char *  delim, int  def  )

static

Definition at line 282 of file app_mysql.c.

References end, and strsep().

Referenced by aMYSQL_clear(), and aMYSQL_disconnect().

{
   char *end;
   int res = def;
   char *s = strsep(data, delim);
   if (s) {
      res = strtol(s, &end, 10);
      if (*end)
         res = def;  /* not an integer */
   }
   return res;
}

set_asterisk_int()

static int set_asterisk_int ( struct ast_channel *  chan, char *  varname, int  id  )

static

Definition at line 266 of file app_mysql.c.

References ast_debug, id, and pbx_builtin_setvar_helper().

Referenced by add_identifier_and_set_asterisk_int(), and aMYSQL_fetch().

{
   if (id >= 0) {
      char s[12] = "";
      snprintf(s, sizeof(s), "%d", id);
      ast_debug(5, "MYSQL: setting var '%s' to value '%s'\n", varname, s);
      pbx_builtin_setvar_helper(chan, varname, s);
   }
   return id;
}

unload_module()

static int unload_module ( void  )

static

Definition at line 618 of file app_mysql.c.

References app, and ast_unregister_application().

{
   return ast_unregister_application(app);
}

Variable Documentation

_mysql_ids_head

struct MYSQLidshead _mysql_ids_head

Referenced by add_identifier(), del_identifier(), find_identifier(), load_module(), mysql_ds_destroy(), and mysql_ds_fixup().

_mysql_mutex

ast_mutex_t _mysql_mutex = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }

static

Definition at line 104 of file app_mysql.c.

Referenced by MYSQL_exec().

app

const char app[] = "MYSQL"

static

Definition at line 62 of file app_mysql.c.

Referenced by __stasis_app_register(), action_originate(), add_extension(), answer_exec_enable(), app_create(), app_dtor(), app_hash(), append_json(), append_name(), applicationmap_handler(), ari_originate_dial(), ari_set_debug(), ari_show_app(), ari_show_apps(), ast_ari_applications_filter(), ast_ari_callback(), ast_bridge_transfer_attended(), ast_complete_applications(), AST_TEST_DEFINE(), attended_transfer_bridge(), bridge_attended_transfer_handler(), bridge_blind_transfer_handler(), bridge_merge_handler(), bridge_subscription_change_handler(), cel_track_app(), check_pval_item(), cleanup_cb(), complete_ari_app(), endpoint_state_cb(), event_session_alloc(), event_session_shutdown(), exec_exec(), execif_exec(), handle_cli_dialplan_add_extension(), handle_cli_status(), handle_show_application(), is_empty(), load_module(), lua_pbx_exec(), message_received_handler(), page_exec(), pbx_builtin_execiftime(), realtime_exec(), run_app_helper(), stasis_app_event_allowed(), stasis_app_exec(), stasis_app_get_debug_by_name(), stasis_app_send(), stasis_app_set_debug_by_name(), stasis_app_set_global_debug(), stasis_app_to_json(), stasis_app_unregister(), sub_bridge_update_handler(), sub_channel_update_handler(), sub_default_handler(), sub_endpoint_update_handler(), sub_subscription_change_handler(), tryexec_exec(), and unload_module().

ast_MYSQL_id

struct ast_MYSQL_id * ast_MYSQL_id

autoclear

int autoclear = 0

static

Definition at line 113 of file app_mysql.c.

Referenced by load_module(), and MYSQL_exec().

descrip

const char descrip[]

static

Definition at line 66 of file app_mysql.c.

Referenced by load_module().

mysql_ds_info

const struct ast_datastore_info mysql_ds_info

static

Initial value:

= {
   .type = "APP_ADDON_SQL_MYSQL",
   .destroy = mysql_ds_destroy,
   .chan_fixup = mysql_ds_fixup,
}

Definition at line 118 of file app_mysql.c.

nullvalue

enum { ... } nullvalue

Referenced by aMYSQL_fetch(), and load_module().

synopsis

const char synopsis[] = "Do several mySQLy things"

static

Definition at line 64 of file app_mysql.c.

Referenced by acf_retrieve_docs(), ast_xmldoc_regenerate_doc_item(), handle_cli_agi_show(), handle_show_function(), handle_showmancmd(), init_acf_query(), load_module(), print_event_instance(), and xmldoc_build_documentation_item().