Annotation of embedaddon/php/ext/interbase/interbase.c, revision 1.1
1.1 ! misho 1: /*
! 2: +----------------------------------------------------------------------+
! 3: | PHP Version 5 |
! 4: +----------------------------------------------------------------------+
! 5: | Copyright (c) 1997-2012 The PHP Group |
! 6: +----------------------------------------------------------------------+
! 7: | This source file is subject to version 3.01 of the PHP license, |
! 8: | that is bundled with this package in the file LICENSE, and is |
! 9: | available through the world-wide-web at the following url: |
! 10: | http://www.php.net/license/3_01.txt |
! 11: | If you did not receive a copy of the PHP license and are unable to |
! 12: | obtain it through the world-wide-web, please send a note to |
! 13: | license@php.net so we can mail you a copy immediately. |
! 14: +----------------------------------------------------------------------+
! 15: | Authors: Jouni Ahto <jouni.ahto@exdec.fi> |
! 16: | Andrew Avdeev <andy@rsc.mv.ru> |
! 17: | Ard Biesheuvel <a.k.biesheuvel@ewi.tudelft.nl> |
! 18: +----------------------------------------------------------------------+
! 19: */
! 20:
! 21: /* $Id: interbase.c 321634 2012-01-01 13:15:04Z felipe $ */
! 22:
! 23: #ifdef HAVE_CONFIG_H
! 24: #include "config.h"
! 25: #endif
! 26:
! 27: #define _GNU_SOURCE
! 28:
! 29: #include "php.h"
! 30:
! 31: #if HAVE_IBASE
! 32:
! 33: #include "php_ini.h"
! 34: #include "ext/standard/php_standard.h"
! 35: #include "ext/standard/md5.h"
! 36: #include "php_interbase.h"
! 37: #include "php_ibase_includes.h"
! 38: #include "SAPI.h"
! 39:
! 40: #include <time.h>
! 41:
! 42: #define ROLLBACK 0
! 43: #define COMMIT 1
! 44: #define RETAIN 2
! 45:
! 46: #define CHECK_LINK(link) { if (link==-1) { php_error_docref(NULL TSRMLS_CC, E_WARNING, "A link to the server could not be established"); RETURN_FALSE; } }
! 47:
! 48: ZEND_DECLARE_MODULE_GLOBALS(ibase)
! 49: static PHP_GINIT_FUNCTION(ibase);
! 50:
! 51: /* {{{ arginfo */
! 52: ZEND_BEGIN_ARG_INFO(arginfo_ibase_errmsg, 0)
! 53: ZEND_END_ARG_INFO()
! 54:
! 55: ZEND_BEGIN_ARG_INFO(arginfo_ibase_errcode, 0)
! 56: ZEND_END_ARG_INFO()
! 57:
! 58: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_connect, 0, 0, 1)
! 59: ZEND_ARG_INFO(0, database)
! 60: ZEND_ARG_INFO(0, username)
! 61: ZEND_ARG_INFO(0, password)
! 62: ZEND_ARG_INFO(0, charset)
! 63: ZEND_ARG_INFO(0, buffers)
! 64: ZEND_ARG_INFO(0, dialect)
! 65: ZEND_ARG_INFO(0, role)
! 66: ZEND_END_ARG_INFO()
! 67:
! 68: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_pconnect, 0, 0, 1)
! 69: ZEND_ARG_INFO(0, database)
! 70: ZEND_ARG_INFO(0, username)
! 71: ZEND_ARG_INFO(0, password)
! 72: ZEND_ARG_INFO(0, charset)
! 73: ZEND_ARG_INFO(0, buffers)
! 74: ZEND_ARG_INFO(0, dialect)
! 75: ZEND_ARG_INFO(0, role)
! 76: ZEND_END_ARG_INFO()
! 77:
! 78: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_close, 0, 0, 0)
! 79: ZEND_ARG_INFO(0, link_identifier)
! 80: ZEND_END_ARG_INFO()
! 81:
! 82: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_drop_db, 0, 0, 0)
! 83: ZEND_ARG_INFO(0, link_identifier)
! 84: ZEND_END_ARG_INFO()
! 85:
! 86: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_trans, 0, 0, 0)
! 87: ZEND_ARG_INFO(0, trans_args)
! 88: ZEND_ARG_INFO(0, link_identifier)
! 89: ZEND_ARG_INFO(0, trans_args)
! 90: ZEND_ARG_INFO(0, link_identifier)
! 91: ZEND_END_ARG_INFO()
! 92:
! 93: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_commit, 0, 0, 1)
! 94: ZEND_ARG_INFO(0, link_identifier)
! 95: ZEND_END_ARG_INFO()
! 96:
! 97: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_rollback, 0, 0, 1)
! 98: ZEND_ARG_INFO(0, link_identifier)
! 99: ZEND_END_ARG_INFO()
! 100:
! 101: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_commit_ret, 0, 0, 1)
! 102: ZEND_ARG_INFO(0, link_identifier)
! 103: ZEND_END_ARG_INFO()
! 104:
! 105: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_rollback_ret, 0, 0, 1)
! 106: ZEND_ARG_INFO(0, link_identifier)
! 107: ZEND_END_ARG_INFO()
! 108:
! 109: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_gen_id, 0, 0, 1)
! 110: ZEND_ARG_INFO(0, generator)
! 111: ZEND_ARG_INFO(0, increment)
! 112: ZEND_ARG_INFO(0, link_identifier)
! 113: ZEND_END_ARG_INFO()
! 114:
! 115: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_blob_create, 0, 0, 0)
! 116: ZEND_ARG_INFO(0, link_identifier)
! 117: ZEND_END_ARG_INFO()
! 118:
! 119: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_blob_open, 0, 0, 0)
! 120: ZEND_ARG_INFO(0, link_identifier)
! 121: ZEND_ARG_INFO(0, blob_id)
! 122: ZEND_END_ARG_INFO()
! 123:
! 124: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_blob_add, 0, 0, 2)
! 125: ZEND_ARG_INFO(0, blob_handle)
! 126: ZEND_ARG_INFO(0, data)
! 127: ZEND_END_ARG_INFO()
! 128:
! 129: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_blob_get, 0, 0, 2)
! 130: ZEND_ARG_INFO(0, blob_handle)
! 131: ZEND_ARG_INFO(0, len)
! 132: ZEND_END_ARG_INFO()
! 133:
! 134: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_blob_close, 0, 0, 1)
! 135: ZEND_ARG_INFO(0, blob_handle)
! 136: ZEND_END_ARG_INFO()
! 137:
! 138: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_blob_cancel, 0, 0, 1)
! 139: ZEND_ARG_INFO(0, blob_handle)
! 140: ZEND_END_ARG_INFO()
! 141:
! 142: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_blob_info, 0, 0, 0)
! 143: ZEND_ARG_INFO(0, link_identifier)
! 144: ZEND_ARG_INFO(0, blob_id)
! 145: ZEND_END_ARG_INFO()
! 146:
! 147: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_blob_echo, 0, 0, 0)
! 148: ZEND_ARG_INFO(0, link_identifier)
! 149: ZEND_ARG_INFO(0, blob_id)
! 150: ZEND_END_ARG_INFO()
! 151:
! 152: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_blob_import, 0, 0, 0)
! 153: ZEND_ARG_INFO(0, link_identifier)
! 154: ZEND_ARG_INFO(0, file)
! 155: ZEND_END_ARG_INFO()
! 156:
! 157: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_query, 0, 0, 0)
! 158: ZEND_ARG_INFO(0, link_identifier)
! 159: ZEND_ARG_INFO(0, link_identifier)
! 160: ZEND_ARG_INFO(0, query)
! 161: ZEND_ARG_INFO(0, bind_arg)
! 162: ZEND_ARG_INFO(0, bind_arg)
! 163: ZEND_END_ARG_INFO()
! 164:
! 165: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_affected_rows, 0, 0, 0)
! 166: ZEND_ARG_INFO(0, link_identifier)
! 167: ZEND_END_ARG_INFO()
! 168:
! 169: #if abies_0
! 170: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_num_rows, 0, 0, 1)
! 171: ZEND_ARG_INFO(0, result_identifier)
! 172: ZEND_END_ARG_INFO()
! 173: #endif
! 174:
! 175: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_fetch_row, 0, 0, 1)
! 176: ZEND_ARG_INFO(0, result)
! 177: ZEND_ARG_INFO(0, fetch_flags)
! 178: ZEND_END_ARG_INFO()
! 179:
! 180: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_fetch_assoc, 0, 0, 1)
! 181: ZEND_ARG_INFO(0, result)
! 182: ZEND_ARG_INFO(0, fetch_flags)
! 183: ZEND_END_ARG_INFO()
! 184:
! 185: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_fetch_object, 0, 0, 1)
! 186: ZEND_ARG_INFO(0, result)
! 187: ZEND_ARG_INFO(0, fetch_flags)
! 188: ZEND_END_ARG_INFO()
! 189:
! 190: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_name_result, 0, 0, 2)
! 191: ZEND_ARG_INFO(0, result)
! 192: ZEND_ARG_INFO(0, name)
! 193: ZEND_END_ARG_INFO()
! 194:
! 195: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_free_result, 0, 0, 1)
! 196: ZEND_ARG_INFO(0, result)
! 197: ZEND_END_ARG_INFO()
! 198:
! 199: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_prepare, 0, 0, 0)
! 200: ZEND_ARG_INFO(0, link_identifier)
! 201: ZEND_ARG_INFO(0, query)
! 202: ZEND_END_ARG_INFO()
! 203:
! 204: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_execute, 0, 0, 1)
! 205: ZEND_ARG_INFO(0, query)
! 206: ZEND_ARG_INFO(0, bind_arg)
! 207: ZEND_ARG_INFO(0, bind_arg)
! 208: ZEND_END_ARG_INFO()
! 209:
! 210: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_free_query, 0, 0, 1)
! 211: ZEND_ARG_INFO(0, query)
! 212: ZEND_END_ARG_INFO()
! 213:
! 214: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_num_fields, 0, 0, 1)
! 215: ZEND_ARG_INFO(0, query_result)
! 216: ZEND_END_ARG_INFO()
! 217:
! 218: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_field_info, 0, 0, 2)
! 219: ZEND_ARG_INFO(0, query_result)
! 220: ZEND_ARG_INFO(0, field_number)
! 221: ZEND_END_ARG_INFO()
! 222:
! 223: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_num_params, 0, 0, 1)
! 224: ZEND_ARG_INFO(0, query)
! 225: ZEND_END_ARG_INFO()
! 226:
! 227: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_param_info, 0, 0, 2)
! 228: ZEND_ARG_INFO(0, query)
! 229: ZEND_ARG_INFO(0, field_number)
! 230: ZEND_END_ARG_INFO()
! 231:
! 232: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_add_user, 0, 0, 3)
! 233: ZEND_ARG_INFO(0, service_handle)
! 234: ZEND_ARG_INFO(0, user_name)
! 235: ZEND_ARG_INFO(0, password)
! 236: ZEND_ARG_INFO(0, first_name)
! 237: ZEND_ARG_INFO(0, middle_name)
! 238: ZEND_ARG_INFO(0, last_name)
! 239: ZEND_END_ARG_INFO()
! 240:
! 241: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_modify_user, 0, 0, 3)
! 242: ZEND_ARG_INFO(0, service_handle)
! 243: ZEND_ARG_INFO(0, user_name)
! 244: ZEND_ARG_INFO(0, password)
! 245: ZEND_ARG_INFO(0, first_name)
! 246: ZEND_ARG_INFO(0, middle_name)
! 247: ZEND_ARG_INFO(0, last_name)
! 248: ZEND_END_ARG_INFO()
! 249:
! 250: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_delete_user, 0, 0, 3)
! 251: ZEND_ARG_INFO(0, service_handle)
! 252: ZEND_ARG_INFO(0, user_name)
! 253: ZEND_ARG_INFO(0, password)
! 254: ZEND_ARG_INFO(0, first_name)
! 255: ZEND_ARG_INFO(0, middle_name)
! 256: ZEND_ARG_INFO(0, last_name)
! 257: ZEND_END_ARG_INFO()
! 258:
! 259: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_service_attach, 0, 0, 3)
! 260: ZEND_ARG_INFO(0, host)
! 261: ZEND_ARG_INFO(0, dba_username)
! 262: ZEND_ARG_INFO(0, dba_password)
! 263: ZEND_END_ARG_INFO()
! 264:
! 265: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_service_detach, 0, 0, 1)
! 266: ZEND_ARG_INFO(0, service_handle)
! 267: ZEND_END_ARG_INFO()
! 268:
! 269: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_backup, 0, 0, 3)
! 270: ZEND_ARG_INFO(0, service_handle)
! 271: ZEND_ARG_INFO(0, source_db)
! 272: ZEND_ARG_INFO(0, dest_file)
! 273: ZEND_ARG_INFO(0, options)
! 274: ZEND_ARG_INFO(0, verbose)
! 275: ZEND_END_ARG_INFO()
! 276:
! 277: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_restore, 0, 0, 3)
! 278: ZEND_ARG_INFO(0, service_handle)
! 279: ZEND_ARG_INFO(0, source_file)
! 280: ZEND_ARG_INFO(0, dest_db)
! 281: ZEND_ARG_INFO(0, options)
! 282: ZEND_ARG_INFO(0, verbose)
! 283: ZEND_END_ARG_INFO()
! 284:
! 285: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_maintain_db, 0, 0, 3)
! 286: ZEND_ARG_INFO(0, service_handle)
! 287: ZEND_ARG_INFO(0, db)
! 288: ZEND_ARG_INFO(0, action)
! 289: ZEND_ARG_INFO(0, argument)
! 290: ZEND_END_ARG_INFO()
! 291:
! 292: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_db_info, 0, 0, 3)
! 293: ZEND_ARG_INFO(0, service_handle)
! 294: ZEND_ARG_INFO(0, db)
! 295: ZEND_ARG_INFO(0, action)
! 296: ZEND_ARG_INFO(0, argument)
! 297: ZEND_END_ARG_INFO()
! 298:
! 299: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_server_info, 0, 0, 2)
! 300: ZEND_ARG_INFO(0, service_handle)
! 301: ZEND_ARG_INFO(0, action)
! 302: ZEND_END_ARG_INFO()
! 303:
! 304: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_wait_event, 0, 0, 1)
! 305: ZEND_ARG_INFO(0, link_identifier)
! 306: ZEND_ARG_INFO(0, event)
! 307: ZEND_ARG_INFO(0, event2)
! 308: ZEND_END_ARG_INFO()
! 309:
! 310: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_set_event_handler, 0, 0, 2)
! 311: ZEND_ARG_INFO(0, link_identifier)
! 312: ZEND_ARG_INFO(0, handler)
! 313: ZEND_ARG_INFO(0, event)
! 314: ZEND_ARG_INFO(0, event2)
! 315: ZEND_END_ARG_INFO()
! 316:
! 317: ZEND_BEGIN_ARG_INFO_EX(arginfo_ibase_free_event_handler, 0, 0, 1)
! 318: ZEND_ARG_INFO(0, event)
! 319: ZEND_END_ARG_INFO()
! 320: /* }}} */
! 321:
! 322: /* {{{ extension definition structures */
! 323: const zend_function_entry ibase_functions[] = {
! 324: PHP_FE(ibase_connect, arginfo_ibase_connect)
! 325: PHP_FE(ibase_pconnect, arginfo_ibase_pconnect)
! 326: PHP_FE(ibase_close, arginfo_ibase_close)
! 327: PHP_FE(ibase_drop_db, arginfo_ibase_drop_db)
! 328: PHP_FE(ibase_query, arginfo_ibase_query)
! 329: PHP_FE(ibase_fetch_row, arginfo_ibase_fetch_row)
! 330: PHP_FE(ibase_fetch_assoc, arginfo_ibase_fetch_assoc)
! 331: PHP_FE(ibase_fetch_object, arginfo_ibase_fetch_object)
! 332: PHP_FE(ibase_free_result, arginfo_ibase_free_result)
! 333: PHP_FE(ibase_name_result, arginfo_ibase_name_result)
! 334: PHP_FE(ibase_prepare, arginfo_ibase_prepare)
! 335: PHP_FE(ibase_execute, arginfo_ibase_execute)
! 336: PHP_FE(ibase_free_query, arginfo_ibase_free_query)
! 337: PHP_FE(ibase_gen_id, arginfo_ibase_gen_id)
! 338: PHP_FE(ibase_num_fields, arginfo_ibase_num_fields)
! 339: PHP_FE(ibase_num_params, arginfo_ibase_num_params)
! 340: #if abies_0
! 341: PHP_FE(ibase_num_rows, arginfo_ibase_num_rows)
! 342: #endif
! 343: PHP_FE(ibase_affected_rows, arginfo_ibase_affected_rows)
! 344: PHP_FE(ibase_field_info, arginfo_ibase_field_info)
! 345: PHP_FE(ibase_param_info, arginfo_ibase_param_info)
! 346:
! 347: PHP_FE(ibase_trans, arginfo_ibase_trans)
! 348: PHP_FE(ibase_commit, arginfo_ibase_commit)
! 349: PHP_FE(ibase_rollback, arginfo_ibase_rollback)
! 350: PHP_FE(ibase_commit_ret, arginfo_ibase_commit_ret)
! 351: PHP_FE(ibase_rollback_ret, arginfo_ibase_rollback_ret)
! 352:
! 353: PHP_FE(ibase_blob_info, arginfo_ibase_blob_info)
! 354: PHP_FE(ibase_blob_create, arginfo_ibase_blob_create)
! 355: PHP_FE(ibase_blob_add, arginfo_ibase_blob_add)
! 356: PHP_FE(ibase_blob_cancel, arginfo_ibase_blob_cancel)
! 357: PHP_FE(ibase_blob_close, arginfo_ibase_blob_close)
! 358: PHP_FE(ibase_blob_open, arginfo_ibase_blob_open)
! 359: PHP_FE(ibase_blob_get, arginfo_ibase_blob_get)
! 360: PHP_FE(ibase_blob_echo, arginfo_ibase_blob_echo)
! 361: PHP_FE(ibase_blob_import, arginfo_ibase_blob_import)
! 362: PHP_FE(ibase_errmsg, arginfo_ibase_errmsg)
! 363: PHP_FE(ibase_errcode, arginfo_ibase_errcode)
! 364:
! 365: PHP_FE(ibase_add_user, arginfo_ibase_add_user)
! 366: PHP_FE(ibase_modify_user, arginfo_ibase_modify_user)
! 367: PHP_FE(ibase_delete_user, arginfo_ibase_delete_user)
! 368:
! 369: PHP_FE(ibase_service_attach, arginfo_ibase_service_attach)
! 370: PHP_FE(ibase_service_detach, arginfo_ibase_service_detach)
! 371: PHP_FE(ibase_backup, arginfo_ibase_backup)
! 372: PHP_FE(ibase_restore, arginfo_ibase_restore)
! 373: PHP_FE(ibase_maintain_db, arginfo_ibase_maintain_db)
! 374: PHP_FE(ibase_db_info, arginfo_ibase_db_info)
! 375: PHP_FE(ibase_server_info, arginfo_ibase_server_info)
! 376:
! 377: PHP_FE(ibase_wait_event, arginfo_ibase_wait_event)
! 378: PHP_FE(ibase_set_event_handler, arginfo_ibase_set_event_handler)
! 379: PHP_FE(ibase_free_event_handler, arginfo_ibase_free_event_handler)
! 380:
! 381: /**
! 382: * These aliases are provided in order to maintain forward compatibility. As Firebird
! 383: * and InterBase are developed independently, functionality might be different between
! 384: * the two branches in future versions.
! 385: * Firebird users should use the aliases, so future InterBase-specific changes will
! 386: * not affect their code
! 387: */
! 388: PHP_FALIAS(fbird_connect, ibase_connect, arginfo_ibase_connect)
! 389: PHP_FALIAS(fbird_pconnect, ibase_pconnect, arginfo_ibase_pconnect)
! 390: PHP_FALIAS(fbird_close, ibase_close, arginfo_ibase_close)
! 391: PHP_FALIAS(fbird_drop_db, ibase_drop_db, arginfo_ibase_drop_db)
! 392: PHP_FALIAS(fbird_query, ibase_query, arginfo_ibase_query)
! 393: PHP_FALIAS(fbird_fetch_row, ibase_fetch_row, arginfo_ibase_fetch_row)
! 394: PHP_FALIAS(fbird_fetch_assoc, ibase_fetch_assoc, arginfo_ibase_fetch_assoc)
! 395: PHP_FALIAS(fbird_fetch_object, ibase_fetch_object, arginfo_ibase_fetch_object)
! 396: PHP_FALIAS(fbird_free_result, ibase_free_result, arginfo_ibase_free_result)
! 397: PHP_FALIAS(fbird_name_result, ibase_name_result, arginfo_ibase_name_result)
! 398: PHP_FALIAS(fbird_prepare, ibase_prepare, arginfo_ibase_prepare)
! 399: PHP_FALIAS(fbird_execute, ibase_execute, arginfo_ibase_execute)
! 400: PHP_FALIAS(fbird_free_query, ibase_free_query, arginfo_ibase_free_query)
! 401: PHP_FALIAS(fbird_gen_id, ibase_gen_id, arginfo_ibase_gen_id)
! 402: PHP_FALIAS(fbird_num_fields, ibase_num_fields, arginfo_ibase_num_fields)
! 403: PHP_FALIAS(fbird_num_params, ibase_num_params, arginfo_ibase_num_params)
! 404: #if abies_0
! 405: PHP_FALIAS(fbird_num_rows, ibase_num_rows, arginfo_ibase_num_rows)
! 406: #endif
! 407: PHP_FALIAS(fbird_affected_rows, ibase_affected_rows, arginfo_ibase_affected_rows)
! 408: PHP_FALIAS(fbird_field_info, ibase_field_info, arginfo_ibase_field_info)
! 409: PHP_FALIAS(fbird_param_info, ibase_param_info, arginfo_ibase_param_info)
! 410:
! 411: PHP_FALIAS(fbird_trans, ibase_trans, arginfo_ibase_trans)
! 412: PHP_FALIAS(fbird_commit, ibase_commit, arginfo_ibase_commit)
! 413: PHP_FALIAS(fbird_rollback, ibase_rollback, arginfo_ibase_rollback)
! 414: PHP_FALIAS(fbird_commit_ret, ibase_commit_ret, arginfo_ibase_commit_ret)
! 415: PHP_FALIAS(fbird_rollback_ret, ibase_rollback_ret, arginfo_ibase_rollback_ret)
! 416:
! 417: PHP_FALIAS(fbird_blob_info, ibase_blob_info, arginfo_ibase_blob_info)
! 418: PHP_FALIAS(fbird_blob_create, ibase_blob_create, arginfo_ibase_blob_create)
! 419: PHP_FALIAS(fbird_blob_add, ibase_blob_add, arginfo_ibase_blob_add)
! 420: PHP_FALIAS(fbird_blob_cancel, ibase_blob_cancel, arginfo_ibase_blob_cancel)
! 421: PHP_FALIAS(fbird_blob_close, ibase_blob_close, arginfo_ibase_blob_close)
! 422: PHP_FALIAS(fbird_blob_open, ibase_blob_open, arginfo_ibase_blob_open)
! 423: PHP_FALIAS(fbird_blob_get, ibase_blob_get, arginfo_ibase_blob_get)
! 424: PHP_FALIAS(fbird_blob_echo, ibase_blob_echo, arginfo_ibase_blob_echo)
! 425: PHP_FALIAS(fbird_blob_import, ibase_blob_import, arginfo_ibase_blob_import)
! 426: PHP_FALIAS(fbird_errmsg, ibase_errmsg, arginfo_ibase_errmsg)
! 427: PHP_FALIAS(fbird_errcode, ibase_errcode, arginfo_ibase_errcode)
! 428:
! 429: PHP_FALIAS(fbird_add_user, ibase_add_user, arginfo_ibase_add_user)
! 430: PHP_FALIAS(fbird_modify_user, ibase_modify_user, arginfo_ibase_modify_user)
! 431: PHP_FALIAS(fbird_delete_user, ibase_delete_user, arginfo_ibase_delete_user)
! 432:
! 433: PHP_FALIAS(fbird_service_attach, ibase_service_attach, arginfo_ibase_service_attach)
! 434: PHP_FALIAS(fbird_service_detach, ibase_service_detach, arginfo_ibase_service_detach)
! 435: PHP_FALIAS(fbird_backup, ibase_backup, arginfo_ibase_backup)
! 436: PHP_FALIAS(fbird_restore, ibase_restore, arginfo_ibase_restore)
! 437: PHP_FALIAS(fbird_maintain_db, ibase_maintain_db, arginfo_ibase_maintain_db)
! 438: PHP_FALIAS(fbird_db_info, ibase_db_info, arginfo_ibase_db_info)
! 439: PHP_FALIAS(fbird_server_info, ibase_server_info, arginfo_ibase_server_info)
! 440:
! 441: PHP_FALIAS(fbird_wait_event, ibase_wait_event, arginfo_ibase_wait_event)
! 442: PHP_FALIAS(fbird_set_event_handler, ibase_set_event_handler, arginfo_ibase_set_event_handler)
! 443: PHP_FALIAS(fbird_free_event_handler, ibase_free_event_handler, arginfo_ibase_free_event_handler)
! 444: PHP_FE_END
! 445: };
! 446:
! 447: zend_module_entry ibase_module_entry = {
! 448: STANDARD_MODULE_HEADER,
! 449: "interbase",
! 450: ibase_functions,
! 451: PHP_MINIT(ibase),
! 452: PHP_MSHUTDOWN(ibase),
! 453: NULL,
! 454: PHP_RSHUTDOWN(ibase),
! 455: PHP_MINFO(ibase),
! 456: NO_VERSION_YET,
! 457: PHP_MODULE_GLOBALS(ibase),
! 458: PHP_GINIT(ibase),
! 459: NULL,
! 460: NULL,
! 461: STANDARD_MODULE_PROPERTIES_EX
! 462: };
! 463:
! 464: #ifdef COMPILE_DL_INTERBASE
! 465: ZEND_GET_MODULE(ibase)
! 466: #endif
! 467:
! 468: /* True globals, no need for thread safety */
! 469: int le_link, le_plink, le_trans;
! 470:
! 471: /* }}} */
! 472:
! 473: /* error handling ---------------------------- */
! 474:
! 475: /* {{{ proto string ibase_errmsg(void)
! 476: Return error message */
! 477: PHP_FUNCTION(ibase_errmsg)
! 478: {
! 479: if (zend_parse_parameters_none() == FAILURE) {
! 480: return;
! 481: }
! 482:
! 483: if (IBG(sql_code) != 0) {
! 484: RETURN_STRING(IBG(errmsg), 1);
! 485: }
! 486:
! 487: RETURN_FALSE;
! 488: }
! 489: /* }}} */
! 490:
! 491: /* {{{ proto int ibase_errcode(void)
! 492: Return error code */
! 493: PHP_FUNCTION(ibase_errcode)
! 494: {
! 495: if (zend_parse_parameters_none() == FAILURE) {
! 496: return;
! 497: }
! 498:
! 499: if (IBG(sql_code) != 0) {
! 500: RETURN_LONG(IBG(sql_code));
! 501: }
! 502: RETURN_FALSE;
! 503: }
! 504: /* }}} */
! 505:
! 506: /* print interbase error and save it for ibase_errmsg() */
! 507: void _php_ibase_error(TSRMLS_D) /* {{{ */
! 508: {
! 509: char *s = IBG(errmsg);
! 510: ISC_STATUS *statusp = IB_STATUS;
! 511:
! 512: IBG(sql_code) = isc_sqlcode(IB_STATUS);
! 513:
! 514: while ((s - IBG(errmsg)) < MAX_ERRMSG - (IBASE_MSGSIZE + 2) && isc_interprete(s, &statusp)) {
! 515: strcat(IBG(errmsg), " ");
! 516: s = IBG(errmsg) + strlen(IBG(errmsg));
! 517: }
! 518:
! 519: php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s", IBG(errmsg));
! 520: }
! 521: /* }}} */
! 522:
! 523: /* print php interbase module error and save it for ibase_errmsg() */
! 524: void _php_ibase_module_error(char *msg TSRMLS_DC, ...) /* {{{ */
! 525: {
! 526: va_list ap;
! 527:
! 528: #ifdef ZTS
! 529: va_start(ap, TSRMLS_C);
! 530: #else
! 531: va_start(ap, msg);
! 532: #endif
! 533:
! 534: /* vsnprintf NUL terminates the buf and writes at most n-1 chars+NUL */
! 535: vsnprintf(IBG(errmsg), MAX_ERRMSG, msg, ap);
! 536: va_end(ap);
! 537:
! 538: IBG(sql_code) = -999; /* no SQL error */
! 539:
! 540: php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s", IBG(errmsg));
! 541: }
! 542: /* }}} */
! 543:
! 544: /* {{{ internal macros, functions and structures */
! 545: typedef struct {
! 546: isc_db_handle *db_ptr;
! 547: long tpb_len;
! 548: char *tpb_ptr;
! 549: } ISC_TEB;
! 550:
! 551: /* }}} */
! 552:
! 553: /* Fill ib_link and trans with the correct database link and transaction. */
! 554: void _php_ibase_get_link_trans(INTERNAL_FUNCTION_PARAMETERS, /* {{{ */
! 555: zval **link_id, ibase_db_link **ib_link, ibase_trans **trans)
! 556: {
! 557: int type;
! 558:
! 559: IBDEBUG("Transaction or database link?");
! 560: if (zend_list_find(Z_LVAL_PP(link_id), &type)) {
! 561: if (type == le_trans) {
! 562: /* Transaction resource: make sure it refers to one link only, then
! 563: fetch it; database link is stored in ib_trans->db_link[]. */
! 564: IBDEBUG("Type is le_trans");
! 565: ZEND_FETCH_RESOURCE(*trans, ibase_trans *, link_id, -1, LE_TRANS, le_trans);
! 566: if ((*trans)->link_cnt > 1) {
! 567: _php_ibase_module_error("Link id is ambiguous: transaction spans multiple connections."
! 568: TSRMLS_CC);
! 569: return;
! 570: }
! 571: *ib_link = (*trans)->db_link[0];
! 572: return;
! 573: }
! 574: }
! 575: IBDEBUG("Type is le_[p]link or id not found");
! 576: /* Database link resource, use default transaction. */
! 577: *trans = NULL;
! 578: ZEND_FETCH_RESOURCE2(*ib_link, ibase_db_link *, link_id, -1, LE_LINK, le_link, le_plink);
! 579: }
! 580: /* }}} */
! 581:
! 582: /* destructors ---------------------- */
! 583:
! 584: static void _php_ibase_commit_link(ibase_db_link *link TSRMLS_DC) /* {{{ */
! 585: {
! 586: unsigned short i = 0, j;
! 587: ibase_tr_list *l;
! 588: ibase_event *e;
! 589: IBDEBUG("Checking transactions to close...");
! 590:
! 591: for (l = link->tr_list; l != NULL; ++i) {
! 592: ibase_tr_list *p = l;
! 593: if (p->trans != NULL) {
! 594: if (i == 0) {
! 595: if (p->trans->handle != NULL) {
! 596: IBDEBUG("Committing default transaction...");
! 597: if (isc_commit_transaction(IB_STATUS, &p->trans->handle)) {
! 598: _php_ibase_error(TSRMLS_C);
! 599: }
! 600: }
! 601: efree(p->trans); /* default transaction is not a registered resource: clean up */
! 602: } else {
! 603: if (p->trans->handle != NULL) {
! 604: /* non-default trans might have been rolled back by other call of this dtor */
! 605: IBDEBUG("Rolling back other transactions...");
! 606: if (isc_rollback_transaction(IB_STATUS, &p->trans->handle)) {
! 607: _php_ibase_error(TSRMLS_C);
! 608: }
! 609: }
! 610: /* set this link pointer to NULL in the transaction */
! 611: for (j = 0; j < p->trans->link_cnt; ++j) {
! 612: if (p->trans->db_link[j] == link) {
! 613: p->trans->db_link[j] = NULL;
! 614: break;
! 615: }
! 616: }
! 617: }
! 618: }
! 619: l = l->next;
! 620: efree(p);
! 621: }
! 622: link->tr_list = NULL;
! 623:
! 624: for (e = link->event_head; e; e = e->event_next) {
! 625: _php_ibase_free_event(e TSRMLS_CC);
! 626: e->link = NULL;
! 627: }
! 628: }
! 629:
! 630: /* }}} */
! 631:
! 632: static void php_ibase_commit_link_rsrc(zend_rsrc_list_entry *rsrc TSRMLS_DC) /* {{{ */
! 633: {
! 634: ibase_db_link *link = (ibase_db_link *) rsrc->ptr;
! 635:
! 636: _php_ibase_commit_link(link TSRMLS_CC);
! 637: }
! 638: /* }}} */
! 639:
! 640: static void _php_ibase_close_link(zend_rsrc_list_entry *rsrc TSRMLS_DC) /* {{{ */
! 641: {
! 642: ibase_db_link *link = (ibase_db_link *) rsrc->ptr;
! 643:
! 644: _php_ibase_commit_link(link TSRMLS_CC);
! 645: if (link->handle != NULL) {
! 646: IBDEBUG("Closing normal link...");
! 647: isc_detach_database(IB_STATUS, &link->handle);
! 648: }
! 649: IBG(num_links)--;
! 650: efree(link);
! 651: }
! 652: /* }}} */
! 653:
! 654: static void _php_ibase_close_plink(zend_rsrc_list_entry *rsrc TSRMLS_DC) /* {{{ */
! 655: {
! 656: ibase_db_link *link = (ibase_db_link *) rsrc->ptr;
! 657:
! 658: _php_ibase_commit_link(link TSRMLS_CC);
! 659: IBDEBUG("Closing permanent link...");
! 660: if (link->handle != NULL) {
! 661: isc_detach_database(IB_STATUS, &link->handle);
! 662: }
! 663: IBG(num_persistent)--;
! 664: IBG(num_links)--;
! 665: free(link);
! 666: }
! 667: /* }}} */
! 668:
! 669: static void _php_ibase_free_trans(zend_rsrc_list_entry *rsrc TSRMLS_DC) /* {{{ */
! 670: {
! 671: ibase_trans *trans = (ibase_trans *)rsrc->ptr;
! 672: unsigned short i;
! 673:
! 674: IBDEBUG("Cleaning up transaction resource...");
! 675: if (trans->handle != NULL) {
! 676: IBDEBUG("Rolling back unhandled transaction...");
! 677: if (isc_rollback_transaction(IB_STATUS, &trans->handle)) {
! 678: _php_ibase_error(TSRMLS_C);
! 679: }
! 680: }
! 681:
! 682: /* now remove this transaction from all the connection-transaction lists */
! 683: for (i = 0; i < trans->link_cnt; ++i) {
! 684: if (trans->db_link[i] != NULL) {
! 685: ibase_tr_list **l;
! 686: for (l = &trans->db_link[i]->tr_list; *l != NULL; l = &(*l)->next) {
! 687: if ( (*l)->trans == trans) {
! 688: ibase_tr_list *p = *l;
! 689: *l = p->next;
! 690: efree(p);
! 691: break;
! 692: }
! 693: }
! 694: }
! 695: }
! 696: efree(trans);
! 697: }
! 698: /* }}} */
! 699:
! 700: /* TODO this function should be part of either Zend or PHP API */
! 701: static PHP_INI_DISP(php_ibase_password_displayer_cb)
! 702: {
! 703: TSRMLS_FETCH();
! 704:
! 705: if ((type == PHP_INI_DISPLAY_ORIG && ini_entry->orig_value)
! 706: || (type == PHP_INI_DISPLAY_ACTIVE && ini_entry->value)) {
! 707: PUTS("********");
! 708: } else if (!sapi_module.phpinfo_as_text) {
! 709: PUTS("<i>no value</i>");
! 710: } else {
! 711: PUTS("no value");
! 712: }
! 713: }
! 714:
! 715: /* {{{ startup, shutdown and info functions */
! 716: PHP_INI_BEGIN()
! 717: PHP_INI_ENTRY_EX("ibase.allow_persistent", "1", PHP_INI_SYSTEM, NULL, zend_ini_boolean_displayer_cb)
! 718: PHP_INI_ENTRY_EX("ibase.max_persistent", "-1", PHP_INI_SYSTEM, NULL, display_link_numbers)
! 719: PHP_INI_ENTRY_EX("ibase.max_links", "-1", PHP_INI_SYSTEM, NULL, display_link_numbers)
! 720: PHP_INI_ENTRY("ibase.default_db", NULL, PHP_INI_SYSTEM, NULL)
! 721: PHP_INI_ENTRY("ibase.default_user", NULL, PHP_INI_ALL, NULL)
! 722: PHP_INI_ENTRY_EX("ibase.default_password", NULL, PHP_INI_ALL, NULL, php_ibase_password_displayer_cb)
! 723: PHP_INI_ENTRY("ibase.default_charset", NULL, PHP_INI_ALL, NULL)
! 724: PHP_INI_ENTRY("ibase.timestampformat", IB_DEF_DATE_FMT " " IB_DEF_TIME_FMT, PHP_INI_ALL, NULL)
! 725: PHP_INI_ENTRY("ibase.dateformat", IB_DEF_DATE_FMT, PHP_INI_ALL, NULL)
! 726: PHP_INI_ENTRY("ibase.timeformat", IB_DEF_TIME_FMT, PHP_INI_ALL, NULL)
! 727: PHP_INI_END()
! 728:
! 729: static PHP_GINIT_FUNCTION(ibase)
! 730: {
! 731: ibase_globals->num_persistent = ibase_globals->num_links = 0;
! 732: ibase_globals->sql_code = *ibase_globals->errmsg = 0;
! 733: ibase_globals->default_link = -1;
! 734: }
! 735:
! 736: PHP_MINIT_FUNCTION(ibase)
! 737: {
! 738: REGISTER_INI_ENTRIES();
! 739:
! 740: le_link = zend_register_list_destructors_ex(_php_ibase_close_link, NULL, LE_LINK, module_number);
! 741: le_plink = zend_register_list_destructors_ex(php_ibase_commit_link_rsrc, _php_ibase_close_plink, LE_PLINK, module_number);
! 742: le_trans = zend_register_list_destructors_ex(_php_ibase_free_trans, NULL, LE_TRANS, module_number);
! 743:
! 744: REGISTER_LONG_CONSTANT("IBASE_DEFAULT", PHP_IBASE_DEFAULT, CONST_PERSISTENT);
! 745: REGISTER_LONG_CONSTANT("IBASE_CREATE", PHP_IBASE_CREATE, CONST_PERSISTENT);
! 746: REGISTER_LONG_CONSTANT("IBASE_TEXT", PHP_IBASE_FETCH_BLOBS, CONST_PERSISTENT); /* deprecated, for BC only */
! 747: REGISTER_LONG_CONSTANT("IBASE_FETCH_BLOBS", PHP_IBASE_FETCH_BLOBS, CONST_PERSISTENT);
! 748: REGISTER_LONG_CONSTANT("IBASE_FETCH_ARRAYS", PHP_IBASE_FETCH_ARRAYS, CONST_PERSISTENT);
! 749: REGISTER_LONG_CONSTANT("IBASE_UNIXTIME", PHP_IBASE_UNIXTIME, CONST_PERSISTENT);
! 750:
! 751: /* transactions */
! 752: REGISTER_LONG_CONSTANT("IBASE_WRITE", PHP_IBASE_WRITE, CONST_PERSISTENT);
! 753: REGISTER_LONG_CONSTANT("IBASE_READ", PHP_IBASE_READ, CONST_PERSISTENT);
! 754: REGISTER_LONG_CONSTANT("IBASE_COMMITTED", PHP_IBASE_COMMITTED, CONST_PERSISTENT);
! 755: REGISTER_LONG_CONSTANT("IBASE_CONSISTENCY", PHP_IBASE_CONSISTENCY, CONST_PERSISTENT);
! 756: REGISTER_LONG_CONSTANT("IBASE_CONCURRENCY", PHP_IBASE_CONCURRENCY, CONST_PERSISTENT);
! 757: REGISTER_LONG_CONSTANT("IBASE_REC_VERSION", PHP_IBASE_REC_VERSION, CONST_PERSISTENT);
! 758: REGISTER_LONG_CONSTANT("IBASE_REC_NO_VERSION", PHP_IBASE_REC_NO_VERSION, CONST_PERSISTENT);
! 759: REGISTER_LONG_CONSTANT("IBASE_NOWAIT", PHP_IBASE_NOWAIT, CONST_PERSISTENT);
! 760: REGISTER_LONG_CONSTANT("IBASE_WAIT", PHP_IBASE_WAIT, CONST_PERSISTENT);
! 761:
! 762: php_ibase_query_minit(INIT_FUNC_ARGS_PASSTHRU);
! 763: php_ibase_blobs_minit(INIT_FUNC_ARGS_PASSTHRU);
! 764: php_ibase_events_minit(INIT_FUNC_ARGS_PASSTHRU);
! 765: php_ibase_service_minit(INIT_FUNC_ARGS_PASSTHRU);
! 766:
! 767: return SUCCESS;
! 768: }
! 769:
! 770: PHP_MSHUTDOWN_FUNCTION(ibase)
! 771: {
! 772: #ifndef PHP_WIN32
! 773: /**
! 774: * When the Interbase client API library libgds.so is first loaded, it registers a call to
! 775: * gds__cleanup() with atexit(), in order to clean up after itself when the process exits.
! 776: * This means that the library is called at process shutdown, and cannot be unloaded beforehand.
! 777: * PHP tries to unload modules after every request [dl()'ed modules], and right before the
! 778: * process shuts down [modules loaded from php.ini]. This results in a segfault for this module.
! 779: * By NULLing the dlopen() handle in the module entry, Zend omits the call to dlclose(),
! 780: * ensuring that the module will remain present until the process exits. However, the functions
! 781: * and classes exported by the module will not be available until the module is 'reloaded'.
! 782: * When reloaded, dlopen() will return the handle of the already loaded module. The module will
! 783: * be unloaded automatically when the process exits.
! 784: */
! 785: zend_module_entry *ibase_entry;
! 786: if (SUCCESS == zend_hash_find(&module_registry, ibase_module_entry.name,
! 787: strlen(ibase_module_entry.name) +1, (void*) &ibase_entry)) {
! 788: ibase_entry->handle = NULL;
! 789: }
! 790: #endif
! 791: UNREGISTER_INI_ENTRIES();
! 792: return SUCCESS;
! 793: }
! 794:
! 795: PHP_RSHUTDOWN_FUNCTION(ibase)
! 796: {
! 797: IBG(num_links) = IBG(num_persistent);
! 798: IBG(default_link)= -1;
! 799:
! 800: RESET_ERRMSG;
! 801:
! 802: return SUCCESS;
! 803: }
! 804:
! 805: PHP_MINFO_FUNCTION(ibase)
! 806: {
! 807: char tmp[64], *s;
! 808:
! 809: php_info_print_table_start();
! 810: php_info_print_table_row(2, "Firebird/InterBase Support",
! 811: #ifdef COMPILE_DL_INTERBASE
! 812: "dynamic");
! 813: #else
! 814: "static");
! 815: #endif
! 816:
! 817: #ifdef FB_API_VER
! 818: snprintf( (s = tmp), sizeof(tmp), "Firebird API version %d", FB_API_VER);
! 819: #elif (SQLDA_CURRENT_VERSION > 1)
! 820: s = "Interbase 7.0 and up";
! 821: #elif !defined(DSC_null)
! 822: s = "Interbase 6";
! 823: #else
! 824: s = "Firebird 1.0";
! 825: #endif
! 826: php_info_print_table_row(2, "Compile-time Client Library Version", s);
! 827:
! 828: #if defined(__GNUC__) || defined(PHP_WIN32)
! 829: do {
! 830: info_func_t info_func = NULL;
! 831: #ifdef __GNUC__
! 832: info_func = (info_func_t)dlsym(RTLD_DEFAULT, "isc_get_client_version");
! 833: #else
! 834: HMODULE l = GetModuleHandle("fbclient");
! 835:
! 836: if (!l && !(l = GetModuleHandle("gds32"))) {
! 837: break;
! 838: }
! 839: info_func = (info_func_t)GetProcAddress(l, "isc_get_client_version");
! 840: #endif
! 841: if (info_func) {
! 842: info_func(s = tmp);
! 843: } else {
! 844: s = "Firebird 1.0/Interbase 6";
! 845: }
! 846: php_info_print_table_row(2, "Run-time Client Library Version", s);
! 847: } while (0);
! 848: #endif
! 849: php_info_print_table_end();
! 850:
! 851: DISPLAY_INI_ENTRIES();
! 852:
! 853: }
! 854: /* }}} */
! 855:
! 856: enum connect_args { DB = 0, USER = 1, PASS = 2, CSET = 3, ROLE = 4, BUF = 0, DLECT = 1, SYNC = 2 };
! 857:
! 858: static char const dpb_args[] = {
! 859: 0, isc_dpb_user_name, isc_dpb_password, isc_dpb_lc_ctype, isc_dpb_sql_role_name, 0
! 860: };
! 861:
! 862: int _php_ibase_attach_db(char **args, int *len, long *largs, isc_db_handle *db TSRMLS_DC)
! 863: {
! 864: short i, dpb_len, buf_len = 257-2; /* version byte at the front, and a null at the end */
! 865: char dpb_buffer[257] = { isc_dpb_version1, 0 }, *dpb;
! 866:
! 867: dpb = dpb_buffer + 1;
! 868:
! 869: for (i = 0; i < sizeof(dpb_args); ++i) {
! 870: if (dpb_args[i] && args[i] && len[i] && buf_len > 0) {
! 871: dpb_len = slprintf(dpb, buf_len, "%c%c%s", dpb_args[i],(unsigned char)len[i],args[i]);
! 872: dpb += dpb_len;
! 873: buf_len -= dpb_len;
! 874: }
! 875: }
! 876: if (largs[BUF] && buf_len > 0) {
! 877: dpb_len = slprintf(dpb, buf_len, "%c\2%c%c", isc_dpb_num_buffers,
! 878: (char)(largs[BUF] >> 8), (char)(largs[BUF] & 0xff));
! 879: dpb += dpb_len;
! 880: buf_len -= dpb_len;
! 881: }
! 882: if (largs[SYNC] && buf_len > 0) {
! 883: dpb_len = slprintf(dpb, buf_len, "%c\1%c", isc_dpb_force_write, largs[SYNC] == isc_spb_prp_wm_sync ? 1 : 0);
! 884: dpb += dpb_len;
! 885: buf_len -= dpb_len;
! 886: }
! 887: if (isc_attach_database(IB_STATUS, (short)len[DB], args[DB], db, (short)(dpb-dpb_buffer), dpb_buffer)) {
! 888: _php_ibase_error(TSRMLS_C);
! 889: return FAILURE;
! 890: }
! 891: return SUCCESS;
! 892: }
! 893: /* }}} */
! 894:
! 895: static void _php_ibase_connect(INTERNAL_FUNCTION_PARAMETERS, int persistent) /* {{{ */
! 896: {
! 897: char *c, hash[16], *args[] = { NULL, NULL, NULL, NULL, NULL };
! 898: int i, len[] = { 0, 0, 0, 0, 0 };
! 899: long largs[] = { 0, 0, 0 };
! 900: PHP_MD5_CTX hash_context;
! 901: zend_rsrc_list_entry new_index_ptr, *le;
! 902: isc_db_handle db_handle = NULL;
! 903: ibase_db_link *ib_link;
! 904:
! 905: RESET_ERRMSG;
! 906:
! 907: if (FAILURE == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|ssssllsl",
! 908: &args[DB], &len[DB], &args[USER], &len[USER], &args[PASS], &len[PASS],
! 909: &args[CSET], &len[CSET], &largs[BUF], &largs[DLECT], &args[ROLE], &len[ROLE],
! 910: &largs[SYNC])) {
! 911: RETURN_FALSE;
! 912: }
! 913:
! 914: /* restrict to the server/db in the .ini if in safe mode */
! 915: if ((!len[DB] || PG(sql_safe_mode)) && (c = INI_STR("ibase.default_db"))) {
! 916: args[DB] = c;
! 917: len[DB] = strlen(c);
! 918: }
! 919: if (!len[USER] && (c = INI_STR("ibase.default_user"))) {
! 920: args[USER] = c;
! 921: len[USER] = strlen(c);
! 922: }
! 923: if (!len[PASS] && (c = INI_STR("ibase.default_password"))) {
! 924: args[PASS] = c;
! 925: len[PASS] = strlen(c);
! 926: }
! 927: if (!len[CSET] && (c = INI_STR("ibase.default_charset"))) {
! 928: args[CSET] = c;
! 929: len[CSET] = strlen(c);
! 930: }
! 931:
! 932: /* don't want usernames and passwords floating around */
! 933: PHP_MD5Init(&hash_context);
! 934: for (i = 0; i < sizeof(args)/sizeof(char*); ++i) {
! 935: PHP_MD5Update(&hash_context,args[i],len[i]);
! 936: }
! 937: for (i = 0; i < sizeof(largs)/sizeof(long); ++i) {
! 938: PHP_MD5Update(&hash_context,(char*)&largs[i],sizeof(long));
! 939: }
! 940: PHP_MD5Final(hash, &hash_context);
! 941:
! 942: /* try to reuse a connection */
! 943: if (SUCCESS == zend_hash_find(&EG(regular_list), hash, sizeof(hash), (void *) &le)) {
! 944: long xlink;
! 945: int type;
! 946:
! 947: if (Z_TYPE_P(le) != le_index_ptr) {
! 948: RETURN_FALSE;
! 949: }
! 950:
! 951: xlink = (long) le->ptr;
! 952: if (zend_list_find(xlink, &type) && ((!persistent && type == le_link) || type == le_plink)) {
! 953: zend_list_addref(xlink);
! 954: RETURN_RESOURCE(IBG(default_link) = xlink);
! 955: } else {
! 956: zend_hash_del(&EG(regular_list), hash, sizeof(hash));
! 957: }
! 958: }
! 959:
! 960: /* ... or a persistent one */
! 961: switch (zend_hash_find(&EG(persistent_list), hash, sizeof(hash), (void *) &le)) {
! 962: long l;
! 963:
! 964: static char info[] = { isc_info_base_level, isc_info_end };
! 965: char result[8];
! 966: ISC_STATUS status[20];
! 967:
! 968: case SUCCESS:
! 969:
! 970: if (Z_TYPE_P(le) != le_plink) {
! 971: RETURN_FALSE;
! 972: }
! 973: /* check if connection has timed out */
! 974: ib_link = (ibase_db_link *) le->ptr;
! 975: if (!isc_database_info(status, &ib_link->handle, sizeof(info), info, sizeof(result), result)) {
! 976: ZEND_REGISTER_RESOURCE(return_value, ib_link, le_plink);
! 977: break;
! 978: }
! 979: zend_hash_del(&EG(persistent_list), hash, sizeof(hash));
! 980:
! 981: default:
! 982:
! 983: /* no link found, so we have to open one */
! 984:
! 985: if ((l = INI_INT("ibase.max_links")) != -1 && IBG(num_links) >= l) {
! 986: _php_ibase_module_error("Too many open links (%ld)" TSRMLS_CC, IBG(num_links));
! 987: RETURN_FALSE;
! 988: }
! 989:
! 990: /* create the ib_link */
! 991: if (FAILURE == _php_ibase_attach_db(args, len, largs, &db_handle TSRMLS_CC)) {
! 992: RETURN_FALSE;
! 993: }
! 994:
! 995: /* use non-persistent if allowed number of persistent links is exceeded */
! 996: if (!persistent || ((l = INI_INT("ibase.max_persistent") != -1) && IBG(num_persistent) >= l)) {
! 997: ib_link = (ibase_db_link *) emalloc(sizeof(ibase_db_link));
! 998: ZEND_REGISTER_RESOURCE(return_value, ib_link, le_link);
! 999: } else {
! 1000: zend_rsrc_list_entry new_le;
! 1001:
! 1002: ib_link = (ibase_db_link *) malloc(sizeof(ibase_db_link));
! 1003: if (!ib_link) {
! 1004: RETURN_FALSE;
! 1005: }
! 1006:
! 1007: /* hash it up */
! 1008: Z_TYPE(new_le) = le_plink;
! 1009: new_le.ptr = ib_link;
! 1010: if (FAILURE == zend_hash_update(&EG(persistent_list), hash, sizeof(hash),
! 1011: (void *) &new_le, sizeof(zend_rsrc_list_entry), NULL)) {
! 1012: free(ib_link);
! 1013: RETURN_FALSE;
! 1014: }
! 1015: ZEND_REGISTER_RESOURCE(return_value, ib_link, le_plink);
! 1016: ++IBG(num_persistent);
! 1017: }
! 1018: ib_link->handle = db_handle;
! 1019: ib_link->dialect = largs[DLECT] ? (unsigned short)largs[DLECT] : SQL_DIALECT_CURRENT;
! 1020: ib_link->tr_list = NULL;
! 1021: ib_link->event_head = NULL;
! 1022:
! 1023: ++IBG(num_links);
! 1024: }
! 1025:
! 1026: /* add it to the hash */
! 1027: new_index_ptr.ptr = (void *) Z_LVAL_P(return_value);
! 1028: Z_TYPE(new_index_ptr) = le_index_ptr;
! 1029: if (FAILURE == zend_hash_update(&EG(regular_list), hash, sizeof(hash),
! 1030: (void *) &new_index_ptr, sizeof(zend_rsrc_list_entry), NULL)) {
! 1031: RETURN_FALSE;
! 1032: }
! 1033: zend_list_addref(IBG(default_link) = Z_LVAL_P(return_value));
! 1034: }
! 1035: /* }}} */
! 1036:
! 1037: /* {{{ proto resource ibase_connect(string database [, string username [, string password [, string charset [, int buffers [, int dialect [, string role]]]]]])
! 1038: Open a connection to an InterBase database */
! 1039: PHP_FUNCTION(ibase_connect)
! 1040: {
! 1041: _php_ibase_connect(INTERNAL_FUNCTION_PARAM_PASSTHRU, 0);
! 1042: }
! 1043: /* }}} */
! 1044:
! 1045: /* {{{ proto resource ibase_pconnect(string database [, string username [, string password [, string charset [, int buffers [, int dialect [, string role]]]]]])
! 1046: Open a persistent connection to an InterBase database */
! 1047: PHP_FUNCTION(ibase_pconnect)
! 1048: {
! 1049: _php_ibase_connect(INTERNAL_FUNCTION_PARAM_PASSTHRU, INI_INT("ibase.allow_persistent"));
! 1050: }
! 1051: /* }}} */
! 1052:
! 1053: /* {{{ proto bool ibase_close([resource link_identifier])
! 1054: Close an InterBase connection */
! 1055: PHP_FUNCTION(ibase_close)
! 1056: {
! 1057: zval *link_arg = NULL;
! 1058: ibase_db_link *ib_link;
! 1059: int link_id;
! 1060:
! 1061: RESET_ERRMSG;
! 1062:
! 1063: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &link_arg) == FAILURE) {
! 1064: return;
! 1065: }
! 1066:
! 1067: if (ZEND_NUM_ARGS() == 0) {
! 1068: link_id = IBG(default_link);
! 1069: CHECK_LINK(link_id);
! 1070: IBG(default_link) = -1;
! 1071: } else {
! 1072: link_id = Z_RESVAL_P(link_arg);
! 1073: }
! 1074:
! 1075: ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, &link_arg, link_id, LE_LINK, le_link, le_plink);
! 1076: zend_list_delete(link_id);
! 1077: RETURN_TRUE;
! 1078: }
! 1079: /* }}} */
! 1080:
! 1081: /* {{{ proto bool ibase_drop_db([resource link_identifier])
! 1082: Drop an InterBase database */
! 1083: PHP_FUNCTION(ibase_drop_db)
! 1084: {
! 1085: zval *link_arg = NULL;
! 1086: ibase_db_link *ib_link;
! 1087: ibase_tr_list *l;
! 1088: int link_id;
! 1089:
! 1090: RESET_ERRMSG;
! 1091:
! 1092: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &link_arg) == FAILURE) {
! 1093: return;
! 1094: }
! 1095:
! 1096: if (ZEND_NUM_ARGS() == 0) {
! 1097: link_id = IBG(default_link);
! 1098: CHECK_LINK(link_id);
! 1099: IBG(default_link) = -1;
! 1100: } else {
! 1101: link_id = Z_RESVAL_P(link_arg);
! 1102: }
! 1103:
! 1104: ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, &link_arg, link_id, LE_LINK, le_link, le_plink);
! 1105:
! 1106: if (isc_drop_database(IB_STATUS, &ib_link->handle)) {
! 1107: _php_ibase_error(TSRMLS_C);
! 1108: RETURN_FALSE;
! 1109: }
! 1110:
! 1111: /* isc_drop_database() doesn't invalidate the transaction handles */
! 1112: for (l = ib_link->tr_list; l != NULL; l = l->next) {
! 1113: if (l->trans != NULL) l->trans->handle = NULL;
! 1114: }
! 1115:
! 1116: zend_list_delete(link_id);
! 1117: RETURN_TRUE;
! 1118: }
! 1119: /* }}} */
! 1120:
! 1121: /* {{{ proto resource ibase_trans([int trans_args [, resource link_identifier [, ... ], int trans_args [, resource link_identifier [, ... ]] [, ...]]])
! 1122: Start a transaction over one or several databases */
! 1123:
! 1124: #define TPB_MAX_SIZE (8*sizeof(char))
! 1125:
! 1126: PHP_FUNCTION(ibase_trans)
! 1127: {
! 1128: unsigned short i, argn, link_cnt = 0, tpb_len = 0;
! 1129: char last_tpb[TPB_MAX_SIZE];
! 1130: ibase_db_link **ib_link = NULL;
! 1131: ibase_trans *ib_trans;
! 1132: isc_tr_handle tr_handle = NULL;
! 1133: ISC_STATUS result;
! 1134:
! 1135: RESET_ERRMSG;
! 1136:
! 1137: argn = ZEND_NUM_ARGS();
! 1138:
! 1139: /* (1+argn) is an upper bound for the number of links this trans connects to */
! 1140: ib_link = (ibase_db_link **) safe_emalloc(sizeof(ibase_db_link *),1+argn,0);
! 1141:
! 1142: if (argn > 0) {
! 1143: long trans_argl = 0;
! 1144: char *tpb;
! 1145: ISC_TEB *teb;
! 1146: zval ***args = NULL;
! 1147:
! 1148: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "+", &args, &argn) == FAILURE) {
! 1149: efree(args);
! 1150: efree(ib_link);
! 1151: RETURN_FALSE;
! 1152: }
! 1153:
! 1154: teb = (ISC_TEB *) safe_emalloc(sizeof(ISC_TEB),argn,0);
! 1155: tpb = (char *) safe_emalloc(TPB_MAX_SIZE,argn,0);
! 1156:
! 1157: /* enumerate all the arguments: assume every non-resource argument
! 1158: specifies modifiers for the link ids that follow it */
! 1159: for (i = 0; i < argn; ++i) {
! 1160:
! 1161: if (Z_TYPE_PP(args[i]) == IS_RESOURCE) {
! 1162:
! 1163: if (!ZEND_FETCH_RESOURCE2_NO_RETURN(ib_link[link_cnt], ibase_db_link *, args[i], -1, LE_LINK, le_link, le_plink)) {
! 1164: efree(teb);
! 1165: efree(tpb);
! 1166: efree(ib_link);
! 1167: efree(args);
! 1168: RETURN_FALSE;
! 1169: }
! 1170:
! 1171: /* copy the most recent modifier string into tbp[] */
! 1172: memcpy(&tpb[TPB_MAX_SIZE * link_cnt], last_tpb, TPB_MAX_SIZE);
! 1173:
! 1174: /* add a database handle to the TEB with the most recently specified set of modifiers */
! 1175: teb[link_cnt].db_ptr = &ib_link[link_cnt]->handle;
! 1176: teb[link_cnt].tpb_len = tpb_len;
! 1177: teb[link_cnt].tpb_ptr = &tpb[TPB_MAX_SIZE * link_cnt];
! 1178:
! 1179: ++link_cnt;
! 1180:
! 1181: } else {
! 1182:
! 1183: tpb_len = 0;
! 1184:
! 1185: convert_to_long_ex(args[i]);
! 1186: trans_argl = Z_LVAL_PP(args[i]);
! 1187:
! 1188: if (trans_argl != PHP_IBASE_DEFAULT) {
! 1189: last_tpb[tpb_len++] = isc_tpb_version3;
! 1190:
! 1191: /* access mode */
! 1192: if (PHP_IBASE_READ == (trans_argl & PHP_IBASE_READ)) {
! 1193: last_tpb[tpb_len++] = isc_tpb_read;
! 1194: } else if (PHP_IBASE_WRITE == (trans_argl & PHP_IBASE_WRITE)) {
! 1195: last_tpb[tpb_len++] = isc_tpb_write;
! 1196: }
! 1197:
! 1198: /* isolation level */
! 1199: if (PHP_IBASE_COMMITTED == (trans_argl & PHP_IBASE_COMMITTED)) {
! 1200: last_tpb[tpb_len++] = isc_tpb_read_committed;
! 1201: if (PHP_IBASE_REC_VERSION == (trans_argl & PHP_IBASE_REC_VERSION)) {
! 1202: last_tpb[tpb_len++] = isc_tpb_rec_version;
! 1203: } else if (PHP_IBASE_REC_NO_VERSION == (trans_argl & PHP_IBASE_REC_NO_VERSION)) {
! 1204: last_tpb[tpb_len++] = isc_tpb_no_rec_version;
! 1205: }
! 1206: } else if (PHP_IBASE_CONSISTENCY == (trans_argl & PHP_IBASE_CONSISTENCY)) {
! 1207: last_tpb[tpb_len++] = isc_tpb_consistency;
! 1208: } else if (PHP_IBASE_CONCURRENCY == (trans_argl & PHP_IBASE_CONCURRENCY)) {
! 1209: last_tpb[tpb_len++] = isc_tpb_concurrency;
! 1210: }
! 1211:
! 1212: /* lock resolution */
! 1213: if (PHP_IBASE_NOWAIT == (trans_argl & PHP_IBASE_NOWAIT)) {
! 1214: last_tpb[tpb_len++] = isc_tpb_nowait;
! 1215: } else if (PHP_IBASE_WAIT == (trans_argl & PHP_IBASE_WAIT)) {
! 1216: last_tpb[tpb_len++] = isc_tpb_wait;
! 1217: }
! 1218: }
! 1219: }
! 1220: }
! 1221:
! 1222: if (link_cnt > 0) {
! 1223: result = isc_start_multiple(IB_STATUS, &tr_handle, link_cnt, teb);
! 1224: }
! 1225:
! 1226: efree(args);
! 1227: efree(tpb);
! 1228: efree(teb);
! 1229: }
! 1230:
! 1231: if (link_cnt == 0) {
! 1232: link_cnt = 1;
! 1233: if (!ZEND_FETCH_RESOURCE2_NO_RETURN(ib_link[0], ibase_db_link *, NULL, IBG(default_link), LE_LINK, le_link, le_plink)) {
! 1234: efree(ib_link);
! 1235: RETURN_FALSE;
! 1236: }
! 1237: result = isc_start_transaction(IB_STATUS, &tr_handle, 1, &ib_link[0]->handle, tpb_len, last_tpb);
! 1238: }
! 1239:
! 1240: /* start the transaction */
! 1241: if (result) {
! 1242: _php_ibase_error(TSRMLS_C);
! 1243: efree(ib_link);
! 1244: RETURN_FALSE;
! 1245: }
! 1246:
! 1247: /* register the transaction in our own data structures */
! 1248: ib_trans = (ibase_trans *) safe_emalloc(link_cnt-1, sizeof(ibase_db_link *), sizeof(ibase_trans));
! 1249: ib_trans->handle = tr_handle;
! 1250: ib_trans->link_cnt = link_cnt;
! 1251: ib_trans->affected_rows = 0;
! 1252: for (i = 0; i < link_cnt; ++i) {
! 1253: ibase_tr_list **l;
! 1254: ib_trans->db_link[i] = ib_link[i];
! 1255:
! 1256: /* the first item in the connection-transaction list is reserved for the default transaction */
! 1257: if (ib_link[i]->tr_list == NULL) {
! 1258: ib_link[i]->tr_list = (ibase_tr_list *) emalloc(sizeof(ibase_tr_list));
! 1259: ib_link[i]->tr_list->trans = NULL;
! 1260: ib_link[i]->tr_list->next = NULL;
! 1261: }
! 1262:
! 1263: /* link the transaction into the connection-transaction list */
! 1264: for (l = &ib_link[i]->tr_list; *l != NULL; l = &(*l)->next);
! 1265: *l = (ibase_tr_list *) emalloc(sizeof(ibase_tr_list));
! 1266: (*l)->trans = ib_trans;
! 1267: (*l)->next = NULL;
! 1268: }
! 1269: efree(ib_link);
! 1270: ZEND_REGISTER_RESOURCE(return_value, ib_trans, le_trans);
! 1271: }
! 1272: /* }}} */
! 1273:
! 1274: int _php_ibase_def_trans(ibase_db_link *ib_link, ibase_trans **trans TSRMLS_DC) /* {{{ */
! 1275: {
! 1276: if (ib_link == NULL) {
! 1277: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Invalid database link");
! 1278: return FAILURE;
! 1279: }
! 1280:
! 1281: /* the first item in the connection-transaction list is reserved for the default transaction */
! 1282: if (ib_link->tr_list == NULL) {
! 1283: ib_link->tr_list = (ibase_tr_list *) emalloc(sizeof(ibase_tr_list));
! 1284: ib_link->tr_list->trans = NULL;
! 1285: ib_link->tr_list->next = NULL;
! 1286: }
! 1287:
! 1288: if (*trans == NULL) {
! 1289: ibase_trans *tr = ib_link->tr_list->trans;
! 1290:
! 1291: if (tr == NULL) {
! 1292: tr = (ibase_trans *) emalloc(sizeof(ibase_trans));
! 1293: tr->handle = NULL;
! 1294: tr->link_cnt = 1;
! 1295: tr->affected_rows = 0;
! 1296: tr->db_link[0] = ib_link;
! 1297: ib_link->tr_list->trans = tr;
! 1298: }
! 1299: if (tr->handle == NULL) {
! 1300: if (isc_start_transaction(IB_STATUS, &tr->handle, 1, &ib_link->handle, 0, NULL)) {
! 1301: _php_ibase_error(TSRMLS_C);
! 1302: return FAILURE;
! 1303: }
! 1304: }
! 1305: *trans = tr;
! 1306: }
! 1307: return SUCCESS;
! 1308: }
! 1309: /* }}} */
! 1310:
! 1311: static void _php_ibase_trans_end(INTERNAL_FUNCTION_PARAMETERS, int commit) /* {{{ */
! 1312: {
! 1313: ibase_trans *trans = NULL;
! 1314: int res_id = 0;
! 1315: ISC_STATUS result;
! 1316: ibase_db_link *ib_link;
! 1317: zval *arg = NULL;
! 1318: int type;
! 1319:
! 1320: RESET_ERRMSG;
! 1321:
! 1322: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &arg) == FAILURE) {
! 1323: return;
! 1324: }
! 1325:
! 1326: if (ZEND_NUM_ARGS() == 0) {
! 1327: ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, NULL, IBG(default_link), LE_LINK, le_link, le_plink);
! 1328: if (ib_link->tr_list == NULL || ib_link->tr_list->trans == NULL) {
! 1329: /* this link doesn't have a default transaction */
! 1330: _php_ibase_module_error("Default link has no default transaction" TSRMLS_CC);
! 1331: RETURN_FALSE;
! 1332: }
! 1333: trans = ib_link->tr_list->trans;
! 1334: } else {
! 1335: /* one id was passed, could be db or trans id */
! 1336: if (zend_list_find(Z_RESVAL_P(arg), &type) && type == le_trans) {
! 1337: ZEND_FETCH_RESOURCE(trans, ibase_trans *, &arg, -1, LE_TRANS, le_trans);
! 1338: res_id = Z_RESVAL_P(arg);
! 1339: } else {
! 1340: ZEND_FETCH_RESOURCE2(ib_link, ibase_db_link *, &arg, -1, LE_LINK, le_link, le_plink);
! 1341:
! 1342: if (ib_link->tr_list == NULL || ib_link->tr_list->trans == NULL) {
! 1343: /* this link doesn't have a default transaction */
! 1344: _php_ibase_module_error("Link has no default transaction" TSRMLS_CC);
! 1345: RETURN_FALSE;
! 1346: }
! 1347: trans = ib_link->tr_list->trans;
! 1348: }
! 1349: }
! 1350:
! 1351: switch (commit) {
! 1352: default: /* == case ROLLBACK: */
! 1353: result = isc_rollback_transaction(IB_STATUS, &trans->handle);
! 1354: break;
! 1355: case COMMIT:
! 1356: result = isc_commit_transaction(IB_STATUS, &trans->handle);
! 1357: break;
! 1358: case (ROLLBACK | RETAIN):
! 1359: result = isc_rollback_retaining(IB_STATUS, &trans->handle);
! 1360: break;
! 1361: case (COMMIT | RETAIN):
! 1362: result = isc_commit_retaining(IB_STATUS, &trans->handle);
! 1363: break;
! 1364: }
! 1365:
! 1366: if (result) {
! 1367: _php_ibase_error(TSRMLS_C);
! 1368: RETURN_FALSE;
! 1369: }
! 1370:
! 1371: /* Don't try to destroy implicitly opened transaction from list... */
! 1372: if ((commit & RETAIN) == 0 && res_id != 0) {
! 1373: zend_list_delete(res_id);
! 1374: }
! 1375: RETURN_TRUE;
! 1376: }
! 1377: /* }}} */
! 1378:
! 1379: /* {{{ proto bool ibase_commit( resource link_identifier )
! 1380: Commit transaction */
! 1381: PHP_FUNCTION(ibase_commit)
! 1382: {
! 1383: _php_ibase_trans_end(INTERNAL_FUNCTION_PARAM_PASSTHRU, COMMIT);
! 1384: }
! 1385: /* }}} */
! 1386:
! 1387: /* {{{ proto bool ibase_rollback( resource link_identifier )
! 1388: Rollback transaction */
! 1389: PHP_FUNCTION(ibase_rollback)
! 1390: {
! 1391: _php_ibase_trans_end(INTERNAL_FUNCTION_PARAM_PASSTHRU, ROLLBACK);
! 1392: }
! 1393: /* }}} */
! 1394:
! 1395: /* {{{ proto bool ibase_commit_ret( resource link_identifier )
! 1396: Commit transaction and retain the transaction context */
! 1397: PHP_FUNCTION(ibase_commit_ret)
! 1398: {
! 1399: _php_ibase_trans_end(INTERNAL_FUNCTION_PARAM_PASSTHRU, COMMIT | RETAIN);
! 1400: }
! 1401: /* }}} */
! 1402:
! 1403: /* {{{ proto bool ibase_rollback_ret( resource link_identifier )
! 1404: Rollback transaction and retain the transaction context */
! 1405: PHP_FUNCTION(ibase_rollback_ret)
! 1406: {
! 1407: _php_ibase_trans_end(INTERNAL_FUNCTION_PARAM_PASSTHRU, ROLLBACK | RETAIN);
! 1408: }
! 1409: /* }}} */
! 1410:
! 1411: /* {{{ proto int ibase_gen_id(string generator [, int increment [, resource link_identifier ]])
! 1412: Increments the named generator and returns its new value */
! 1413: PHP_FUNCTION(ibase_gen_id)
! 1414: {
! 1415: zval *link = NULL;
! 1416: char query[128], *generator;
! 1417: int gen_len;
! 1418: long inc = 1;
! 1419: ibase_db_link *ib_link;
! 1420: ibase_trans *trans = NULL;
! 1421: XSQLDA out_sqlda;
! 1422: ISC_INT64 result;
! 1423:
! 1424: RESET_ERRMSG;
! 1425:
! 1426: if (FAILURE == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|lr", &generator, &gen_len,
! 1427: &inc, &link)) {
! 1428: RETURN_FALSE;
! 1429: }
! 1430:
! 1431: if (gen_len > 31) {
! 1432: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Invalid generator name");
! 1433: RETURN_FALSE;
! 1434: }
! 1435:
! 1436: PHP_IBASE_LINK_TRANS(link, ib_link, trans);
! 1437:
! 1438: snprintf(query, sizeof(query), "SELECT GEN_ID(%s,%ld) FROM rdb$database", generator, inc);
! 1439:
! 1440: /* allocate a minimal descriptor area */
! 1441: out_sqlda.sqln = out_sqlda.sqld = 1;
! 1442: out_sqlda.version = SQLDA_CURRENT_VERSION;
! 1443:
! 1444: /* allocate the field for the result */
! 1445: out_sqlda.sqlvar[0].sqltype = SQL_INT64;
! 1446: out_sqlda.sqlvar[0].sqlscale = 0;
! 1447: out_sqlda.sqlvar[0].sqllen = sizeof(result);
! 1448: out_sqlda.sqlvar[0].sqldata = (void*) &result;
! 1449:
! 1450: /* execute the query */
! 1451: if (isc_dsql_exec_immed2(IB_STATUS, &ib_link->handle, &trans->handle, 0, query,
! 1452: SQL_DIALECT_CURRENT, NULL, &out_sqlda)) {
! 1453: _php_ibase_error(TSRMLS_C);
! 1454: RETURN_FALSE;
! 1455: }
! 1456:
! 1457: /* don't return the generator value as a string unless it doesn't fit in a long */
! 1458: #if SIZEOF_LONG < 8
! 1459: if (result < LONG_MIN || result > LONG_MAX) {
! 1460: char *res;
! 1461: int l;
! 1462:
! 1463: l = spprintf(&res, 0, "%" LL_MASK "d", result);
! 1464: RETURN_STRINGL(res, l, 0);
! 1465: }
! 1466: #endif
! 1467: RETURN_LONG((long)result);
! 1468: }
! 1469:
! 1470: /* }}} */
! 1471:
! 1472: #endif /* HAVE_IBASE */
! 1473:
! 1474: /*
! 1475: * Local variables:
! 1476: * tab-width: 4
! 1477: * c-basic-offset: 4
! 1478: * End:
! 1479: * vim600: sw=4 ts=4 fdm=marker
! 1480: * vim<600: sw=4 ts=4
! 1481: */
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to interbase.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / php / ext / interbase