kenmirrors/asterisk
1
0
Fork 0
mirror of https://github.com/asterisk/asterisk.git synced 2025-11-16 23:08:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Convert func_odbc to use SQLExecDirect for speed

Browse Source 
(closes issue #10723)
 Reported by: mnicholson
 Patches: 
       func-odbc-direct-execute1.diff uploaded by mnicholson (license 96)
 Tested by: Corydon76, mnicholson, falves11


git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@99018 65c4cc65-6c06-0410-ace0-fbb531ad65f3
This commit is contained in:
Tilghman Lesher
2008-01-18 06:58:35 +00:00
parent 8dd48a5e7c
commit f124988a35
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
funcs/func_odbc.c
View File

@@ -98,7 +98,7 @@ static void odbc_datastore_free(void *data)
ast_free(result); ast_free(result);
} }
static SQLHSTMT generic_prepare(struct odbc_obj *obj, void *data) static SQLHSTMT generic_execute(struct odbc_obj *obj, void *data)
{ {
int res; int res;
char *sql = data; char *sql = data;
@@ -110,9 +110,9 @@ static SQLHSTMT generic_prepare(struct odbc_obj *obj, void *data)
return NULL; return NULL;
} }
res = SQLPrepare(stmt, (unsigned char *)sql, SQL_NTS); res = SQLExecDirect(stmt, (unsigned char *)sql, SQL_NTS);
if ((res != SQL_SUCCESS) && (res != SQL_SUCCESS_WITH_INFO)) { if ((res != SQL_SUCCESS) && (res != SQL_SUCCESS_WITH_INFO)) {
ast_log(LOG_WARNING, "SQL Prepare failed![%s]\n", sql); ast_log(LOG_WARNING, "SQL Exec Direct failed![%s]\n", sql);
SQLCloseCursor(stmt); SQLCloseCursor(stmt);
SQLFreeHandle (SQL_HANDLE_STMT, stmt); SQLFreeHandle (SQL_HANDLE_STMT, stmt);
return NULL; return NULL;
@@ -209,7 +209,7 @@ static int acf_odbc_write(struct ast_channel *chan, const char *cmd, char *s, co
if (!ast_strlen_zero(query->writehandle[dsn])) { if (!ast_strlen_zero(query->writehandle[dsn])) {
obj = ast_odbc_request_obj(query->writehandle[dsn], 0); obj = ast_odbc_request_obj(query->writehandle[dsn], 0);
if (obj) if (obj)
stmt = ast_odbc_prepare_and_execute(obj, generic_prepare, buf); stmt = ast_odbc_direct_execute(obj, generic_execute, buf);
} }
if (stmt) if (stmt)
break; break;
@@ -310,7 +310,7 @@ static int acf_odbc_read(struct ast_channel *chan, const char *cmd, char *s, cha
if (!ast_strlen_zero(query->writehandle[dsn])) { if (!ast_strlen_zero(query->writehandle[dsn])) {
obj = ast_odbc_request_obj(query->writehandle[dsn], 0); obj = ast_odbc_request_obj(query->writehandle[dsn], 0);
if (obj) if (obj)
stmt = ast_odbc_prepare_and_execute(obj, generic_prepare, sql); stmt = ast_odbc_direct_execute(obj, generic_execute, sql);
} }
if (stmt) if (stmt)
break; break;