2 * Asterisk -- A telephony toolkit for Linux.
6 * Brian K. West <brian@bkw.org>
8 * This program is free software, distributed under the terms of
9 * the GNU General Public License.
11 * Copyright (c) 2003 Digium, Inc.
15 #include <sys/types.h>
16 #include <asterisk/config.h>
17 #include <asterisk/options.h>
18 #include <asterisk/channel.h>
19 #include <asterisk/cdr.h>
20 #include <asterisk/module.h>
21 #include <asterisk/logger.h>
22 #include "../asterisk.h"
35 #define DATE_FORMAT "%Y-%m-%d %T"
37 static char *desc = "ODBC CDR Backend";
38 static char *name = "ODBC";
39 static char *config = "cdr_odbc.conf";
40 static char *dsn = NULL, *username = NULL, *password = NULL, *loguniqueid = NULL;
41 static int dsn_alloc = 0, username_alloc = 0, password_alloc = 0;
42 static int connected = 0;
44 static ast_mutex_t odbc_lock = AST_MUTEX_INITIALIZER;
46 extern int odbc_do_query(char *sqlcmd);
47 extern int odbc_init(void);
49 static SQLHENV ODBC_env = SQL_NULL_HANDLE; /* global ODBC Environment */
50 static int ODBC_res; /* global ODBC Result of Functions */
51 static SQLHDBC ODBC_con; /* global ODBC Connection Handle */
52 static SQLHSTMT ODBC_stmt; /* global ODBC Statement Handle */
54 static int odbc_log(struct ast_cdr *cdr)
58 long int ODBC_err, ODBC_id;
60 char ODBC_msg[200], ODBC_buffer[200], ODBC_stat[10];
65 char sqlcmd[2048], timestr[128];
67 ast_mutex_lock(&odbc_lock);
69 gettimeofday(&tv,NULL);
72 strftime(timestr,128,DATE_FORMAT,&tm);
74 memset(sqlcmd,0,2048);
76 if((strcmp(loguniqueid, "1") == 0) || (strcmp(loguniqueid, "yes") == 0))
78 sprintf(sqlcmd,"INSERT INTO cdr (calldate,clid,src,dst,dcontext,channel,dstchannel,lastapp,lastdata,duration,billsec,disposition,amaflags,accountcode,uniqueid) VALUES ('%s','%s','%s','%s','%s', '%s','%s','%s','%s',%i,%i,%i,%i,'%s','%s')", timestr, cdr->clid, cdr->src, cdr->dst, cdr->dcontext, cdr->channel, cdr->dstchannel, cdr->lastapp, cdr->lastdata, cdr->duration, cdr->billsec, cdr->disposition, cdr->amaflags, cdr->accountcode, cdr->uniqueid);
82 sprintf(sqlcmd,"INSERT INTO cdr (calldate,clid,src,dst,dcontext,channel,dstchannel,lastapp,lastdata,duration,billsec,disposition,amaflags,accountcode) VALUES ('%s','%s','%s','%s','%s', '%s','%s','%s','%s',%i,%i,%i,%i,'%s')", timestr, cdr->clid, cdr->src, cdr->dst, cdr->dcontext, cdr->channel, cdr->dstchannel, cdr->lastapp, cdr->lastdata, cdr->duration, cdr->billsec, cdr->disposition, cdr->amaflags, cdr->accountcode);
87 res = odbc_do_query(sqlcmd);
90 if(option_verbose > 3)
91 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Query FAILED Call not logged!\n");
93 if(option_verbose > 3)
94 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Reconnecting to dsn %s\n", dsn);
97 if(option_verbose > 3)
98 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: %s has gone away!\n", dsn);
103 if(option_verbose > 3)
104 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Trying Query again!\n");
105 res = odbc_do_query(sqlcmd);
108 if(option_verbose > 3)
109 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Query FAILED Call not logged!\n");
116 if(option_verbose > 3)
117 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Reconnecting to dsn %s\n", dsn);
121 if(option_verbose > 3)
123 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: %s has gone away!\n", dsn);
124 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Call not logged!\n");
129 if(option_verbose > 3)
130 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Trying Query again!\n");
131 res = odbc_do_query(sqlcmd);
134 if(option_verbose > 3)
135 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Query FAILED Call not logged!\n");
139 ast_mutex_unlock(&odbc_lock);
143 char *description(void)
148 static int odbc_unload_module(void)
152 if(option_verbose > 3)
153 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Disconnecting from %s\n", dsn);
154 SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmt);
155 SQLDisconnect(ODBC_con);
156 SQLFreeHandle(SQL_HANDLE_DBC, ODBC_con);
157 SQLFreeHandle(SQL_HANDLE_ENV, ODBC_env);
160 if (dsn && dsn_alloc)
162 if(option_verbose > 3)
163 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: free dsn\n");
168 if (username && username_alloc)
170 if(option_verbose > 3)
171 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: free username\n");
176 if (password && password_alloc)
178 if(option_verbose > 3)
179 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: free password\n");
184 ast_cdr_unregister(name);
188 static int odbc_load_module(void)
191 struct ast_config *cfg;
192 struct ast_variable *var;
195 cfg = ast_load(config);
198 ast_log(LOG_WARNING, "cdr_odbc: Unable to load config for ODBC CDR's: %s\n", config);
202 var = ast_variable_browse(cfg, "global");
204 /* nothing configured */
208 tmp = ast_variable_retrieve(cfg,"global","dsn");
211 dsn = malloc(strlen(tmp) + 1);
219 ast_log(LOG_ERROR,"cdr_odbc: Out of memory error.\n");
225 ast_log(LOG_WARNING,"cdr_odbc: dsn not specified. Assuming asteriskdb\n");
229 tmp = ast_variable_retrieve(cfg,"global","username");
232 username = malloc(strlen(tmp) + 1);
233 if (username != NULL)
236 strcpy(username,tmp);
240 ast_log(LOG_ERROR,"cdr_odbc: Out of memory error.\n");
246 ast_log(LOG_WARNING,"cdr_odbc: username not specified. Assuming root\n");
250 tmp = ast_variable_retrieve(cfg,"global","password");
253 password = malloc(strlen(tmp) + 1);
254 if (password != NULL)
257 strcpy(password,tmp);
261 ast_log(LOG_ERROR,"cdr_odbc: Out of memory error.\n");
267 ast_log(LOG_WARNING,"cdr_odbc: database password not specified. Assuming blank\n");
271 tmp = ast_variable_retrieve(cfg,"global","loguniqueid");
274 loguniqueid = malloc(strlen(tmp) + 1);
275 if (loguniqueid != NULL)
277 strcpy(loguniqueid,tmp);
278 ast_log(LOG_WARNING,"cdr_odbc: Logging uniqueid\n");
282 ast_log(LOG_ERROR,"cdr_odbc: Not logging uniqueid\n");
287 ast_log(LOG_WARNING,"cdr_odbc: Not logging uniqueid\n");
292 if(option_verbose > 3)
294 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: dsn is %s\n",dsn);
295 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: username is %s\n",username);
296 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: password is [secret]\n");
303 ast_log(LOG_ERROR, "cdr_odbc: Unable to connect to datasource: %s\n", dsn);
304 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Unable to connect to datasource: %s\n", dsn);
307 res = ast_cdr_register(name, desc, odbc_log);
310 ast_log(LOG_ERROR, "cdr_odbc: Unable to register ODBC CDR handling\n");
315 int odbc_do_query(char *sqlcmd)
319 char ODBC_msg[200], ODBC_stat[10];
321 ODBC_res = SQLAllocHandle(SQL_HANDLE_STMT, ODBC_con, &ODBC_stmt);
323 if((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO))
325 if(option_verbose > 3)
326 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Failure in AllocStatement %d\n", ODBC_res);
327 SQLGetDiagRec(SQL_HANDLE_DBC, ODBC_con, 1, ODBC_stat, &ODBC_err, ODBC_msg, 100, &ODBC_mlen);
328 SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmt);
333 ODBC_res = SQLPrepare(ODBC_stmt, sqlcmd, SQL_NTS);
335 if((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO))
337 if(option_verbose > 3)
338 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Error in PREPARE %d\n", ODBC_res);
339 SQLGetDiagRec(SQL_HANDLE_DBC, ODBC_con, 1, ODBC_stat, &ODBC_err, ODBC_msg, 100, &ODBC_mlen);
340 SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmt);
344 ODBC_res = SQLExecute(ODBC_stmt);
346 if((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO))
348 if(option_verbose > 3)
349 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Error in Query %d\n", ODBC_res);
350 SQLGetDiagRec(SQL_HANDLE_DBC, ODBC_con, 1, ODBC_stat, &ODBC_err, ODBC_msg, 100, &ODBC_mlen);
351 SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmt);
357 if(option_verbose > 3)
358 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Query Successful!\n");
368 char ODBC_msg[200], ODBC_stat[10];
370 if ( ODBC_env == SQL_NULL_HANDLE || connected == 0)
372 ODBC_res = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &ODBC_env);
374 if((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO))
376 if(option_verbose > 3)
377 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Error AllocHandle\n");
382 ODBC_res = SQLSetEnvAttr(ODBC_env, SQL_ATTR_ODBC_VERSION, (void*)SQL_OV_ODBC3, 0);
384 if((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO))
386 if(option_verbose > 3)
387 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Error SetEnv\n");
388 SQLFreeHandle(SQL_HANDLE_ENV, ODBC_env);
393 ODBC_res = SQLAllocHandle(SQL_HANDLE_DBC, ODBC_env, &ODBC_con);
395 if((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO))
397 if(option_verbose > 3)
398 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Error AllocHDB %d\n", ODBC_res);
399 SQLFreeHandle(SQL_HANDLE_ENV, ODBC_env);
404 SQLSetConnectAttr(ODBC_con, SQL_LOGIN_TIMEOUT, (SQLPOINTER *)10, 0);
407 ODBC_res = SQLConnect(ODBC_con, (SQLCHAR*)dsn, SQL_NTS, (SQLCHAR*)username, SQL_NTS, (SQLCHAR*)password, SQL_NTS);
409 if((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO))
411 if(option_verbose > 3)
412 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Error SQLConnect %d\n", ODBC_res);
413 SQLGetDiagRec(SQL_HANDLE_DBC, ODBC_con, 1, ODBC_stat, &ODBC_err, ODBC_msg, 100, &ODBC_mlen);
414 SQLFreeHandle(SQL_HANDLE_ENV, ODBC_env);
420 if(option_verbose > 3)
421 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Connected to %s\n", dsn);
428 int load_module(void)
430 return odbc_load_module();
433 int unload_module(void)
435 return odbc_unload_module();
440 odbc_unload_module();
441 return odbc_load_module();
451 return ASTERISK_GPL_KEY;