123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100 |
- /*
- +----------------------------------------------------------------------+
- | PHP Version 5 |
- +----------------------------------------------------------------------+
- | Copyright (c) 1997-2016 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: Ard Biesheuvel <a.k.biesheuvel@its.tudelft.nl> |
- +----------------------------------------------------------------------+
- */
- #ifdef HAVE_CONFIG_H
- #include "config.h"
- #endif
- #include "php.h"
- #include "php_ini.h"
- #if HAVE_IBASE
- #include "ext/standard/php_standard.h"
- #include "php_interbase.h"
- #include "php_ibase_includes.h"
- #define ISC_LONG_MIN INT_MIN
- #define ISC_LONG_MAX INT_MAX
- #define QUERY_RESULT 1
- #define EXECUTE_RESULT 2
- #define FETCH_ROW 1
- #define FETCH_ARRAY 2
- typedef struct {
- ISC_ARRAY_DESC ar_desc;
- ISC_LONG ar_size; /* size of entire array in bytes */
- unsigned short el_type, el_size;
- } ibase_array;
- typedef struct {
- ibase_db_link *link;
- ibase_trans *trans;
- struct _ib_query *query;
- isc_stmt_handle stmt;
- unsigned short type;
- unsigned char has_more_rows, statement_type;
- XSQLDA *out_sqlda;
- ibase_array out_array[1]; /* last member */
- } ibase_result;
- typedef struct _ib_query {
- ibase_db_link *link;
- ibase_trans *trans;
- ibase_result *result;
- int result_res_id;
- isc_stmt_handle stmt;
- XSQLDA *in_sqlda, *out_sqlda;
- ibase_array *in_array, *out_array;
- unsigned short in_array_cnt, out_array_cnt;
- unsigned short dialect;
- char statement_type;
- char *query;
- long trans_res_id;
- } ibase_query;
- typedef struct {
- unsigned short vary_length;
- char vary_string[1];
- } IBVARY;
- /* sql variables union
- * used for convert and binding input variables
- */
- typedef struct {
- union {
- short sval;
- float fval;
- ISC_LONG lval;
- ISC_QUAD qval;
- ISC_TIMESTAMP tsval;
- ISC_DATE dtval;
- ISC_TIME tmval;
- } val;
- short sqlind;
- } BIND_BUF;
- static int le_result, le_query;
- #define LE_RESULT "Firebird/InterBase result"
- #define LE_QUERY "Firebird/InterBase query"
- 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);
- }
- }
- /* }}} */
- static void _php_ibase_free_stmt_handle(ibase_db_link *link, isc_stmt_handle stmt TSRMLS_DC) /* {{{ */
- {
- static char info[] = { isc_info_base_level, isc_info_end };
- if (stmt) {
- char res_buf[8];
- IBDEBUG("Dropping statement handle (free_stmt_handle)...");
- /* Only free statement if db-connection is still open */
- if (SUCCESS == isc_database_info(IB_STATUS, &link->handle,
- sizeof(info), info, sizeof(res_buf), res_buf)) {
- if (isc_dsql_free_statement(IB_STATUS, &stmt, DSQL_drop)) {
- _php_ibase_error(TSRMLS_C);
- }
- }
- }
- }
- /* }}} */
- 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->query != NULL) {
- IBDEBUG("query still valid; don't drop statement handle");
- ib_result->query->result = NULL; /* Indicate to query, that result is released */
- } else {
- _php_ibase_free_stmt_handle(ib_result->link, ib_result->stmt TSRMLS_CC);
- }
- efree(ib_result);
- }
- }
- /* }}} */
- 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->result != NULL) {
- IBDEBUG("result still valid; don't drop statement handle");
- ib_query->result->query = NULL; /* Indicate to result, that query is released */
- } else {
- _php_ibase_free_stmt_handle(ib_query->link, ib_query->stmt TSRMLS_CC);
- }
- 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);
- }
- }
- /* }}} */
- 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);
- efree(ib_query);
- }
- }
- /* }}} */
- void php_ibase_query_minit(INIT_FUNC_ARGS) /* {{{ */
- {
- 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);
- }
- /* }}} */
- static int _php_ibase_alloc_array(ibase_array **ib_arrayp, XSQLDA *sqlda, /* {{{ */
- isc_db_handle link, isc_tr_handle trans, unsigned short *array_cnt TSRMLS_DC)
- {
- unsigned short i, n;
- ibase_array *ar;
- /* first check if we have any arrays at all */
- for (i = *array_cnt = 0; i < sqlda->sqld; ++i) {
- if ((sqlda->sqlvar[i].sqltype & ~1) == SQL_ARRAY) {
- ++*array_cnt;
- }
- }
- if (! *array_cnt) return SUCCESS;
- ar = safe_emalloc(sizeof(ibase_array), *array_cnt, 0);
- for (i = n = 0; i < sqlda->sqld; ++i) {
- unsigned short dim;
- unsigned long ar_size = 1;
- XSQLVAR *var = &sqlda->sqlvar[i];
- if ((var->sqltype & ~1) == SQL_ARRAY) {
- ibase_array *a = &ar[n++];
- ISC_ARRAY_DESC *ar_desc = &a->ar_desc;
- if (isc_array_lookup_bounds(IB_STATUS, &link, &trans, var->relname,
- var->sqlname, ar_desc)) {
- _php_ibase_error(TSRMLS_C);
- efree(ar);
- return FAILURE;
- }
- switch (ar_desc->array_desc_dtype) {
- case blr_text:
- case blr_text2:
- a->el_type = SQL_TEXT;
- a->el_size = ar_desc->array_desc_length;
- break;
- case blr_short:
- a->el_type = SQL_SHORT;
- a->el_size = sizeof(short);
- break;
- case blr_long:
- a->el_type = SQL_LONG;
- a->el_size = sizeof(ISC_LONG);
- break;
- case blr_float:
- a->el_type = SQL_FLOAT;
- a->el_size = sizeof(float);
- break;
- case blr_double:
- a->el_type = SQL_DOUBLE;
- a->el_size = sizeof(double);
- break;
- case blr_int64:
- a->el_type = SQL_INT64;
- a->el_size = sizeof(ISC_INT64);
- break;
- case blr_timestamp:
- a->el_type = SQL_TIMESTAMP;
- a->el_size = sizeof(ISC_TIMESTAMP);
- break;
- case blr_sql_date:
- a->el_type = SQL_TYPE_DATE;
- a->el_size = sizeof(ISC_DATE);
- break;
- case blr_sql_time:
- a->el_type = SQL_TYPE_TIME;
- a->el_size = sizeof(ISC_TIME);
- break;
- 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.
- */
- a->el_type = SQL_TEXT;
- a->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(ar);
- 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;
- }
- a->ar_size = a->el_size * ar_size;
- } /* if SQL_ARRAY */
- } /* for column */
- *ib_arrayp = ar;
- return SUCCESS;
- }
- /* }}} */
- /* 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];
- /* Return FAILURE, if querystring is empty */
- if (*query == '\0') {
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "Querystring empty.");
- return FAILURE;
- }
- ib_query->link = link;
- ib_query->trans = trans;
- ib_query->result_res_id = 0;
- ib_query->result = NULL;
- 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;
- ib_query->out_sqlda = NULL;
- ib_query->in_sqlda = NULL;
- 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 (FAILURE == _php_ibase_alloc_array(&ib_query->in_array, ib_query->in_sqlda,
- link->handle, trans->handle, &ib_query->in_array_cnt TSRMLS_CC)) {
- 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 (FAILURE == _php_ibase_alloc_array(&ib_query->out_array, ib_query->out_sqlda,
- link->handle, trans->handle, &ib_query->out_array_cnt TSRMLS_CC)) {
- 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;
- }
- /* }}} */
- 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;
- case SQL_INT64:
- {
- long double l;
- convert_to_string(val);
- if (!sscanf(Z_STRVAL_P(val), "%Lf", &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;
- }
- } else {
- struct tm t = { 0, 0, 0, 0, 0, 0 };
- switch (array->el_type) {
- unsigned short n;
- ISC_INT64 l;
- 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;
- case SQL_INT64:
- #if (SIZEOF_LONG >= 8)
- convert_to_long(val);
- *(long *) buf = Z_LVAL_P(val);
- #else
- 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;
- 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;
- case SQL_TIMESTAMP:
- convert_to_string(val);
- #ifdef HAVE_STRPTIME
- strptime(Z_STRVAL_P(val), INI_STR("ibase.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
- isc_encode_timestamp(&t, (ISC_TIMESTAMP * ) buf);
- break;
- case SQL_TYPE_DATE:
- convert_to_string(val);
- #ifdef HAVE_STRPTIME
- strptime(Z_STRVAL_P(val), INI_STR("ibase.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), INI_STR("ibase.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;
- default:
- convert_to_string(val);
- strlcpy(buf, Z_STRVAL_P(val), buf_size);
- }
- }
- }
- return SUCCESS;
- }
- /* }}} */
- static int _php_ibase_bind(XSQLDA *sqlda, zval ***b_vars, BIND_BUF *buf, /* {{{ */
- ibase_query *ib_query TSRMLS_DC)
- {
- int i, array_cnt = 0, rv = SUCCESS;
- for (i = 0; i < sqlda->sqld; ++i) { /* bound vars */
- zval *b_var = *b_vars[i];
- XSQLVAR *var = &sqlda->sqlvar[i];
- var->sqlind = &buf[i].sqlind;
- /* check if a NULL should be inserted */
- switch (Z_TYPE_P(b_var)) {
- int force_null;
- case IS_STRING:
- force_null = 0;
- /* for these types, an empty string can be handled like a NULL value */
- switch (var->sqltype & ~1) {
- case SQL_SHORT:
- case SQL_LONG:
- case SQL_INT64:
- case SQL_FLOAT:
- case SQL_DOUBLE:
- case SQL_TIMESTAMP:
- case SQL_TYPE_DATE:
- case SQL_TYPE_TIME:
- force_null = (Z_STRLEN_P(b_var) == 0);
- }
- if (! force_null) break;
- case IS_NULL:
- buf[i].sqlind = -1;
- if (var->sqltype & SQL_ARRAY) ++array_cnt;
- continue;
- }
- /* if we make it to this point, we must provide a value for the parameter */
- buf[i].sqlind = 0;
- var->sqldata = (void*)&buf[i].val;
- switch (var->sqltype & ~1) {
- struct tm t;
- case SQL_TIMESTAMP:
- case SQL_TYPE_DATE:
- case SQL_TYPE_TIME:
- if (Z_TYPE_P(b_var) == IS_LONG) {
- struct tm *res;
- res = php_gmtime_r(&Z_LVAL_P(b_var), &t);
- if (!res) {
- return FAILURE;
- }
- } else {
- #ifdef HAVE_STRPTIME
- char *format = INI_STR("ibase.timestampformat");
- convert_to_string(b_var);
- switch (var->sqltype & ~1) {
- case SQL_TYPE_DATE:
- format = INI_STR("ibase.dateformat");
- break;
- case SQL_TYPE_TIME:
- format = INI_STR("ibase.timeformat");
- }
- if (!strptime(Z_STRVAL_P(b_var), format, &t)) {
- /* strptime() cannot handle it, so let IB have a try */
- break;
- }
- #else /* ifndef HAVE_STRPTIME */
- break; /* let IB parse it as a string */
- #endif
- }
- switch (var->sqltype & ~1) {
- default: /* == case SQL_TIMESTAMP */
- isc_encode_timestamp(&t, &buf[i].val.tsval);
- break;
- case SQL_TYPE_DATE:
- isc_encode_sql_date(&t, &buf[i].val.dtval);
- break;
- case SQL_TYPE_TIME:
- isc_encode_sql_time(&t, &buf[i].val.tmval);
- break;
- }
- continue;
- 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, 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;
- }
- continue;
- 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 */
- ibase_array *ar = &ib_query->in_array[array_cnt];
- void *array_data = emalloc(ar->ar_size);
- ISC_QUAD array_id = { 0, 0 };
- if (FAILURE == _php_ibase_bind_array(b_var, array_data, ar->ar_size,
- ar, 0 TSRMLS_CC)) {
- _php_ibase_module_error("Parameter %d: failed to bind array argument"
- TSRMLS_CC,i+1);
- efree(array_data);
- rv = FAILURE;
- continue;
- }
- if (isc_array_put_slice(IB_STATUS, &ib_query->link->handle, &ib_query->trans->handle,
- &array_id, &ar->ar_desc, array_data, &ar->ar_size)) {
- _php_ibase_error(TSRMLS_C);
- efree(array_data);
- return FAILURE;
- }
- buf[i].val.qval = array_id;
- efree(array_data);
- }
- ++array_cnt;
- continue;
- } /* switch */
- /* we end up here if none of the switch cases handled the field */
- convert_to_string(b_var);
- var->sqldata = Z_STRVAL_P(b_var);
- var->sqllen = Z_STRLEN_P(b_var);
- var->sqltype = SQL_TEXT;
- } /* for */
- return rv;
- }
- /* }}} */
- static void _php_ibase_alloc_xsqlda(XSQLDA *sqlda) /* {{{ */
- {
- int i;
- for (i = 0; i < sqlda->sqld; i++) {
- XSQLVAR *var = &sqlda->sqlvar[i];
- 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;
- case SQL_INT64:
- var->sqldata = emalloc(sizeof(ISC_INT64));
- break;
- 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;
- 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 */
- }
- /* }}} */
- static int _php_ibase_exec(INTERNAL_FUNCTION_PARAMETERS, ibase_result **ib_resultp, /* {{{ */
- ibase_query *ib_query, zval ***args)
- {
- XSQLDA *in_sqlda = NULL, *out_sqlda = NULL;
- BIND_BUF *bind_buf = NULL;
- int i, rv = FAILURE;
- static char info_count[] = { isc_info_sql_records };
- char result[64];
- ISC_STATUS isc_result;
- int argc = ib_query->in_sqlda ? ib_query->in_sqlda->sqld : 0;
-
- RESET_ERRMSG;
- for (i = 0; i < argc; ++i) {
- SEPARATE_ZVAL(args[i]);
- }
- 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);
- }
- RETVAL_TRUE;
- return SUCCESS;
- default:
- RETVAL_FALSE;
- }
- /* allocate sqlda and output buffers */
- if (ib_query->out_sqlda) { /* output variables in select, select for update */
- ibase_result *res;
- IBDEBUG("Query wants XSQLDA for output");
- res = emalloc(sizeof(ibase_result)+sizeof(ibase_array)*max(0,ib_query->out_array_cnt-1));
- res->link = ib_query->link;
- res->trans = ib_query->trans;
- res->stmt = ib_query->stmt;
- /* ib_result and ib_query point at each other to handle release of statement handle properly */
- res->query = ib_query;
- ib_query->result = res;
- res->statement_type = ib_query->statement_type;
- res->has_more_rows = 1;
- out_sqlda = res->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(&res->out_array, ib_query->out_array, sizeof(ibase_array)*ib_query->out_array_cnt);
- }
- *ib_resultp = res;
- }
- if (ib_query->in_sqlda) { /* has placeholders */
- IBDEBUG("Query wants XSQLDA for input");
- 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;
- }
- }
- ib_query->trans->affected_rows = affected_rows;
- if (!ib_query->out_sqlda) { /* no result set is being returned */
- if (affected_rows) {
- RETVAL_LONG(affected_rows);
- } else {
- RETVAL_TRUE;
- }
- break;
- }
- default:
- RETVAL_TRUE;
- }
- rv = SUCCESS;
- _php_ibase_exec_error:
- if (in_sqlda) {
- efree(in_sqlda);
- }
- if (bind_buf)
- efree(bind_buf);
- if (rv == FAILURE) {
- if (*ib_resultp) {
- efree(*ib_resultp);
- *ib_resultp = NULL;
- }
- if (out_sqlda) {
- _php_ibase_free_xsqlda(out_sqlda);
- }
- }
- return rv;
- }
- /* }}} */
- /* {{{ 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 *zlink, *ztrans, ***bind_args = NULL;
- char *query;
- int bind_i, query_len, bind_num;
- long 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;
- RESET_ERRMSG;
-
- RETVAL_FALSE;
- switch (ZEND_NUM_ARGS()) {
- long l;
- default:
- if (SUCCESS == zend_parse_parameters_ex(ZEND_PARSE_PARAMS_QUIET, 3 TSRMLS_CC, "rrs",
- &zlink, &ztrans, &query, &query_len)) {
- ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link*, &zlink, -1, LE_LINK, le_link, le_plink);
- ZEND_FETCH_RESOURCE(trans, ibase_trans*, &ztrans, -1, LE_TRANS, le_trans);
-
- trans_res_id = Z_LVAL_P(ztrans);
- bind_i = 3;
- break;
- }
- case 2:
- if (SUCCESS == zend_parse_parameters_ex(ZEND_PARSE_PARAMS_QUIET, 2 TSRMLS_CC, "rs",
- &zlink, &query, &query_len)) {
- _php_ibase_get_link_trans(INTERNAL_FUNCTION_PARAM_PASSTHRU, &zlink, &ib_link, &trans);
-
- if (trans != NULL) {
- trans_res_id = Z_LVAL_P(zlink);
- }
- bind_i = 2;
- break;
- }
- /* the statement is 'CREATE DATABASE ...' if the link argument is IBASE_CREATE */
- if (SUCCESS == zend_parse_parameters_ex(ZEND_PARSE_PARAMS_QUIET, ZEND_NUM_ARGS()
- TSRMLS_CC, "ls", &l, &query, &query_len) && l == PHP_IBASE_CREATE) {
- isc_db_handle db = NULL;
- isc_tr_handle trans = NULL;
- if (PG(sql_safe_mode)) {
- _php_ibase_module_error("CREATE DATABASE is not allowed in SQL safe mode"
- TSRMLS_CC);
- } else if (((l = INI_INT("ibase.max_links")) != -1) && (IBG(num_links) >= l)) {
- _php_ibase_module_error("CREATE DATABASE is not allowed: maximum link count "
- "(%ld) reached" TSRMLS_CC, l);
- } else if (isc_dsql_execute_immediate(IB_STATUS, &db, &trans, (short)query_len,
- query, SQL_DIALECT_CURRENT, NULL)) {
- _php_ibase_error(TSRMLS_C);
- } else if (!db) {
- _php_ibase_module_error("Connection to created database could not be "
- "established" TSRMLS_CC);
- } 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;
- ib_link->event_head = 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);
- }
- return;
- }
- case 1:
- case 0:
- if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() ? 1 : 0 TSRMLS_CC, "s", &query,
- &query_len)) {
- ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, NULL, IBG(default_link), LE_LINK,
- le_link, le_plink);
- bind_i = 1;
- break;
- }
- return;
- }
- /* open default transaction */
- if (ib_link == NULL || FAILURE == _php_ibase_def_trans(ib_link, &trans TSRMLS_CC)
- || FAILURE == _php_ibase_alloc_query(&ib_query, ib_link, trans, query, ib_link->dialect,
- trans_res_id TSRMLS_CC)) {
- return;
- }
- do {
- int bind_n = ZEND_NUM_ARGS() - bind_i,
- expected_n = ib_query.in_sqlda ? ib_query.in_sqlda->sqld : 0;
-
- if (bind_n != expected_n) {
- php_error_docref(NULL TSRMLS_CC, (bind_n < expected_n) ? E_WARNING : E_NOTICE,
- "Statement expects %d arguments, %d given", expected_n, bind_n);
- if (bind_n < expected_n) {
- break;
- }
- } else if (bind_n > 0) {
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "+", &bind_args, &bind_num) == FAILURE) {
- return;
- }
- }
-
- if (FAILURE == _php_ibase_exec(INTERNAL_FUNCTION_PARAM_PASSTHRU, &result, &ib_query,
- &bind_args[bind_i])) {
- break;
- }
- 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);
- }
- } while (0);
- _php_ibase_free_query(&ib_query TSRMLS_CC);
- if (bind_args) {
- efree(bind_args);
- }
- }
- /* }}} */
- /* {{{ 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;
- ibase_db_link *ib_link;
- zval *arg = NULL;
-
- RESET_ERRMSG;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &arg) == FAILURE) {
- return;
- }
- if (!arg) {
- ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, NULL, IBG(default_link), LE_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;
- } else {
- /* 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, LE_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;
- }
- }
- RETURN_LONG(trans->affected_rows);
- }
- /* }}} */
- /* {{{ proto int ibase_num_rows( resource result_identifier )
- Return the number of rows that are available in a result */
- #if abies_0
- PHP_FUNCTION(ibase_num_rows)
- {
- /**
- * 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.
- */
- zval *result_arg;
- ibase_result *ib_result;
- static char info_count[] = {isc_info_sql_records};
- char result[64];
- RESET_ERRMSG;
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &result_arg) == FAILURE) {
- return;
- }
- ZEND_FETCH_RESOURCE(ib_result, ibase_result *, &result_arg, -1, LE_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
- /* }}} */
- static int _php_ibase_var_zval(zval *val, void *data, int type, int len, /* {{{ */
- int scale, int flag TSRMLS_DC)
- {
- static ISC_INT64 const scales[] = { 1, 10, 100, 1000,
- 10000,
- 100000,
- 1000000,
- 10000000,
- 100000000,
- 1000000000,
- LL_LIT(10000000000),
- LL_LIT(100000000000),
- LL_LIT(1000000000000),
- LL_LIT(10000000000000),
- LL_LIT(100000000000000),
- LL_LIT(1000000000000000),
- LL_LIT(10000000000000000),
- LL_LIT(100000000000000000),
- LL_LIT(1000000000000000000)
- };
- switch (type & ~1) {
- unsigned short l;
- long n;
- char string_data[255];
- struct tm t;
- char *format;
- case SQL_VARYING:
- len = ((IBVARY *) data)->vary_length;
- data = ((IBVARY *) data)->vary_string;
- /* no break */
- case SQL_TEXT:
- ZVAL_STRINGL(val,(char *) data,len,1);
- break;
- case SQL_SHORT:
- n = *(short *) data;
- goto _sql_long;
- case SQL_INT64:
- #if (SIZEOF_LONG >= 8)
- n = *(long *) data;
- goto _sql_long;
- #else
- if (scale == 0) {
- l = slprintf(string_data, sizeof(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 = slprintf(string_data, sizeof(string_data), "%" LL_MASK "d.%0*" LL_MASK "d", n / f, -scale, n % f);
- } else if (n <= -f) {
- l = slprintf(string_data, sizeof(string_data), "%" LL_MASK "d.%0*" LL_MASK "d", n / f, -scale, -n % f);
- } else {
- l = slprintf(string_data, sizeof(string_data), "-0.%0*" LL_MASK "d", -scale, -n % f);
- }
- ZVAL_STRINGL(val,string_data,l,1);
- }
- break;
- #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 = slprintf(string_data, sizeof(string_data), "%ld.%0*ld", n / f, -scale, n % f);
- } else if (n <= -f) {
- l = slprintf(string_data, sizeof(string_data), "%ld.%0*ld", n / f, -scale, -n % f);
- } else {
- l = slprintf(string_data, sizeof(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;
- case SQL_DATE: /* == case SQL_TIMESTAMP: */
- format = INI_STR("ibase.timestampformat");
- isc_decode_timestamp((ISC_TIMESTAMP *) data, &t);
- goto format_date_time;
- case SQL_TYPE_DATE:
- format = INI_STR("ibase.dateformat");
- isc_decode_sql_date((ISC_DATE *) data, &t);
- goto format_date_time;
- case SQL_TYPE_TIME:
- format = INI_STR("ibase.timeformat");
- isc_decode_sql_time((ISC_TIME *) data, &t);
- format_date_time:
- /*
- 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 = slprintf(string_data, sizeof(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;
- case SQL_TYPE_DATE:
- l = slprintf(string_data, sizeof(string_data), "%02d/%02d/%4d", t.tm_mon + 1, t.tm_mday, t.tm_year+1900);
- break;
- case SQL_TYPE_TIME:
- l = slprintf(string_data, sizeof(string_data), "%02d:%02d:%02d", t.tm_hour, t.tm_min, t.tm_sec);
- break;
- }
- #endif
- ZVAL_STRINGL(val,string_data,l,1);
- break;
- }
- } /* switch (type) */
- return SUCCESS;
- }
- /* }}} */
- 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)
- {
- /**
- * Create multidimension array - recursion function
- */
- 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 (FAILURE == _php_ibase_arr_zval(slice_zval, data, slice_size, ib_array, dim + 1,
- flag TSRMLS_CC)) {
- return FAILURE;
- }
- data += slice_size;
- add_index_zval(ar_zval,l_bound+i,slice_zval);
- }
- } else { /* data at last */
- if (FAILURE == _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)) {
- 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;
- }
- /* }}} */
- static void _php_ibase_fetch_hash(INTERNAL_FUNCTION_PARAMETERS, int fetch_type) /* {{{ */
- {
- zval *result_arg;
- long i, array_cnt = 0, flag = 0;
- ibase_result *ib_result;
- RESET_ERRMSG;
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r|l", &result_arg, &flag)) {
- return;
- }
- ZEND_FETCH_RESOURCE(ib_result, ibase_result *, &result_arg, -1, LE_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);
- for (i = 0; i < ib_result->out_sqlda->sqld; ++i) {
- XSQLVAR *var = &ib_result->out_sqlda->sqlvar[i];
- char buf[METADATALENGTH+4], *alias = var->aliasname;
-
- if (! (fetch_type & FETCH_ROW)) {
- int i = 0;
- char const *base = "FIELD"; /* use 'FIELD' if name is empty */
-
- /**
- * Ensure no two columns have identical names:
- * keep generating new names until we find one that is unique.
- */
- switch (*alias) {
- void *p;
-
- default:
- i = 1;
- base = alias;
-
- while (SUCCESS == zend_symtable_find(
- Z_ARRVAL_P(return_value),alias,strlen(alias)+1,&p)) {
-
- case '\0':
- snprintf(alias = buf, sizeof(buf), "%s_%02d", base, i++);
- }
- }
- }
- 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 (SUCCESS != _php_ibase_blob_get(result, &blob_handle,
- max_len TSRMLS_CC)) {
- 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[array_cnt++];
- 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 (FAILURE == _php_ibase_arr_zval(result, ar_data, ib_array->ar_size, ib_array,
- 0, flag TSRMLS_CC)) {
- 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, alias, result);
- }
- } else {
- if (fetch_type & FETCH_ROW) {
- add_index_null(return_value, i);
- } else {
- add_assoc_null(return_value, alias);
- }
- }
- } /* 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;
- char *name_arg;
- int name_arg_len;
- ibase_result *ib_result;
- RESET_ERRMSG;
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rs", &result_arg, &name_arg, &name_arg_len) == FAILURE) {
- return;
- }
- ZEND_FETCH_RESOURCE(ib_result, ibase_result *, &result_arg, -1, LE_RESULT, le_result);
- if (isc_dsql_set_cursor_name(IB_STATUS, &ib_result->stmt, 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_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &result_arg) == FAILURE) {
- return;
- }
- ZEND_FETCH_RESOURCE(ib_result, ibase_result *, &result_arg, -1, LE_RESULT, le_result);
- zend_list_delete(Z_RESVAL_P(result_arg));
- RETURN_TRUE;
- }
- /* }}} */
- /* {{{ proto resource ibase_prepare(resource link_identifier[, string query [, resource trans_identifier ]])
- Prepare a query for later execution */
- PHP_FUNCTION(ibase_prepare)
- {
- zval *link_arg, *trans_arg;
- ibase_db_link *ib_link;
- ibase_trans *trans = NULL;
- int query_len, trans_res_id = 0;
- ibase_query *ib_query;
- char *query;
- RESET_ERRMSG;
-
- if (ZEND_NUM_ARGS() == 1) {
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &query, &query_len) == FAILURE) {
- return;
- }
- ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, NULL, IBG(default_link), LE_LINK, le_link, le_plink);
- } else if (ZEND_NUM_ARGS() == 2) {
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rs", &link_arg, &query, &query_len) == FAILURE) {
- return;
- }
- _php_ibase_get_link_trans(INTERNAL_FUNCTION_PARAM_PASSTHRU, &link_arg, &ib_link, &trans);
- if (trans != NULL) {
- trans_res_id = Z_RESVAL_P(link_arg);
- }
- } else {
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rrs", &link_arg, &trans_arg, &query, &query_len) == FAILURE) {
- return;
- }
- ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, &link_arg, -1, LE_LINK, le_link, le_plink);
- ZEND_FETCH_RESOURCE(trans, ibase_trans *, &trans_arg, -1, LE_TRANS, le_trans);
- trans_res_id = Z_RESVAL_P(trans_arg);
- }
- if (FAILURE == _php_ibase_def_trans(ib_link, &trans TSRMLS_CC)) {
- RETURN_FALSE;
- }
- ib_query = (ibase_query *) emalloc(sizeof(ibase_query));
- if (FAILURE == _php_ibase_alloc_query(ib_query, ib_link, trans, query, ib_link->dialect, trans_res_id TSRMLS_CC)) {
- 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 *query, ***args = NULL;
- ibase_query *ib_query;
- ibase_result *result = NULL;
- ALLOCA_FLAG(use_heap)
- RESET_ERRMSG;
-
- RETVAL_FALSE;
- if (FAILURE == zend_parse_parameters(ZEND_NUM_ARGS() ? 1 : 0 TSRMLS_CC, "r", &query)) {
- return;
- }
- ZEND_FETCH_RESOURCE(ib_query, ibase_query *, &query, -1, LE_QUERY, le_query);
- do {
- int bind_n = ZEND_NUM_ARGS() - 1,
- expected_n = ib_query->in_sqlda ? ib_query->in_sqlda->sqld : 0;
- if (bind_n != expected_n) {
- php_error_docref(NULL TSRMLS_CC, (bind_n < expected_n) ? E_WARNING : E_NOTICE,
- "Statement expects %d arguments, %d given", expected_n, bind_n);
- if (bind_n < expected_n) {
- break;
- }
- }
- /* have variables to bind */
- args = (zval ***) do_alloca((expected_n + 1) * sizeof(zval **), use_heap);
-
- if (FAILURE == zend_get_parameters_array_ex((expected_n + 1), args)) {
- break;
- }
- /* 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);
- break;
- }
- /* invalidate previous results returned by this query (not necessary for exec proc) */
- zend_list_delete(ib_query->result_res_id);
- }
- if (FAILURE == _php_ibase_exec(INTERNAL_FUNCTION_PARAM_PASSTHRU, &result, ib_query,
- &args[1])) {
- break;
- }
- /* free the query if trans handle was released */
- if (ib_query->trans->handle == NULL) {
- zend_list_delete(Z_LVAL_P(query));
- }
-
- 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 TSRMLS_CC);
- RETVAL_RESOURCE(ib_query->result_res_id);
- }
- } while (0);
- if (args) {
- free_alloca(args, use_heap);
- }
- }
- /* }}} */
- /* {{{ 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_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &query_arg) == FAILURE) {
- return;
- }
- ZEND_FETCH_RESOURCE(ib_query, ibase_query *, &query_arg, -1, LE_QUERY, le_query);
- zend_list_delete(Z_RESVAL_P(query_arg));
- RETURN_TRUE;
- }
- /* }}} */
- /* {{{ 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_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &result) == FAILURE) {
- return;
- }
- zend_list_find(Z_RESVAL_P(result), &type);
- if (type == le_query) {
- ibase_query *ib_query;
- ZEND_FETCH_RESOURCE(ib_query, ibase_query *, &result, -1, LE_QUERY, le_query);
- sqlda = ib_query->out_sqlda;
- } else {
- ibase_result *ib_result;
- ZEND_FETCH_RESOURCE(ib_result, ibase_result *, &result, -1, LE_RESULT, le_result);
- sqlda = ib_result->out_sqlda;
- }
- if (sqlda == NULL) {
- RETURN_LONG(0);
- } else {
- RETURN_LONG(sqlda->sqld);
- }
- }
- /* }}} */
- 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 = slprintf(buf, 16, "%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 = 0;
- switch (var->sqltype & ~1) {
- case SQL_SHORT:
- precision = 4;
- break;
- case SQL_LONG:
- precision = 9;
- break;
- case SQL_INT64:
- precision = 18;
- break;
- }
- len = slprintf(buf, 16, "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;
- case SQL_INT64:
- s = "BIGINT";
- break;
- case SQL_TIMESTAMP:
- s = "TIMESTAMP";
- break;
- case SQL_TYPE_DATE:
- s = "DATE";
- break;
- case SQL_TYPE_TIME:
- s = "TIME";
- break;
- 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;
- long field_arg;
- int type;
- XSQLDA *sqlda;
- RESET_ERRMSG;
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rl", &result_arg, &field_arg) == FAILURE) {
- return;
- }
- zend_list_find(Z_RESVAL_P(result_arg), &type);
- if (type == le_query) {
- ibase_query *ib_query;
- ZEND_FETCH_RESOURCE(ib_query, ibase_query *, &result_arg, -1, LE_QUERY, le_query);
- sqlda = ib_query->out_sqlda;
- } else {
- ibase_result *ib_result;
- ZEND_FETCH_RESOURCE(ib_result, ibase_result *, &result_arg, -1, LE_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;
- }
- if (field_arg < 0 || field_arg >= sqlda->sqld) {
- RETURN_FALSE;
- }
- _php_ibase_field_info(return_value, sqlda->sqlvar + 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_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &result) == FAILURE) {
- return;
- }
- ZEND_FETCH_RESOURCE(ib_query, ibase_query *, &result, -1, LE_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;
- long field_arg;
- ibase_query *ib_query;
- RESET_ERRMSG;
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rl", &result_arg, &field_arg) == FAILURE) {
- return;
- }
- ZEND_FETCH_RESOURCE(ib_query, ibase_query *, &result_arg, -1, LE_QUERY, le_query);
- if (ib_query->in_sqlda == NULL) {
- RETURN_FALSE;
- }
- if (field_arg < 0 || field_arg >= ib_query->in_sqlda->sqld) {
- RETURN_FALSE;
- }
- _php_ibase_field_info(return_value,ib_query->in_sqlda->sqlvar + field_arg);
- }
- /* }}} */
- #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
- */
|