diff options
author | SVN Migration <svn@php.net> | 2004-01-26 01:59:15 +0000 |
---|---|---|
committer | SVN Migration <svn@php.net> | 2004-01-26 01:59:15 +0000 |
commit | c99a4f4747eac00e5e7fb44eb9e6467e258b30c6 (patch) | |
tree | 99ab150cf56eb6b75e0c0327d0b608e74445df58 /ext/interbase/interbase.c | |
parent | 3507f040622d2267950f26c69b6ac30c1beb94f4 (diff) | |
download | php-git-RELEASE_1_3b6.tar.gz |
This commit was manufactured by cvs2svn to create tag 'RELEASE_1_3b6'.RELEASE_1_3b6
Diffstat (limited to 'ext/interbase/interbase.c')
-rw-r--r-- | ext/interbase/interbase.c | 4542 |
1 files changed, 0 insertions, 4542 deletions
diff --git a/ext/interbase/interbase.c b/ext/interbase/interbase.c deleted file mode 100644 index bcb29c1ee3..0000000000 --- a/ext/interbase/interbase.c +++ /dev/null @@ -1,4542 +0,0 @@ -/* - +----------------------------------------------------------------------+ - | PHP Version 5 | - +----------------------------------------------------------------------+ - | Copyright (c) 1997-2004 The PHP Group | - +----------------------------------------------------------------------+ - | This source file is subject to version 3.0 of the PHP license, | - | that is bundled with this package in the file LICENSE, and is | - | available through the world-wide-web at the following url: | - | http://www.php.net/license/3_0.txt. | - | If you did not receive a copy of the PHP license and are unable to | - | obtain it through the world-wide-web, please send a note to | - | license@php.net so we can mail you a copy immediately. | - +----------------------------------------------------------------------+ - | Authors: Jouni Ahto <jouni.ahto@exdec.fi> | - | Andrew Avdeev <andy@rsc.mv.ru> | - | Ard Biesheuvel <a.k.biesheuvel@its.tudelft.nl> | - +----------------------------------------------------------------------+ - */ - -/* $Id$ */ - -#ifdef HAVE_CONFIG_H -#include "config.h" -#endif - -#include "php.h" - -#define FILE_REVISION "$Revision$" - -#if HAVE_IBASE - -#include "php_ini.h" -#include "ext/standard/php_standard.h" -#include "php_interbase.h" - -#include <time.h> - -#ifndef SQLDA_CURRENT_VERSION -#define SQLDA_CURRENT_VERSION SQLDA_VERSION1 -#endif - -#ifndef SQL_DIALECT_CURRENT -#define SQL_DIALECT_CURRENT 1 /* == SQL_DIALECT_V5 */ - -/* IB < 6 doesn't define these */ -#ifdef PHP_WIN32 -typedef __int64 ISC_INT64; -typedef unsigned __int64 ISC_UINT64; -#else -typedef long long ISC_INT64; -typedef unsigned long long ISC_UINT64; -#endif -#endif - -#ifdef ZEND_DEBUG_ -#define IBDEBUG(a) php_printf("::: %s (%d)\n", a, __LINE__); -#endif - -#ifndef IBDEBUG -#define IBDEBUG(a) -#endif - -#define SAFE_STRING(s) ((s)?(s):"") - -#define ISC_LONG_MIN (-ISC_LONG_MAX - 1) -#define ISC_LONG_MAX 2147483647 - -#ifdef PHP_WIN32 -#define LL_MASK "I64" -#define LL_LIT(lit) lit ## I64 -#ifdef FB_SQLDA -#pragma comment(lib, "fbclient_ms.lib") -#else -#pragma comment(lib, "gds32_ms.lib") -#endif -#else -#define LL_MASK "ll" -#define LL_LIT(lit) lit ## ll -#endif - -#define QUERY_RESULT 1 -#define EXECUTE_RESULT 2 - -#define ROLLBACK 0 -#define COMMIT 1 -#define RETAIN 2 - -#define FETCH_ROW 1 -#define FETCH_ARRAY 2 - -#define BLOB_ID_LEN 18 -#define BLOB_ID_MASK "0x%" LL_MASK "x" - -#define BLOB_INPUT 1 -#define BLOB_OUTPUT 2 - -#define BLOB_CLOSE 1 -#define BLOB_CANCEL 2 - -/* {{{ extension definition structures */ -function_entry ibase_functions[] = { - PHP_FE(ibase_connect, NULL) - PHP_FE(ibase_pconnect, NULL) - PHP_FE(ibase_close, NULL) - PHP_FE(ibase_drop_db, NULL) - PHP_FE(ibase_query, NULL) - PHP_FE(ibase_fetch_row, NULL) - PHP_FE(ibase_fetch_assoc, NULL) - PHP_FE(ibase_fetch_object, NULL) - PHP_FE(ibase_free_result, NULL) - PHP_FE(ibase_name_result, NULL) - PHP_FE(ibase_prepare, NULL) - PHP_FE(ibase_execute, NULL) - PHP_FE(ibase_free_query, NULL) -#if HAVE_STRFTIME - PHP_FE(ibase_timefmt, NULL) -#endif - PHP_FE(ibase_gen_id, NULL) - PHP_FE(ibase_num_fields, NULL) - PHP_FE(ibase_num_params, NULL) -#if abies_0 - PHP_FE(ibase_num_rows, NULL) -#endif - PHP_FE(ibase_affected_rows, NULL) - PHP_FE(ibase_field_info, NULL) - PHP_FE(ibase_param_info, NULL) - - PHP_FE(ibase_trans, NULL) - PHP_FE(ibase_commit, NULL) - PHP_FE(ibase_rollback, NULL) - PHP_FE(ibase_commit_ret, NULL) - - PHP_FE(ibase_blob_info, NULL) - PHP_FE(ibase_blob_create, NULL) - PHP_FE(ibase_blob_add, NULL) - PHP_FE(ibase_blob_cancel, NULL) - PHP_FE(ibase_blob_close, NULL) - PHP_FE(ibase_blob_open, NULL) - PHP_FE(ibase_blob_get, NULL) - PHP_FE(ibase_blob_echo, NULL) - PHP_FE(ibase_blob_import, NULL) - PHP_FE(ibase_errmsg, NULL) - PHP_FE(ibase_errcode, NULL) - -#ifdef SQL_DIALECT_V6 - PHP_FE(ibase_add_user, NULL) - PHP_FE(ibase_modify_user, NULL) - PHP_FE(ibase_delete_user, NULL) - - PHP_FE(ibase_rollback_ret, NULL) -#endif - PHP_FE(ibase_wait_event, NULL) - PHP_FE(ibase_set_event_handler, NULL) - PHP_FE(ibase_free_event_handler, NULL) - {NULL, NULL, NULL} -}; - -zend_module_entry ibase_module_entry = { - STANDARD_MODULE_HEADER, - "interbase", - ibase_functions, - PHP_MINIT(ibase), - PHP_MSHUTDOWN(ibase), - PHP_RINIT(ibase), - PHP_RSHUTDOWN(ibase), - PHP_MINFO(ibase), - NO_VERSION_YET, - STANDARD_MODULE_PROPERTIES -}; - -#ifdef COMPILE_DL_INTERBASE -ZEND_GET_MODULE(ibase) -#define DL_MALLOC(size) malloc(size) -#define DL_STRDUP(str) strdup(str) -#define DL_FREE(ptr) free(ptr) -#else -#define DL_MALLOC(size) emalloc(size) -#define DL_STRDUP(str) estrdup(str) -#define DL_FREE(ptr) efree(ptr) -#endif - -/* True globals, no need for thread safety */ -static int le_blob, le_link, le_plink, le_result, le_query, le_trans, le_event; - -ZEND_DECLARE_MODULE_GLOBALS(ibase) - -/* }}} */ - -/* error handling ---------------------------- */ - -#define IB_STATUS (IBG(status)) - -/* {{{ proto string ibase_errmsg(void) - Return error message */ -PHP_FUNCTION(ibase_errmsg) -{ - if (ZEND_NUM_ARGS() != 0) { - WRONG_PARAM_COUNT; - } - - if (IBG(sql_code) != 0) { - RETURN_STRING(IBG(errmsg), 1); - } - - RETURN_FALSE; -} -/* }}} */ - -/* {{{ proto int ibase_errcode(void) - Return error code */ -PHP_FUNCTION(ibase_errcode) -{ - if (ZEND_NUM_ARGS() != 0) { - WRONG_PARAM_COUNT; - } - - if (IBG(sql_code) != 0) { - RETURN_LONG(IBG(sql_code)); - } - RETURN_FALSE; -} -/* }}} */ - -/* {{{ _php_ibase_error(TSRMLS_D) - print interbase error and save it for ibase_errmsg() */ -static void _php_ibase_error(TSRMLS_D) -{ - char *s = IBG(errmsg); - ISC_STATUS *statusp = IB_STATUS; - - IBG(sql_code) = isc_sqlcode(IB_STATUS); - - while ((s - IBG(errmsg)) < MAX_ERRMSG - (IBASE_MSGSIZE + 2) && isc_interprete(s, &statusp)) { - strcat(IBG(errmsg), " "); - s = IBG(errmsg) + strlen(IBG(errmsg)); - } - - php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s", IBG(errmsg)); -} -/* }}} */ - -/* {{{ _php_ibase_module_error() - print php interbase module error and save it for ibase_errmsg() */ -static void _php_ibase_module_error(char * TSRMLS_DC, ...) PHP_ATTRIBUTE_FORMAT(printf,1,PHP_ATTR_FMT_OFFSET +2); - -static void _php_ibase_module_error(char *msg TSRMLS_DC, ...) -{ - va_list ap; - -#ifdef ZTS - va_start(ap, TSRMLS_C); -#else - va_start(ap, msg); -#endif - - /* vsnprintf NUL terminates the buf and writes at most n-1 chars+NUL */ - vsnprintf(IBG(errmsg), MAX_ERRMSG, msg, ap); - va_end(ap); - - IBG(sql_code) = -999; /* no SQL error */ - - php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s", IBG(errmsg)); -} -/* }}} */ - -/* {{{ internal macros, functions and structures */ - -typedef struct { - isc_db_handle *db_ptr; - long tpb_len; - char *tpb_ptr; -} ISC_TEB; - -typedef struct { - unsigned short vary_length; - char vary_string[1]; -} IBVARY; - -/* Fill ib_link and trans with the correct database link and transaction. - */ -static void _php_ibase_get_link_trans(INTERNAL_FUNCTION_PARAMETERS, zval **link_id, ibase_db_link **ib_link, ibase_trans **trans) -{ - int type; - - IBDEBUG("Transaction or database link?"); - if (zend_list_find(Z_LVAL_PP(link_id), &type)) { - if (type == le_trans) { - /* Transaction resource: make sure it refers to one link only, then - fetch it; database link is stored in ib_trans->db_link[]. */ - IBDEBUG("Type is le_trans"); - ZEND_FETCH_RESOURCE(*trans, ibase_trans *, link_id, -1, "InterBase transaction", le_trans); - if ((*trans)->link_cnt > 1) { - _php_ibase_module_error("Link id is ambiguous: transaction spans multiple connections." TSRMLS_CC); - return; - } - *ib_link = (*trans)->db_link[0]; - return; - } - } - IBDEBUG("Type is le_[p]link or id not found"); - /* Database link resource, use default transaction. */ - *trans = NULL; - ZEND_FETCH_RESOURCE2(*ib_link, ibase_db_link *, link_id, -1, "InterBase link", le_link, le_plink); -} - -#define RESET_ERRMSG { IBG(errmsg)[0] = '\0'; IBG(sql_code) = 0; } - -/* sql variables union - * used for convert and binding input variables - */ -typedef struct { - union { - short sval; - float fval; - ISC_LONG lval; - ISC_QUAD qval; -#ifdef ISC_TIMESTAMP - ISC_TIMESTAMP tsval; - ISC_DATE dtval; - ISC_TIME tmval; -#endif - } val; - short sqlind; -} BIND_BUF; - -static inline int _php_ibase_string_to_quad(char const *id, ISC_QUAD *qd) -{ - /* shortcut for most common case */ - if (sizeof(ISC_QUAD) == sizeof(ISC_UINT64)) { - return sscanf(id, BLOB_ID_MASK, (ISC_UINT64 *) qd); - } else { - ISC_UINT64 res; - if (sscanf(id, BLOB_ID_MASK, &res)) { - qd->gds_quad_high = (ISC_LONG) (res >> 0x20); - qd->gds_quad_low = (ISC_LONG) (res & 0xFFFFFFFF); - return 1; - } - return 0; - } -} - -static inline char *_php_ibase_quad_to_string(ISC_QUAD const qd) -{ - char *result = (char *) emalloc(BLOB_ID_LEN+1); - - /* shortcut for most common case */ - if (sizeof(ISC_QUAD) == sizeof(ISC_UINT64)) { - sprintf(result, BLOB_ID_MASK, *(ISC_UINT64*)(void *) &qd); - } else { - ISC_UINT64 res = ((ISC_UINT64) qd.gds_quad_high << 0x20) | qd.gds_quad_low; - sprintf(result, BLOB_ID_MASK, res); - } - result[BLOB_ID_LEN] = '\0'; - return result; -} - -/* blob information struct */ -typedef struct { - ISC_LONG max_segment; /* Length of longest segment */ - ISC_LONG num_segments; /* Total number of segments */ - ISC_LONG total_length; /* Total length of blob */ - int bl_stream; /* blob is stream ? */ -} IBASE_BLOBINFO; - -/* }}} */ - - -/* destructors ---------------------- */ - -/* {{{ _php_ibase_free_xsqlda() (not actual destructor) - */ -static void _php_ibase_free_xsqlda(XSQLDA *sqlda) -{ - int i; - XSQLVAR *var; - - IBDEBUG("Free XSQLDA?"); - if (sqlda) { - IBDEBUG("Freeing XSQLDA..."); - var = sqlda->sqlvar; - for (i = 0; i < sqlda->sqld; i++, var++) { - efree(var->sqldata); - if (var->sqlind) { - efree(var->sqlind); - } - } - efree(sqlda); - } -} -/* }}} */ - -/* {{{ _php_ibase_commit_link() - */ -static void _php_ibase_commit_link(ibase_db_link *link TSRMLS_DC) -{ - unsigned short i = 0, j; - ibase_tr_list *l; - IBDEBUG("Checking transactions to close..."); - - for (l = link->tr_list; l != NULL; ++i) { - ibase_tr_list *p = l; - if (p->trans != NULL) { - if (i == 0) { - if (p->trans->handle != NULL) { - IBDEBUG("Committing default transaction..."); - if (isc_commit_transaction(IB_STATUS, &p->trans->handle)) { - _php_ibase_error(TSRMLS_C); - } - } - efree(p->trans); /* default transaction is not a registered resource: clean up */ - } - else { - if (p->trans->handle != NULL) { - /* non-default transaction might have been rolled back by other call of this dtor */ - IBDEBUG("Rolling back other transactions..."); - if (isc_rollback_transaction(IB_STATUS, &p->trans->handle)) { - _php_ibase_error(TSRMLS_C); - } - } - /* set this link pointer to NULL in the transaction */ - for (j = 0; j < p->trans->link_cnt; ++j) { - if (p->trans->db_link[j] == link) { - p->trans->db_link[j] = NULL; - break; - } - } - } - } - l = l->next; - efree(p); - } - link->tr_list = NULL; -} -/* }}} */ - -static void php_ibase_commit_link_rsrc(zend_rsrc_list_entry *rsrc TSRMLS_DC) -{ - ibase_db_link *link = (ibase_db_link *) rsrc->ptr; - - _php_ibase_commit_link(link TSRMLS_CC); -} - -/* {{{ _php_ibase_close_link() - */ -static void _php_ibase_close_link(zend_rsrc_list_entry *rsrc TSRMLS_DC) -{ - ibase_db_link *link = (ibase_db_link *) rsrc->ptr; - - _php_ibase_commit_link(link TSRMLS_CC); - if (link->handle != NULL) { - IBDEBUG("Closing normal link..."); - isc_detach_database(IB_STATUS, &link->handle); - } - IBG(num_links)--; - efree(link); -} -/* }}} */ - -/* {{{ _php_ibase_close_plink() - */ -static void _php_ibase_close_plink(zend_rsrc_list_entry *rsrc TSRMLS_DC) -{ - ibase_db_link *link = (ibase_db_link *) rsrc->ptr; - - _php_ibase_commit_link(link TSRMLS_CC); - IBDEBUG("Closing permanent link..."); - if (link->handle != NULL) { - isc_detach_database(IB_STATUS, &link->handle); - } - IBG(num_persistent)--; - IBG(num_links)--; - free(link); -} -/* }}} */ - -/* {{{ _php_ibase_free_result() - */ -static void _php_ibase_free_result(zend_rsrc_list_entry *rsrc TSRMLS_DC) -{ - ibase_result *ib_result = (ibase_result *) rsrc->ptr; - - IBDEBUG("Freeing result by dtor..."); - if (ib_result) { - _php_ibase_free_xsqlda(ib_result->out_sqlda); - if (ib_result->stmt && ib_result->type != EXECUTE_RESULT) { - IBDEBUG("Dropping statement handle (free_result dtor)..."); - isc_dsql_free_statement(IB_STATUS, &ib_result->stmt, DSQL_drop); - } - efree(ib_result); - } -} -/* }}} */ - -/* {{{ _php_ibase_free_query() */ -static void _php_ibase_free_query(ibase_query *ib_query TSRMLS_DC) -{ - IBDEBUG("Freeing query..."); - - if (ib_query->in_sqlda) { - efree(ib_query->in_sqlda); - } - if (ib_query->out_sqlda) { - efree(ib_query->out_sqlda); - } - if (ib_query->stmt) { - IBDEBUG("Dropping statement handle (free_query)..."); - if (isc_dsql_free_statement(IB_STATUS, &ib_query->stmt, DSQL_drop)) { - _php_ibase_error(TSRMLS_C); - } - } - if (ib_query->in_array) { - efree(ib_query->in_array); - } - if (ib_query->out_array) { - efree(ib_query->out_array); - } - if (ib_query->query) { - efree(ib_query->query); - } -} -/* }}} */ - -/* {{{ php_ibase_free_query_rsrc() */ -static void php_ibase_free_query_rsrc(zend_rsrc_list_entry *rsrc TSRMLS_DC) -{ - ibase_query *ib_query = (ibase_query *)rsrc->ptr; - - if (ib_query != NULL) { - IBDEBUG("Preparing to free query by dtor..."); - - _php_ibase_free_query(ib_query TSRMLS_CC); - if (ib_query->statement_type != isc_info_sql_stmt_exec_procedure) { - zend_list_delete(ib_query->result_res_id); - } - efree(ib_query); - } -} -/* }}} */ - -/* {{{ _php_ibase_free_blob() */ -static void _php_ibase_free_blob(zend_rsrc_list_entry *rsrc TSRMLS_DC) -{ - ibase_blob *ib_blob = (ibase_blob *)rsrc->ptr; - - if (ib_blob->bl_handle != NULL) { /* blob open*/ - if (isc_cancel_blob(IB_STATUS, &ib_blob->bl_handle)) { - _php_ibase_module_error("You can lose data. Close any blob after " - "reading from or writing to it. Use ibase_blob_close() before calling ibase_close()" TSRMLS_CC); - } - } - efree(ib_blob); -} -/* }}} */ - -/* {{{ _php_ibase_free_trans() */ -static void _php_ibase_free_trans(zend_rsrc_list_entry *rsrc TSRMLS_DC) -{ - ibase_trans *trans = (ibase_trans *)rsrc->ptr; - unsigned short i; - - IBDEBUG("Cleaning up transaction resource..."); - if (trans->handle != NULL) { - IBDEBUG("Rolling back unhandled transaction..."); - if (isc_rollback_transaction(IB_STATUS, &trans->handle)) { - _php_ibase_error(TSRMLS_C); - } - } - - /* now remove this transaction from all the connection-transaction lists */ - for (i = 0; i < trans->link_cnt; ++i) { - if (trans->db_link[i] != NULL) { - ibase_tr_list **l; - for (l = &trans->db_link[i]->tr_list; *l != NULL; l = &(*l)->next) { - if ( (*l)->trans == trans) { - ibase_tr_list *p = *l; - *l = p->next; - efree(p); - break; - } - } - } - } - efree(trans); -} -/* }}} */ - -/* {{{ _php_ibase_event_free() */ -static void _php_ibase_event_free(char *event_buf, char *result_buf) -{ - isc_free(event_buf); - isc_free(result_buf); -} -/* }}} */ - -/* {{{ _php_ibase_free_event */ -static void _php_ibase_free_event(zend_rsrc_list_entry *rsrc TSRMLS_DC) -{ - ibase_event *event = (ibase_event *) rsrc->ptr; - - IBDEBUG("Cleaning up event resource"); - - zval_dtor(event->callback); - event->callback = NULL; - - if (event->link->handle != NULL) { - if (isc_cancel_events(IB_STATUS, &event->link->handle, &event->event_id)) { - _php_ibase_error(TSRMLS_C); - } - } - _php_ibase_event_free(event->event_buffer,event->result_buffer); -} -/* }}} */ - -/* {{{ startup, shutdown and info functions */ -PHP_INI_BEGIN() - STD_PHP_INI_BOOLEAN("ibase.allow_persistent", "1", PHP_INI_SYSTEM, OnUpdateLong, allow_persistent, zend_ibase_globals, ibase_globals) - STD_PHP_INI_ENTRY_EX("ibase.max_persistent", "-1", PHP_INI_SYSTEM, OnUpdateLong, max_persistent, zend_ibase_globals, ibase_globals, display_link_numbers) - STD_PHP_INI_ENTRY_EX("ibase.max_links", "-1", PHP_INI_SYSTEM, OnUpdateLong, max_links, zend_ibase_globals, ibase_globals, display_link_numbers) - STD_PHP_INI_ENTRY("ibase.default_user", NULL, PHP_INI_ALL, OnUpdateString, default_user, zend_ibase_globals, ibase_globals) - STD_PHP_INI_ENTRY("ibase.default_password", NULL, PHP_INI_ALL, OnUpdateString, default_password, zend_ibase_globals, ibase_globals) - STD_PHP_INI_ENTRY("ibase.timestampformat", "%m/%d/%Y %H:%M:%S", PHP_INI_ALL, OnUpdateString, cfg_timestampformat, zend_ibase_globals, ibase_globals) - STD_PHP_INI_ENTRY("ibase.dateformat", "%m/%d/%Y", PHP_INI_ALL, OnUpdateString, cfg_dateformat, zend_ibase_globals, ibase_globals) - STD_PHP_INI_ENTRY("ibase.timeformat", "%H:%M:%S", PHP_INI_ALL, OnUpdateString, cfg_timeformat, zend_ibase_globals, ibase_globals) -PHP_INI_END() - -static void php_ibase_init_globals(zend_ibase_globals *ibase_globals) -{ - ibase_globals->timestampformat = NULL; - ibase_globals->dateformat = NULL; - ibase_globals->timeformat = NULL; - ibase_globals->num_persistent = 0; - ibase_globals->sql_code = 0; -} - -PHP_MINIT_FUNCTION(ibase) -{ - ZEND_INIT_MODULE_GLOBALS(ibase, php_ibase_init_globals, NULL); - - REGISTER_INI_ENTRIES(); - - le_result = zend_register_list_destructors_ex(_php_ibase_free_result, NULL, "interbase result", module_number); - le_query = zend_register_list_destructors_ex(php_ibase_free_query_rsrc, NULL, "interbase query", module_number); - le_blob = zend_register_list_destructors_ex(_php_ibase_free_blob, NULL, "interbase blob", module_number); - le_link = zend_register_list_destructors_ex(_php_ibase_close_link, NULL, "interbase link", module_number); - le_plink = zend_register_list_destructors_ex(php_ibase_commit_link_rsrc, _php_ibase_close_plink, "interbase link persistent", module_number); - le_trans = zend_register_list_destructors_ex(_php_ibase_free_trans, NULL, "interbase transaction", module_number); - le_event = zend_register_list_destructors_ex(_php_ibase_free_event, NULL, "interbase event", module_number); - - REGISTER_LONG_CONSTANT("IBASE_DEFAULT", PHP_IBASE_DEFAULT, CONST_PERSISTENT); - REGISTER_LONG_CONSTANT("IBASE_TEXT", PHP_IBASE_FETCH_BLOBS, CONST_PERSISTENT); /* deprecated, for BC only */ - REGISTER_LONG_CONSTANT("IBASE_FETCH_BLOBS", PHP_IBASE_FETCH_BLOBS, CONST_PERSISTENT); - REGISTER_LONG_CONSTANT("IBASE_FETCH_ARRAYS", PHP_IBASE_FETCH_ARRAYS, CONST_PERSISTENT); - REGISTER_LONG_CONSTANT("IBASE_UNIXTIME", PHP_IBASE_UNIXTIME, CONST_PERSISTENT); - REGISTER_LONG_CONSTANT("IBASE_TIMESTAMP", PHP_IBASE_TIMESTAMP, CONST_PERSISTENT); - REGISTER_LONG_CONSTANT("IBASE_DATE", PHP_IBASE_DATE, CONST_PERSISTENT); - REGISTER_LONG_CONSTANT("IBASE_TIME", PHP_IBASE_TIME, CONST_PERSISTENT); - /* transactions */ - REGISTER_LONG_CONSTANT("IBASE_WRITE", PHP_IBASE_WRITE, CONST_PERSISTENT); - REGISTER_LONG_CONSTANT("IBASE_READ", PHP_IBASE_READ, CONST_PERSISTENT); - REGISTER_LONG_CONSTANT("IBASE_COMMITTED", PHP_IBASE_COMMITTED, CONST_PERSISTENT); - REGISTER_LONG_CONSTANT("IBASE_CONSISTENCY", PHP_IBASE_CONSISTENCY, CONST_PERSISTENT); - REGISTER_LONG_CONSTANT("IBASE_CONCURRENCY", PHP_IBASE_CONCURRENCY, CONST_PERSISTENT); - REGISTER_LONG_CONSTANT("IBASE_REC_VERSION", PHP_IBASE_REC_VERSION, CONST_PERSISTENT); - REGISTER_LONG_CONSTANT("IBASE_REC_NO_VERSION", PHP_IBASE_REC_NO_VERSION, CONST_PERSISTENT); - REGISTER_LONG_CONSTANT("IBASE_NOWAIT", PHP_IBASE_NOWAIT, CONST_PERSISTENT); - REGISTER_LONG_CONSTANT("IBASE_WAIT", PHP_IBASE_WAIT, CONST_PERSISTENT); - - return SUCCESS; -} - -PHP_RINIT_FUNCTION(ibase) -{ - IBG(default_link)= -1; - IBG(num_links) = IBG(num_persistent); - - if (IBG(timestampformat)) { - DL_FREE(IBG(timestampformat)); - } - IBG(timestampformat) = DL_STRDUP(IBG(cfg_timestampformat)); - - if (IBG(dateformat)) { - DL_FREE(IBG(dateformat)); - } - IBG(dateformat) = DL_STRDUP(IBG(cfg_dateformat)); - - if (IBG(timeformat)) { - DL_FREE(IBG(timeformat)); - } - IBG(timeformat) = DL_STRDUP(IBG(cfg_timeformat)); - - RESET_ERRMSG; - - return SUCCESS; -} - -PHP_MSHUTDOWN_FUNCTION(ibase) -{ -#ifndef PHP_WIN32 - /** - * When the Interbase client API library libgds.so is first loaded, it registers a call to - * gds__cleanup() with atexit(), in order to clean up after itself when the process exits. - * This means that the library is called at process shutdown, and cannot be unloaded beforehand. - * PHP tries to unload modules after every request [dl()'ed modules], and right before the - * process shuts down [modules loaded from php.ini]. This results in a segfault for this module. - * By NULLing the dlopen() handle in the module entry, Zend omits the call to dlclose(), - * ensuring that the module will remain present until the process exits. However, the functions - * and classes exported by the module will not be available until the module is 'reloaded'. - * When reloaded, dlopen() will return the handle of the already loaded module. The module will - * be unloaded automatically when the process exits. - */ - zend_module_entry *ibase_entry; - if (SUCCESS == zend_hash_find(&module_registry, ibase_module_entry.name, strlen(ibase_module_entry.name) +1, (void*) &ibase_entry)) - { - ibase_entry->handle = NULL; - } -#endif - UNREGISTER_INI_ENTRIES(); - return SUCCESS; -} - -PHP_RSHUTDOWN_FUNCTION(ibase) -{ - if (IBG(timestampformat)) { - DL_FREE(IBG(timestampformat)); - } - IBG(timestampformat) = NULL; - - if (IBG(dateformat)) { - DL_FREE(IBG(dateformat)); - } - IBG(dateformat) = NULL; - - if (IBG(timeformat)) { - DL_FREE(IBG(timeformat)); - } - IBG(timeformat) = NULL; - - return SUCCESS; -} - -PHP_MINFO_FUNCTION(ibase) -{ - char tmp[64]; - - php_info_print_table_start(); - php_info_print_table_row(2, "Interbase Support", "enabled"); - -#if (SQLDA_CURRENT_VERSION > 1) || defined(FB_SQLDA) - isc_get_client_version(tmp); - php_info_print_table_row(2, "Client Library", tmp); -#elif (SQL_DIALECT_CURRENT == 1) - php_info_print_table_row(2, "Client Library", "Interbase 5.6 or earlier"); -#elif !defined(DSC_null) - php_info_print_table_row(2, "Client Library", "Interbase 6"); -#else - php_info_print_table_row(2, "Client Library", "Firebird 1.0"); -#endif - - php_info_print_table_row(2, "Revision", FILE_REVISION); -#ifdef COMPILE_DL_INTERBASE - php_info_print_table_row(2, "Dynamic Module", "Yes"); -#endif - php_info_print_table_row(2, "Allow Persistent Links", (IBG(allow_persistent) ? "Yes" : "No")); - - if (IBG(max_persistent) == -1) { - sprintf(tmp, "%ld/unlimited", IBG(num_persistent)); - } else { - sprintf(tmp, "%ld/%ld", IBG(num_persistent), IBG(max_persistent)); - } - php_info_print_table_row(2, "Persistent Links", tmp); - - if (IBG(max_links) == -1) { - sprintf(tmp, "%ld/unlimited", IBG(num_links)); - } else { - sprintf(tmp, "%ld/%ld", IBG(num_links), IBG(max_links)); - } - php_info_print_table_row(2, "Total Links", tmp); - - php_info_print_table_row(2, "Timestamp Format", IBG(timestampformat)); - php_info_print_table_row(2, "Date Format", IBG(dateformat)); - php_info_print_table_row(2, "Time Format", IBG(timeformat)); - - php_info_print_table_end(); -} -/* }}} */ - -/* {{{ _php_ibase_attach_db() */ -static int _php_ibase_attach_db(char *server, char *uname, char *passwd, char *charset, int buffers, char *role, isc_db_handle *db TSRMLS_DC) -{ - char dpb_buffer[256], *dpb, *p; - int dpb_length, len; - - dpb = dpb_buffer; - - *dpb++ = isc_dpb_version1; - - if (uname != NULL && (len = strlen(uname))) { - *dpb++ = isc_dpb_user_name; - *dpb++ = len; - for (p = uname; *p;) { - *dpb++ = *p++; - } - } - - if (passwd != NULL && (len = strlen(passwd))) { - *dpb++ = isc_dpb_password; - *dpb++ = strlen(passwd); - for (p = passwd; *p;) { - *dpb++ = *p++; - } - } - - if (charset != NULL && (len = strlen(charset))) { - *dpb++ = isc_dpb_lc_ctype; - *dpb++ = strlen(charset); - for (p = charset; *p;) { - *dpb++ = *p++; - } - } - - if (buffers) { - *dpb++ = isc_dpb_num_buffers; - *dpb++ = 1; - *dpb++ = buffers; - } - -#ifdef isc_dpb_sql_role_name - if (role != NULL && (len = strlen(role))) { - *dpb++ = isc_dpb_sql_role_name; - *dpb++ = strlen(role); - for (p = role; *p;) { - *dpb++ = *p++; - } - } -#endif - - dpb_length = dpb - dpb_buffer; - - if (isc_attach_database(IB_STATUS, (short) strlen(server), server, db, (short) dpb_length, dpb_buffer)) { - _php_ibase_error(TSRMLS_C); - return FAILURE; - } - return SUCCESS; -} -/* }}} */ - -/* {{{ _php_ibase_connect() */ -static void _php_ibase_connect(INTERNAL_FUNCTION_PARAMETERS, int persistent) -{ - zval ***args; - char *ib_server = NULL, *ib_uname, *ib_passwd, *ib_charset = NULL, *ib_buffers = NULL, *ib_dialect = NULL, *ib_role = NULL; - unsigned short sql_dialect = SQL_DIALECT_CURRENT; - int ib_uname_len, ib_passwd_len; - isc_db_handle db_handle = NULL; - char *hashed_details; - int hashed_details_length = 0; - ibase_db_link *ib_link = NULL; - - RESET_ERRMSG; - - ib_uname = IBG(default_user); - ib_passwd = IBG(default_password); - ib_uname_len = ib_uname ? strlen(ib_uname) : 0; - ib_passwd_len = ib_passwd ? strlen(ib_passwd) : 0; - - if (ZEND_NUM_ARGS() < 1 || ZEND_NUM_ARGS() > 7) { - WRONG_PARAM_COUNT; - } - - args = (zval ***) safe_emalloc(sizeof(zval **), ZEND_NUM_ARGS(), 0); - if (zend_get_parameters_array_ex(ZEND_NUM_ARGS(), args) == FAILURE) { - efree(args); - RETURN_FALSE; - } - - switch (ZEND_NUM_ARGS()) { - unsigned short d; - - case 7: - convert_to_string_ex(args[6]); - ib_role = Z_STRVAL_PP(args[6]); - hashed_details_length += Z_STRLEN_PP(args[6]); - /* fallout */ - case 6: - convert_to_string_ex(args[5]); - ib_dialect = Z_STRVAL_PP(args[5]); - if ((d = (unsigned short)strtoul(ib_dialect, NULL, 10))) - { - sql_dialect = d; - } - hashed_details_length += Z_STRLEN_PP(args[5]); - /* fallout */ - case 5: - convert_to_string_ex(args[4]); - ib_buffers = Z_STRVAL_PP(args[4]); - hashed_details_length += Z_STRLEN_PP(args[4]); - /* fallout */ - case 4: - convert_to_string_ex(args[3]); - ib_charset = Z_STRVAL_PP(args[3]); - hashed_details_length += Z_STRLEN_PP(args[3]); - /* fallout */ - case 3: - convert_to_string_ex(args[2]); - ib_passwd = Z_STRVAL_PP(args[2]); - hashed_details_length += Z_STRLEN_PP(args[2]); - /* fallout */ - case 2: - convert_to_string_ex(args[1]); - ib_uname = Z_STRVAL_PP(args[1]); - hashed_details_length += Z_STRLEN_PP(args[1]); - /* fallout */ - case 1: - convert_to_string_ex(args[0]); - ib_server = Z_STRVAL_PP(args[0]); - hashed_details_length += Z_STRLEN_PP(args[0]); - } /* case */ - - efree(args); - - hashed_details = (char *) emalloc(hashed_details_length + strlen("ibase_%s_%s_%s_%s_%s_%s_%s") + 1); - sprintf(hashed_details, "ibase_%s_%s_%s_%s_%s_%s_%s", SAFE_STRING(ib_server), SAFE_STRING(ib_uname), SAFE_STRING(ib_passwd), SAFE_STRING(ib_charset), SAFE_STRING(ib_buffers), SAFE_STRING(ib_dialect), SAFE_STRING(ib_role)); - - if (persistent) { - list_entry *le; - int open_new_connection = 1; - - if ( (zend_hash_find(&EG(persistent_list), hashed_details, hashed_details_length + 1, (void *) &le) != FAILURE) ) { - static char info[] = {isc_info_base_level, isc_info_end}; - char result[8]; /* Enough? Hope so... */ - - if (Z_TYPE_P(le) != le_plink) { - RETURN_FALSE; - } - /* Check if connection has timed out */ - ib_link = (ibase_db_link *) le->ptr; - if (!isc_database_info(IB_STATUS, &ib_link->handle, sizeof(info), info, sizeof(result), result)) { - open_new_connection = 0; - } - } - - /* There was no previous connection to use or it has timed out */ - if (open_new_connection) { - list_entry new_le; - - if ((IBG(max_links) != -1) && (IBG(num_links) >= IBG(max_links))) { - _php_ibase_module_error("Too many open links (%ld)" TSRMLS_CC, IBG(num_links)); - efree(hashed_details); - RETURN_FALSE; - } - if ((IBG(max_persistent) != -1) && (IBG(num_persistent) >= IBG(max_persistent))) { - _php_ibase_module_error("Too many open persistent links (%ld)" TSRMLS_CC, IBG(num_persistent)); - efree(hashed_details); - RETURN_FALSE; - } - - /* create the ib_link */ - - if (_php_ibase_attach_db(ib_server, ib_uname, ib_passwd, ib_charset, - (ib_buffers ? strtoul(ib_buffers, NULL, 0) : 0), - ib_role, &db_handle TSRMLS_CC) == FAILURE) { - efree(hashed_details); - RETURN_FALSE; - } - - ib_link = (ibase_db_link *) malloc(sizeof(ibase_db_link)); - ib_link->handle = db_handle; - ib_link->dialect = sql_dialect; - ib_link->tr_list = NULL; - - /* hash it up */ - Z_TYPE(new_le) = le_plink; - new_le.ptr = ib_link; - if (zend_hash_update(&EG(persistent_list), hashed_details, hashed_details_length + 1, (void *) &new_le, sizeof(list_entry), NULL) == FAILURE) { - efree(hashed_details); - free(ib_link); - RETURN_FALSE; - } - IBG(num_links)++; - IBG(num_persistent)++; - } - - ZEND_REGISTER_RESOURCE(return_value, ib_link, le_plink); - - } else { - list_entry *index_ptr, new_index_ptr; - - /* first we check the hash for the hashed_details key. if it exists, - * it should point us to the right offset where the actual ib_link sits. - * if it doesn't, open a new ib_link, add it to the resource list, - * and add a pointer to it with hashed_details as the key. - */ - if ( (zend_hash_find(&EG(regular_list), hashed_details, hashed_details_length + 1, (void *) &index_ptr) == SUCCESS) ) { - int type; - long xlink; - void *ptr; - - if (Z_TYPE_P(index_ptr) != le_index_ptr) { - RETURN_FALSE; - } - xlink = (long) index_ptr->ptr; - ptr = zend_list_find(xlink, &type); /* check if the xlink is still there */ - if (ptr && (type == le_link || type == le_plink)) { - zend_list_addref(xlink); - Z_LVAL_P(return_value) = xlink; - Z_TYPE_P(return_value) = IS_RESOURCE; - IBG(default_link) = Z_LVAL_P(return_value); - efree(hashed_details); - return; - } else { - zend_hash_del(&EG(regular_list), hashed_details, hashed_details_length + 1); - } - } - if ((IBG(max_links) != -1) && (IBG(num_links) >= IBG(max_links))) { - _php_ibase_module_error("Too many open links (%ld)" TSRMLS_CC, IBG(num_links)); - efree(hashed_details); - RETURN_FALSE; - } - /* create the ib_link */ - - if (_php_ibase_attach_db(ib_server, ib_uname, ib_passwd, ib_charset, - (ib_buffers ? strtoul(ib_buffers, NULL, 0) : 0), - ib_role, &db_handle TSRMLS_CC) == FAILURE) { - efree(hashed_details); - RETURN_FALSE; - } - - ib_link = (ibase_db_link *) emalloc(sizeof(ibase_db_link)); - ib_link->handle = db_handle; - ib_link->dialect = sql_dialect; - ib_link->tr_list = NULL; - - ZEND_REGISTER_RESOURCE(return_value, ib_link, le_link); - - /* add it to the hash */ - new_index_ptr.ptr = (void *) Z_LVAL_P(return_value); - Z_TYPE(new_index_ptr) = le_index_ptr; - if (zend_hash_update(&EG(regular_list), hashed_details, hashed_details_length + 1, (void *) &new_index_ptr, sizeof(list_entry), NULL) == FAILURE) { - efree(hashed_details); - RETURN_FALSE; - } - IBG(num_links)++; - } - efree(hashed_details); - zend_list_addref(Z_LVAL_P(return_value)); - IBG(default_link) = Z_LVAL_P(return_value); -} -/* }}} */ - -/* {{{ proto resource ibase_connect(string database [, string username [, string password [, string charset [, int buffers [, int dialect [, string role]]]]]]) - Open a connection to an InterBase database */ -PHP_FUNCTION(ibase_connect) -{ - _php_ibase_connect(INTERNAL_FUNCTION_PARAM_PASSTHRU, 0); -} -/* }}} */ - -/* {{{ proto resource ibase_pconnect(string database [, string username [, string password [, string charset [, int buffers [, int dialect [, string role]]]]]]) - Open a persistent connection to an InterBase database */ -PHP_FUNCTION(ibase_pconnect) -{ - _php_ibase_connect(INTERNAL_FUNCTION_PARAM_PASSTHRU, 1); -} -/* }}} */ - -/* {{{ proto bool ibase_close([resource link_identifier]) - Close an InterBase connection */ -PHP_FUNCTION(ibase_close) -{ - zval **link_arg = NULL; - ibase_db_link *ib_link; - int link_id; - - RESET_ERRMSG; - - switch (ZEND_NUM_ARGS()) { - case 0: - link_id = IBG(default_link); - IBG(default_link) = -1; - break; - case 1: - if (zend_get_parameters_ex(1, &link_arg) == FAILURE) { - RETURN_FALSE; - } - convert_to_long_ex(link_arg); - link_id = Z_LVAL_PP(link_arg); - break; - default: - WRONG_PARAM_COUNT; - break; - } - - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, link_arg, link_id, "InterBase link", le_link, le_plink); - zend_list_delete(link_id); - RETURN_TRUE; -} -/* }}} */ - -/* {{{ proto bool ibase_drop_db([resource link_identifier]) - Drop an InterBase database */ -PHP_FUNCTION(ibase_drop_db) -{ - zval **link_arg = NULL; - ibase_db_link *ib_link; - ibase_tr_list *l; - int link_id; - - RESET_ERRMSG; - - switch (ZEND_NUM_ARGS()) { - case 0: - link_id = IBG(default_link); - IBG(default_link) = -1; - break; - case 1: - if (zend_get_parameters_ex(1, &link_arg) == FAILURE) { - RETURN_FALSE; - } - convert_to_long_ex(link_arg); - link_id = Z_LVAL_PP(link_arg); - break; - default: - WRONG_PARAM_COUNT; - break; - } - - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, link_arg, link_id, "InterBase link", le_link, le_plink); - if (isc_drop_database(IB_STATUS, &ib_link->handle)) { - _php_ibase_error(TSRMLS_C); - RETURN_FALSE; - } - - /* isc_drop_database() doesn't invalidate the transaction handles */ - for (l = ib_link->tr_list; l != NULL; l = l->next) { - if (l->trans != NULL) l->trans->handle = NULL; - } - - zend_list_delete(link_id); - RETURN_TRUE; -} -/* }}} */ - -/* {{{ _php_ibase_alloc_array() */ -static int _php_ibase_alloc_array(ibase_array **ib_arrayp, XSQLDA *sqlda, isc_db_handle link, isc_tr_handle trans TSRMLS_DC) -{ -#define IB_ARRAY (*ib_arrayp) - - unsigned short i; - XSQLVAR *var = sqlda->sqlvar; - - IB_ARRAY = safe_emalloc(sizeof(ibase_array), sqlda->sqld, 0); - - for (i = 0; i < sqlda->sqld; i++, var++) { - unsigned short dim; - unsigned long ar_size = 1; - - if ((var->sqltype & ~1) == SQL_ARRAY) { - ISC_ARRAY_DESC *ar_desc = &IB_ARRAY[i].ar_desc; - - if (isc_array_lookup_bounds(IB_STATUS, &link, &trans, var->relname, var->sqlname, ar_desc)) { - _php_ibase_error(TSRMLS_C); - efree(IB_ARRAY); - IB_ARRAY = NULL; - return FAILURE; - } - - switch (ar_desc->array_desc_dtype) { - case blr_text: - case blr_text2: - IB_ARRAY[i].el_type = SQL_TEXT; - IB_ARRAY[i].el_size = ar_desc->array_desc_length; - break; - case blr_short: - IB_ARRAY[i].el_type = SQL_SHORT; - IB_ARRAY[i].el_size = sizeof(short); - break; - case blr_long: - IB_ARRAY[i].el_type = SQL_LONG; - IB_ARRAY[i].el_size = sizeof(ISC_LONG); - break; - case blr_float: - IB_ARRAY[i].el_type = SQL_FLOAT; - IB_ARRAY[i].el_size = sizeof(float); - break; - case blr_double: - IB_ARRAY[i].el_type = SQL_DOUBLE; - IB_ARRAY[i].el_size = sizeof(double); - break; -#ifdef blr_int64 - case blr_int64: - IB_ARRAY[i].el_type = SQL_INT64; - IB_ARRAY[i].el_size = sizeof(ISC_INT64); - break; -#endif -#ifndef blr_timestamp - case blr_date: - IB_ARRAY[i].el_type = SQL_DATE; - IB_ARRAY[i].el_size = sizeof(ISC_QUAD); - break; -#else - case blr_timestamp: - IB_ARRAY[i].el_type = SQL_TIMESTAMP; - IB_ARRAY[i].el_size = sizeof(ISC_TIMESTAMP); - break; - case blr_sql_date: - IB_ARRAY[i].el_type = SQL_TYPE_DATE; - IB_ARRAY[i].el_size = sizeof(ISC_DATE); - break; - case blr_sql_time: - IB_ARRAY[i].el_type = SQL_TYPE_TIME; - IB_ARRAY[i].el_size = sizeof(ISC_TIME); - break; -#endif - case blr_varying: - case blr_varying2: - /** - * IB has a strange way of handling VARCHAR arrays. It doesn't store - * the length in the first short, as with VARCHAR fields. It does, - * however, expect the extra short to be allocated for each element. - */ - IB_ARRAY[i].el_type = SQL_TEXT; - IB_ARRAY[i].el_size = ar_desc->array_desc_length + sizeof(short); - break; - case blr_quad: - case blr_blob_id: - case blr_cstring: - case blr_cstring2: - /** - * These types are mentioned as array types in the manual, but I - * wouldn't know how to create an array field with any of these - * types. I assume these types are not applicable to arrays, and - * were mentioned erroneously. - */ - default: - _php_ibase_module_error("Unsupported array type %d in relation '%s' column '%s'" TSRMLS_CC, ar_desc->array_desc_dtype, var->relname, var->sqlname); - efree(IB_ARRAY); - IB_ARRAY = NULL; - return FAILURE; - } /* switch array_desc_type */ - - /* calculate elements count */ - for (dim = 0; dim < ar_desc->array_desc_dimensions; dim++) { - ar_size *= 1 + ar_desc->array_desc_bounds[dim].array_bound_upper - ar_desc->array_desc_bounds[dim].array_bound_lower; - } - IB_ARRAY[i].ar_size = IB_ARRAY[i].el_size * ar_size; - } /* if SQL_ARRAY */ - } /* for column */ - return SUCCESS; -#undef IB_ARRAY -} -/* }}} */ - -/* {{{ _php_ibase_alloc_query() */ -/* allocate and prepare query */ -static int _php_ibase_alloc_query(ibase_query *ib_query, ibase_db_link *link, ibase_trans *trans, char *query, unsigned short dialect, int trans_res_id TSRMLS_DC) -{ - static char info_type[] = {isc_info_sql_stmt_type}; - char result[8]; - - ib_query->link = link; - ib_query->trans = trans; - ib_query->result_res_id = 0; - ib_query->stmt = NULL; - ib_query->in_array = NULL; - ib_query->out_array = NULL; - ib_query->dialect = dialect; - ib_query->query = estrdup(query); - ib_query->trans_res_id = trans_res_id; - - if (isc_dsql_allocate_statement(IB_STATUS, &link->handle, &ib_query->stmt)) { - _php_ibase_error(TSRMLS_C); - goto _php_ibase_alloc_query_error; - } - - ib_query->out_sqlda = (XSQLDA *) emalloc(XSQLDA_LENGTH(1)); - ib_query->out_sqlda->sqln = 1; - ib_query->out_sqlda->version = SQLDA_CURRENT_VERSION; - - if (isc_dsql_prepare(IB_STATUS, &ib_query->trans->handle, &ib_query->stmt, 0, query, dialect, ib_query->out_sqlda)) { - _php_ibase_error(TSRMLS_C); - goto _php_ibase_alloc_query_error; - } - - /* find out what kind of statement was prepared */ - if (isc_dsql_sql_info(IB_STATUS, &ib_query->stmt, sizeof(info_type), info_type, sizeof(result), result)) { - _php_ibase_error(TSRMLS_C); - goto _php_ibase_alloc_query_error; - } - ib_query->statement_type = result[3]; - - /* not enough output variables ? */ - if (ib_query->out_sqlda->sqld > ib_query->out_sqlda->sqln) { - ib_query->out_sqlda = erealloc(ib_query->out_sqlda, XSQLDA_LENGTH(ib_query->out_sqlda->sqld)); - ib_query->out_sqlda->sqln = ib_query->out_sqlda->sqld; - ib_query->out_sqlda->version = SQLDA_CURRENT_VERSION; - if (isc_dsql_describe(IB_STATUS, &ib_query->stmt, SQLDA_CURRENT_VERSION, ib_query->out_sqlda)) { - _php_ibase_error(TSRMLS_C); - goto _php_ibase_alloc_query_error; - } - } - - /* maybe have input placeholders? */ - ib_query->in_sqlda = emalloc(XSQLDA_LENGTH(1)); - ib_query->in_sqlda->sqln = 1; - ib_query->in_sqlda->version = SQLDA_CURRENT_VERSION; - if (isc_dsql_describe_bind(IB_STATUS, &ib_query->stmt, SQLDA_CURRENT_VERSION, ib_query->in_sqlda)) { - _php_ibase_error(TSRMLS_C); - goto _php_ibase_alloc_query_error; - } - - /* not enough input variables ? */ - if (ib_query->in_sqlda->sqln < ib_query->in_sqlda->sqld) { - ib_query->in_sqlda = erealloc(ib_query->in_sqlda, XSQLDA_LENGTH(ib_query->in_sqlda->sqld)); - ib_query->in_sqlda->sqln = ib_query->in_sqlda->sqld; - ib_query->in_sqlda->version = SQLDA_CURRENT_VERSION; - if (isc_dsql_describe_bind(IB_STATUS, &ib_query->stmt, SQLDA_CURRENT_VERSION, ib_query->in_sqlda)) { - _php_ibase_error(TSRMLS_C); - goto _php_ibase_alloc_query_error; - } - } - - /* no, haven't placeholders at all */ - if (ib_query->in_sqlda->sqld == 0) { - efree(ib_query->in_sqlda); - ib_query->in_sqlda = NULL; - } else if (_php_ibase_alloc_array(&ib_query->in_array, ib_query->in_sqlda, link->handle, trans->handle TSRMLS_CC) == FAILURE) { - goto _php_ibase_alloc_query_error; - } - - if (ib_query->out_sqlda->sqld == 0) { - efree(ib_query->out_sqlda); - ib_query->out_sqlda = NULL; - } else if (_php_ibase_alloc_array(&ib_query->out_array, ib_query->out_sqlda, link->handle, trans->handle TSRMLS_CC) == FAILURE) { - goto _php_ibase_alloc_query_error; - } - - return SUCCESS; - -_php_ibase_alloc_query_error: - - if (ib_query->out_sqlda) { - efree(ib_query->out_sqlda); - } - if (ib_query->in_sqlda) { - efree(ib_query->in_sqlda); - } - if (ib_query->out_array) { - efree(ib_query->out_array); - } - if (ib_query->query) { - efree(ib_query->query); - } - return FAILURE; -} -/* }}} */ - -/* ((( _php_ibase_blob_add */ -static int _php_ibase_blob_add(zval **string_arg, ibase_blob *ib_blob TSRMLS_DC) -{ - unsigned long put_cnt = 0, rem_cnt; - unsigned short chunk_size; - - convert_to_string_ex(string_arg); - - for (rem_cnt = Z_STRLEN_PP(string_arg); rem_cnt > 0; rem_cnt -= chunk_size) { - - chunk_size = rem_cnt > USHRT_MAX ? USHRT_MAX : (unsigned short)rem_cnt; - - if (isc_put_segment(IB_STATUS, &ib_blob->bl_handle, chunk_size, &Z_STRVAL_PP(string_arg)[put_cnt] )) { - _php_ibase_error(TSRMLS_C); - return FAILURE; - } - put_cnt += chunk_size; - } - return SUCCESS; -} -/* }}} */ - -/* {{{ _php_ibase_bind_array() */ -static int _php_ibase_bind_array(zval *val, char *buf, unsigned long buf_size, ibase_array *array, int dim TSRMLS_DC) -{ - zval null_val, *pnull_val = &null_val; - int u_bound = array->ar_desc.array_desc_bounds[dim].array_bound_upper, - l_bound = array->ar_desc.array_desc_bounds[dim].array_bound_lower, - dim_len = 1 + u_bound - l_bound; - - ZVAL_NULL(pnull_val); - - if (dim < array->ar_desc.array_desc_dimensions) { - unsigned long slice_size = buf_size / dim_len; - unsigned short i; - zval **subval = &val; - - if (Z_TYPE_P(val) == IS_ARRAY) { - zend_hash_internal_pointer_reset(Z_ARRVAL_P(val)); - } - - for (i = 0; i < dim_len; ++i) { - - if (Z_TYPE_P(val) == IS_ARRAY && - zend_hash_get_current_data(Z_ARRVAL_P(val), (void *) &subval) == FAILURE) - { - subval = &pnull_val; - } - - if (_php_ibase_bind_array(*subval, buf, slice_size, array, dim + 1 TSRMLS_CC) == FAILURE) - { - return FAILURE; - } - buf += slice_size; - - if (Z_TYPE_P(val) == IS_ARRAY) { - zend_hash_move_forward(Z_ARRVAL_P(val)); - } - } - - if (Z_TYPE_P(val) == IS_ARRAY) { - zend_hash_internal_pointer_reset(Z_ARRVAL_P(val)); - } - - } else { - /* expect a single value */ - if (Z_TYPE_P(val) == IS_NULL) { - memset(buf, 0, buf_size); - } else if (array->ar_desc.array_desc_scale < 0) { - - /* no coercion for array types */ - double l; - - convert_to_double(val); - - if (Z_DVAL_P(val) > 0) { - l = Z_DVAL_P(val) * pow(10, -array->ar_desc.array_desc_scale) + .5; - } else { - l = Z_DVAL_P(val) * pow(10, -array->ar_desc.array_desc_scale) - .5; - } - - switch (array->el_type) { - case SQL_SHORT: - if (l > SHRT_MAX || l < SHRT_MIN) { - _php_ibase_module_error("Array parameter exceeds field width" TSRMLS_CC); - return FAILURE; - } - *(short*) buf = (short) l; - break; - case SQL_LONG: - if (l > ISC_LONG_MAX || l < ISC_LONG_MIN) { - _php_ibase_module_error("Array parameter exceeds field width" TSRMLS_CC); - return FAILURE; - } - *(ISC_LONG*) buf = (ISC_LONG) l; - break; -#ifdef SQL_INT64 - case SQL_INT64: - { - long double l; - - convert_to_string(val); - - if (!sscanf(Z_STRVAL_P(val), "%" LL_MASK "f", &l)) { - _php_ibase_module_error("Cannot convert '%s' to long double" TSRMLS_CC, Z_STRVAL_P(val)); - return FAILURE; - } - - if (l > 0) { - *(ISC_INT64 *) buf = (ISC_INT64) (l * pow(10, -array->ar_desc.array_desc_scale) + .5); - } else { - *(ISC_INT64 *) buf = (ISC_INT64) (l * pow(10, -array->ar_desc.array_desc_scale) - .5); - } - } - break; -#endif - } - } else { - struct tm t = { 0, 0, 0, 0, 0, 0 }; - - switch (array->el_type) { - unsigned short n; - - case SQL_SHORT: - convert_to_long(val); - if (Z_LVAL_P(val) > SHRT_MAX || Z_LVAL_P(val) < SHRT_MIN) { - _php_ibase_module_error("Array parameter exceeds field width" TSRMLS_CC); - return FAILURE; - } - *(short *) buf = (short) Z_LVAL_P(val); - break; - case SQL_LONG: - convert_to_long(val); -#if (SIZEOF_LONG > 4) - if (Z_LVAL_P(val) > ISC_LONG_MAX || Z_LVAL_P(val) < ISC_LONG_MIN) { - _php_ibase_module_error("Array parameter exceeds field width" TSRMLS_CC); - return FAILURE; - } -#endif - *(ISC_LONG *) buf = (ISC_LONG) Z_LVAL_P(val); - break; -#ifdef SQL_INT64 - case SQL_INT64: -#if (SIZEOF_LONG >= 8) - convert_to_long(val); - *(long *) buf = Z_LVAL_P(val); -#else - { - ISC_INT64 l; - - convert_to_string(val); - if (!sscanf(Z_STRVAL_P(val), "%" LL_MASK "d", &l)) { - _php_ibase_module_error("Cannot convert '%s' to long integer" TSRMLS_CC, Z_STRVAL_P(val)); - return FAILURE; - } else { - *(ISC_INT64 *) buf = l; - } - } -#endif - break; -#endif - case SQL_FLOAT: - convert_to_double(val); - *(float*) buf = (float) Z_DVAL_P(val); - break; - case SQL_DOUBLE: - convert_to_double(val); - *(double*) buf = Z_DVAL_P(val); - break; -#ifndef SQL_TIMESTAMP - case SQL_DATE: -#else - case SQL_TIMESTAMP: -#endif - convert_to_string(val); -#ifdef HAVE_STRPTIME - strptime(Z_STRVAL_P(val), IBG(timestampformat), &t); -#else - n = sscanf(Z_STRVAL_P(val), "%d%*[/]%d%*[/]%d %d%*[:]%d%*[:]%d", &t.tm_mon, &t.tm_mday, &t.tm_year, &t.tm_hour, &t.tm_min, &t.tm_sec); - - if (n != 3 && n != 6) { - _php_ibase_module_error("Invalid date/time format (expected 3 or 6 fields, got %d. Use format 'm/d/Y H:i:s'. You gave '%s')" TSRMLS_CC, n, Z_STRVAL_P(val)); - return FAILURE; - } - t.tm_year -= 1900; - t.tm_mon--; -#endif -#ifndef SQL_TIMESTAMP - isc_encode_date(&t, (ISC_QUAD *) buf); - break; -#else - isc_encode_timestamp(&t, (ISC_TIMESTAMP * ) buf); - break; - case SQL_TYPE_DATE: - convert_to_string(val); -#ifdef HAVE_STRPTIME - strptime(Z_STRVAL_P(val), IBG(dateformat), &t); -#else - n = sscanf(Z_STRVAL_P(val), "%d%*[/]%d%*[/]%d", &t.tm_mon, &t.tm_mday, &t.tm_year); - - if (n != 3) { - _php_ibase_module_error("Invalid date format (expected 3 fields, got %d. Use format 'm/d/Y' You gave '%s')" TSRMLS_CC, n, Z_STRVAL_P(val)); - return FAILURE; - } - t.tm_year -= 1900; - t.tm_mon--; -#endif - isc_encode_sql_date(&t, (ISC_DATE *) buf); - break; - case SQL_TYPE_TIME: - convert_to_string(val); -#ifdef HAVE_STRPTIME - strptime(Z_STRVAL_P(val), IBG(timeformat), &t); -#else - n = sscanf(Z_STRVAL_P(val), "%d%*[:]%d%*[:]%d", &t.tm_hour, &t.tm_min, &t.tm_sec); - - if (n != 3) { - _php_ibase_module_error("Invalid time format (expected 3 fields, got %d. Use format 'H:i:s'. You gave '%s')" TSRMLS_CC, n, Z_STRVAL_P(val)); - return FAILURE; - } -#endif - isc_encode_sql_time(&t, (ISC_TIME *) buf); - break; -#endif - default: - convert_to_string(val); - strncpy(buf, Z_STRVAL_P(val), array->el_size); - buf[array->el_size-1] = '\0'; - } - } - } - return SUCCESS; -} -/* }}} */ - -/* {{{ _php_ibase_bind() - Bind parameter placeholders in a previously prepared query */ -static int _php_ibase_bind(XSQLDA *sqlda, zval **b_vars, BIND_BUF *buf, ibase_query *ib_query TSRMLS_DC) -{ - int i, rv = SUCCESS; - XSQLVAR *var = sqlda->sqlvar; - - for (i = 0; i < sqlda->sqld; ++var, ++i) { /* bound vars */ - - zval *b_var = b_vars[i]; - - var->sqlind = &buf[i].sqlind; - - if (Z_TYPE_P(b_var) == IS_NULL) { - buf[i].sqlind = -1; - } else { - buf[i].sqlind = 0; - - if (var->sqlscale < 0) { - /* - DECIMAL or NUMERIC field are stored internally as scaled integers. - Coerce it to string and let InterBase's internal routines handle it. - */ - var->sqltype = SQL_TEXT; - } - - switch (var->sqltype & ~1) { - case SQL_SHORT: - convert_to_long(b_var); - if (Z_LVAL_P(b_var) > SHRT_MAX || Z_LVAL_P(b_var) < SHRT_MIN) { - _php_ibase_module_error("Parameter %d exceeds field width" TSRMLS_CC, i+1); - rv = FAILURE; - } - buf[i].val.sval = (short) Z_LVAL_P(b_var); - var->sqldata = (void *) &buf[i].val.sval; - break; - case SQL_LONG: - convert_to_long(b_var); -#if (SIZEOF_LONG > 4) - /* ISC_LONG is always 32-bit */ - if (Z_LVAL_P(b_var) > ISC_LONG_MAX || Z_LVAL_P(b_var) < ISC_LONG_MIN) { - _php_ibase_module_error("Parameter %d exceeds field width" TSRMLS_CC, i+1); - rv = FAILURE; - } -#endif - buf[i].val.lval = (ISC_LONG) Z_LVAL_P(b_var); - var->sqldata = (void *) &buf[i].val.lval; - break; -#if defined(SQL_INT64) && (SIZEOF_LONG == 8) - case SQL_INT64: - convert_to_long(b_var); - var->sqldata = (void *) &Z_LVAL_P(b_var); - break; -#endif - case SQL_FLOAT: - convert_to_double(b_var); - buf[i].val.fval = (float) Z_DVAL_P(b_var); - var->sqldata = (void *) &buf[i].val.fval; - break; - case SQL_DOUBLE: - convert_to_double(b_var); - var->sqldata = (void *) &Z_DVAL_P(b_var); - break; -#ifndef SQL_TIMESTAMP - case SQL_DATE: - convert_to_string(b_var); - { - struct tm t; -#ifdef HAVE_STRPTIME - strptime(Z_STRVAL_P(b_var), IBG(timestampformat), &t); -#else - /* Parsing doesn't seem to happen with older versions... */ - int n; - - t.tm_year = t.tm_mon = t.tm_mday = t.tm_hour = t.tm_min = t.tm_sec = 0; - - n = sscanf(Z_STRVAL_P(b_var), "%d%*[/]%d%*[/]%d %d%*[:]%d%*[:]%d", &t.tm_mon, &t.tm_mday, &t.tm_year, &t.tm_hour, &t.tm_min, &t.tm_sec); - - if (n != 3 && n != 6) { - _php_ibase_module_error("Parameter %d: invalid date/time format (expected 3 or 6 fields, got %d. Use format m/d/Y H:i:s. You gave '%s')" TSRMLS_CC, i+1, n, Z_STRVAL_P(b_var)); - rv = FAILURE; - } - t.tm_year -= 1900; - t.tm_mon--; -#endif - isc_encode_date(&t, &buf[i].val.qval); - var->sqldata = (void *) (&buf[i].val.qval); - } -#else -#ifdef HAVE_STRPTIME - case SQL_TIMESTAMP: - case SQL_TYPE_DATE: - case SQL_TYPE_TIME: - { - struct tm t; - - convert_to_string(b_var); - - switch (var->sqltype & ~1) { - case SQL_TIMESTAMP: - strptime(Z_STRVAL_P(b_var), IBG(timestampformat), &t); - isc_encode_timestamp(&t, &buf[i].val.tsval); - var->sqldata = (void *) (&buf[i].val.tsval); - break; - case SQL_TYPE_DATE: - strptime(Z_STRVAL_P(b_var), IBG(dateformat), &t); - isc_encode_sql_date(&t, &buf[i].val.dtval); - var->sqldata = (void *) (&buf[i].val.dtval); - break; - case SQL_TYPE_TIME: - strptime(Z_STRVAL_P(b_var), IBG(timeformat), &t); - isc_encode_sql_time(&t, &buf[i].val.tmval); - var->sqldata = (void *) (&buf[i].val.tmval); - break; - } - } -#endif -#endif - break; - case SQL_BLOB: - - convert_to_string(b_var); - - if (Z_STRLEN_P(b_var) != BLOB_ID_LEN || - !_php_ibase_string_to_quad(Z_STRVAL_P(b_var), &buf[i].val.qval)) { - - ibase_blob ib_blob = { NULL, {0, 0}, BLOB_INPUT }; - - if (isc_create_blob(IB_STATUS, &ib_query->link->handle, &ib_query->trans->handle, &ib_blob.bl_handle, &ib_blob.bl_qd)) { - _php_ibase_error(TSRMLS_C); - return FAILURE; - } - - if (_php_ibase_blob_add(&b_var, &ib_blob TSRMLS_CC) != SUCCESS) { - return FAILURE; - } - - if (isc_close_blob(IB_STATUS, &ib_blob.bl_handle)) { - _php_ibase_error(TSRMLS_C); - return FAILURE; - } - buf[i].val.qval = ib_blob.bl_qd; - } - var->sqldata = (void *) &buf[i].val.qval; - break; - case SQL_ARRAY: - if (Z_TYPE_P(b_var) != IS_ARRAY) { - convert_to_string(b_var); - - if (Z_STRLEN_P(b_var) != BLOB_ID_LEN || - !_php_ibase_string_to_quad(Z_STRVAL_P(b_var), &buf[i].val.qval)) { - - _php_ibase_module_error("Parameter %d: invalid array ID" TSRMLS_CC,i+1); - rv = FAILURE; - } - } else { - /* convert the array data into something IB can understand */ - void *array_data = emalloc(ib_query->in_array[i].ar_size); - ISC_QUAD array_id = { 0, 0 }; - - if (_php_ibase_bind_array(b_var, array_data, ib_query->in_array[i].ar_size, - &ib_query->in_array[i], 0 TSRMLS_CC) == FAILURE) - { - _php_ibase_module_error("Parameter %d: failed to bind array argument" TSRMLS_CC,i+1); - efree(array_data); - rv = FAILURE; - break; - } - - if (isc_array_put_slice(IB_STATUS, - &ib_query->link->handle, - &ib_query->trans->handle, - &array_id, - &ib_query->in_array[i].ar_desc, - array_data, - &ib_query->in_array[i].ar_size)) - { - _php_ibase_error(TSRMLS_C); - efree(array_data); - return FAILURE; - } - buf[i].val.qval = array_id; - efree(array_data); - } - var->sqldata = (void *) &buf[i].val.qval; - break; - default: - convert_to_string(b_var); - var->sqldata = Z_STRVAL_P(b_var); - var->sqllen = Z_STRLEN_P(b_var); - var->sqltype = SQL_TEXT; - } /* switch */ - } /* if */ - } /* for */ - return rv; -} -/* }}} */ - -/* {{{ _php_ibase_alloc_xsqlda() */ -static void _php_ibase_alloc_xsqlda(XSQLDA *sqlda) -{ - int i; - XSQLVAR *var = sqlda->sqlvar; - - for (i = 0; i < sqlda->sqld; i++, var++) { - switch (var->sqltype & ~1) { - case SQL_TEXT: - var->sqldata = safe_emalloc(sizeof(char), (var->sqllen), 0); - break; - case SQL_VARYING: - var->sqldata = safe_emalloc(sizeof(char), (var->sqllen + sizeof(short)), 0); - break; - case SQL_SHORT: - var->sqldata = emalloc(sizeof(short)); - break; - case SQL_LONG: - var->sqldata = emalloc(sizeof(ISC_LONG)); - break; - case SQL_FLOAT: - var->sqldata = emalloc(sizeof(float)); - break; - case SQL_DOUBLE: - var->sqldata = emalloc(sizeof(double)); - break; -#ifdef SQL_INT64 - case SQL_INT64: - var->sqldata = emalloc(sizeof(ISC_INT64)); - break; -#endif -#ifdef SQL_TIMESTAMP - case SQL_TIMESTAMP: - var->sqldata = emalloc(sizeof(ISC_TIMESTAMP)); - break; - case SQL_TYPE_DATE: - var->sqldata = emalloc(sizeof(ISC_DATE)); - break; - case SQL_TYPE_TIME: - var->sqldata = emalloc(sizeof(ISC_TIME)); - break; -#else - case SQL_DATE: -#endif - case SQL_BLOB: - case SQL_ARRAY: - var->sqldata = emalloc(sizeof(ISC_QUAD)); - break; - } /* switch */ - - if (var->sqltype & 1) { /* sql NULL flag */ - var->sqlind = emalloc(sizeof(short)); - } else { - var->sqlind = NULL; - } - } /* for */ -} -/* }}} */ - -/* {{{ _php_ibase_exec() */ -static int _php_ibase_exec(INTERNAL_FUNCTION_PARAMETERS, ibase_result **ib_resultp, ibase_query *ib_query, int argc, zval **args) -{ -#define IB_RESULT (*ib_resultp) - XSQLDA *in_sqlda = NULL, *out_sqlda = NULL; - BIND_BUF *bind_buf = NULL; - int rv = FAILURE; - static char info_count[] = {isc_info_sql_records}; - char result[64]; - ISC_STATUS isc_result; - - RESET_ERRMSG; - - if (argc > 0 && args != NULL) { - SEPARATE_ZVAL(args); - } - - switch (ib_query->statement_type) { - isc_tr_handle tr; - ibase_tr_list **l; - ibase_trans *trans; - - case isc_info_sql_stmt_start_trans: - - /* a SET TRANSACTION statement should be executed with a NULL trans handle */ - tr = NULL; - - if (isc_dsql_execute_immediate(IB_STATUS, &ib_query->link->handle, &tr, 0, ib_query->query, ib_query->dialect, NULL)) { - _php_ibase_error(TSRMLS_C); - goto _php_ibase_exec_error; - } - - trans = (ibase_trans *) emalloc(sizeof(ibase_trans)); - trans->handle = tr; - trans->link_cnt = 1; - trans->affected_rows = 0; - trans->db_link[0] = ib_query->link; - - if (ib_query->link->tr_list == NULL) { - ib_query->link->tr_list = (ibase_tr_list *) emalloc(sizeof(ibase_tr_list)); - ib_query->link->tr_list->trans = NULL; - ib_query->link->tr_list->next = NULL; - } - - /* link the transaction into the connection-transaction list */ - for (l = &ib_query->link->tr_list; *l != NULL; l = &(*l)->next); - *l = (ibase_tr_list *) emalloc(sizeof(ibase_tr_list)); - (*l)->trans = trans; - (*l)->next = NULL; - - ZEND_REGISTER_RESOURCE(return_value, trans, le_trans); - - return SUCCESS; - - case isc_info_sql_stmt_commit: - case isc_info_sql_stmt_rollback: - - if (isc_dsql_execute_immediate(IB_STATUS, &ib_query->link->handle, &ib_query->trans->handle, 0, ib_query->query, ib_query->dialect, NULL)) { - _php_ibase_error(TSRMLS_C); - goto _php_ibase_exec_error; - } - - if (ib_query->trans->handle == NULL && ib_query->trans_res_id != 0) { - /* transaction was released by the query and was a registered resource, - so we have to release it */ - zend_list_delete(ib_query->trans_res_id); - } - - return SUCCESS; - - default: - - RETVAL_BOOL(1); - } - - /* allocate sqlda and output buffers */ - if (ib_query->out_sqlda) { /* output variables in select, select for update */ - IBDEBUG("Query wants XSQLDA for output"); - IB_RESULT = emalloc(sizeof(ibase_result) + sizeof(ibase_array) * (ib_query->out_sqlda->sqld-1)); - IB_RESULT->link = ib_query->link; - IB_RESULT->trans = ib_query->trans; - IB_RESULT->stmt = ib_query->stmt; - IB_RESULT->statement_type = ib_query->statement_type; - IB_RESULT->out_sqlda = NULL; - IB_RESULT->has_more_rows = 1; - - out_sqlda = IB_RESULT->out_sqlda = emalloc(XSQLDA_LENGTH(ib_query->out_sqlda->sqld)); - memcpy(out_sqlda, ib_query->out_sqlda, XSQLDA_LENGTH(ib_query->out_sqlda->sqld)); - _php_ibase_alloc_xsqlda(out_sqlda); - - if (ib_query->out_array) { - memcpy(&IB_RESULT->out_array, ib_query->out_array, sizeof(ibase_array) * out_sqlda->sqld); - } - } - - if (ib_query->in_sqlda) { /* has placeholders */ - IBDEBUG("Query wants XSQLDA for input"); - if (ib_query->in_sqlda->sqld != argc) { - _php_ibase_module_error("Placeholders (%d) and variables (%d) mismatch" TSRMLS_CC, ib_query->in_sqlda->sqld, argc); - goto _php_ibase_exec_error; - } - in_sqlda = emalloc(XSQLDA_LENGTH(ib_query->in_sqlda->sqld)); - memcpy(in_sqlda, ib_query->in_sqlda, XSQLDA_LENGTH(ib_query->in_sqlda->sqld)); - bind_buf = safe_emalloc(sizeof(BIND_BUF), ib_query->in_sqlda->sqld, 0); - if (_php_ibase_bind(in_sqlda, args, bind_buf, ib_query TSRMLS_CC) == FAILURE) { - IBDEBUG("Could not bind input XSQLDA"); - goto _php_ibase_exec_error; - } - } - - if (ib_query->statement_type == isc_info_sql_stmt_exec_procedure) { - isc_result = isc_dsql_execute2(IB_STATUS, &ib_query->trans->handle, &ib_query->stmt, SQLDA_CURRENT_VERSION, in_sqlda, out_sqlda); - } else { - isc_result = isc_dsql_execute(IB_STATUS, &ib_query->trans->handle, &ib_query->stmt, SQLDA_CURRENT_VERSION, in_sqlda); - } - if (isc_result) { - IBDEBUG("Could not execute query"); - _php_ibase_error(TSRMLS_C); - goto _php_ibase_exec_error; - } - ib_query->trans->affected_rows = 0; - - switch (ib_query->statement_type) { - - unsigned long affected_rows; - - case isc_info_sql_stmt_insert: - case isc_info_sql_stmt_update: - case isc_info_sql_stmt_delete: - case isc_info_sql_stmt_exec_procedure: - - if (isc_dsql_sql_info(IB_STATUS, &ib_query->stmt, sizeof(info_count), info_count, sizeof(result), result)) { - _php_ibase_error(TSRMLS_C); - goto _php_ibase_exec_error; - } - - affected_rows = 0; - - if (result[0] == isc_info_sql_records) { - unsigned i = 3, result_size = isc_vax_integer(&result[1],2); - - while (result[i] != isc_info_end && i < result_size) { - short len = (short)isc_vax_integer(&result[i+1],2); - if (result[i] != isc_info_req_select_count) { - affected_rows += isc_vax_integer(&result[i+3],len); - } - i += len+3; - } - } - if (affected_rows > 0) { - ib_query->trans->affected_rows = affected_rows; - RETVAL_LONG(affected_rows); - } - } - - rv = SUCCESS; - -_php_ibase_exec_error: /* I'm a bad boy... */ - - if (in_sqlda) { - efree(in_sqlda); - } - if (bind_buf) - efree(bind_buf); - - if (rv == FAILURE) { - if (IB_RESULT) { - efree(IB_RESULT); - IB_RESULT = NULL; - } - if (out_sqlda) { - _php_ibase_free_xsqlda(out_sqlda); - } - } - - return rv; -#undef IB_RESULT -} -/* }}} */ - -/* {{{ proto resource ibase_trans([int trans_args [, resource link_identifier [, ... ], int trans_args [, resource link_identifier [, ... ]] [, ...]]]) - Start a transaction over one or several databases */ - -#define TPB_MAX_SIZE (8*sizeof(char)) - -PHP_FUNCTION(ibase_trans) -{ - unsigned short i, argn, link_cnt = 0, tpb_len = 0; - char last_tpb[TPB_MAX_SIZE]; - ibase_db_link **ib_link = NULL; - ibase_trans *ib_trans; - isc_tr_handle tr_handle = NULL; - ISC_STATUS result; - - RESET_ERRMSG; - - argn = ZEND_NUM_ARGS(); - - /* (1+argn) is an upper bound for the number of links this trans connects to */ - ib_link = (ibase_db_link **) do_alloca(sizeof(ibase_db_link *) * (1+argn)); - - if (argn > 0) { - long trans_argl = 0; - char *tpb; - ISC_TEB *teb; - zval ***args = (zval ***) do_alloca(sizeof(zval **) * argn); - - if (zend_get_parameters_array_ex(argn, args) == FAILURE) { - free_alloca(args); - free_alloca(ib_link); - RETURN_FALSE; - } - - teb = (ISC_TEB *) do_alloca(sizeof(ISC_TEB) * argn); - tpb = (char *) do_alloca(TPB_MAX_SIZE * argn); - - /* enumerate all the arguments: assume every non-resource argument - specifies modifiers for the link ids that follow it */ - for (i = 0; i < argn; ++i) { - - if (Z_TYPE_PP(args[i]) == IS_RESOURCE) { - - ZEND_FETCH_RESOURCE2(ib_link[link_cnt], ibase_db_link *, args[i], -1, "InterBase link", le_link, le_plink); - - /* copy the most recent modifier string into tbp[] */ - memcpy(&tpb[TPB_MAX_SIZE * link_cnt], last_tpb, TPB_MAX_SIZE); - - /* add a database handle to the TEB with the most recently specified set of modifiers */ - teb[link_cnt].db_ptr = &ib_link[link_cnt]->handle; - teb[link_cnt].tpb_len = tpb_len; - teb[link_cnt].tpb_ptr = &tpb[TPB_MAX_SIZE * link_cnt]; - - ++link_cnt; - - } else { - - tpb_len = 0; - - convert_to_long_ex(args[i]); - trans_argl = Z_LVAL_PP(args[i]); - - if (trans_argl != PHP_IBASE_DEFAULT) { - last_tpb[tpb_len++] = isc_tpb_version3; - - /* access mode */ - if (PHP_IBASE_READ == (trans_argl & PHP_IBASE_READ)) { - last_tpb[tpb_len++] = isc_tpb_read; - } else if (PHP_IBASE_WRITE == (trans_argl & PHP_IBASE_WRITE)) { - last_tpb[tpb_len++] = isc_tpb_write; - } - - /* isolation level */ - if (PHP_IBASE_COMMITTED == (trans_argl & PHP_IBASE_COMMITTED)) { - last_tpb[tpb_len++] = isc_tpb_read_committed; - if (PHP_IBASE_REC_VERSION == (trans_argl & PHP_IBASE_REC_VERSION)) { - last_tpb[tpb_len++] = isc_tpb_rec_version; - } else if (PHP_IBASE_REC_NO_VERSION == (trans_argl & PHP_IBASE_REC_NO_VERSION)) { - last_tpb[tpb_len++] = isc_tpb_no_rec_version; - } - } else if (PHP_IBASE_CONSISTENCY == (trans_argl & PHP_IBASE_CONSISTENCY)) { - last_tpb[tpb_len++] = isc_tpb_consistency; - } else if (PHP_IBASE_CONCURRENCY == (trans_argl & PHP_IBASE_CONCURRENCY)) { - last_tpb[tpb_len++] = isc_tpb_concurrency; - } - - /* lock resolution */ - if (PHP_IBASE_NOWAIT == (trans_argl & PHP_IBASE_NOWAIT)) { - last_tpb[tpb_len++] = isc_tpb_nowait; - } else if (PHP_IBASE_WAIT == (trans_argl & PHP_IBASE_WAIT)) { - last_tpb[tpb_len++] = isc_tpb_wait; - } - } - } - } - - if (link_cnt > 0) { - result = isc_start_multiple(IB_STATUS, &tr_handle, link_cnt, teb); - } - - free_alloca(args); - free_alloca(tpb); - free_alloca(teb); - } - - if (link_cnt == 0) { - link_cnt = 1; - ZEND_FETCH_RESOURCE2(ib_link[0], ibase_db_link *, NULL, IBG(default_link), "InterBase link", le_link, le_plink); - result = isc_start_transaction(IB_STATUS, &tr_handle, 1, &ib_link[0]->handle, tpb_len, last_tpb); - } - - /* start the transaction */ - if (result) { - _php_ibase_error(TSRMLS_C); - free_alloca(ib_link); - RETURN_FALSE; - } - - /* register the transaction in our own data structures */ - ib_trans = (ibase_trans *) safe_emalloc((link_cnt-1), sizeof(ibase_db_link *), sizeof(ibase_trans)); - ib_trans->handle = tr_handle; - ib_trans->link_cnt = link_cnt; - ib_trans->affected_rows = 0; - for (i = 0; i < link_cnt; ++i) { - ibase_tr_list **l; - ib_trans->db_link[i] = ib_link[i]; - - /* the first item in the connection-transaction list is reserved for the default transaction */ - if (ib_link[i]->tr_list == NULL) { - ib_link[i]->tr_list = (ibase_tr_list *) emalloc(sizeof(ibase_tr_list)); - ib_link[i]->tr_list->trans = NULL; - ib_link[i]->tr_list->next = NULL; - } - - /* link the transaction into the connection-transaction list */ - for (l = &ib_link[i]->tr_list; *l != NULL; l = &(*l)->next); - *l = (ibase_tr_list *) emalloc(sizeof(ibase_tr_list)); - (*l)->trans = ib_trans; - (*l)->next = NULL; - } - free_alloca(ib_link); - ZEND_REGISTER_RESOURCE(return_value, ib_trans, le_trans); -} -/* }}} */ - -/* {{{ _php_ibase_def_trans() */ -/* open default transaction */ -static int _php_ibase_def_trans(ibase_db_link *ib_link, ibase_trans **trans TSRMLS_DC) -{ - if (ib_link == NULL) { - php_error_docref(NULL TSRMLS_CC, E_WARNING, "Invalid database link"); - return FAILURE; - } - - /* the first item in the connection-transaction list is reserved for the default transaction */ - if (ib_link->tr_list == NULL) { - ib_link->tr_list = (ibase_tr_list *) emalloc(sizeof(ibase_tr_list)); - ib_link->tr_list->trans = NULL; - ib_link->tr_list->next = NULL; - } - - if (*trans == NULL) { - ibase_trans *tr = ib_link->tr_list->trans; - - if (tr == NULL) { - tr = (ibase_trans *) emalloc(sizeof(ibase_trans)); - tr->handle = NULL; - tr->link_cnt = 1; - tr->affected_rows = 0; - tr->db_link[0] = ib_link; - ib_link->tr_list->trans = tr; - } - if (tr->handle == NULL) { - if (isc_start_transaction(IB_STATUS, &tr->handle, 1, &ib_link->handle, 0, NULL)) { - _php_ibase_error(TSRMLS_C); - return FAILURE; - } - } - *trans = tr; - } - return SUCCESS; -} -/* }}} */ - -/* {{{ _php_ibase_trans_end() */ -static void _php_ibase_trans_end(INTERNAL_FUNCTION_PARAMETERS, int commit) -{ - ibase_trans *trans = NULL; - int res_id = 0; - ISC_STATUS result; - - RESET_ERRMSG; - - switch (ZEND_NUM_ARGS()) { - - ibase_db_link *ib_link; - zval **arg; - - case 0: - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, NULL, IBG(default_link), "InterBase link", le_link, le_plink); - if (ib_link->tr_list == NULL || ib_link->tr_list->trans == NULL) { - /* this link doesn't have a default transaction */ - _php_ibase_module_error("Default link has no default transaction" TSRMLS_CC); - RETURN_FALSE; - } - trans = ib_link->tr_list->trans; - break; - - case 1: - if (zend_get_parameters_ex(1, &arg) == FAILURE) { - RETURN_FALSE; - } - /* one id was passed, could be db or trans id */ - _php_ibase_get_link_trans(INTERNAL_FUNCTION_PARAM_PASSTHRU, arg, &ib_link, &trans); - if (trans != NULL) { - convert_to_long_ex(arg); - res_id = Z_LVAL_PP(arg); - - } else { - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, arg, -1, "InterBase link", le_link, le_plink); - - if (ib_link->tr_list == NULL || ib_link->tr_list->trans == NULL) { - /* this link doesn't have a default transaction */ - _php_ibase_module_error("Link has no default transaction" TSRMLS_CC); - RETURN_FALSE; - } - trans = ib_link->tr_list->trans; - } - break; - - default: - WRONG_PARAM_COUNT; - break; - } - - switch (commit) { - - default: /* == case ROLLBACK: */ - result = isc_rollback_transaction(IB_STATUS, &trans->handle); - break; - case COMMIT: - result = isc_commit_transaction(IB_STATUS, &trans->handle); - break; -#ifdef SQL_DIALECT_V6 - case (ROLLBACK | RETAIN): - result = isc_rollback_retaining(IB_STATUS, &trans->handle); - break; -#endif - case (COMMIT | RETAIN): - result = isc_commit_retaining(IB_STATUS, &trans->handle); - break; - } - - if (result) { - _php_ibase_error(TSRMLS_C); - RETURN_FALSE; - } - - /* Don't try to destroy implicitly opened transaction from list... */ - if ( (commit & RETAIN) == 0 && res_id != 0) { - zend_list_delete(res_id); - } - RETURN_TRUE; -} -/* }}} */ - -/* {{{ proto bool ibase_commit( resource link_identifier ) - Commit transaction */ -PHP_FUNCTION(ibase_commit) -{ - _php_ibase_trans_end(INTERNAL_FUNCTION_PARAM_PASSTHRU, COMMIT); -} -/* }}} */ - -/* {{{ proto bool ibase_rollback( resource link_identifier ) - Rollback transaction */ -PHP_FUNCTION(ibase_rollback) -{ - _php_ibase_trans_end(INTERNAL_FUNCTION_PARAM_PASSTHRU, ROLLBACK); -} -/* }}} */ - -/* {{{ proto bool ibase_commit_ret( resource link_identifier ) - Commit transaction and retain the transaction context */ -PHP_FUNCTION(ibase_commit_ret) -{ - _php_ibase_trans_end(INTERNAL_FUNCTION_PARAM_PASSTHRU, COMMIT | RETAIN); -} -/* }}} */ - -/* {{{ proto bool ibase_rollback_ret( resource link_identifier ) - Rollback transaction and retain the transaction context */ -#ifdef SQL_DIALECT_V6 - -PHP_FUNCTION(ibase_rollback_ret) -{ - _php_ibase_trans_end(INTERNAL_FUNCTION_PARAM_PASSTHRU, ROLLBACK | RETAIN); -} - -#endif -/* }}} */ - -/* {{{ proto mixed ibase_query([resource link_identifier, [ resource link_identifier, ]] string query [, mixed bind_arg [, mixed bind_arg [, ...]]]) - Execute a query */ -PHP_FUNCTION(ibase_query) -{ - zval ***args, **bind_args = NULL; - int i, bind_n = 0, trans_res_id = 0; - ibase_db_link *ib_link = NULL; - ibase_trans *trans = NULL; - ibase_query ib_query = { NULL, NULL, 0, 0 }; - ibase_result *result = NULL; - char *query; - - RESET_ERRMSG; - - if (ZEND_NUM_ARGS() < 1) { - WRONG_PARAM_COUNT; - } - - /* use stack to avoid leaks */ - args = (zval ***) do_alloca(sizeof(zval **) * ZEND_NUM_ARGS()); - if (zend_get_parameters_array_ex(ZEND_NUM_ARGS(), args) == FAILURE) { - free_alloca(args); - RETURN_FALSE; - } - - i = 0; - while (Z_TYPE_PP(args[i++]) != IS_STRING) { - if (i >= ZEND_NUM_ARGS()) { - _php_ibase_module_error("Query argument missing" TSRMLS_CC); - free_alloca(args); - RETURN_FALSE; - } - } - - convert_to_string_ex(args[i-1]); - query = Z_STRVAL_PP(args[i-1]); - - /* find out if the first one or two arguments refer to either a link id, - a trans id or both */ - switch (i) { - case 1: - - /* no link ids were passed: if there's no default link, use exec_immediate() with - a NULL handle; this will enable the use of CREATE DATABASE statements. */ - if (IBG(default_link) == -1) { - isc_db_handle db = NULL; - isc_tr_handle trans = NULL; - - if (isc_dsql_execute_immediate(IB_STATUS, &db, &trans, 0, query, SQL_DIALECT_CURRENT, NULL)) { - _php_ibase_error(TSRMLS_C); - free_alloca(args); - RETURN_FALSE; - } - - /* has a new database been created ? */ - if (db != NULL) { - - if ((IBG(max_links) != -1) && (IBG(num_links) >= IBG(max_links))) { - - /* too many links already ? => close it up immediately */ - if (isc_detach_database(IB_STATUS, &db)) { - _php_ibase_error(TSRMLS_C); - free_alloca(args); - RETURN_FALSE; - } - } else { - - /* register the link as a resource; unfortunately, we cannot register - it in the hash table, because we don't know the connection params */ - ib_link = (ibase_db_link *) emalloc(sizeof(ibase_db_link)); - ib_link->handle = db; - ib_link->dialect = SQL_DIALECT_CURRENT; - ib_link->tr_list = NULL; - - ZEND_REGISTER_RESOURCE(return_value, ib_link, le_link); - zend_list_addref(Z_LVAL_P(return_value)); - IBG(default_link) = Z_LVAL_P(return_value); - IBG(num_links)++; - - free_alloca(args); - return; - } - } - RETURN_TRUE; - } - - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, NULL, IBG(default_link), "InterBase link", le_link, le_plink); - break; - case 2: - /* one id was passed, could be db or trans id */ - _php_ibase_get_link_trans(INTERNAL_FUNCTION_PARAM_PASSTHRU, args[0], &ib_link, &trans); - - if (trans != NULL) { - /* argument was a trans id */ - convert_to_long_ex(args[0]); - trans_res_id = Z_LVAL_PP(args[0]); - } - break; - case 3: - /* two ids were passed, first should be link and second should be trans; */ - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link*, args[0], -1, "InterBase link", le_link, le_plink); - ZEND_FETCH_RESOURCE(trans, ibase_trans*, args[1], -1, "InterBase transaction", le_trans); - - convert_to_long_ex(args[1]); - trans_res_id = Z_LVAL_PP(args[1]); - - break; - default: - /* more than two arguments preceed the SQL string */ - _php_ibase_module_error("Invalid arguments" TSRMLS_CC); - free_alloca(args); - RETURN_FALSE; - } - - if (ZEND_NUM_ARGS() > i) { /* have variables to bind */ - /* Using variables in a query without preparing it can be - useful, because it allows you to use (among other things) - SQL-queries as consts and the passing of string arguments - without the horror of [un]slashing them. */ - bind_n = ZEND_NUM_ARGS() - i; - bind_args = args[i]; - } - - /* open default transaction */ - if (ib_link == NULL || _php_ibase_def_trans(ib_link, &trans TSRMLS_CC) == FAILURE) { - free_alloca(args); - RETURN_FALSE; - } - - if (_php_ibase_alloc_query(&ib_query, ib_link, trans, query, ib_link->dialect, trans_res_id TSRMLS_CC) == FAILURE) { - free_alloca(args); - RETURN_FALSE; - } - - if (_php_ibase_exec(INTERNAL_FUNCTION_PARAM_PASSTHRU, &result, &ib_query, bind_n, bind_args) == FAILURE) { - _php_ibase_free_query(&ib_query TSRMLS_CC); - free_alloca(args); - RETURN_FALSE; - } - - free_alloca(args); - - if (result != NULL) { /* statement returns a result */ - result->type = QUERY_RESULT; - - /* EXECUTE PROCEDURE returns only one row => statement can be released immediately */ - if (ib_query.statement_type != isc_info_sql_stmt_exec_procedure) { - ib_query.stmt = NULL; /* keep stmt when free query */ - } - ZEND_REGISTER_RESOURCE(return_value, result, le_result); - } - _php_ibase_free_query(&ib_query TSRMLS_CC); -} -/* }}} */ - -/* {{{ proto int ibase_affected_rows( [ resource link_identifier ] ) - Returns the number of rows affected by the previous INSERT, UPDATE or DELETE statement */ -PHP_FUNCTION(ibase_affected_rows) -{ - ibase_trans *trans = NULL; - - RESET_ERRMSG; - - switch (ZEND_NUM_ARGS()) { - - ibase_db_link *ib_link; - zval **arg; - - case 0: - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, NULL, IBG(default_link), "InterBase link", le_link, le_plink); - if (ib_link->tr_list == NULL || ib_link->tr_list->trans == NULL) { - RETURN_FALSE; - } - trans = ib_link->tr_list->trans; - break; - - case 1: - if (zend_get_parameters_ex(1, &arg) == FAILURE) { - RETURN_FALSE; - } - /* one id was passed, could be db or trans id */ - _php_ibase_get_link_trans(INTERNAL_FUNCTION_PARAM_PASSTHRU, arg, &ib_link, &trans); - if (trans == NULL) { - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, arg, -1, "InterBase link", le_link, le_plink); - - if (ib_link->tr_list == NULL || ib_link->tr_list->trans == NULL) { - RETURN_FALSE; - } - trans = ib_link->tr_list->trans; - } - break; - - default: - WRONG_PARAM_COUNT; - break; - } - RETURN_LONG(trans->affected_rows); -} -/* }}} */ - -/* {{{ proto int ibase_num_rows( resource result_identifier ) - */ -#if abies_0 -PHP_FUNCTION(ibase_num_rows) -{ - /** - * PLEASE READ THIS FIRST before adding this function to the main PHP - * documentation: - * - * As this function relies on the InterBase API function isc_dsql_sql_info() - * which has a couple of limitations (which I hope will be fixed in future - * releases of Firebird), this function is fairly useless. I'm leaving it - * in place for people who can live with the limitations, which I only - * found out about after I had implemented it anyway. - * - * Currently, there's no way to determine how many rows can be fetched from - * a cursor. The only number that _can_ be determined is the number of rows - * that have already been pre-fetched by the client library. - * This implies the following: - * - num_rows() always returns zero before the first fetch; - * - num_rows() for SELECT ... FOR UPDATE is broken -> never returns a - * higher number than the number of records fetched so far (no pre-fetch); - * - the result of num_rows() for other statements is merely a lower bound - * on the number of records => calling ibase_num_rows() again after a couple - * of fetches will most likely return a new (higher) figure for large result - * sets. - * - * 12-aug-2003 Ard Biesheuvel - */ - - zval **result_arg; - ibase_result *ib_result; - static char info_count[] = {isc_info_sql_records}; - char result[64]; - - RESET_ERRMSG; - - if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &result_arg) == FAILURE) { - WRONG_PARAM_COUNT; - } - - ZEND_FETCH_RESOURCE(ib_result, ibase_result *, result_arg, -1, "InterBase result", le_result); - - if (isc_dsql_sql_info(IB_STATUS, &ib_result->stmt, sizeof(info_count), info_count, sizeof(result), result)) { - _php_ibase_error(TSRMLS_C); - RETURN_FALSE; - } - - if (result[0] == isc_info_sql_records) { - unsigned i = 3, result_size = isc_vax_integer(&result[1],2); - - while (result[i] != isc_info_end && i < result_size) { - short len = (short)isc_vax_integer(&result[i+1],2); - if (result[i] == isc_info_req_select_count) { - RETURN_LONG(isc_vax_integer(&result[i+3],len)); - } - i += len+3; - } - } -} -#endif -/* }}} */ - -/* {{{ _php_ibase_var_zval() */ -static int _php_ibase_var_zval(zval *val, void *data, int type, int len, int scale, int flag TSRMLS_DC) -{ -#ifdef SQL_INT64 - static ISC_INT64 const scales[] = { 1, 10, 100, 1000, 10000, 100000, 1000000, 100000000, 1000000000, - 1000000000, LL_LIT(10000000000),LL_LIT(100000000000),LL_LIT(10000000000000),LL_LIT(100000000000000), - LL_LIT(1000000000000000),LL_LIT(1000000000000000),LL_LIT(1000000000000000000) }; -#else - static long const scales[] = { 1, 10, 100, 1000, 10000, 100000, 1000000, 100000000, 1000000000, 1000000000 }; -#endif - - switch (type & ~1) { - unsigned short l; - long n; - char string_data[255]; - - case SQL_VARYING: - len = ((IBVARY *) data)->vary_length; - data = ((IBVARY *) data)->vary_string; - /* no break */ - case SQL_TEXT: - if (PG(magic_quotes_runtime)) { - Z_STRVAL_P(val) = php_addslashes(data, len, &Z_STRLEN_P(val), 0 TSRMLS_CC); - Z_TYPE_P(val) = IS_STRING; - } else { - ZVAL_STRINGL(val,(char *) data,len,1); - } - break; - case SQL_SHORT: - n = *(short *) data; - goto _sql_long; -#ifdef SQL_INT64 - case SQL_INT64: -#if (SIZEOF_LONG >= 8) - n = *(long *) data; - goto _sql_long; -#else - if (scale == 0) { - l = sprintf(string_data, "%" LL_MASK "d", *(ISC_INT64 *) data); - ZVAL_STRINGL(val,string_data,l,1); - } else { - ISC_INT64 n = *(ISC_INT64 *) data, f = scales[-scale]; - - if (n >= 0) { - l = sprintf(string_data, "%" LL_MASK "d.%0*" LL_MASK "d", n / f, -scale, n % f); - } else if (n < -f) { - l = sprintf(string_data, "%" LL_MASK "d.%0*" LL_MASK "d", n / f, -scale, -n % f); - } else { - l = sprintf(string_data, "-0.%0*" LL_MASK "d", -scale, -n % f); - } - ZVAL_STRINGL(val,string_data,l,1); - } - break; -#endif -#endif - case SQL_LONG: - n = *(ISC_LONG *) data; - _sql_long: - if (scale == 0) { - ZVAL_LONG(val,n); - } else { - long f = (long) scales[-scale]; - - if (n >= 0) { - l = sprintf(string_data, "%ld.%0*ld", n / f, -scale, n % f); - } else if (n < -f) { - l = sprintf(string_data, "%ld.%0*ld", n / f, -scale, -n % f); - } else { - l = sprintf(string_data, "-0.%0*ld", -scale, -n % f); - } - ZVAL_STRINGL(val,string_data,l,1); - } - break; - case SQL_FLOAT: - ZVAL_DOUBLE(val, *(float *) data); - break; - case SQL_DOUBLE: - ZVAL_DOUBLE(val, *(double *) data); - break; - default: /* == any date/time type */ - { - struct tm t; - char *format = NULL; - -#ifndef SQL_TIMESTAMP - isc_decode_date((ISC_QUAD *) data, &t); - format = IBG(timestampformat); -#else - switch (type & ~1) { - default: /* == case SQL_TIMESTAMP: */ - isc_decode_timestamp((ISC_TIMESTAMP *) data, &t); - format = IBG(timestampformat); - break; - case SQL_TYPE_DATE: - isc_decode_sql_date((ISC_DATE *) data, &t); - format = IBG(dateformat); - break; - case SQL_TYPE_TIME: - isc_decode_sql_time((ISC_TIME *) data, &t); - format = IBG(timeformat); - break; - } -#endif - /* - XXX - Might have to remove this later - seems that isc_decode_date() - always sets tm_isdst to 0, sometimes incorrectly (InterBase 6 bug?) - */ - t.tm_isdst = -1; -#if HAVE_TM_ZONE - t.tm_zone = tzname[0]; -#endif - if (flag & PHP_IBASE_UNIXTIME) { - ZVAL_LONG(val, mktime(&t)); - } else { -#if HAVE_STRFTIME - l = strftime(string_data, sizeof(string_data), format, &t); -#else - switch (type & ~1) { - default: - l = sprintf(string_data, "%02d/%02d/%4d %02d:%02d:%02d", t.tm_mon+1, t.tm_mday, t.tm_year + 1900, t.tm_hour, t.tm_min, t.tm_sec); - break; -#ifdef SQL_TIMESTAMP - case SQL_TYPE_DATE: - l = sprintf(string_data, "%02d/%02d/%4d", t.tm_mon + 1, t.tm_mday, t.tm_year + 1900); - break; - case SQL_TYPE_TIME: - l = sprintf(string_data, "%02d:%02d:%02d", t.tm_hour, t.tm_min, t.tm_sec); - break; -#endif - } -#endif - ZVAL_STRINGL(val,string_data,l,1); - break; - } - } - } /* switch (type) */ - return SUCCESS; -} -/* }}} */ - -/* {{{ _php_ibase_arr_zval() */ -/* create multidimension array - recursion function - * (*datap) argument changed - */ -static int _php_ibase_arr_zval(zval *ar_zval, char *data, unsigned long data_size, ibase_array *ib_array, int dim, int flag TSRMLS_DC) -{ - int - u_bound = ib_array->ar_desc.array_desc_bounds[dim].array_bound_upper, - l_bound = ib_array->ar_desc.array_desc_bounds[dim].array_bound_lower, - dim_len = 1 + u_bound - l_bound; - unsigned short i; - - if (dim < ib_array->ar_desc.array_desc_dimensions) { /* array again */ - unsigned long slice_size = data_size / dim_len; - - array_init(ar_zval); - - for (i = 0; i < dim_len; ++i) { - zval *slice_zval; - ALLOC_INIT_ZVAL(slice_zval); - - /* recursion here */ - if (_php_ibase_arr_zval(slice_zval, data, slice_size, ib_array, dim + 1, flag TSRMLS_CC) == FAILURE) { - return FAILURE; - } - data += slice_size; - - add_index_zval(ar_zval,l_bound+i,slice_zval); - } - } else { /* data at last */ - - if (_php_ibase_var_zval(ar_zval, data, - ib_array->el_type, - ib_array->ar_desc.array_desc_length, - ib_array->ar_desc.array_desc_scale, - flag TSRMLS_CC) == FAILURE) { - return FAILURE; - } - - /* fix for peculiar handling of VARCHAR arrays; - truncate the field to the cstring length */ - if (ib_array->ar_desc.array_desc_dtype == blr_varying || - ib_array->ar_desc.array_desc_dtype == blr_varying2) { - - Z_STRLEN_P(ar_zval) = strlen(Z_STRVAL_P(ar_zval)); - } - } - return SUCCESS; -} -/* }}} */ - - -/* {{{ _php_ibase_blob_get */ -static int _php_ibase_blob_get(zval *return_value, ibase_blob *ib_blob, unsigned long max_len TSRMLS_DC) -{ - if (ib_blob->bl_qd.gds_quad_high || ib_blob->bl_qd.gds_quad_low) { /*not null ?*/ - - ISC_STATUS stat; - char *bl_data; - unsigned long cur_len; - unsigned short seg_len; - - bl_data = emalloc(max_len + 1); - - for (cur_len = stat = 0; (stat == 0 || stat == isc_segment) && cur_len < max_len; cur_len += seg_len) { - - unsigned short chunk_size = (max_len-cur_len) > USHRT_MAX ? USHRT_MAX : (unsigned short)(max_len-cur_len); - - stat = isc_get_segment(IB_STATUS, &ib_blob->bl_handle, &seg_len, chunk_size, &bl_data[cur_len]); - } - - bl_data[cur_len] = '\0'; - if (IB_STATUS[0] == 1 && (stat != 0 && stat != isc_segstr_eof && stat != isc_segment)) { - efree(bl_data); - _php_ibase_error(TSRMLS_C); - return FAILURE; - } - RETVAL_STRINGL(bl_data, cur_len, 0); - } else { /* null blob */ - RETVAL_STRING("", 1); /* empty string */ - } - return SUCCESS; -} - -/* }}} */ - -/* {{{ _php_ibase_fetch_hash() */ -static void _php_ibase_fetch_hash(INTERNAL_FUNCTION_PARAMETERS, int fetch_type) -{ - zval **result_arg, **flag_arg; - long i, flag = 0; - ibase_result *ib_result; - XSQLVAR *var; - - RESET_ERRMSG; - - switch (ZEND_NUM_ARGS()) { - case 1: - if (ZEND_NUM_ARGS() == 1 && zend_get_parameters_ex(1, &result_arg) == FAILURE) { - RETURN_FALSE; - } - break; - case 2: - if (ZEND_NUM_ARGS() == 2 && zend_get_parameters_ex(2, &result_arg, &flag_arg) == FAILURE) { - RETURN_FALSE; - } - convert_to_long_ex(flag_arg); - flag = Z_LVAL_PP(flag_arg); - break; - default: - WRONG_PARAM_COUNT; - break; - } - - ZEND_FETCH_RESOURCE(ib_result, ibase_result *, result_arg, -1, "InterBase result", le_result); - - if (ib_result->out_sqlda == NULL || !ib_result->has_more_rows) { - RETURN_FALSE; - } - - if (ib_result->statement_type != isc_info_sql_stmt_exec_procedure) { - - if (isc_dsql_fetch(IB_STATUS, &ib_result->stmt, 1, ib_result->out_sqlda)) { - - ib_result->has_more_rows = 0; - if (IB_STATUS[0] && IB_STATUS[1]) { /* error in fetch */ - _php_ibase_error(TSRMLS_C); - } - RETURN_FALSE; - } - } else { - ib_result->has_more_rows = 0; - } - - array_init(return_value); - - var = ib_result->out_sqlda->sqlvar; - for (i = 0; i < ib_result->out_sqlda->sqld; i++, var++) { - if (((var->sqltype & 1) == 0) || *var->sqlind != -1) { - zval *result; - ALLOC_INIT_ZVAL(result); - - switch (var->sqltype & ~1) { - - default: - _php_ibase_var_zval(result, var->sqldata, var->sqltype, var->sqllen, var->sqlscale, flag TSRMLS_CC); - break; - case SQL_BLOB: - if (flag & PHP_IBASE_FETCH_BLOBS) { /* fetch blob contents into hash */ - - ibase_blob blob_handle; - unsigned long max_len = 0; - static char bl_items[] = {isc_info_blob_total_length}; - char bl_info[20]; - unsigned short i; - - blob_handle.bl_handle = NULL; - blob_handle.bl_qd = *(ISC_QUAD *) var->sqldata; - - if (isc_open_blob(IB_STATUS, &ib_result->link->handle, &ib_result->trans->handle, &blob_handle.bl_handle, &blob_handle.bl_qd)) { - _php_ibase_error(TSRMLS_C); - goto _php_ibase_fetch_error; - } - - if (isc_blob_info(IB_STATUS, &blob_handle.bl_handle, sizeof(bl_items), bl_items, sizeof(bl_info), bl_info)) { - _php_ibase_error(TSRMLS_C); - goto _php_ibase_fetch_error; - } - - /* find total length of blob's data */ - for (i = 0; i < sizeof(bl_info); ) { - unsigned short item_len; - char item = bl_info[i++]; - - if (item == isc_info_end || item == isc_info_truncated || - item == isc_info_error || i >= sizeof(bl_info)) { - - _php_ibase_module_error("Could not determine BLOB size (internal error)" TSRMLS_CC); - goto _php_ibase_fetch_error; - } - - item_len = (unsigned short) isc_vax_integer(&bl_info[i], 2); - - if (item == isc_info_blob_total_length) { - max_len = isc_vax_integer(&bl_info[i+2], item_len); - break; - } - i += item_len+2; - } - - if (max_len == 0) { - ZVAL_STRING(result, "", 1); - } else if (_php_ibase_blob_get(result, &blob_handle, max_len TSRMLS_CC) != SUCCESS) { - goto _php_ibase_fetch_error; - } - - if (isc_close_blob(IB_STATUS, &blob_handle.bl_handle)) { - _php_ibase_error(TSRMLS_C); - goto _php_ibase_fetch_error; - } - - } else { /* blob id only */ - ISC_QUAD bl_qd = *(ISC_QUAD *) var->sqldata; - ZVAL_STRINGL(result,_php_ibase_quad_to_string(bl_qd), BLOB_ID_LEN, 0); - } - break; - case SQL_ARRAY: - if (flag & PHP_IBASE_FETCH_ARRAYS) { /* array can be *huge* so only fetch if asked */ - ISC_QUAD ar_qd = *(ISC_QUAD *) var->sqldata; - ibase_array *ib_array = &ib_result->out_array[i]; - void *ar_data = emalloc(ib_array->ar_size); - - if (isc_array_get_slice(IB_STATUS, &ib_result->link->handle, &ib_result->trans->handle, &ar_qd, &ib_array->ar_desc, ar_data, &ib_array->ar_size)) { - _php_ibase_error(TSRMLS_C); - efree(ar_data); - goto _php_ibase_fetch_error; - } - - if (_php_ibase_arr_zval(result, ar_data, ib_array->ar_size, ib_array, 0, flag TSRMLS_CC) == FAILURE) { - efree(ar_data); - goto _php_ibase_fetch_error; - } - efree(ar_data); - - } else { /* blob id only */ - ISC_QUAD ar_qd = *(ISC_QUAD *) var->sqldata; - ZVAL_STRINGL(result,_php_ibase_quad_to_string(ar_qd), BLOB_ID_LEN, 0); - } - break; - _php_ibase_fetch_error: - zval_dtor(result); - FREE_ZVAL(result); - RETURN_FALSE; - } /* switch */ - - if (fetch_type & FETCH_ROW) { - add_index_zval(return_value, i, result); - } else { - add_assoc_zval(return_value, var->aliasname, result); - } - } else { - if (fetch_type & FETCH_ROW) { - add_index_null(return_value, i); - } else { - add_assoc_null(return_value, var->aliasname); - } - } - } /* for field */ -} -/* }}} */ - -/* {{{ proto array ibase_fetch_row(resource result [, int fetch_flags]) - Fetch a row from the results of a query */ -PHP_FUNCTION(ibase_fetch_row) -{ - _php_ibase_fetch_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, FETCH_ROW); -} -/* }}} */ - -/* {{{ proto array ibase_fetch_assoc(resource result [, int fetch_flags]) - Fetch a row from the results of a query */ -PHP_FUNCTION(ibase_fetch_assoc) -{ - _php_ibase_fetch_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, FETCH_ARRAY); -} -/* }}} */ - -/* {{{ proto object ibase_fetch_object(resource result [, int fetch_flags]) - Fetch a object from the results of a query */ -PHP_FUNCTION(ibase_fetch_object) -{ - _php_ibase_fetch_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, FETCH_ARRAY); - - if (Z_TYPE_P(return_value) == IS_ARRAY) { - object_and_properties_init(return_value, ZEND_STANDARD_CLASS_DEF_PTR, Z_ARRVAL_P(return_value)); - } -} -/* }}} */ - - -/* {{{ proto bool ibase_name_result(resource result, string name) - Assign a name to a result for use with ... WHERE CURRENT OF <name> statements */ -PHP_FUNCTION(ibase_name_result) -{ - zval **result_arg, **name_arg; - ibase_result *ib_result; - - RESET_ERRMSG; - - if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &result_arg, &name_arg) == FAILURE) { - WRONG_PARAM_COUNT; - } - - ZEND_FETCH_RESOURCE(ib_result, ibase_result *, result_arg, -1, "InterBase result", le_result); - convert_to_string_ex(name_arg); - - if (isc_dsql_set_cursor_name(IB_STATUS, &ib_result->stmt, Z_STRVAL_PP(name_arg), 0)) { - _php_ibase_error(TSRMLS_C); - RETURN_FALSE; - } - RETURN_TRUE; -} -/* }}} */ - - -/* {{{ proto bool ibase_free_result(resource result) - Free the memory used by a result */ -PHP_FUNCTION(ibase_free_result) -{ - zval **result_arg; - ibase_result *ib_result; - - RESET_ERRMSG; - - if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &result_arg) == FAILURE) { - WRONG_PARAM_COUNT; - } - - ZEND_FETCH_RESOURCE(ib_result, ibase_result *, result_arg, -1, "InterBase result", le_result); - zend_list_delete(Z_LVAL_PP(result_arg)); - RETURN_TRUE; -} -/* }}} */ - -/* {{{ proto resource ibase_prepare([resource link_identifier, ] string query) - Prepare a query for later execution */ -PHP_FUNCTION(ibase_prepare) -{ - zval **link_arg, **trans_arg, **query_arg; - ibase_db_link *ib_link; - ibase_trans *trans = NULL; - int trans_res_id = 0; - ibase_query *ib_query; - char *query; - - RESET_ERRMSG; - - switch (ZEND_NUM_ARGS()) { - case 1: - if (zend_get_parameters_ex(1, &query_arg) == FAILURE) { - RETURN_FALSE; - } - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, NULL, IBG(default_link), "InterBase link", le_link, le_plink); - break; - case 2: - if (zend_get_parameters_ex(2, &link_arg, &query_arg) == FAILURE) { - RETURN_FALSE; - } - _php_ibase_get_link_trans(INTERNAL_FUNCTION_PARAM_PASSTHRU, link_arg, &ib_link, &trans); - - if (trans != NULL) { - convert_to_long_ex(link_arg); - trans_res_id = Z_LVAL_PP(link_arg); - } - - break; - case 3: - if (zend_get_parameters_ex(3, &link_arg, &trans_arg, &query_arg) == FAILURE) { - RETURN_FALSE; - } - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link*, link_arg, -1, "InterBase link", le_link, le_plink); - ZEND_FETCH_RESOURCE(trans, ibase_trans*, trans_arg, -1, "InterBase transaction", le_trans); - - convert_to_long_ex(trans_arg); - trans_res_id = Z_LVAL_PP(trans_arg); - - break; - default: - WRONG_PARAM_COUNT; - break; - } - - convert_to_string_ex(query_arg); - query = Z_STRVAL_PP(query_arg); - - /* open default transaction */ - if (_php_ibase_def_trans(ib_link, &trans TSRMLS_CC) == FAILURE) { - RETURN_FALSE; - } - - ib_query = (ibase_query *) emalloc(sizeof(ibase_query)); - - if (_php_ibase_alloc_query(ib_query, ib_link, trans, query, ib_link->dialect, trans_res_id TSRMLS_CC) == FAILURE) { - efree(ib_query); - RETURN_FALSE; - } - ZEND_REGISTER_RESOURCE(return_value, ib_query, le_query); -} -/* }}} */ - -/* {{{ proto mixed ibase_execute(resource query [, mixed bind_arg [, mixed bind_arg [, ...]]]) - Execute a previously prepared query */ -PHP_FUNCTION(ibase_execute) -{ - zval ***args, **bind_args = NULL; - ibase_query *ib_query; - ibase_result *result = NULL; - - RESET_ERRMSG; - - if (ZEND_NUM_ARGS() < 1) { - WRONG_PARAM_COUNT; - } - - /* use stack to avoid leaks */ - args = (zval ***) do_alloca(ZEND_NUM_ARGS() * sizeof(zval **)); - if (zend_get_parameters_array_ex(ZEND_NUM_ARGS(), args) == FAILURE) { - free_alloca(args); - RETURN_FALSE; - } - - ZEND_FETCH_RESOURCE(ib_query, ibase_query *, args[0], -1, "InterBase query", le_query); - - if (ZEND_NUM_ARGS() > 1) { /* have variables to bind */ - bind_args = args[1]; - } - - /* Have we used this cursor before and it's still open (exec proc has no cursor) ? */ - if (ib_query->result_res_id != 0 && ib_query->statement_type != isc_info_sql_stmt_exec_procedure) { - IBDEBUG("Implicitly closing a cursor"); - if (isc_dsql_free_statement(IB_STATUS, &ib_query->stmt, DSQL_close)) { - _php_ibase_error(TSRMLS_C); - } - /* invalidate previous results returned by this query (not necessary for exec proc) */ - zend_list_delete(ib_query->result_res_id); - } - - if (_php_ibase_exec(INTERNAL_FUNCTION_PARAM_PASSTHRU, &result, ib_query, ZEND_NUM_ARGS() - 1, bind_args) == FAILURE) { - free_alloca(args); - RETURN_FALSE; - } - - /* free the query if trans handle was released */ - if (ib_query->trans->handle == NULL) { - zend_list_delete(Z_LVAL_PP(args[0])); - } - - free_alloca(args); - - if (result != NULL) { - result->type = EXECUTE_RESULT; - if (ib_query->statement_type == isc_info_sql_stmt_exec_procedure) { - result->stmt = NULL; - } - ib_query->result_res_id = zend_list_insert(result, le_result); - RETURN_RESOURCE(ib_query->result_res_id); - } -} -/* }}} */ - -/* {{{ proto bool ibase_free_query(resource query) - Free memory used by a query */ -PHP_FUNCTION(ibase_free_query) -{ - zval **query_arg; - ibase_query *ib_query; - - RESET_ERRMSG; - - if (ZEND_NUM_ARGS()!=1 || zend_get_parameters_ex(1, &query_arg) == FAILURE) { - WRONG_PARAM_COUNT; - } - - ZEND_FETCH_RESOURCE(ib_query, ibase_query *, query_arg, -1, "InterBase query", le_query); - zend_list_delete(Z_LVAL_PP(query_arg)); - RETURN_TRUE; -} -/* }}} */ - -#if HAVE_STRFTIME -/* {{{ proto bool ibase_timefmt(string format) - Sets the format of timestamp, date and time columns returned from queries */ -PHP_FUNCTION(ibase_timefmt) -{ - zval ***args; - char *fmt = NULL; - int type = PHP_IBASE_TIMESTAMP; - - RESET_ERRMSG; /* ??? */ - - if (ZEND_NUM_ARGS() < 1 || ZEND_NUM_ARGS() > 2) { - WRONG_PARAM_COUNT; - } - - args = (zval ***) safe_emalloc(sizeof(zval **), ZEND_NUM_ARGS(), 0); - if (zend_get_parameters_array_ex(ZEND_NUM_ARGS(), args) == FAILURE) { - efree(args); - RETURN_FALSE; - } - - switch (ZEND_NUM_ARGS()) { - case 2: - convert_to_long_ex(args[1]); - type = Z_LVAL_PP(args[1]); - case 1: - convert_to_string_ex(args[0]); - fmt = Z_STRVAL_PP(args[0]); - } - - switch (type) { - case PHP_IBASE_TIMESTAMP: - if (IBG(timestampformat)) { - DL_FREE(IBG(timestampformat)); - } - IBG(timestampformat) = DL_STRDUP(fmt); - break; - case PHP_IBASE_DATE: - if (IBG(dateformat)) { - DL_FREE(IBG(dateformat)); - } - IBG(dateformat) = DL_STRDUP(fmt); - break; - case PHP_IBASE_TIME: - if (IBG(timeformat)) { - DL_FREE(IBG(timeformat)); - } - IBG(timeformat) = DL_STRDUP(fmt); - break; - } - - efree(args); - RETURN_TRUE; -} -/* }}} */ -#endif - -/* {{{ proto int ibase_num_fields(resource query_result) - Get the number of fields in result */ -PHP_FUNCTION(ibase_num_fields) -{ - zval **result; - int type; - XSQLDA *sqlda; - - RESET_ERRMSG; - - if (ZEND_NUM_ARGS()!=1 || zend_get_parameters_ex(1, &result)==FAILURE) { - WRONG_PARAM_COUNT; - } - - zend_list_find(Z_LVAL_PP(result), &type); - - if (type == le_query) { - ibase_query *ib_query; - - ZEND_FETCH_RESOURCE(ib_query, ibase_query *, result, -1, "InterBase query", le_query); - sqlda = ib_query->out_sqlda; - } else { - ibase_result *ib_result; - - ZEND_FETCH_RESOURCE(ib_result, ibase_result *, result, -1, "InterBase result", le_result); - sqlda = ib_result->out_sqlda; - } - - if (sqlda == NULL) { - RETURN_LONG(0); - } else { - RETURN_LONG(sqlda->sqld); - } -} -/* }}} */ - -/* {{{ _php_ibase_field_info() */ -static void _php_ibase_field_info(zval *return_value, XSQLVAR *var) -{ - unsigned short len; - char buf[16], *s = buf; - - array_init(return_value); - - add_index_stringl(return_value, 0, var->sqlname, var->sqlname_length, 1); - add_assoc_stringl(return_value, "name", var->sqlname, var->sqlname_length, 1); - - add_index_stringl(return_value, 1, var->aliasname, var->aliasname_length, 1); - add_assoc_stringl(return_value, "alias", var->aliasname, var->aliasname_length, 1); - - add_index_stringl(return_value, 2, var->relname, var->relname_length, 1); - add_assoc_stringl(return_value, "relation", var->relname, var->relname_length, 1); - - len = sprintf(buf, "%d", var->sqllen); - add_index_stringl(return_value, 3, buf, len, 1); - add_assoc_stringl(return_value, "length", buf, len, 1); - - if (var->sqlscale < 0) { - unsigned short precision; - - switch (var->sqltype & ~1) { - - case SQL_SHORT: - precision = 4; - break; - case SQL_LONG: - precision = 9; - break; -#ifdef SQL_INT64 - case SQL_INT64: - precision = 18; - break; -#endif - } - len = sprintf(buf, "NUMERIC(%d,%d)", precision, -var->sqlscale); - add_index_stringl(return_value, 4, s, len, 1); - add_assoc_stringl(return_value, "type", s, len, 1); - } else { - switch (var->sqltype & ~1) { - case SQL_TEXT: - s = "CHAR"; - break; - case SQL_VARYING: - s = "VARCHAR"; - break; - case SQL_SHORT: - s = "SMALLINT"; - break; - case SQL_LONG: - s = "INTEGER"; - break; - case SQL_FLOAT: - s = "FLOAT"; break; - case SQL_DOUBLE: - case SQL_D_FLOAT: - s = "DOUBLE PRECISION"; break; -#ifdef SQL_INT64 - case SQL_INT64: - s = "BIGINT"; - break; -#endif -#ifdef SQL_TIMESTAMP - case SQL_TIMESTAMP: - s = "TIMESTAMP"; - break; - case SQL_TYPE_DATE: - s = "DATE"; - break; - case SQL_TYPE_TIME: - s = "TIME"; - break; -#else - case SQL_DATE: - s = "DATE"; - break; -#endif - case SQL_BLOB: - s = "BLOB"; - break; - case SQL_ARRAY: - s = "ARRAY"; - break; - /* FIXME: provide more detailed information about the field type, field size - * and array dimensions */ - case SQL_QUAD: - s = "QUAD"; - break; - } - add_index_string(return_value, 4, s, 1); - add_assoc_string(return_value, "type", s, 1); - } -} -/* }}} */ - -/* {{{ proto array ibase_field_info(resource query_result, int field_number) - Get information about a field */ -PHP_FUNCTION(ibase_field_info) -{ - zval **result_arg, **field_arg; - int type; - XSQLDA *sqlda; - - RESET_ERRMSG; - - if (ZEND_NUM_ARGS()!=2 || zend_get_parameters_ex(2, &result_arg, &field_arg)==FAILURE) { - WRONG_PARAM_COUNT; - } - - zend_list_find(Z_LVAL_PP(result_arg), &type); - - if (type == le_query) { - ibase_query *ib_query; - - ZEND_FETCH_RESOURCE(ib_query, ibase_query *, result_arg, -1, "InterBase query", le_query); - sqlda = ib_query->out_sqlda; - } else { - ibase_result *ib_result; - - ZEND_FETCH_RESOURCE(ib_result, ibase_result *, result_arg, -1, "InterBase result", le_result); - sqlda = ib_result->out_sqlda; - } - - if (sqlda == NULL) { - _php_ibase_module_error("Trying to get field info from a non-select query" TSRMLS_CC); - RETURN_FALSE; - } - - convert_to_long_ex(field_arg); - - if (Z_LVAL_PP(field_arg) < 0 || Z_LVAL_PP(field_arg) >= sqlda->sqld) { - RETURN_FALSE; - } - _php_ibase_field_info(return_value,sqlda->sqlvar + Z_LVAL_PP(field_arg)); -} -/* }}} */ - -/* {{{ proto int ibase_num_params(resource query) - Get the number of params in a prepared query */ -PHP_FUNCTION(ibase_num_params) -{ - zval **result; - ibase_query *ib_query; - - RESET_ERRMSG; - - if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &result) == FAILURE) { - WRONG_PARAM_COUNT; - } - - ZEND_FETCH_RESOURCE(ib_query, ibase_query *, result, -1, "InterBase query", le_query); - - if (ib_query->in_sqlda == NULL) { - RETURN_LONG(0); - } else { - RETURN_LONG(ib_query->in_sqlda->sqld); - } -} -/* }}} */ - -/* {{{ proto array ibase_param_info(resource query, int field_number) - Get information about a parameter */ -PHP_FUNCTION(ibase_param_info) -{ - zval **result_arg, **field_arg; - ibase_query *ib_query; - - RESET_ERRMSG; - - if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &result_arg, &field_arg) == FAILURE) { - WRONG_PARAM_COUNT; - } - - ZEND_FETCH_RESOURCE(ib_query, ibase_query *, result_arg, -1, "InterBase query", le_query); - - if (ib_query->in_sqlda == NULL) { - RETURN_FALSE; - } - - convert_to_long_ex(field_arg); - - if (Z_LVAL_PP(field_arg) < 0 || Z_LVAL_PP(field_arg) >= ib_query->in_sqlda->sqld) { - RETURN_FALSE; - } - - _php_ibase_field_info(return_value,ib_query->in_sqlda->sqlvar + Z_LVAL_PP(field_arg)); -} -/* }}} */ - -/* blobs ----------------------------------- */ - -/* {{{ _php_ibase_blob_info(isc_blob_handle bl_handle, IBASE_BLOBINFO *bl_info) */ -static int _php_ibase_blob_info(isc_blob_handle bl_handle, IBASE_BLOBINFO *bl_info TSRMLS_DC) -{ - static char bl_items[] = { - isc_info_blob_num_segments, - isc_info_blob_max_segment, - isc_info_blob_total_length, - isc_info_blob_type - }; - - char bl_inf[sizeof(long)*8], *p; - - bl_info->max_segment = 0; - bl_info->num_segments = 0; - bl_info->total_length = 0; - bl_info->bl_stream = 0; - - if (isc_blob_info(IB_STATUS, &bl_handle, sizeof(bl_items), bl_items, sizeof(bl_inf), bl_inf)) { - _php_ibase_error(TSRMLS_C); - return FAILURE; - } - - for (p = bl_inf; *p != isc_info_end && p < bl_inf + sizeof(bl_inf);) { - unsigned short item_len; - int item = *p++; - - item_len = (short) isc_vax_integer(p, 2); - p += 2; - switch (item) { - case isc_info_blob_num_segments: - bl_info->num_segments = isc_vax_integer(p, item_len); - break; - case isc_info_blob_max_segment: - bl_info->max_segment = isc_vax_integer(p, item_len); - break; - case isc_info_blob_total_length: - bl_info->total_length = isc_vax_integer(p, item_len); - break; - case isc_info_blob_type: - bl_info->bl_stream = isc_vax_integer(p, item_len); - break; - case isc_info_end: - break; - case isc_info_truncated: - case isc_info_error: /* hmm. don't think so...*/ - _php_ibase_module_error("PHP module internal error" TSRMLS_CC); - return FAILURE; - } /* switch */ - p += item_len; - } /* for */ - return SUCCESS; -} -/* }}} */ - -/* {{{ proto resource ibase_blob_create([resource link_identifier]) - Create blob for adding data */ -PHP_FUNCTION(ibase_blob_create) -{ - zval **link_arg; - ibase_db_link *ib_link; - ibase_trans *trans = NULL; - ibase_blob *ib_blob; - - RESET_ERRMSG; - - switch (ZEND_NUM_ARGS()) { - case 0: - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, NULL, IBG(default_link), "InterBase link", le_link, le_plink); - break; - case 1: - if (zend_get_parameters_ex(1, &link_arg) == FAILURE) { - RETURN_FALSE; - } - _php_ibase_get_link_trans(INTERNAL_FUNCTION_PARAM_PASSTHRU, link_arg, &ib_link, &trans); - break; - default: - WRONG_PARAM_COUNT; - break; - } - - /* open default transaction */ - if (_php_ibase_def_trans(ib_link, &trans TSRMLS_CC) == FAILURE) { - RETURN_FALSE; - } - - ib_blob = (ibase_blob *) emalloc(sizeof(ibase_blob)); - ib_blob->bl_handle = NULL; - ib_blob->type = BLOB_INPUT; - - if (isc_create_blob(IB_STATUS, &ib_link->handle, &trans->handle, &ib_blob->bl_handle, &ib_blob->bl_qd)) { - _php_ibase_error(TSRMLS_C); - efree(ib_blob); - RETURN_FALSE; - } - - ZEND_REGISTER_RESOURCE(return_value, ib_blob, le_blob); -} -/* }}} */ - -/* {{{ proto resource ibase_blob_open([ resource link_identifier, ] string blob_id) - Open blob for retrieving data parts */ -PHP_FUNCTION(ibase_blob_open) -{ - zval **blob_arg, **link_arg; - ibase_db_link *link; - ibase_trans *trans = NULL; - ibase_blob *ib_blob; - - RESET_ERRMSG; - - switch (ZEND_NUM_ARGS()) { - - case 1: - if (zend_get_parameters_ex(1, &blob_arg) != SUCCESS) { - WRONG_PARAM_COUNT; - } - ZEND_FETCH_RESOURCE2(link, ibase_db_link *, NULL, IBG(default_link), "InterBase link", le_link, le_plink); - break; - case 2: - if (zend_get_parameters_ex(2, &link_arg, &blob_arg) != SUCCESS) { - WRONG_PARAM_COUNT; - } - _php_ibase_get_link_trans(INTERNAL_FUNCTION_PARAM_PASSTHRU, link_arg, &link, &trans); - break; - default: - WRONG_PARAM_COUNT; - } - - convert_to_string_ex(blob_arg); - - ib_blob = (ibase_blob *) emalloc(sizeof(ibase_blob)); - ib_blob->bl_handle = NULL; - ib_blob->type = BLOB_OUTPUT; - - if (! _php_ibase_string_to_quad(Z_STRVAL_PP(blob_arg), &(ib_blob->bl_qd))) { - _php_ibase_module_error("String is not a BLOB ID" TSRMLS_CC); - efree(ib_blob); - RETURN_FALSE; - } - - /* open default transaction */ - if (_php_ibase_def_trans(link, &trans TSRMLS_CC) == FAILURE) { - efree(ib_blob); - RETURN_FALSE; - } - - if (isc_open_blob(IB_STATUS, &link->handle, &trans->handle, &ib_blob->bl_handle, &ib_blob->bl_qd)) { - _php_ibase_error(TSRMLS_C); - efree(ib_blob); - RETURN_FALSE; - } - - ZEND_REGISTER_RESOURCE(return_value, ib_blob, le_blob); -} -/* }}} */ - -/* {{{ proto bool ibase_blob_add(resource blob_handle, string data) - Add data into created blob */ -PHP_FUNCTION(ibase_blob_add) -{ - zval **blob_arg, **string_arg; - ibase_blob *ib_blob; - - RESET_ERRMSG; - - if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &blob_arg, &string_arg) == FAILURE) { - WRONG_PARAM_COUNT; - } - - ZEND_FETCH_RESOURCE(ib_blob, ibase_blob *, blob_arg, -1, "Interbase blob", le_blob); - - if (ib_blob->type != BLOB_INPUT) { - _php_ibase_module_error("BLOB is not open for input" TSRMLS_CC); - RETURN_FALSE; - } - - if (_php_ibase_blob_add(string_arg, ib_blob TSRMLS_CC) != SUCCESS) { - RETURN_FALSE; - } -} -/* }}} */ - -/* {{{ proto string ibase_blob_get(resource blob_handle, int len) - Get len bytes data from open blob */ -PHP_FUNCTION(ibase_blob_get) -{ - zval **blob_arg, **len_arg; - ibase_blob *ib_blob; - - RESET_ERRMSG; - - if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &blob_arg, &len_arg) == FAILURE) { - WRONG_PARAM_COUNT; - } - - ZEND_FETCH_RESOURCE(ib_blob, ibase_blob *, blob_arg, -1, "Interbase blob", le_blob); - - if (ib_blob->type != BLOB_OUTPUT) { - _php_ibase_module_error("BLOB is not open for output" TSRMLS_CC); - RETURN_FALSE; - } - - convert_to_long_ex(len_arg); - - if (_php_ibase_blob_get(return_value, ib_blob, Z_LVAL_PP(len_arg) TSRMLS_CC) != SUCCESS) { - RETURN_FALSE; - } -} -/* }}} */ - -/* {{{ _php_ibase_blob_end() */ -/* Close or Cancel created or Close open blob */ -static void _php_ibase_blob_end(INTERNAL_FUNCTION_PARAMETERS, int bl_end) -{ - zval **blob_arg; - ibase_blob *ib_blob; - - RESET_ERRMSG; - - if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &blob_arg) == FAILURE) { - WRONG_PARAM_COUNT; - } - - ZEND_FETCH_RESOURCE(ib_blob, ibase_blob *, blob_arg, -1, "Interbase blob", le_blob); - - if (bl_end == BLOB_CLOSE) { /* return id here */ - - if (ib_blob->bl_qd.gds_quad_high || ib_blob->bl_qd.gds_quad_low) { /*not null ?*/ - if (isc_close_blob(IB_STATUS, &ib_blob->bl_handle)) { - _php_ibase_error(TSRMLS_C); - RETURN_FALSE; - } - } - ib_blob->bl_handle = NULL; - - RETVAL_STRINGL(_php_ibase_quad_to_string(ib_blob->bl_qd), BLOB_ID_LEN, 0); - } else { /* discard created blob */ - if (isc_cancel_blob(IB_STATUS, &ib_blob->bl_handle)) { - _php_ibase_error(TSRMLS_C); - RETURN_FALSE; - } - ib_blob->bl_handle = NULL; - RETVAL_BOOL(1); - } - zend_list_delete(Z_LVAL_PP(blob_arg)); -} -/* }}} */ - -/* {{{ proto string ibase_blob_close(resource blob_handle) - Close blob */ -PHP_FUNCTION(ibase_blob_close) -{ - _php_ibase_blob_end(INTERNAL_FUNCTION_PARAM_PASSTHRU, BLOB_CLOSE); -} -/* }}} */ - -/* {{{ proto bool ibase_blob_cancel(resource blob_handle) - Cancel creating blob */ -PHP_FUNCTION(ibase_blob_cancel) -{ - _php_ibase_blob_end(INTERNAL_FUNCTION_PARAM_PASSTHRU, BLOB_CANCEL); -} -/* }}} */ - -/* {{{ proto array ibase_blob_info([ resource link_identifier, ] string blob_id) - Return blob length and other useful info */ -PHP_FUNCTION(ibase_blob_info) -{ - zval **blob_arg, **link_arg; - ibase_db_link *link; - ibase_trans *trans = NULL; - ibase_blob ib_blob = { NULL, { 0, 0 }, BLOB_INPUT }; - IBASE_BLOBINFO bl_info; - - RESET_ERRMSG; - - switch (ZEND_NUM_ARGS()) { - - case 1: - if (zend_get_parameters_ex(1, &blob_arg) != SUCCESS) { - WRONG_PARAM_COUNT; - } - ZEND_FETCH_RESOURCE2(link, ibase_db_link *, NULL, IBG(default_link), "InterBase link", le_link, le_plink); - break; - case 2: - if (zend_get_parameters_ex(2, &link_arg, &blob_arg) != SUCCESS) { - WRONG_PARAM_COUNT; - } - _php_ibase_get_link_trans(INTERNAL_FUNCTION_PARAM_PASSTHRU, link_arg, &link, &trans); - break; - default: - WRONG_PARAM_COUNT; - } - - convert_to_string_ex(blob_arg); - - if (! _php_ibase_string_to_quad(Z_STRVAL_PP(blob_arg), &(ib_blob.bl_qd))) { - _php_ibase_module_error("Unrecognized BLOB ID" TSRMLS_CC); - RETURN_FALSE; - } - - /* open default transaction */ - if (_php_ibase_def_trans(link, &trans TSRMLS_CC) == FAILURE) { - RETURN_FALSE; - } - - if (ib_blob.bl_qd.gds_quad_high || ib_blob.bl_qd.gds_quad_low) { /* not null ? */ - if (isc_open_blob(IB_STATUS, &link->handle, &trans->handle, &ib_blob.bl_handle, &ib_blob.bl_qd)) { - _php_ibase_error(TSRMLS_C); - RETURN_FALSE; - } - - if (_php_ibase_blob_info(ib_blob.bl_handle, &bl_info TSRMLS_CC)) { - RETURN_FALSE; - } - if (isc_close_blob(IB_STATUS, &ib_blob.bl_handle)) { - _php_ibase_error(TSRMLS_C); - RETURN_FALSE; - } - } else { /* null blob, all values to zero */ - bl_info.max_segment = 0; - bl_info.num_segments = 0; - bl_info.total_length = 0; - bl_info.bl_stream = 0; - } - - array_init(return_value); - - add_index_long(return_value, 0, bl_info.total_length); - add_assoc_long(return_value, "length", bl_info.total_length); - - add_index_long(return_value, 1, bl_info.num_segments); - add_assoc_long(return_value, "numseg", bl_info.num_segments); - - add_index_long(return_value, 2, bl_info.max_segment); - add_assoc_long(return_value, "maxseg", bl_info.max_segment); - - add_index_bool(return_value, 3, bl_info.bl_stream); - add_assoc_bool(return_value, "stream", bl_info.bl_stream); - - add_index_bool(return_value, 4, (!ib_blob.bl_qd.gds_quad_high && !ib_blob.bl_qd.gds_quad_low)); - add_assoc_bool(return_value, "isnull", (!ib_blob.bl_qd.gds_quad_high && !ib_blob.bl_qd.gds_quad_low)); -} -/* }}} */ - -/* {{{ proto bool ibase_blob_echo([ resource link_identifier, ] string blob_id) - Output blob contents to browser */ -PHP_FUNCTION(ibase_blob_echo) -{ - zval **blob_arg, **link_arg; - ibase_db_link *link; - ibase_trans *trans = NULL; - ibase_blob ib_blob_id = { NULL, { 0, 0 }, BLOB_OUTPUT }; - char bl_data[IBASE_BLOB_SEG]; - unsigned short seg_len; - - RESET_ERRMSG; - - switch (ZEND_NUM_ARGS()) { - - case 1: - if (zend_get_parameters_ex(1, &blob_arg) != SUCCESS) { - WRONG_PARAM_COUNT; - } - ZEND_FETCH_RESOURCE2(link, ibase_db_link *, NULL, IBG(default_link), "InterBase link", le_link, le_plink); - break; - case 2: - if (zend_get_parameters_ex(2, &link_arg, &blob_arg) != SUCCESS) { - WRONG_PARAM_COUNT; - } - _php_ibase_get_link_trans(INTERNAL_FUNCTION_PARAM_PASSTHRU, link_arg, &link, &trans); - break; - default: - WRONG_PARAM_COUNT; - } - - convert_to_string_ex(blob_arg); - - if (! _php_ibase_string_to_quad(Z_STRVAL_PP(blob_arg), &(ib_blob_id.bl_qd))) { - _php_ibase_module_error("Unrecognized BLOB ID" TSRMLS_CC); - RETURN_FALSE; - } - - /* open default transaction */ - if (_php_ibase_def_trans(link, &trans TSRMLS_CC) == FAILURE) { - RETURN_FALSE; - } - - if (isc_open_blob(IB_STATUS, &link->handle, &trans->handle, &ib_blob_id.bl_handle, &ib_blob_id.bl_qd)) { - _php_ibase_error(TSRMLS_C); - RETURN_FALSE; - } - - while (!isc_get_segment(IB_STATUS, &ib_blob_id.bl_handle, &seg_len, sizeof(bl_data), bl_data) || IB_STATUS[1] == isc_segment) { - PHPWRITE(bl_data, seg_len); - } - - if (IB_STATUS[0] && (IB_STATUS[1] != isc_segstr_eof)) { - _php_ibase_error(TSRMLS_C); - RETURN_FALSE; - } - - if (isc_close_blob(IB_STATUS, &ib_blob_id.bl_handle)) { - _php_ibase_error(TSRMLS_C); - RETURN_FALSE; - } - RETURN_TRUE; -} -/* }}} */ - -/* {{{ proto string ibase_blob_import([resource link_identifier, ] int file_id) - Create blob, copy file in it, and close it */ -PHP_FUNCTION(ibase_blob_import) -{ - zval **link_arg, **file_arg; - int link_id = 0, size; - unsigned short b; - ibase_blob ib_blob = { NULL, { 0, 0 }, 0 }; - ibase_db_link *ib_link; - ibase_trans *trans = NULL; - char bl_data[IBASE_BLOB_SEG]; - php_stream *stream; - - RESET_ERRMSG; - - switch (ZEND_NUM_ARGS()) { - case 1: - if (zend_get_parameters_ex(1, &file_arg) == FAILURE) { - RETURN_FALSE; - } - link_id = IBG(default_link); - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, NULL, link_id, "InterBase link", le_link, le_plink); - break; - case 2: - if (zend_get_parameters_ex(2, &link_arg, &file_arg) == FAILURE) { - RETURN_FALSE; - } - _php_ibase_get_link_trans(INTERNAL_FUNCTION_PARAM_PASSTHRU, link_arg, &ib_link, &trans); - break; - default: - WRONG_PARAM_COUNT; - break; - } - - /* open default transaction */ - if (_php_ibase_def_trans(ib_link, &trans TSRMLS_CC) == FAILURE) { - RETURN_FALSE; - } - - php_stream_from_zval(stream, file_arg); - - if (isc_create_blob(IB_STATUS, &ib_link->handle, &trans->handle, &ib_blob.bl_handle, &ib_blob.bl_qd)) { - _php_ibase_error(TSRMLS_C); - RETURN_FALSE; - } - - size = 0; - - while ((b = php_stream_read(stream, bl_data, sizeof(bl_data))) > 0) { - if (isc_put_segment(IB_STATUS, &ib_blob.bl_handle, b, bl_data)) { - _php_ibase_error(TSRMLS_C); - RETURN_FALSE; - } - size += b; - } - - if (isc_close_blob(IB_STATUS, &ib_blob.bl_handle)) { - _php_ibase_error(TSRMLS_C); - RETURN_FALSE; - } - - RETURN_STRINGL( _php_ibase_quad_to_string(ib_blob.bl_qd), BLOB_ID_LEN, 0); -} -/* }}} */ - -#ifdef SQL_DIALECT_V6 -/* {{{ _php_ibase_user() */ -static void _php_ibase_user(INTERNAL_FUNCTION_PARAMETERS, int operation) -{ - zval **args[8]; - char *ib_server, *dba_user_name, *dba_password, *user_name, *user_password = NULL; - char *first_name = NULL, *middle_name = NULL, *last_name = NULL; - char service_name_buffer[128], *service_name = service_name_buffer; - char spb_buffer[128], *spb = spb_buffer; - unsigned short spb_length; - isc_svc_handle service_handle = NULL; - - RESET_ERRMSG; - - switch (operation) { - case isc_action_svc_add_user: - case isc_action_svc_modify_user: - /* 5 to 8 parameters for ADD or MODIFY operation */ - if (ZEND_NUM_ARGS() < 5 || ZEND_NUM_ARGS() > 8) { - WRONG_PARAM_COUNT; - } - break; - - case isc_action_svc_delete_user: - /* 4 parameters for DELETE operation */ - if (ZEND_NUM_ARGS() != 4) { - WRONG_PARAM_COUNT; - } - } - - if (zend_get_parameters_array_ex(ZEND_NUM_ARGS(), args) == FAILURE) { - RETURN_FALSE; - } - - switch (ZEND_NUM_ARGS()) { - case 8: - convert_to_string_ex(args[7]); - last_name = Z_STRVAL_PP(args[7]); - /* fallout */ - case 7: - convert_to_string_ex(args[6]); - middle_name = Z_STRVAL_PP(args[6]); - /* fallout */ - case 6: - convert_to_string_ex(args[5]); - first_name = Z_STRVAL_PP(args[5]); - /* fallout */ - } - - if (operation != isc_action_svc_delete_user) { - /* Parameter not available for DELETE operation */ - convert_to_string_ex(args[4]); - user_password = Z_STRVAL_PP(args[4]); - } - - convert_to_string_ex(args[3]); - user_name = Z_STRVAL_PP(args[3]); - - convert_to_string_ex(args[2]); - dba_password = Z_STRVAL_PP(args[2]); - - convert_to_string_ex(args[1]); - dba_user_name = Z_STRVAL_PP(args[1]); - - convert_to_string_ex(args[0]); - ib_server = Z_STRVAL_PP(args[0]); - -/* - zend_printf("server : %s<br>", ib_server); - zend_printf("admin : %s<br>", dba_user_name); - zend_printf("admin pwd: %s<br>", dba_password); - zend_printf("user : %s<br>", user_name); - zend_printf("user pwd : %s<br>", user_password); - zend_printf("fname : %s<br>", first_name); - zend_printf("mname : %s<br>", middle_name); - zend_printf("lname : %s<br>", last_name); -*/ - - /* Build buffer for isc_service_attach() */ - *spb++ = isc_spb_version; - *spb++ = isc_spb_current_version; - *spb++ = isc_spb_user_name; - *spb++ = strlen(dba_user_name); - strcpy(spb, dba_user_name); - spb += strlen(dba_user_name); - *spb++ = isc_spb_password; - *spb++ = strlen(dba_password); - strcpy(spb, dba_password); - spb += strlen(dba_password); - spb_length = spb - spb_buffer; - - /* Attach to the Service Manager */ - sprintf(service_name, "%s:service_mgr", ib_server); - if (isc_service_attach(IB_STATUS, 0, service_name, &service_handle, spb_length, spb_buffer)) { - _php_ibase_error(TSRMLS_C); - RETURN_FALSE; - } else { - char request[128], *x, *p = request; - - /* Identify cluster (here, isc_action_svc_*_user) */ - *p++ = operation; - - /* Argument for username */ - *p++ = isc_spb_sec_username; - ADD_SPB_LENGTH(p, strlen(user_name)); - for (x = user_name ; *x;) *p++ = *x++; - - /* Argument for password */ - if (user_password) { - *p++ = isc_spb_sec_password; - ADD_SPB_LENGTH(p, strlen(user_password)); - for (x = user_password ; *x;) *p++ = *x++; - } - - /* Argument for first name */ - if (first_name) { - *p++ = isc_spb_sec_firstname; - ADD_SPB_LENGTH(p, strlen(first_name)); - for (x = first_name ; *x;) *p++ = *x++; - } - - /* Argument for middle name */ - if (middle_name) { - *p++ = isc_spb_sec_middlename; - ADD_SPB_LENGTH(p, strlen(middle_name)); - for (x = middle_name ; *x;) *p++ = *x++; - } - - /* Argument for last name */ - if (last_name) { - *p++ = isc_spb_sec_lastname; - ADD_SPB_LENGTH(p, strlen(last_name)); - for (x = last_name ; *x;) *p++ = *x++; - } - - /* Let's go update: start Service Manager */ - if (isc_service_start(IB_STATUS, &service_handle, NULL, (unsigned short) (p - request), request)) { - _php_ibase_error(TSRMLS_C); - isc_service_detach(IB_STATUS, &service_handle); - RETURN_FALSE; - } else { - /* Detach from Service Manager */ - isc_service_detach(IB_STATUS, &service_handle); - } - } - - RETURN_TRUE; -} -/* }}} */ - -/* {{{ proto bool ibase_add_user(string server, string dba_user_name, string dba_password, string user_name, string password [, string first_name [, string middle_name [, string last_name]]]) - Add an user to security database (only for IB6 or later) */ -PHP_FUNCTION(ibase_add_user) -{ - _php_ibase_user(INTERNAL_FUNCTION_PARAM_PASSTHRU, isc_action_svc_add_user); -} -/* }}} */ - -/* {{{ proto bool ibase_modify_user(string server, string dba_user_name, string dba_password, string user_name, string password [, string first_name [, string middle_name [, string last_name]]]) - Modify an user in security database (only for IB6 or later) */ -PHP_FUNCTION(ibase_modify_user) -{ - _php_ibase_user(INTERNAL_FUNCTION_PARAM_PASSTHRU, isc_action_svc_modify_user); -} -/* }}} */ - -/* {{{ proto bool ibase_delete_user(string server, string dba_user_name, string dba_password, string username) - Delete an user from security database (only for IB6 or later) */ -PHP_FUNCTION(ibase_delete_user) -{ - _php_ibase_user(INTERNAL_FUNCTION_PARAM_PASSTHRU, isc_action_svc_delete_user); -} -/* }}} */ -#endif /* SQL_DIALECT_V6 */ - -/* {{{ _php_ibase_event_block() */ -static void _php_ibase_event_block(ibase_db_link *ib_link, unsigned short count, char **events, - unsigned short *l, char **event_buf, char **result_buf) -{ - ISC_STATUS dummy_result[20]; - unsigned long dummy_count[15]; - - /** - * Unfortunately, there's no clean and portable way in C to pass arguments to - * a variadic function if you don't know the number of arguments at compile time. - * (And even if there were a way, the Interbase API doesn't provide a version of - * this function that takes a va_list as an argument) - * - * In this case, the number of arguments is limited to 18 by the underlying API, - * so we can work around it. - */ - - *l = (unsigned short) isc_event_block(event_buf, result_buf, count, events[0], - events[1], events[2], events[3], events[4], events[5], events[6], events[7], - events[8], events[9], events[10], events[11], events[12], events[13], events[14]); - - /** - * Currently, this is the only way to correctly initialize an event buffer. - * This is clearly something that should be fixed, cause the semantics of - * isc_wait_for_event() indicate that it blocks until an event occurs. - * If the Firebird people ever fix this, these lines should be removed, - * otherwise, events will have to fire twice before ibase_wait_event() returns. - */ - - isc_wait_for_event(dummy_result, &ib_link->handle, *l, *event_buf, *result_buf); - isc_event_counts(dummy_count, *l, *event_buf, *result_buf); -} -/* }}} */ - -/* {{{ proto string ibase_wait_event([resource link_identifier,] string event [, string event [, ...]]) - Waits for any one of the passed Interbase events to be posted by the database, and returns its name */ -PHP_FUNCTION(ibase_wait_event) -{ - zval ***args; - ibase_db_link *ib_link; - char *event_buffer, *result_buffer, *events[15]; - unsigned short i = 0, event_count = 0, buffer_size; - unsigned long occurred_event[15]; - - RESET_ERRMSG; - - /* no more than 15 events */ - if (ZEND_NUM_ARGS() < 1 || ZEND_NUM_ARGS() > 16) { - WRONG_PARAM_COUNT; - } - - args = (zval ***) safe_emalloc(sizeof(zval **), ZEND_NUM_ARGS(), 0); - if (zend_get_parameters_array_ex(ZEND_NUM_ARGS(), args) == FAILURE) { - efree(args); - RETURN_FALSE; - } - - if (Z_TYPE_PP(args[0]) == IS_RESOURCE) { - - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, args[0], -1, "InterBase link", le_link, le_plink); - i = 1; - - } else { - - if (ZEND_NUM_ARGS() > 15) { - efree(args); - WRONG_PARAM_COUNT; - } - - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, NULL, IBG(default_link), "InterBase link", le_link, le_plink); - } - - for (; i < ZEND_NUM_ARGS(); ++i) { - convert_to_string_ex(args[i]); - events[event_count++] = Z_STRVAL_PP(args[i]); - } - - /* fills the required data structure with information about the events */ - _php_ibase_event_block(ib_link, event_count, events, &buffer_size, &event_buffer, &result_buffer); - - /* now block until an event occurs */ - if (isc_wait_for_event(IB_STATUS, &ib_link->handle, buffer_size, event_buffer, result_buffer)) { - _php_ibase_error(TSRMLS_C); - _php_ibase_event_free(event_buffer,result_buffer); - efree(args); - RETURN_FALSE; - } - - /* find out which event occurred */ - isc_event_counts(occurred_event, buffer_size, event_buffer, result_buffer); - for (i = 0; i < event_count; ++i) { - if (occurred_event[i]) { - char *result = estrdup(events[i]); - _php_ibase_event_free(event_buffer,result_buffer); - efree(args); - RETURN_STRING(result,0); - } - } - - /* If we reach this line, isc_wait_for_event() did return, but we don't know - which event fired. */ - _php_ibase_event_free(event_buffer,result_buffer); - efree(args); - RETURN_FALSE; -} -/* }}} */ - -/* {{{ _php_ibase_callback() */ -static isc_callback _php_ibase_callback(ibase_event *event, unsigned short buffer_size, char *result_buf) -{ - /* this function is called asynchronously by the Interbase client library. */ - TSRMLS_FETCH_FROM_CTX(event->thread_ctx); - - /** - * The callback function is called when the event is first registered and when the event - * is cancelled. I consider this is a bug. By clearing event->callback, we make sure - * nothing happens if no event was actually posted. - */ - if (event->callback != NULL) { - - unsigned short i; - unsigned long occurred_event[15]; - zval event_name, link_id, return_value, *args[2]; - - /* initialize at runtime to satisify picky compilers */ - args[0] = &event_name; - args[1] = &link_id; - - /* copy the updated results into the result buffer */ - memcpy(event->result_buffer, result_buf, buffer_size); - - INIT_ZVAL(event_name); - INIT_ZVAL(link_id); - ZVAL_RESOURCE(&link_id, event->link_res_id); - - /* find out which event occurred */ - isc_event_counts(occurred_event, buffer_size, event->event_buffer, event->result_buffer); - for (i = 0; i < event->event_count; ++i) { - if (occurred_event[i]) { - ZVAL_STRING(&event_name,event->events[i],0); - break; - } - } - - /* call the callback provided by the user */ - if (SUCCESS != call_user_function(EG(function_table), NULL, event->callback, &return_value, 2, args TSRMLS_CC)) { - _php_ibase_module_error("Error calling callback %s" TSRMLS_CC, Z_STRVAL_P(event->callback)); - return 0; - } - - if (Z_TYPE(return_value) == IS_BOOL && !Z_BVAL(return_value)) { - return 0; - } - } - - /* re-register the event */ - if (isc_que_events(IB_STATUS, &event->link->handle, &event->event_id, buffer_size, - event->event_buffer,(isc_callback)_php_ibase_callback, (void *)event)) { - - _php_ibase_error(TSRMLS_C); - } - return 0; -} -/* }}} */ - -/* {{{ proto resource ibase_set_event_handler([resource link_identifier,] callback handler, string event [, string event [, ...]]) - Register the callback for handling each of the named events */ -PHP_FUNCTION(ibase_set_event_handler) -{ - /** - * The callback passed to this function should take an event name (string) and a - * link resource id (int) as arguments. The value returned from the function is - * used to determine if the event handler should remain set. - */ - - zval ***args, **cb_arg; - ibase_db_link *ib_link; - ibase_event *event; - char *callback_name; - unsigned short i = 1, buffer_size; - int link_res_id; - - RESET_ERRMSG; - - /* no more than 15 events */ - if (ZEND_NUM_ARGS() < 1 || ZEND_NUM_ARGS() > 17) { - WRONG_PARAM_COUNT; - } - - args = (zval ***) safe_emalloc(sizeof(zval **), ZEND_NUM_ARGS(), 0); - if (zend_get_parameters_array_ex(ZEND_NUM_ARGS(), args) == FAILURE) { - efree(args); - RETURN_FALSE; - } - - /* get a working link */ - if (Z_TYPE_PP(args[0]) != IS_STRING) { - - cb_arg = args[1]; - i = 2; - - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, args[0], -1, "InterBase link", le_link, le_plink); - - convert_to_long_ex(args[0]); - link_res_id = Z_LVAL_PP(args[0]); - - } else { - - if (ZEND_NUM_ARGS() > 16) { - efree(args); - WRONG_PARAM_COUNT; - } - - cb_arg = args[0]; - - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, NULL, IBG(default_link), "InterBase link", le_link, le_plink); - link_res_id = IBG(default_link); - } - - /* get the callback */ - if (!zend_is_callable(*cb_arg, 0, &callback_name)) { - _php_ibase_module_error("Callback argument %s is not a callable function" TSRMLS_CC, callback_name); - efree(callback_name); - efree(args); - RETURN_FALSE; - } - efree(callback_name); - - /* allocate the event resource */ - event = (ibase_event *) safe_emalloc(sizeof(ibase_event), 1, 0); - TSRMLS_SET_CTX(event->thread_ctx); - event->link_res_id = link_res_id; - event->link = ib_link; - event->event_count = 0; - event->callback = NULL; - event->events = (char **) safe_emalloc(sizeof(char *),ZEND_NUM_ARGS()-i,0); - - for (; i < ZEND_NUM_ARGS(); ++i) { - convert_to_string_ex(args[i]); - event->events[event->event_count++] = estrdup(Z_STRVAL_PP(args[i])); - } - - /* fills the required data structure with information about the events */ - _php_ibase_event_block(ib_link, event->event_count, event->events, - &buffer_size, &event->event_buffer, &event->result_buffer); - - /* now register the events with the Interbase API */ - if (isc_que_events(IB_STATUS, &ib_link->handle, &event->event_id, buffer_size, - event->event_buffer,(isc_callback)_php_ibase_callback, (void *)event)) { - - _php_ibase_error(TSRMLS_C); - efree(args); - efree(event); - RETURN_FALSE; - } - - ALLOC_ZVAL(event->callback); - *event->callback = **cb_arg; - INIT_PZVAL(event->callback); - zval_copy_ctor(event->callback); - - efree(args); - - ZEND_REGISTER_RESOURCE(return_value, event, le_event); - zend_list_addref(Z_LVAL_P(return_value)); -} - -/* {{{ proto bool ibase_free_event_handler(resource event) - Frees the event handler set by ibase_set_event_handler() */ -PHP_FUNCTION(ibase_free_event_handler) -{ - zval **event_arg; - ibase_event *event; - - RESET_ERRMSG; - - if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &event_arg) == FAILURE) { - WRONG_PARAM_COUNT; - } - - ZEND_FETCH_RESOURCE(event, ibase_event *, event_arg, -1, "Interbase event", le_event); - zend_list_delete(Z_LVAL_PP(event_arg)); - RETURN_TRUE; -} -/* }}} */ - -/* {{{ proto int ibase_gen_id([ resource link_identifier, ] string generator [, int increment ]) - Increments the named generator and returns its new value */ -PHP_FUNCTION(ibase_gen_id) -{ - char query[128]; - - zval **arg1, **arg2, **arg3, **query_arg; - ibase_db_link *ib_link; - ibase_trans *trans = NULL; - long increment; -#ifdef SQL_INT64 - ISC_INT64 result; -#else - ISC_LONG result; -#endif - - XSQLDA out_sqlda; - - RESET_ERRMSG; - - switch (ZEND_NUM_ARGS()) { - case 1: - if (zend_get_parameters_ex(1, &arg1) == FAILURE) { - RETURN_FALSE; - } - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, NULL, IBG(default_link), "InterBase link", le_link, le_plink); - query_arg = arg1; - increment = 1; - break; - case 2: - if (zend_get_parameters_ex(2, &arg1, &arg2) == FAILURE) { - RETURN_FALSE; - } - - if (Z_TYPE_PP(arg1) == IS_STRING) /* first param is generator, second is inc */ - { - query_arg = arg1; - convert_to_long_ex(arg2); - increment = Z_LVAL_PP(arg2); - - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, NULL, IBG(default_link), "InterBase link", le_link, le_plink); - } else { - _php_ibase_get_link_trans(INTERNAL_FUNCTION_PARAM_PASSTHRU, arg1, &ib_link, &trans); - query_arg = arg2; - increment = 1; - } - break; - case 3: - if (zend_get_parameters_ex(3, &arg1, &arg2, &arg3) == FAILURE) { - RETURN_FALSE; - } - ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link*, arg1, -1, "InterBase link", le_link, le_plink); - - query_arg = arg2; - convert_to_long_ex(arg3); - increment = Z_LVAL_PP(arg3); - - break; - default: - WRONG_PARAM_COUNT; - break; - } - - convert_to_string_ex(query_arg); - sprintf(query, "SELECT GEN_ID(%s,%ld) FROM rdb$database", Z_STRVAL_PP(query_arg), increment); - - /* open default transaction */ - if (_php_ibase_def_trans(ib_link, &trans TSRMLS_CC) == FAILURE) { - RETURN_FALSE; - } - - /* allocate a minimal descriptor area */ - out_sqlda.sqln = out_sqlda.sqld = 1; - out_sqlda.version = SQLDA_CURRENT_VERSION; - - /* allocate the field for the result */ -#ifdef SQL_INT64 - out_sqlda.sqlvar[0].sqltype = SQL_INT64; -#else - out_sqlda.sqlvar[0].sqltype = SQL_LONG; -#endif - out_sqlda.sqlvar[0].sqlscale = 0; - out_sqlda.sqlvar[0].sqllen = sizeof(result); - out_sqlda.sqlvar[0].sqldata = (void*) &result; - - /* execute the query */ - if (isc_dsql_exec_immed2(IB_STATUS, &ib_link->handle, &trans->handle, 0, query, SQL_DIALECT_CURRENT, NULL, &out_sqlda)) - { - _php_ibase_error(TSRMLS_C); - RETURN_FALSE; - } - - /* don't return the generator value as a string unless it doesn't fit in a long */ -#ifdef SQL_INT64 - if (result > LONG_MAX) - { - char res[24]; - - sprintf(res,"%" LL_MASK "d", result); - RETURN_STRING(res,1); - } -#endif - RETURN_LONG((long)result); -} - -/* }}} */ - -#endif /* HAVE_IBASE */ - -/* - * Local variables: - * tab-width: 4 - * c-basic-offset: 4 - * End: - * vim600: sw=4 ts=4 fdm=marker - * vim<600: sw=4 ts=4 - */ |