diff options
Diffstat (limited to 'ext/odbc/velocis.c')
| -rw-r--r-- | ext/odbc/velocis.c | 646 |
1 files changed, 646 insertions, 0 deletions
diff --git a/ext/odbc/velocis.c b/ext/odbc/velocis.c new file mode 100644 index 0000000000..0c5b03eab0 --- /dev/null +++ b/ext/odbc/velocis.c @@ -0,0 +1,646 @@ +/* + +----------------------------------------------------------------------+ + | PHP HTML Embedded Scripting Language Version 3.0 | + +----------------------------------------------------------------------+ + | Copyright (c) 1997,1998 PHP Development Team (See Credits file) | + +----------------------------------------------------------------------+ + | This program is free software; you can redistribute it and/or modify | + | it under the terms of one of the following licenses: | + | | + | A) the GNU General Public License as published by the Free Software | + | Foundation; either version 2 of the License, or (at your option) | + | any later version. | + | | + | B) the PHP License as published by the PHP Development Team and | + | included in the distribution in the file: LICENSE | + | | + | This program is distributed in the hope that it will be useful, | + | but WITHOUT ANY WARRANTY; without even the implied warranty of | + | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | + | GNU General Public License for more details. | + | | + | You should have received a copy of both licenses referred to here. | + | If you did not, or have any questions about PHP licensing, please | + | contact core@php.net. | + +----------------------------------------------------------------------+ + | Authors: Nikolay P. Romanyuk <mag@redcom.ru> | + | | + +----------------------------------------------------------------------+ + */ + +/* $Id$ */ + +/* + * TODO: + * velocis_fetch_into(), + * Check all on real life apps. + */ + +#include "php.h" +#include "php3_velocis.h" + +#if HAVE_VELOCIS && !HAVE_UODBC + +function_entry velocis_functions[] = { + {"velocis_connect", php3_velocis_connect, NULL}, + {"velocis_close", php3_velocis_close, NULL}, + {"velocis_exec", php3_velocis_exec, NULL}, + {"velocis_fetch", php3_velocis_fetch, NULL}, + {"velocis_result", php3_velocis_result, NULL}, + {"velocis_freeresult", php3_velocis_freeresult, NULL}, + {"velocis_autocommit", php3_velocis_autocommit, NULL}, + {"velocis_off_autocommit", php3_velocis_off_autocommit, NULL}, + {"velocis_commit", php3_velocis_commit, NULL}, + {"velocis_rollback", php3_velocis_rollback, NULL}, + {"velocis_fieldnum", php3_velocis_fieldnum, NULL}, + {"velocis_fieldname", php3_velocis_fieldname, NULL}, + {NULL, NULL, NULL} +}; + +php3_module_entry velocis_module_entry = { + "Velocis", velocis_functions, php3_minit_velocis, php3_shutdown_velocis, + php3_rinit_velocis, NULL, php3_info_velocis, STANDARD_MODULE_PROPERTIES +}; + + +#if COMPILE_DL +php3_module_entry *get_module() { return &velocis_module_entry; } +#endif + +THREAD_LS velocis_module php3_velocis_module; +THREAD_LS static HENV henv; + +static void _close_velocis_link(VConn *conn) +{ + if ( conn ) { + efree(conn); + } +} + +static void _free_velocis_result(Vresult *res) +{ + if ( res && res->values ) { + register int i; + for ( i=0; i < res->numcols; i++ ) { + if ( res->values[i].value ) + efree(res->values[i].value); + } + efree(res->values); + } + if ( res ) { + efree(res); + } +} + +int php3_minit_velocis(INIT_FUNC_ARGS) +{ + SQLAllocEnv(&henv); + if ( cfg_get_long("velocis.max_links",&php3_velocis_module.max_links) == FAILURE ) { + php3_velocis_module.max_links = -1; + } + php3_velocis_module.num_links = 0; + php3_velocis_module.le_link = register_list_destructors(_close_velocis_link,NULL); + php3_velocis_module.le_result = register_list_destructors(_free_velocis_result,NULL); + + return SUCCESS; +} + +int php3_rinit_velocis(INIT_FUNC_ARGS) +{ + return SUCCESS; +} + + +void php3_info_velocis(void) +{ + php3_printf("RAIMA Velocis Support Active"); +} + +int php3_shutdown_velocis(void) +{ + SQLFreeEnv(henv); + return SUCCESS; +} + +/* Some internal functions. Connections and result manupulate */ + +static int +velocis_add_conn(HashTable *list,VConn *conn,HDBC hdbc) +{ + int ind; + + ind = php3_list_insert(conn,php3_velocis_module.le_link); + conn->hdbc = hdbc; + conn->index = ind; + + return(ind); +} + +static VConn * +velocis_find_conn(HashTable *list,int ind) +{ + VConn *conn; + int type; + + conn = php3_list_find(ind,&type); + if ( !conn || type != php3_velocis_module.le_link ) { + return(NULL); + } + return(conn); +} + +static void +velocis_del_conn(HashTable *list,int ind) +{ + php3_list_delete(ind); +} + +static int +velocis_add_result(HashTable *list,Vresult *res,VConn *conn) +{ + int ind; + + ind = php3_list_insert(res,php3_velocis_module.le_result); + res->conn = conn; + res->index = ind; + + return(ind); +} + +static Vresult * +velocis_find_result(HashTable *list,int ind) +{ + Vresult *res; + int type; + + res = php3_list_find(ind,&type); + if ( !res || type != php3_velocis_module.le_result ) { + return(NULL); + } + return(res); +} + +static void +velocis_del_result(HashTable *list,int ind) +{ + php3_list_delete(ind); +} + +/* Users functions */ + +void php3_velocis_connect(INTERNAL_FUNCTION_PARAMETERS) +{ + pval *serv,*user,*pass; + char *Serv = NULL; + char *User = NULL; + char *Pass = NULL; + RETCODE stat; + HDBC hdbc; + VConn *new; + long ind; + + if ( php3_velocis_module.max_links != -1 && php3_velocis_module.num_links == php3_velocis_module.max_links ) { + php3_error(E_WARNING,"Velocis: Too many open connections (%d)",php3_velocis_module.num_links); + RETURN_FALSE; + } + if ( ARG_COUNT(ht) != 3 || + getParameters(ht,3,&serv,&user,&pass) == FAILURE ) { + WRONG_PARAM_COUNT; + } + convert_to_string(serv); + convert_to_string(user); + convert_to_string(pass); + Serv = serv->value.str.val; + User = user->value.str.val; + Pass = pass->value.str.val; + stat = SQLAllocConnect(henv,&hdbc); + if ( stat != SQL_SUCCESS ) { + php3_error(E_WARNING,"Velocis: Could not allocate connection handle"); + RETURN_FALSE; + } + stat = SQLConnect(hdbc,Serv,SQL_NTS,User,SQL_NTS,Pass,SQL_NTS); + if ( stat != SQL_SUCCESS && stat != SQL_SUCCESS_WITH_INFO ) { + php3_error(E_WARNING,"Velocis: Could not connect to server \"%s\" for %s",Serv,User); + SQLFreeConnect(hdbc); + RETURN_FALSE; + } + new = (VConn *)emalloc(sizeof(VConn)); + if ( new == NULL ) { + php3_error(E_WARNING,"Velocis: Out of memory for store connection"); + SQLFreeConnect(hdbc); + RETURN_FALSE; + } + ind = velocis_add_conn(list,new,hdbc); + php3_velocis_module.num_links++; + RETURN_LONG(ind); +} + +void php3_velocis_close(INTERNAL_FUNCTION_PARAMETERS) +{ + pval *id; + VConn *conn; + + if ( ARG_COUNT(ht) != 1 || getParameters(ht,1,&id) == FAILURE ) { + WRONG_PARAM_COUNT; + } + convert_to_long(id); + conn = velocis_find_conn(list,id->value.lval); + if ( !conn ) { + php3_error(E_WARNING,"Velocis: Not connection index (%d)",id->value.lval); + RETURN_FALSE; + } + SQLDisconnect(conn->hdbc); + SQLFreeConnect(conn->hdbc); + velocis_del_conn(list,id->value.lval); + php3_velocis_module.num_links--; + RETURN_TRUE; +} + +void php3_velocis_exec(INTERNAL_FUNCTION_PARAMETERS) +{ + pval *ind,*exec_str; + char *query = NULL; + int indx; + VConn *conn; + Vresult *res; + RETCODE stat; + SWORD cols,i,colnamelen; + SDWORD rows,coldesc; + + if ( ARG_COUNT(ht) != 2 || getParameters(ht,2,&ind,&exec_str) == FAILURE ) { + WRONG_PARAM_COUNT; + } + convert_to_long(ind); + conn = velocis_find_conn(list,ind->value.lval); + if ( !conn ) { + php3_error(E_WARNING,"Velocis: Not connection index (%d)",ind->value.lval); + RETURN_FALSE; + } + convert_to_string(exec_str); + query = exec_str->value.str.val; + + res = (Vresult *)emalloc(sizeof(Vresult)); + if ( res == NULL ) { + php3_error(E_WARNING,"Velocis: Out of memory for result"); + RETURN_FALSE; + } + stat = SQLAllocStmt(conn->hdbc,&res->hstmt); + if ( stat != SQL_SUCCESS && stat != SQL_SUCCESS_WITH_INFO ) { + php3_error(E_WARNING,"Velocis: SQLAllocStmt return %d",stat); + efree(res); + RETURN_FALSE; + } + stat = SQLExecDirect(res->hstmt,query,SQL_NTS); + if ( stat != SQL_SUCCESS && stat != SQL_SUCCESS_WITH_INFO ) { + php3_error(E_WARNING,"Velocis: Can not execute \"%s\" query",query); + SQLFreeStmt(res->hstmt,SQL_DROP); + efree(res); + RETURN_FALSE; + } + /* Success query */ + stat = SQLNumResultCols(res->hstmt,&cols); + if ( stat != SQL_SUCCESS ) { + php3_error(E_WARNING,"Velocis: SQLNumResultCols return %d",stat); + SQLFreeStmt(res->hstmt,SQL_DROP); + efree(res); + RETURN_FALSE; + } + if ( !cols ) { /* Was INSERT, UPDATE, DELETE, etc. query */ + stat = SQLRowCount(res->hstmt,&rows); + if ( stat != SQL_SUCCESS ) { + php3_error(E_WARNING,"Velocis: SQLNumResultCols return %d",stat); + SQLFreeStmt(res->hstmt,SQL_DROP); + efree(res); + RETURN_FALSE; + } + SQLFreeStmt(res->hstmt,SQL_DROP); + efree(res); + RETURN_LONG(rows); + } else { /* Was SELECT query */ + res->values = (VResVal *)emalloc(sizeof(VResVal)*cols); + if ( res->values == NULL ) { + php3_error(E_WARNING,"Velocis: Out of memory for result columns"); + SQLFreeStmt(res->hstmt,SQL_DROP); + efree(res); + RETURN_FALSE; + } + res->numcols = cols; + for ( i = 0; i < cols; i++ ) { + SQLColAttributes(res->hstmt,i+1,SQL_COLUMN_NAME, + res->values[i].name,sizeof(res->values[i].name), + &colnamelen,NULL); + SQLColAttributes(res->hstmt,i+1,SQL_COLUMN_TYPE, + NULL,0,NULL,&res->values[i].valtype); + switch ( res->values[i].valtype ) { + case SQL_LONGVARBINARY: + case SQL_LONGVARCHAR: + res->values[i].value = NULL; + continue; + default: + break; + } + SQLColAttributes(res->hstmt,i+1,SQL_COLUMN_DISPLAY_SIZE, + NULL,0,NULL,&coldesc); + res->values[i].value = (char *)emalloc(coldesc+1); + if ( res->values[i].value != NULL ) { + SQLBindCol(res->hstmt,i+1,SQL_C_CHAR, + res->values[i].value,coldesc+1, + &res->values[i].vallen); + } + } + } + res->fetched = 0; + indx = velocis_add_result(list,res,conn); + RETURN_LONG(indx); +} + +void php3_velocis_fetch(INTERNAL_FUNCTION_PARAMETERS) +{ + pval *ind; + Vresult *res; + RETCODE stat; + UDWORD row; + UWORD RowStat[1]; + + if ( ARG_COUNT(ht) != 1 || getParameters(ht,1,&ind) == FAILURE ) { + WRONG_PARAM_COUNT; + } + convert_to_long(ind); + res = velocis_find_result(list,ind->value.lval); + if ( !res ) { + php3_error(E_WARNING,"Velocis: Not result index (%d)",ind->value.lval); + RETURN_FALSE; + } + stat = SQLExtendedFetch(res->hstmt,SQL_FETCH_NEXT,1,&row,RowStat); + if ( stat == SQL_NO_DATA_FOUND ) { + SQLFreeStmt(res->hstmt,SQL_DROP); + velocis_del_result(list,ind->value.lval); + RETURN_FALSE; + } + if ( stat != SQL_SUCCESS && stat != SQL_SUCCESS_WITH_INFO ) { + php3_error(E_WARNING,"Velocis: SQLFetch return error"); + SQLFreeStmt(res->hstmt,SQL_DROP); + velocis_del_result(list,ind->value.lval); + RETURN_FALSE; + } + res->fetched = 1; + RETURN_TRUE; +} + +void php3_velocis_result(INTERNAL_FUNCTION_PARAMETERS) +{ + pval *ind,*col; + Vresult *res; + RETCODE stat; + int i,sql_c_type; + UDWORD row; + UWORD RowStat[1]; + SWORD indx = -1; + char *field = NULL; + + if ( ARG_COUNT(ht) != 2 || getParameters(ht,2,&ind,&col) == FAILURE ) { + WRONG_PARAM_COUNT; + } + convert_to_long(ind); + res = velocis_find_result(list,ind->value.lval); + if ( !res ) { + php3_error(E_WARNING,"Velocis: Not result index (%d),ind->value.lval"); + RETURN_FALSE; + } + if ( col->type == IS_STRING ) { + field = col->value.str.val; + } else { + convert_to_long(col); + indx = col->value.lval; + } + if ( field ) { + for ( i = 0; i < res->numcols; i++ ) { + if ( !strcasecmp(res->values[i].name,field)) { + indx = i; + break; + } + } + if ( indx < 0 ) { + php3_error(E_WARNING, "Field %s not found",field); + RETURN_FALSE; + } + } else { + if ( indx < 0 || indx >= res->numcols ) { + php3_error(E_WARNING,"Velocis: Field index not in range"); + RETURN_FALSE; + } + } + if ( !res->fetched ) { + stat = SQLExtendedFetch(res->hstmt,SQL_FETCH_NEXT,1,&row,RowStat); + if ( stat == SQL_NO_DATA_FOUND ) { + SQLFreeStmt(res->hstmt,SQL_DROP); + velocis_del_result(list,ind->value.lval); + RETURN_FALSE; + } + if ( stat != SQL_SUCCESS && stat != SQL_SUCCESS_WITH_INFO ) { + php3_error(E_WARNING,"Velocis: SQLFetch return error"); + SQLFreeStmt(res->hstmt,SQL_DROP); + velocis_del_result(list,ind->value.lval); + RETURN_FALSE; + } + res->fetched = 1; + } + switch ( res->values[indx].valtype ) { + case SQL_LONGVARBINARY: + sql_c_type = SQL_C_BINARY; + goto l1; + case SQL_LONGVARCHAR: + sql_c_type = SQL_C_CHAR; +l1: + if ( !res->values[indx].value ) { + res->values[indx].value = emalloc(4096); + if ( !res->values[indx].value ) { + php3_error(E_WARNING,"Out of memory"); + RETURN_FALSE; + } + } + stat = SQLGetData(res->hstmt,indx+1,sql_c_type, + res->values[indx].value,4095,&res->values[indx].vallen); + if ( stat == SQL_NO_DATA_FOUND ) { + SQLFreeStmt(res->hstmt,SQL_DROP); + velocis_del_result(list,ind->value.lval); + RETURN_FALSE; + } + if ( stat != SQL_SUCCESS && stat != SQL_SUCCESS_WITH_INFO ) { + php3_error(E_WARNING,"Velocis: SQLGetData return error"); + SQLFreeStmt(res->hstmt,SQL_DROP); + velocis_del_result(list,ind->value.lval); + RETURN_FALSE; + } + if ( res->values[indx].valtype == SQL_LONGVARCHAR ) { + RETURN_STRING(res->values[indx].value,TRUE); + } else { + RETURN_LONG((long)res->values[indx].value); + } + default: + if ( res->values[indx].value != NULL ) { + RETURN_STRING(res->values[indx].value,TRUE); + } + } +} + +void php3_velocis_freeresult(INTERNAL_FUNCTION_PARAMETERS) +{ + pval *ind; + Vresult *res; + + if ( ARG_COUNT(ht) != 1 || getParameters(ht,1,&ind) == FAILURE ) { + WRONG_PARAM_COUNT; + } + convert_to_long(ind); + res = velocis_find_result(list,ind->value.lval); + if ( !res ) { + php3_error(E_WARNING,"Velocis: Not result index (%d)",ind->value.lval); + RETURN_FALSE; + } + SQLFreeStmt(res->hstmt,SQL_DROP); + velocis_del_result(list,ind->value.lval); + RETURN_TRUE; +} + +void php3_velocis_autocommit(INTERNAL_FUNCTION_PARAMETERS) +{ + pval *id; + RETCODE stat; + VConn *conn; + + if ( ARG_COUNT(ht) != 1 || getParameters(ht,1,&id) == FAILURE ) { + WRONG_PARAM_COUNT; + } + convert_to_long(id); + conn = velocis_find_conn(list,id->value.lval); + if ( !conn ) { + php3_error(E_WARNING,"Velocis: Not connection index (%d)",id->value.lval); + RETURN_FALSE; + } + stat = SQLSetConnectOption(conn->hdbc,SQL_AUTOCOMMIT,SQL_AUTOCOMMIT_ON); + if ( stat != SQL_SUCCESS && stat != SQL_SUCCESS_WITH_INFO ) { + php3_error(E_WARNING,"Velocis: Set autocommit_on option failure"); + RETURN_FALSE; + } + RETURN_TRUE; +} + +void php3_velocis_off_autocommit(INTERNAL_FUNCTION_PARAMETERS) +{ + pval *id; + RETCODE stat; + VConn *conn; + + if ( ARG_COUNT(ht) != 1 || getParameters(ht,1,&id) == FAILURE ) { + WRONG_PARAM_COUNT; + } + convert_to_long(id); + conn = velocis_find_conn(list,id->value.lval); + if ( !conn ) { + php3_error(E_WARNING,"Velocis: Not connection index (%d)",id->value.lval); + RETURN_FALSE; + } + stat = SQLSetConnectOption(conn->hdbc,SQL_AUTOCOMMIT,SQL_AUTOCOMMIT_OFF); + if ( stat != SQL_SUCCESS && stat != SQL_SUCCESS_WITH_INFO ) { + php3_error(E_WARNING,"Velocis: Set autocommit_off option failure"); + RETURN_FALSE; + } + RETURN_TRUE; +} + +void php3_velocis_commit(INTERNAL_FUNCTION_PARAMETERS) +{ + pval *id; + RETCODE stat; + VConn *conn; + + if ( ARG_COUNT(ht) != 1 || getParameters(ht,1,&id) == FAILURE ) { + WRONG_PARAM_COUNT; + } + convert_to_long(id); + conn = velocis_find_conn(list,id->value.lval); + if ( !conn ) { + php3_error(E_WARNING,"Velocis: Not connection index (%d)",id->value.lval); + RETURN_FALSE; + } + stat = SQLTransact(NULL,conn->hdbc,SQL_COMMIT); + if ( stat != SQL_SUCCESS ) { + php3_error(E_WARNING,"Velocis: Commit failure"); + RETURN_FALSE; + } + RETURN_TRUE; +} + +void php3_velocis_rollback(INTERNAL_FUNCTION_PARAMETERS) +{ + pval *id; + RETCODE stat; + VConn *conn; + + if ( ARG_COUNT(ht) != 1 || getParameters(ht,1,&id) == FAILURE ) { + WRONG_PARAM_COUNT; + } + convert_to_long(id); + conn = velocis_find_conn(list,id->value.lval); + if ( !conn ) { + php3_error(E_WARNING,"Velocis: Not connection index (%d)",id->value.lval); + RETURN_FALSE; + } + stat = SQLTransact(NULL,conn->hdbc,SQL_ROLLBACK); + if ( stat != SQL_SUCCESS ) { + php3_error(E_WARNING,"Velocis: Rollback failure"); + RETURN_FALSE; + } + RETURN_TRUE; +} + +void php3_velocis_fieldname(INTERNAL_FUNCTION_PARAMETERS) +{ + pval *ind,*col; + Vresult *res; + SWORD indx; + + if ( ARG_COUNT(ht) != 2 || getParameters(ht,2,&ind,&col) == FAILURE ) { + WRONG_PARAM_COUNT; + } + convert_to_long(ind); + res = velocis_find_result(list,ind->value.lval); + if ( !res ) { + php3_error(E_WARNING,"Velocis: Not result index (%d),ind->value.lval"); + RETURN_FALSE; + } + convert_to_long(col); + indx = col->value.lval; + if ( indx < 0 || indx >= res->numcols ) { + php3_error(E_WARNING,"Velocis: Field index not in range"); + RETURN_FALSE; + } + RETURN_STRING(res->values[indx].name,TRUE); +} + +void php3_velocis_fieldnum(INTERNAL_FUNCTION_PARAMETERS) +{ + pval *ind; + Vresult *res; + + if ( ARG_COUNT(ht) != 1 || getParameters(ht,1,&ind) == FAILURE ) { + WRONG_PARAM_COUNT; + } + convert_to_long(ind); + res = velocis_find_result(list,ind->value.lval); + if ( !res ) { + php3_error(E_WARNING,"Velocis: Not result index (%d),ind->value.lval"); + RETURN_FALSE; + } + RETURN_LONG(res->numcols); +} + +#endif /* HAVE_VELOCIS */ + +/* + * Local variables: + * tab-width: 4 + * c-basic-offset: 4 + * End: + */ |