mirror of
https://github.com/php/php-src.git
synced 2024-09-22 10:27:25 +00:00
4b778faa80
Improve some error handling to produce error text on some rare edge cases. Disambiguate the Oracle library function call return status values from ORA error numbers. Review and unify error data types.
840 lines
25 KiB
C
840 lines
25 KiB
C
/*
|
|
+----------------------------------------------------------------------+
|
|
| PHP Version 5 |
|
|
+----------------------------------------------------------------------+
|
|
| Copyright (c) 1997-2013 The PHP Group |
|
|
+----------------------------------------------------------------------+
|
|
| This source file is subject to version 3.01 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_01.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: Stig Sæther Bakken <ssb@php.net> |
|
|
| Thies C. Arntzen <thies@thieso.net> |
|
|
| |
|
|
| Collection support by Andy Sautins <asautins@veripost.net> |
|
|
| Temporary LOB support by David Benson <dbenson@mancala.com> |
|
|
| ZTS per process OCIPLogon by Harald Radi <harald.radi@nme.at> |
|
|
| |
|
|
| Redesigned by: Antony Dovgal <antony@zend.com> |
|
|
| Andi Gutmans <andi@zend.com> |
|
|
| Wez Furlong <wez@omniti.com> |
|
|
+----------------------------------------------------------------------+
|
|
*/
|
|
|
|
/* $Id$ */
|
|
|
|
|
|
|
|
#ifdef HAVE_CONFIG_H
|
|
#include "config.h"
|
|
#endif
|
|
|
|
#include "php.h"
|
|
#include "ext/standard/info.h"
|
|
#include "php_ini.h"
|
|
|
|
#if HAVE_OCI8
|
|
|
|
#include "php_oci8.h"
|
|
#include "php_oci8_int.h"
|
|
|
|
/* {{{ php_oci_collection_create()
|
|
Create and return connection handle */
|
|
php_oci_collection *php_oci_collection_create(php_oci_connection *connection, char *tdo, int tdo_len, char *schema, int schema_len TSRMLS_DC)
|
|
{
|
|
dvoid *dschp1 = NULL;
|
|
dvoid *parmp1;
|
|
dvoid *parmp2;
|
|
php_oci_collection *collection;
|
|
sword errstatus;
|
|
|
|
collection = emalloc(sizeof(php_oci_collection));
|
|
|
|
collection->connection = connection;
|
|
collection->collection = NULL;
|
|
zend_list_addref(collection->connection->id);
|
|
|
|
/* get type handle by name */
|
|
PHP_OCI_CALL_RETURN(errstatus, OCITypeByName,
|
|
(
|
|
connection->env,
|
|
connection->err,
|
|
connection->svc,
|
|
(text *) schema,
|
|
(ub4) schema_len,
|
|
(text *) tdo,
|
|
(ub4) tdo_len,
|
|
(CONST text *) 0,
|
|
(ub4) 0,
|
|
OCI_DURATION_SESSION,
|
|
OCI_TYPEGET_ALL,
|
|
&(collection->tdo)
|
|
)
|
|
);
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
goto CLEANUP;
|
|
}
|
|
|
|
/* allocate describe handle */
|
|
PHP_OCI_CALL_RETURN(errstatus, OCIHandleAlloc, (connection->env, (dvoid **) &dschp1, (ub4) OCI_HTYPE_DESCRIBE, (size_t) 0, (dvoid **) 0));
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
goto CLEANUP;
|
|
}
|
|
|
|
/* describe TDO */
|
|
PHP_OCI_CALL_RETURN(errstatus, OCIDescribeAny,
|
|
(
|
|
connection->svc,
|
|
connection->err,
|
|
(dvoid *) collection->tdo,
|
|
(ub4) 0,
|
|
OCI_OTYPE_PTR,
|
|
(ub1) OCI_DEFAULT,
|
|
(ub1) OCI_PTYPE_TYPE,
|
|
dschp1
|
|
)
|
|
);
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
goto CLEANUP;
|
|
}
|
|
|
|
/* get first parameter handle */
|
|
PHP_OCI_CALL_RETURN(errstatus, OCIAttrGet, ((dvoid *) dschp1, (ub4) OCI_HTYPE_DESCRIBE, (dvoid *)&parmp1, (ub4 *)0, (ub4)OCI_ATTR_PARAM, connection->err));
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
goto CLEANUP;
|
|
}
|
|
|
|
/* get the collection type code of the attribute */
|
|
PHP_OCI_CALL_RETURN(errstatus, OCIAttrGet,
|
|
(
|
|
(dvoid*) parmp1,
|
|
(ub4) OCI_DTYPE_PARAM,
|
|
(dvoid*) &(collection->coll_typecode),
|
|
(ub4 *) 0,
|
|
(ub4) OCI_ATTR_COLLECTION_TYPECODE,
|
|
connection->err
|
|
)
|
|
);
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
goto CLEANUP;
|
|
}
|
|
|
|
switch(collection->coll_typecode) {
|
|
case OCI_TYPECODE_TABLE:
|
|
case OCI_TYPECODE_VARRAY:
|
|
/* get collection element handle */
|
|
PHP_OCI_CALL_RETURN(errstatus, OCIAttrGet,
|
|
(
|
|
(dvoid*) parmp1,
|
|
(ub4) OCI_DTYPE_PARAM,
|
|
(dvoid*) &parmp2,
|
|
(ub4 *) 0,
|
|
(ub4) OCI_ATTR_COLLECTION_ELEMENT,
|
|
connection->err
|
|
)
|
|
);
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
goto CLEANUP;
|
|
}
|
|
|
|
/* get REF of the TDO for the type */
|
|
PHP_OCI_CALL_RETURN(errstatus, OCIAttrGet,
|
|
(
|
|
(dvoid*) parmp2,
|
|
(ub4) OCI_DTYPE_PARAM,
|
|
(dvoid*) &(collection->elem_ref),
|
|
(ub4 *) 0,
|
|
(ub4) OCI_ATTR_REF_TDO,
|
|
connection->err
|
|
)
|
|
);
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
goto CLEANUP;
|
|
}
|
|
|
|
/* get the TDO (only header) */
|
|
PHP_OCI_CALL_RETURN(errstatus, OCITypeByRef,
|
|
(
|
|
connection->env,
|
|
connection->err,
|
|
collection->elem_ref,
|
|
OCI_DURATION_SESSION,
|
|
OCI_TYPEGET_HEADER,
|
|
&(collection->element_type)
|
|
)
|
|
);
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
goto CLEANUP;
|
|
}
|
|
|
|
/* get typecode */
|
|
PHP_OCI_CALL_RETURN(errstatus, OCIAttrGet,
|
|
(
|
|
(dvoid*) parmp2,
|
|
(ub4) OCI_DTYPE_PARAM,
|
|
(dvoid*) &(collection->element_typecode),
|
|
(ub4 *) 0,
|
|
(ub4) OCI_ATTR_TYPECODE,
|
|
connection->err
|
|
)
|
|
);
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
goto CLEANUP;
|
|
}
|
|
break;
|
|
/* we only support VARRAYs and TABLEs */
|
|
default:
|
|
php_error_docref(NULL TSRMLS_CC, E_WARNING, "unknown collection type %d", collection->coll_typecode);
|
|
break;
|
|
}
|
|
|
|
/* Create object to hold return table */
|
|
PHP_OCI_CALL_RETURN(errstatus, OCIObjectNew,
|
|
(
|
|
connection->env,
|
|
connection->err,
|
|
connection->svc,
|
|
OCI_TYPECODE_TABLE,
|
|
collection->tdo,
|
|
(dvoid *)0,
|
|
OCI_DURATION_DEFAULT,
|
|
TRUE,
|
|
(dvoid **) &(collection->collection)
|
|
)
|
|
);
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
goto CLEANUP;
|
|
}
|
|
|
|
/* free the describe handle (Bug #44113) */
|
|
PHP_OCI_CALL(OCIHandleFree, ((dvoid *) dschp1, OCI_HTYPE_DESCRIBE));
|
|
PHP_OCI_REGISTER_RESOURCE(collection, le_collection);
|
|
connection->errcode = 0; /* retain backwards compat with OCI8 1.4 */
|
|
return collection;
|
|
|
|
CLEANUP:
|
|
|
|
if (dschp1) {
|
|
/* free the describe handle (Bug #44113) */
|
|
PHP_OCI_CALL(OCIHandleFree, ((dvoid *) dschp1, OCI_HTYPE_DESCRIBE));
|
|
}
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
php_oci_collection_close(collection TSRMLS_CC);
|
|
return NULL;
|
|
}
|
|
/* }}} */
|
|
|
|
/* {{{ php_oci_collection_size()
|
|
Return size of the collection */
|
|
int php_oci_collection_size(php_oci_collection *collection, sb4 *size TSRMLS_DC)
|
|
{
|
|
php_oci_connection *connection = collection->connection;
|
|
sword errstatus;
|
|
|
|
PHP_OCI_CALL_RETURN(errstatus, OCICollSize, (connection->env, connection->err, collection->collection, (sb4 *)size));
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
return 1;
|
|
}
|
|
connection->errcode = 0; /* retain backwards compat with OCI8 1.4 */
|
|
return 0;
|
|
}
|
|
/* }}} */
|
|
|
|
/* {{{ php_oci_collection_max()
|
|
Return max number of elements in the collection */
|
|
int php_oci_collection_max(php_oci_collection *collection, long *max TSRMLS_DC)
|
|
{
|
|
php_oci_connection *connection = collection->connection;
|
|
|
|
PHP_OCI_CALL_RETURN(*max, OCICollMax, (connection->env, collection->collection));
|
|
|
|
/* error handling is not necessary here? */
|
|
return 0;
|
|
}
|
|
/* }}} */
|
|
|
|
/* {{{ php_oci_collection_trim()
|
|
Trim collection to the given number of elements */
|
|
int php_oci_collection_trim(php_oci_collection *collection, long trim_size TSRMLS_DC)
|
|
{
|
|
php_oci_connection *connection = collection->connection;
|
|
sword errstatus;
|
|
|
|
PHP_OCI_CALL_RETURN(errstatus, OCICollTrim, (connection->env, connection->err, trim_size, collection->collection));
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
errstatus = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
return 1;
|
|
}
|
|
connection->errcode = 0; /* retain backwards compat with OCI8 1.4 */
|
|
return 0;
|
|
}
|
|
/* }}} */
|
|
|
|
/* {{{ php_oci_collection_append_null()
|
|
Append NULL element to the end of the collection */
|
|
int php_oci_collection_append_null(php_oci_collection *collection TSRMLS_DC)
|
|
{
|
|
OCIInd null_index = OCI_IND_NULL;
|
|
php_oci_connection *connection = collection->connection;
|
|
sword errstatus;
|
|
|
|
/* append NULL element */
|
|
PHP_OCI_CALL_RETURN(errstatus, OCICollAppend, (connection->env, connection->err, (dvoid *)0, &null_index, collection->collection));
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
errstatus = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
return 1;
|
|
}
|
|
connection->errcode = 0; /* retain backwards compat with OCI8 1.4 */
|
|
return 0;
|
|
}
|
|
/* }}} */
|
|
|
|
/* {{{ php_oci_collection_append_date()
|
|
Append DATE element to the end of the collection (use "DD-MON-YY" format) */
|
|
int php_oci_collection_append_date(php_oci_collection *collection, char *date, int date_len TSRMLS_DC)
|
|
{
|
|
OCIInd new_index = OCI_IND_NOTNULL;
|
|
OCIDate oci_date;
|
|
php_oci_connection *connection = collection->connection;
|
|
sword errstatus;
|
|
|
|
/* format and language are NULLs, so format is "DD-MON-YY" and language is the default language of the session */
|
|
PHP_OCI_CALL_RETURN(errstatus, OCIDateFromText, (connection->err, (CONST text *)date, date_len, NULL, 0, NULL, 0, &oci_date));
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
/* failed to convert string to date */
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
return 1;
|
|
}
|
|
|
|
PHP_OCI_CALL_RETURN(errstatus, OCICollAppend,
|
|
(
|
|
connection->env,
|
|
connection->err,
|
|
(dvoid *) &oci_date,
|
|
(dvoid *) &new_index,
|
|
(OCIColl *) collection->collection
|
|
)
|
|
);
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
return 1;
|
|
}
|
|
|
|
connection->errcode = 0; /* retain backwards compat with OCI8 1.4 */
|
|
return 0;
|
|
}
|
|
/* }}} */
|
|
|
|
/* {{{ php_oci_collection_append_number()
|
|
Append NUMBER to the end of the collection */
|
|
int php_oci_collection_append_number(php_oci_collection *collection, char *number, int number_len TSRMLS_DC)
|
|
{
|
|
OCIInd new_index = OCI_IND_NOTNULL;
|
|
double element_double;
|
|
OCINumber oci_number;
|
|
php_oci_connection *connection = collection->connection;
|
|
sword errstatus;
|
|
|
|
#if (PHP_MAJOR_VERSION == 4 && PHP_MINOR_VERSION == 3 && PHP_RELEASE_VERSION < 10)
|
|
/* minimum PHP version ext/oci8/config.m4 accepts is 4.3.9 */
|
|
element_double = strtod(number, NULL);
|
|
#else
|
|
/* zend_strtod was introduced in PHP 4.3.10 */
|
|
element_double = zend_strtod(number, NULL);
|
|
#endif
|
|
|
|
PHP_OCI_CALL_RETURN(errstatus, OCINumberFromReal, (connection->err, &element_double, sizeof(double), &oci_number));
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
return 1;
|
|
}
|
|
|
|
PHP_OCI_CALL_RETURN(errstatus, OCICollAppend,
|
|
(
|
|
connection->env,
|
|
connection->err,
|
|
(dvoid *) &oci_number,
|
|
(dvoid *) &new_index,
|
|
(OCIColl *) collection->collection
|
|
)
|
|
);
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
return 1;
|
|
}
|
|
|
|
connection->errcode = 0; /* retain backwards compat with OCI8 1.4 */
|
|
return 0;
|
|
}
|
|
/* }}} */
|
|
|
|
/* {{{ php_oci_collection_append_string()
|
|
Append STRING to the end of the collection */
|
|
int php_oci_collection_append_string(php_oci_collection *collection, char *element, int element_len TSRMLS_DC)
|
|
{
|
|
OCIInd new_index = OCI_IND_NOTNULL;
|
|
OCIString *ocistr = (OCIString *)0;
|
|
php_oci_connection *connection = collection->connection;
|
|
sword errstatus;
|
|
|
|
PHP_OCI_CALL_RETURN(errstatus, OCIStringAssignText, (connection->env, connection->err, (CONST oratext *)element, element_len, &ocistr));
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
return 1;
|
|
}
|
|
|
|
PHP_OCI_CALL_RETURN(errstatus, OCICollAppend,
|
|
(
|
|
connection->env,
|
|
connection->err,
|
|
(dvoid *) ocistr,
|
|
(dvoid *) &new_index,
|
|
(OCIColl *) collection->collection
|
|
)
|
|
);
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
return 1;
|
|
}
|
|
|
|
connection->errcode = 0; /* retain backwards compat with OCI8 1.4 */
|
|
return 0;
|
|
}
|
|
/* }}} */
|
|
|
|
/* {{{ php_oci_collection_append()
|
|
Append wrapper. Appends any supported element to the end of the collection */
|
|
int php_oci_collection_append(php_oci_collection *collection, char *element, int element_len TSRMLS_DC)
|
|
{
|
|
if (element_len == 0) {
|
|
return php_oci_collection_append_null(collection TSRMLS_CC);
|
|
}
|
|
|
|
switch(collection->element_typecode) {
|
|
case OCI_TYPECODE_DATE:
|
|
return php_oci_collection_append_date(collection, element, element_len TSRMLS_CC);
|
|
break;
|
|
|
|
case OCI_TYPECODE_VARCHAR2 :
|
|
return php_oci_collection_append_string(collection, element, element_len TSRMLS_CC);
|
|
break;
|
|
|
|
case OCI_TYPECODE_UNSIGNED16 : /* UNSIGNED SHORT */
|
|
case OCI_TYPECODE_UNSIGNED32 : /* UNSIGNED LONG */
|
|
case OCI_TYPECODE_REAL : /* REAL */
|
|
case OCI_TYPECODE_DOUBLE : /* DOUBLE */
|
|
case OCI_TYPECODE_INTEGER : /* INT */
|
|
case OCI_TYPECODE_SIGNED16 : /* SHORT */
|
|
case OCI_TYPECODE_SIGNED32 : /* LONG */
|
|
case OCI_TYPECODE_DECIMAL : /* DECIMAL */
|
|
case OCI_TYPECODE_FLOAT : /* FLOAT */
|
|
case OCI_TYPECODE_NUMBER : /* NUMBER */
|
|
case OCI_TYPECODE_SMALLINT : /* SMALLINT */
|
|
return php_oci_collection_append_number(collection, element, element_len TSRMLS_CC);
|
|
break;
|
|
|
|
default:
|
|
php_error_docref(NULL TSRMLS_CC, E_NOTICE, "Unknown or unsupported type of element: %d", collection->element_typecode);
|
|
return 1;
|
|
break;
|
|
}
|
|
/* never reached */
|
|
return 1;
|
|
}
|
|
/* }}} */
|
|
|
|
/* {{{ php_oci_collection_element_get()
|
|
Get the element with the given index */
|
|
int php_oci_collection_element_get(php_oci_collection *collection, long index, zval **result_element TSRMLS_DC)
|
|
{
|
|
php_oci_connection *connection = collection->connection;
|
|
dvoid *element;
|
|
OCIInd *element_index;
|
|
boolean exists;
|
|
oratext buff[1024];
|
|
ub4 buff_len = 1024;
|
|
sword errstatus;
|
|
|
|
MAKE_STD_ZVAL(*result_element);
|
|
ZVAL_NULL(*result_element);
|
|
|
|
connection->errcode = 0; /* retain backwards compat with OCI8 1.4 */
|
|
|
|
PHP_OCI_CALL_RETURN(errstatus, OCICollGetElem,
|
|
(
|
|
connection->env,
|
|
connection->err,
|
|
collection->collection,
|
|
(ub4)index,
|
|
&exists,
|
|
&element,
|
|
(dvoid **)&element_index
|
|
)
|
|
);
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
FREE_ZVAL(*result_element);
|
|
return 1;
|
|
}
|
|
|
|
if (exists == 0) {
|
|
/* element doesn't exist */
|
|
FREE_ZVAL(*result_element);
|
|
return 1;
|
|
}
|
|
|
|
if (*element_index == OCI_IND_NULL) {
|
|
/* this is not an error, we're returning NULL here */
|
|
return 0;
|
|
}
|
|
|
|
switch (collection->element_typecode) {
|
|
case OCI_TYPECODE_DATE:
|
|
PHP_OCI_CALL_RETURN(errstatus, OCIDateToText, (connection->err, element, 0, 0, 0, 0, &buff_len, buff));
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
FREE_ZVAL(*result_element);
|
|
return 1;
|
|
}
|
|
|
|
ZVAL_STRINGL(*result_element, (char *)buff, buff_len, 1);
|
|
Z_STRVAL_P(*result_element)[buff_len] = '\0';
|
|
|
|
return 0;
|
|
break;
|
|
|
|
case OCI_TYPECODE_VARCHAR2:
|
|
{
|
|
OCIString *oci_string = *(OCIString **)element;
|
|
text *str;
|
|
|
|
PHP_OCI_CALL_RETURN(str, OCIStringPtr, (connection->env, oci_string));
|
|
|
|
if (str) {
|
|
ZVAL_STRING(*result_element, (char *)str, 1);
|
|
}
|
|
return 0;
|
|
}
|
|
break;
|
|
|
|
case OCI_TYPECODE_UNSIGNED16: /* UNSIGNED SHORT */
|
|
case OCI_TYPECODE_UNSIGNED32: /* UNSIGNED LONG */
|
|
case OCI_TYPECODE_REAL: /* REAL */
|
|
case OCI_TYPECODE_DOUBLE: /* DOUBLE */
|
|
case OCI_TYPECODE_INTEGER: /* INT */
|
|
case OCI_TYPECODE_SIGNED16: /* SHORT */
|
|
case OCI_TYPECODE_SIGNED32: /* LONG */
|
|
case OCI_TYPECODE_DECIMAL: /* DECIMAL */
|
|
case OCI_TYPECODE_FLOAT: /* FLOAT */
|
|
case OCI_TYPECODE_NUMBER: /* NUMBER */
|
|
case OCI_TYPECODE_SMALLINT: /* SMALLINT */
|
|
{
|
|
double double_number;
|
|
|
|
PHP_OCI_CALL_RETURN(errstatus, OCINumberToReal, (connection->err, (CONST OCINumber *) element, (uword) sizeof(double), (dvoid *) &double_number));
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
FREE_ZVAL(*result_element);
|
|
return 1;
|
|
}
|
|
|
|
ZVAL_DOUBLE(*result_element, double_number);
|
|
|
|
return 0;
|
|
}
|
|
break;
|
|
default:
|
|
php_error_docref(NULL TSRMLS_CC, E_NOTICE, "Unknown or unsupported type of element: %d", collection->element_typecode);
|
|
FREE_ZVAL(*result_element);
|
|
return 1;
|
|
break;
|
|
}
|
|
/* never reached */
|
|
return 1;
|
|
}
|
|
/* }}} */
|
|
|
|
/* {{{ php_oci_collection_element_set_null()
|
|
Set the element with the given index to NULL */
|
|
int php_oci_collection_element_set_null(php_oci_collection *collection, long index TSRMLS_DC)
|
|
{
|
|
OCIInd null_index = OCI_IND_NULL;
|
|
php_oci_connection *connection = collection->connection;
|
|
sword errstatus;
|
|
|
|
/* set NULL element */
|
|
PHP_OCI_CALL_RETURN(errstatus, OCICollAssignElem, (connection->env, connection->err, (ub4) index, (dvoid *)"", &null_index, collection->collection));
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
return 1;
|
|
}
|
|
connection->errcode = 0; /* retain backwards compat with OCI8 1.4 */
|
|
return 0;
|
|
}
|
|
/* }}} */
|
|
|
|
/* {{{ php_oci_collection_element_set_date()
|
|
Change element's value to the given DATE */
|
|
int php_oci_collection_element_set_date(php_oci_collection *collection, long index, char *date, int date_len TSRMLS_DC)
|
|
{
|
|
OCIInd new_index = OCI_IND_NOTNULL;
|
|
OCIDate oci_date;
|
|
php_oci_connection *connection = collection->connection;
|
|
sword errstatus;
|
|
|
|
/* format and language are NULLs, so format is "DD-MON-YY" and language is the default language of the session */
|
|
PHP_OCI_CALL_RETURN(errstatus, OCIDateFromText, (connection->err, (CONST text *)date, date_len, NULL, 0, NULL, 0, &oci_date));
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
/* failed to convert string to date */
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
return 1;
|
|
}
|
|
|
|
PHP_OCI_CALL_RETURN(errstatus, OCICollAssignElem,
|
|
(
|
|
connection->env,
|
|
connection->err,
|
|
(ub4)index,
|
|
(dvoid *) &oci_date,
|
|
(dvoid *) &new_index,
|
|
(OCIColl *) collection->collection
|
|
)
|
|
);
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
return 1;
|
|
}
|
|
|
|
connection->errcode = 0; /* retain backwards compat with OCI8 1.4 */
|
|
return 0;
|
|
}
|
|
/* }}} */
|
|
|
|
/* {{{ php_oci_collection_element_set_number()
|
|
Change element's value to the given NUMBER */
|
|
int php_oci_collection_element_set_number(php_oci_collection *collection, long index, char *number, int number_len TSRMLS_DC)
|
|
{
|
|
OCIInd new_index = OCI_IND_NOTNULL;
|
|
double element_double;
|
|
OCINumber oci_number;
|
|
php_oci_connection *connection = collection->connection;
|
|
sword errstatus;
|
|
|
|
#if (PHP_MAJOR_VERSION == 4 && PHP_MINOR_VERSION == 3 && PHP_RELEASE_VERSION < 10)
|
|
/* minimum PHP version ext/oci8/config.m4 accepts is 4.3.9 */
|
|
element_double = strtod(number, NULL);
|
|
#else
|
|
/* zend_strtod was introduced in PHP 4.3.10 */
|
|
element_double = zend_strtod(number, NULL);
|
|
#endif
|
|
|
|
PHP_OCI_CALL_RETURN(errstatus, OCINumberFromReal, (connection->err, &element_double, sizeof(double), &oci_number));
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
return 1;
|
|
}
|
|
|
|
PHP_OCI_CALL_RETURN(errstatus, OCICollAssignElem,
|
|
(
|
|
connection->env,
|
|
connection->err,
|
|
(ub4) index,
|
|
(dvoid *) &oci_number,
|
|
(dvoid *) &new_index,
|
|
(OCIColl *) collection->collection
|
|
)
|
|
);
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
return 1;
|
|
}
|
|
|
|
connection->errcode = 0; /* retain backwards compat with OCI8 1.4 */
|
|
return 0;
|
|
}
|
|
/* }}} */
|
|
|
|
/* {{{ php_oci_collection_element_set_string()
|
|
Change element's value to the given string */
|
|
int php_oci_collection_element_set_string(php_oci_collection *collection, long index, char *element, int element_len TSRMLS_DC)
|
|
{
|
|
OCIInd new_index = OCI_IND_NOTNULL;
|
|
OCIString *ocistr = (OCIString *)0;
|
|
php_oci_connection *connection = collection->connection;
|
|
sword errstatus;
|
|
|
|
PHP_OCI_CALL_RETURN(errstatus, OCIStringAssignText, (connection->env, connection->err, (CONST oratext *)element, element_len, &ocistr));
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
return 1;
|
|
}
|
|
|
|
PHP_OCI_CALL_RETURN(errstatus, OCICollAssignElem,
|
|
(
|
|
connection->env,
|
|
connection->err,
|
|
(ub4)index,
|
|
(dvoid *) ocistr,
|
|
(dvoid *) &new_index,
|
|
(OCIColl *) collection->collection
|
|
)
|
|
);
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
return 1;
|
|
}
|
|
|
|
connection->errcode = 0; /* retain backwards compat with OCI8 1.4 */
|
|
return 0;
|
|
}
|
|
/* }}} */
|
|
|
|
/* {{{ php_oci_collection_element_set()
|
|
Collection element setter */
|
|
int php_oci_collection_element_set(php_oci_collection *collection, long index, char *value, int value_len TSRMLS_DC)
|
|
{
|
|
if (value_len == 0) {
|
|
return php_oci_collection_element_set_null(collection, index TSRMLS_CC);
|
|
}
|
|
|
|
switch(collection->element_typecode) {
|
|
case OCI_TYPECODE_DATE:
|
|
return php_oci_collection_element_set_date(collection, index, value, value_len TSRMLS_CC);
|
|
break;
|
|
|
|
case OCI_TYPECODE_VARCHAR2 :
|
|
return php_oci_collection_element_set_string(collection, index, value, value_len TSRMLS_CC);
|
|
break;
|
|
|
|
case OCI_TYPECODE_UNSIGNED16 : /* UNSIGNED SHORT */
|
|
case OCI_TYPECODE_UNSIGNED32 : /* UNSIGNED LONG */
|
|
case OCI_TYPECODE_REAL : /* REAL */
|
|
case OCI_TYPECODE_DOUBLE : /* DOUBLE */
|
|
case OCI_TYPECODE_INTEGER : /* INT */
|
|
case OCI_TYPECODE_SIGNED16 : /* SHORT */
|
|
case OCI_TYPECODE_SIGNED32 : /* LONG */
|
|
case OCI_TYPECODE_DECIMAL : /* DECIMAL */
|
|
case OCI_TYPECODE_FLOAT : /* FLOAT */
|
|
case OCI_TYPECODE_NUMBER : /* NUMBER */
|
|
case OCI_TYPECODE_SMALLINT : /* SMALLINT */
|
|
return php_oci_collection_element_set_number(collection, index, value, value_len TSRMLS_CC);
|
|
break;
|
|
|
|
default:
|
|
php_error_docref(NULL TSRMLS_CC, E_NOTICE, "Unknown or unsupported type of element: %d", collection->element_typecode);
|
|
return 1;
|
|
break;
|
|
}
|
|
/* never reached */
|
|
return 1;
|
|
}
|
|
/* }}} */
|
|
|
|
/* {{{ php_oci_collection_assign()
|
|
Assigns a value to the collection from another collection */
|
|
int php_oci_collection_assign(php_oci_collection *collection_dest, php_oci_collection *collection_from TSRMLS_DC)
|
|
{
|
|
php_oci_connection *connection = collection_dest->connection;
|
|
sword errstatus;
|
|
|
|
PHP_OCI_CALL_RETURN(errstatus, OCICollAssign, (connection->env, connection->err, collection_from->collection, collection_dest->collection));
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
return 1;
|
|
}
|
|
connection->errcode = 0; /* retain backwards compat with OCI8 1.4 */
|
|
return 0;
|
|
}
|
|
/* }}} */
|
|
|
|
/* {{{ php_oci_collection_close()
|
|
Destroy collection and all associated resources */
|
|
void php_oci_collection_close(php_oci_collection *collection TSRMLS_DC)
|
|
{
|
|
php_oci_connection *connection = collection->connection;
|
|
sword errstatus;
|
|
|
|
if (collection->collection) {
|
|
PHP_OCI_CALL_RETURN(errstatus, OCIObjectFree, (connection->env, connection->err, (dvoid *)collection->collection, (ub2)OCI_OBJECTFREE_FORCE));
|
|
|
|
if (errstatus != OCI_SUCCESS) {
|
|
connection->errcode = php_oci_error(connection->err, errstatus TSRMLS_CC);
|
|
PHP_OCI_HANDLE_ERROR(connection, connection->errcode);
|
|
} else {
|
|
connection->errcode = 0; /* retain backwards compat with OCI8 1.4 */
|
|
}
|
|
}
|
|
|
|
zend_list_delete(collection->connection->id);
|
|
efree(collection);
|
|
return;
|
|
}
|
|
/* }}} */
|
|
|
|
#endif /* HAVE_OCI8 */
|
|
|
|
/*
|
|
* Local variables:
|
|
* tab-width: 4
|
|
* c-basic-offset: 4
|
|
* End:
|
|
* vim600: noet sw=4 ts=4 fdm=marker
|
|
* vim<600: noet sw=4 ts=4
|
|
*/
|