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 static int odbc_do_query(void);
47 static int odbc_init(void);
49 static SQLHENV ODBC_env = SQL_NULL_HANDLE; /* global ODBC Environment */
50 static SQLHDBC ODBC_con; /* global ODBC Connection Handle */
51 static SQLHSTMT ODBC_stmt; /* global ODBC Statement Handle */
53 static int odbc_log(struct ast_cdr *cdr)
58 char ODBC_msg[200], ODBC_stat[10];
59 char sqlcmd[2048], timestr[128];
65 gettimeofday(&tv,NULL);
69 ast_mutex_lock(&odbc_lock);
70 strftime(timestr,128,DATE_FORMAT,&tm);
71 memset(sqlcmd,0,2048);
72 if((loguniqueid != NULL) && ((strcmp(loguniqueid, "1") == 0) || (strcmp(loguniqueid, "yes") == 0)))
74 sprintf(sqlcmd,"INSERT INTO cdr "
75 "(calldate,clid,src,dst,dcontext,channel,dstchannel,lastapp,"
76 "lastdata,duration,billsec,disposition,amaflags,accountcode,uniqueid) "
77 "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)");
81 sprintf(sqlcmd,"INSERT INTO cdr "
82 "(calldate,clid,src,dst,dcontext,channel,dstchannel,lastapp,lastdata,"
83 "duration,billsec,disposition,amaflags,accountcode) "
84 "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?)");
93 ast_mutex_unlock(&odbc_lock);
99 ODBC_res = SQLAllocHandle(SQL_HANDLE_STMT, ODBC_con, &ODBC_stmt);
101 if((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO))
103 if(option_verbose > 3)
104 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Failure in AllocStatement %d\n", ODBC_res);
105 SQLGetDiagRec(SQL_HANDLE_DBC, ODBC_con, 1, ODBC_stat, &ODBC_err, ODBC_msg, 100, &ODBC_mlen);
106 SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmt);
108 ast_mutex_unlock(&odbc_lock);
112 /* We really should only have to do this once. But for some
113 strange reason if I don't it blows holes in memory like
114 like a shotgun. So we just do this so its safe. */
116 ODBC_res = SQLPrepare(ODBC_stmt, sqlcmd, SQL_NTS);
118 if((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO))
120 if(option_verbose > 3)
121 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Error in PREPARE %d\n", ODBC_res);
122 SQLGetDiagRec(SQL_HANDLE_DBC, ODBC_con, 1, ODBC_stat, &ODBC_err, ODBC_msg, 100, &ODBC_mlen);
123 SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmt);
125 ast_mutex_unlock(&odbc_lock);
129 SQLBindParameter(ODBC_stmt, 1, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, 0, 0, ×tr, 0, NULL);
130 SQLBindParameter(ODBC_stmt, 2, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, 0, 0, cdr->clid, 0, NULL);
131 SQLBindParameter(ODBC_stmt, 3, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, 0, 0, cdr->src, 0, NULL);
132 SQLBindParameter(ODBC_stmt, 4, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, 0, 0, cdr->dst, 0, NULL);
133 SQLBindParameter(ODBC_stmt, 5, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, 0, 0, cdr->dcontext, 0, NULL);
134 SQLBindParameter(ODBC_stmt, 6, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, 0, 0, cdr->channel, 0, NULL);
135 SQLBindParameter(ODBC_stmt, 7, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, 0, 0, cdr->dstchannel, 0, NULL);
136 SQLBindParameter(ODBC_stmt, 8, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, 0, 0, cdr->lastapp, 0, NULL);
137 SQLBindParameter(ODBC_stmt, 9, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, 0, 0, cdr->lastdata, 0, NULL);
138 SQLBindParameter(ODBC_stmt, 10, SQL_PARAM_INPUT, SQL_C_SSHORT, SQL_INTEGER, 0, 0, &cdr->duration, 0, NULL);
139 SQLBindParameter(ODBC_stmt, 11, SQL_PARAM_INPUT, SQL_C_SSHORT, SQL_INTEGER, 0, 0, &cdr->billsec, 0, NULL);
140 SQLBindParameter(ODBC_stmt, 12, SQL_PARAM_INPUT, SQL_C_SSHORT, SQL_INTEGER, 0, 0, &cdr->disposition, 0, NULL);
141 SQLBindParameter(ODBC_stmt, 13, SQL_PARAM_INPUT, SQL_C_SSHORT, SQL_INTEGER, 0, 0, &cdr->amaflags, 0, NULL);
142 SQLBindParameter(ODBC_stmt, 14, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, 0, 0, cdr->accountcode, 0, NULL);
144 if((loguniqueid != NULL) && ((strcmp(loguniqueid, "1") == 0) || (strcmp(loguniqueid, "yes") == 0)))
146 SQLBindParameter(ODBC_stmt, 15, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, 0, 0, cdr->uniqueid, 0, NULL);
151 res = odbc_do_query();
154 if(option_verbose > 3)
155 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Query FAILED Call not logged!\n");
157 if(option_verbose > 3)
158 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Reconnecting to dsn %s\n", dsn);
161 if(option_verbose > 3)
162 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: %s has gone away!\n", dsn);
167 if(option_verbose > 3)
168 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Trying Query again!\n");
169 res = odbc_do_query();
172 if(option_verbose > 3)
173 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Query FAILED Call not logged!\n");
180 if(option_verbose > 3)
181 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Query FAILED Call not logged!\n");
183 ast_mutex_unlock(&odbc_lock);
187 char *description(void)
192 static int odbc_unload_module(void)
194 ast_mutex_lock(&odbc_lock);
197 if(option_verbose > 3)
198 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Disconnecting from %s\n", dsn);
199 SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmt);
200 SQLDisconnect(ODBC_con);
201 SQLFreeHandle(SQL_HANDLE_DBC, ODBC_con);
202 SQLFreeHandle(SQL_HANDLE_ENV, ODBC_env);
205 if (dsn && dsn_alloc)
207 if(option_verbose > 3)
208 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: free dsn\n");
213 if (username && username_alloc)
215 if(option_verbose > 3)
216 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: free username\n");
221 if (password && password_alloc)
223 if(option_verbose > 3)
224 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: free password\n");
229 ast_cdr_unregister(name);
230 ast_mutex_unlock(&odbc_lock);
234 static int odbc_load_module(void)
237 struct ast_config *cfg;
238 struct ast_variable *var;
241 ast_mutex_lock(&odbc_lock);
243 cfg = ast_load(config);
246 ast_log(LOG_WARNING, "cdr_odbc: Unable to load config for ODBC CDR's: %s\n", config);
250 var = ast_variable_browse(cfg, "global");
252 /* nothing configured */
256 tmp = ast_variable_retrieve(cfg,"global","dsn");
259 dsn = malloc(strlen(tmp) + 1);
267 ast_log(LOG_ERROR,"cdr_odbc: Out of memory error.\n");
273 ast_log(LOG_WARNING,"cdr_odbc: dsn not specified. Assuming asteriskdb\n");
277 tmp = ast_variable_retrieve(cfg,"global","username");
280 username = malloc(strlen(tmp) + 1);
281 if (username != NULL)
284 strcpy(username,tmp);
288 ast_log(LOG_ERROR,"cdr_odbc: Out of memory error.\n");
294 ast_log(LOG_WARNING,"cdr_odbc: username not specified. Assuming root\n");
298 tmp = ast_variable_retrieve(cfg,"global","password");
301 password = malloc(strlen(tmp) + 1);
302 if (password != NULL)
305 strcpy(password,tmp);
309 ast_log(LOG_ERROR,"cdr_odbc: Out of memory error.\n");
315 ast_log(LOG_WARNING,"cdr_odbc: database password not specified. Assuming blank\n");
319 tmp = ast_variable_retrieve(cfg,"global","loguniqueid");
322 loguniqueid = malloc(strlen(tmp) + 1);
323 if (loguniqueid != NULL)
325 strcpy(loguniqueid,tmp);
326 ast_log(LOG_WARNING,"cdr_odbc: Logging uniqueid\n");
330 ast_log(LOG_ERROR,"cdr_odbc: Not logging uniqueid\n");
336 ast_log(LOG_WARNING,"cdr_odbc: Not logging uniqueid\n");
341 if(option_verbose > 3)
343 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: dsn is %s\n",dsn);
344 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: username is %s\n",username);
345 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: password is [secret]\n");
352 ast_log(LOG_ERROR, "cdr_odbc: Unable to connect to datasource: %s\n", dsn);
353 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Unable to connect to datasource: %s\n", dsn);
356 res = ast_cdr_register(name, desc, odbc_log);
359 ast_log(LOG_ERROR, "cdr_odbc: Unable to register ODBC CDR handling\n");
361 ast_mutex_unlock(&odbc_lock);
365 static int odbc_do_query(void)
370 char ODBC_msg[200], ODBC_stat[10];
372 ODBC_res = SQLExecute(ODBC_stmt);
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 in Query %d\n", ODBC_res);
378 SQLGetDiagRec(SQL_HANDLE_DBC, ODBC_con, 1, ODBC_stat, &ODBC_err, ODBC_msg, 100, &ODBC_mlen);
379 SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmt);
385 if(option_verbose > 3)
386 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Query Successful!\n");
392 static int odbc_init(void)
397 char ODBC_msg[200], ODBC_stat[10];
399 if ( ODBC_env == SQL_NULL_HANDLE || connected == 0 )
401 ODBC_res = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &ODBC_env);
403 if((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO))
405 if(option_verbose > 3)
406 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Error AllocHandle\n");
411 ODBC_res = SQLSetEnvAttr(ODBC_env, SQL_ATTR_ODBC_VERSION, (void*)SQL_OV_ODBC3, 0);
413 if((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO))
415 if(option_verbose > 3)
416 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Error SetEnv\n");
417 SQLFreeHandle(SQL_HANDLE_ENV, ODBC_env);
422 ODBC_res = SQLAllocHandle(SQL_HANDLE_DBC, ODBC_env, &ODBC_con);
424 if((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO))
426 if(option_verbose > 3)
427 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Error AllocHDB %d\n", ODBC_res);
428 SQLFreeHandle(SQL_HANDLE_ENV, ODBC_env);
433 SQLSetConnectAttr(ODBC_con, SQL_LOGIN_TIMEOUT, (SQLPOINTER *)10, 0);
436 ODBC_res = SQLConnect(ODBC_con, (SQLCHAR*)dsn, SQL_NTS, (SQLCHAR*)username, SQL_NTS, (SQLCHAR*)password, SQL_NTS);
438 if((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO))
440 if(option_verbose > 3)
441 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Error SQLConnect %d\n", ODBC_res);
442 SQLGetDiagRec(SQL_HANDLE_DBC, ODBC_con, 1, ODBC_stat, &ODBC_err, ODBC_msg, 100, &ODBC_mlen);
443 SQLFreeHandle(SQL_HANDLE_ENV, ODBC_env);
449 if(option_verbose > 3)
450 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Connected to %s\n", dsn);
456 int load_module(void)
458 return odbc_load_module();
461 int unload_module(void)
463 return odbc_unload_module();
468 odbc_unload_module();
469 return odbc_load_module();
479 return ASTERISK_GPL_KEY;