2 * Asterisk -- A telephony toolkit for Linux.
6 * Copyright (C) 2003-2005, Digium, Inc.
8 * Brian K. West <brian@bkw.org>
10 * This program is free software, distributed under the terms of
11 * the GNU General Public License
14 #include <sys/types.h>
28 ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
30 #include "asterisk/config.h"
31 #include "asterisk/options.h"
32 #include "asterisk/channel.h"
33 #include "asterisk/cdr.h"
34 #include "asterisk/module.h"
35 #include "asterisk/logger.h"
37 #define DATE_FORMAT "%Y-%m-%d %T"
39 static char *desc = "ODBC CDR Backend";
40 static char *name = "ODBC";
41 static char *config = "cdr_odbc.conf";
42 static char *dsn = NULL, *username = NULL, *password = NULL, *table = NULL;
43 static int loguniqueid = 0;
44 static int usegmtime = 0;
45 static int dispositionstring = 0;
46 static int connected = 0;
48 AST_MUTEX_DEFINE_STATIC(odbc_lock);
50 static int odbc_do_query(void);
51 static int odbc_init(void);
53 static SQLHENV ODBC_env = SQL_NULL_HANDLE; /* global ODBC Environment */
54 static SQLHDBC ODBC_con; /* global ODBC Connection Handle */
55 static SQLHSTMT ODBC_stmt; /* global ODBC Statement Handle */
57 static int odbc_log(struct ast_cdr *cdr)
62 char ODBC_msg[200], ODBC_stat[10];
63 char sqlcmd[2048] = "", timestr[128];
68 gmtime_r(&cdr->start.tv_sec,&tm);
70 localtime_r(&cdr->start.tv_sec,&tm);
72 ast_mutex_lock(&odbc_lock);
73 strftime(timestr, sizeof(timestr), DATE_FORMAT, &tm);
74 memset(sqlcmd,0,2048);
76 snprintf(sqlcmd,sizeof(sqlcmd),"INSERT INTO %s "
77 "(calldate,clid,src,dst,dcontext,channel,dstchannel,lastapp,"
78 "lastdata,duration,billsec,disposition,amaflags,accountcode,uniqueid,userfield) "
79 "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)", table);
81 snprintf(sqlcmd,sizeof(sqlcmd),"INSERT INTO %s "
82 "(calldate,clid,src,dst,dcontext,channel,dstchannel,lastapp,lastdata,"
83 "duration,billsec,disposition,amaflags,accountcode) "
84 "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?)", table);
91 ast_mutex_unlock(&odbc_lock);
96 ODBC_res = SQLAllocHandle(SQL_HANDLE_STMT, ODBC_con, &ODBC_stmt);
98 if ((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO)) {
99 if (option_verbose > 10)
100 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Failure in AllocStatement %d\n", ODBC_res);
101 SQLGetDiagRec(SQL_HANDLE_DBC, ODBC_con, 1, ODBC_stat, &ODBC_err, ODBC_msg, 100, &ODBC_mlen);
102 SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmt);
104 ast_mutex_unlock(&odbc_lock);
108 /* We really should only have to do this once. But for some
109 strange reason if I don't it blows holes in memory like
110 like a shotgun. So we just do this so its safe. */
112 ODBC_res = SQLPrepare(ODBC_stmt, sqlcmd, SQL_NTS);
114 if ((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO)) {
115 if (option_verbose > 10)
116 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Error in PREPARE %d\n", ODBC_res);
117 SQLGetDiagRec(SQL_HANDLE_DBC, ODBC_con, 1, ODBC_stat, &ODBC_err, ODBC_msg, 100, &ODBC_mlen);
118 SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmt);
120 ast_mutex_unlock(&odbc_lock);
124 SQLBindParameter(ODBC_stmt, 1, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(timestr), 0, ×tr, 0, NULL);
125 SQLBindParameter(ODBC_stmt, 2, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(cdr->clid), 0, cdr->clid, 0, NULL);
126 SQLBindParameter(ODBC_stmt, 3, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(cdr->src), 0, cdr->src, 0, NULL);
127 SQLBindParameter(ODBC_stmt, 4, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(cdr->dst), 0, cdr->dst, 0, NULL);
128 SQLBindParameter(ODBC_stmt, 5, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(cdr->dcontext), 0, cdr->dcontext, 0, NULL);
129 SQLBindParameter(ODBC_stmt, 6, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(cdr->channel), 0, cdr->channel, 0, NULL);
130 SQLBindParameter(ODBC_stmt, 7, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(cdr->dstchannel), 0, cdr->dstchannel, 0, NULL);
131 SQLBindParameter(ODBC_stmt, 8, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(cdr->lastapp), 0, cdr->lastapp, 0, NULL);
132 SQLBindParameter(ODBC_stmt, 9, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(cdr->lastdata), 0, cdr->lastdata, 0, NULL);
133 SQLBindParameter(ODBC_stmt, 10, SQL_PARAM_INPUT, SQL_C_SLONG, SQL_INTEGER, 0, 0, &cdr->duration, 0, NULL);
134 SQLBindParameter(ODBC_stmt, 11, SQL_PARAM_INPUT, SQL_C_SLONG, SQL_INTEGER, 0, 0, &cdr->billsec, 0, NULL);
135 if (dispositionstring)
136 SQLBindParameter(ODBC_stmt, 12, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, strlen(ast_cdr_disp2str(cdr->disposition)) + 1, 0, ast_cdr_disp2str(cdr->disposition), 0, NULL);
138 SQLBindParameter(ODBC_stmt, 12, SQL_PARAM_INPUT, SQL_C_SLONG, SQL_INTEGER, 0, 0, &cdr->disposition, 0, NULL);
139 SQLBindParameter(ODBC_stmt, 13, SQL_PARAM_INPUT, SQL_C_SLONG, SQL_INTEGER, 0, 0, &cdr->amaflags, 0, NULL);
140 SQLBindParameter(ODBC_stmt, 14, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(cdr->accountcode), 0, cdr->accountcode, 0, NULL);
143 SQLBindParameter(ODBC_stmt, 15, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(cdr->uniqueid), 0, cdr->uniqueid, 0, NULL);
144 SQLBindParameter(ODBC_stmt, 16, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(cdr->userfield), 0, cdr->userfield, 0, NULL);
148 res = odbc_do_query();
150 if (option_verbose > 10)
151 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Query FAILED Call not logged!\n");
153 if (option_verbose > 10)
154 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Reconnecting to dsn %s\n", dsn);
156 if (option_verbose > 10)
157 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: %s has gone away!\n", dsn);
160 if (option_verbose > 10)
161 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Trying Query again!\n");
162 res = odbc_do_query();
164 if (option_verbose > 10)
165 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Query FAILED Call not logged!\n");
170 if (option_verbose > 10)
171 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Query FAILED Call not logged!\n");
173 SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmt);
174 ast_mutex_unlock(&odbc_lock);
178 char *description(void)
183 static int odbc_unload_module(void)
185 ast_mutex_lock(&odbc_lock);
187 if (option_verbose > 10)
188 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Disconnecting from %s\n", dsn);
189 SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmt);
190 SQLDisconnect(ODBC_con);
191 SQLFreeHandle(SQL_HANDLE_DBC, ODBC_con);
192 SQLFreeHandle(SQL_HANDLE_ENV, ODBC_env);
195 if (option_verbose > 10)
196 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: free dsn\n");
200 if (option_verbose > 10)
201 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: free username\n");
205 if (option_verbose > 10)
206 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: free password\n");
210 if (option_verbose > 10)
211 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: free table\n");
215 ast_cdr_unregister(name);
216 ast_mutex_unlock(&odbc_lock);
220 static int odbc_load_module(void)
223 struct ast_config *cfg;
224 struct ast_variable *var;
227 ast_mutex_lock(&odbc_lock);
229 cfg = ast_config_load(config);
231 ast_log(LOG_WARNING, "cdr_odbc: Unable to load config for ODBC CDR's: %s\n", config);
235 var = ast_variable_browse(cfg, "global");
237 /* nothing configured */
241 tmp = ast_variable_retrieve(cfg,"global","dsn");
243 ast_log(LOG_WARNING,"cdr_odbc: dsn not specified. Assuming asteriskdb\n");
248 ast_log(LOG_ERROR,"cdr_odbc: Out of memory error.\n");
253 tmp = ast_variable_retrieve(cfg,"global","dispositionstring");
255 dispositionstring = ast_true(tmp);
257 dispositionstring = 0;
260 tmp = ast_variable_retrieve(cfg,"global","username");
262 username = strdup(tmp);
263 if (username == NULL) {
264 ast_log(LOG_ERROR,"cdr_odbc: Out of memory error.\n");
270 tmp = ast_variable_retrieve(cfg,"global","password");
272 password = strdup(tmp);
273 if (password == NULL) {
274 ast_log(LOG_ERROR,"cdr_odbc: Out of memory error.\n");
280 tmp = ast_variable_retrieve(cfg,"global","loguniqueid");
282 loguniqueid = ast_true(tmp);
284 ast_log(LOG_DEBUG,"cdr_odbc: Logging uniqueid\n");
286 ast_log(LOG_DEBUG,"cdr_odbc: Not logging uniqueid\n");
289 ast_log(LOG_DEBUG,"cdr_odbc: Not logging uniqueid\n");
293 tmp = ast_variable_retrieve(cfg,"global","usegmtime");
295 usegmtime = ast_true(tmp);
297 ast_log(LOG_DEBUG,"cdr_odbc: Logging in GMT\n");
299 ast_log(LOG_DEBUG,"cdr_odbc: Not logging in GMT\n");
302 ast_log(LOG_DEBUG,"cdr_odbc: Not logging in GMT\n");
306 tmp = ast_variable_retrieve(cfg,"global","table");
308 ast_log(LOG_WARNING,"cdr_odbc: table not specified. Assuming cdr\n");
313 ast_log(LOG_ERROR,"cdr_odbc: Out of memory error.\n");
318 ast_config_destroy(cfg);
319 if (option_verbose > 2) {
320 ast_verbose( VERBOSE_PREFIX_3 "cdr_odbc: dsn is %s\n",dsn);
323 ast_verbose( VERBOSE_PREFIX_3 "cdr_odbc: username is %s\n",username);
324 ast_verbose( VERBOSE_PREFIX_3 "cdr_odbc: password is [secret]\n");
327 ast_verbose( VERBOSE_PREFIX_3 "cdr_odbc: retreiving username and password from odbc config\n");
328 ast_verbose( VERBOSE_PREFIX_3 "cdr_odbc: table is %s\n",table);
333 ast_log(LOG_ERROR, "cdr_odbc: Unable to connect to datasource: %s\n", dsn);
334 if (option_verbose > 2) {
335 ast_verbose( VERBOSE_PREFIX_3 "cdr_odbc: Unable to connect to datasource: %s\n", dsn);
338 res = ast_cdr_register(name, desc, odbc_log);
340 ast_log(LOG_ERROR, "cdr_odbc: Unable to register ODBC CDR handling\n");
343 ast_mutex_unlock(&odbc_lock);
347 static int odbc_do_query(void)
352 char ODBC_msg[200], ODBC_stat[10];
354 ODBC_res = SQLExecute(ODBC_stmt);
356 if ((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO)) {
357 if (option_verbose > 10)
358 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Error in Query %d\n", ODBC_res);
359 SQLGetDiagRec(SQL_HANDLE_DBC, ODBC_con, 1, ODBC_stat, &ODBC_err, ODBC_msg, 100, &ODBC_mlen);
360 SQLFreeHandle(SQL_HANDLE_STMT, ODBC_stmt);
364 if (option_verbose > 10)
365 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Query Successful!\n");
371 static int odbc_init(void)
376 char ODBC_msg[200], ODBC_stat[10];
378 if (ODBC_env == SQL_NULL_HANDLE || connected == 0) {
379 ODBC_res = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &ODBC_env);
380 if ((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO)) {
381 if (option_verbose > 10)
382 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Error AllocHandle\n");
387 ODBC_res = SQLSetEnvAttr(ODBC_env, SQL_ATTR_ODBC_VERSION, (void*)SQL_OV_ODBC3, 0);
389 if ((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO)) {
390 if (option_verbose > 10)
391 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Error SetEnv\n");
392 SQLFreeHandle(SQL_HANDLE_ENV, ODBC_env);
397 ODBC_res = SQLAllocHandle(SQL_HANDLE_DBC, ODBC_env, &ODBC_con);
399 if ((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO)) {
400 if (option_verbose > 10)
401 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Error AllocHDB %d\n", ODBC_res);
402 SQLFreeHandle(SQL_HANDLE_ENV, ODBC_env);
406 SQLSetConnectAttr(ODBC_con, SQL_LOGIN_TIMEOUT, (SQLPOINTER *)10, 0);
409 /* XXX note username and password could be NULL here */
410 ODBC_res = SQLConnect(ODBC_con, (SQLCHAR*)dsn, SQL_NTS, (SQLCHAR*)username, SQL_NTS, (SQLCHAR*)password, SQL_NTS);
412 if ((ODBC_res != SQL_SUCCESS) && (ODBC_res != SQL_SUCCESS_WITH_INFO)) {
413 if (option_verbose > 10)
414 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Error SQLConnect %d\n", ODBC_res);
415 SQLGetDiagRec(SQL_HANDLE_DBC, ODBC_con, 1, ODBC_stat, &ODBC_err, ODBC_msg, 100, &ODBC_mlen);
416 SQLFreeHandle(SQL_HANDLE_ENV, ODBC_env);
420 if (option_verbose > 10)
421 ast_verbose( VERBOSE_PREFIX_4 "cdr_odbc: Connected to %s\n", dsn);
427 int load_module(void)
429 return odbc_load_module();
432 int unload_module(void)
434 return odbc_unload_module();
439 odbc_unload_module();
440 return odbc_load_module();
445 /* Simplistic use count */
446 if (ast_mutex_trylock(&odbc_lock)) {
449 ast_mutex_unlock(&odbc_lock);
456 return ASTERISK_GPL_KEY;