Annotation of embedaddon/php/ext/mysql/php_mysql.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: Zeev Suraski <zeev@zend.com> |
! 16: | Zak Greant <zak@mysql.com> |
! 17: | Georg Richter <georg@php.net> |
! 18: +----------------------------------------------------------------------+
! 19: */
! 20:
! 21: /* $Id: php_mysql.c 321634 2012-01-01 13:15:04Z felipe $ */
! 22:
! 23: /* TODO:
! 24: *
! 25: * ? Safe mode implementation
! 26: */
! 27:
! 28: #ifdef HAVE_CONFIG_H
! 29: # include "config.h"
! 30: #endif
! 31:
! 32: #include "php.h"
! 33: #include "php_globals.h"
! 34: #include "ext/standard/info.h"
! 35: #include "ext/standard/php_string.h"
! 36: #include "ext/standard/basic_functions.h"
! 37:
! 38: #ifdef ZEND_ENGINE_2
! 39: # include "zend_exceptions.h"
! 40: #else
! 41: /* PHP 4 compat */
! 42: # define OnUpdateLong OnUpdateInt
! 43: # define E_STRICT E_NOTICE
! 44: #endif
! 45:
! 46: #if HAVE_MYSQL
! 47:
! 48: #ifdef PHP_WIN32
! 49: # include <winsock2.h>
! 50: # define signal(a, b) NULL
! 51: #elif defined(NETWARE)
! 52: # include <sys/socket.h>
! 53: # define signal(a, b) NULL
! 54: #else
! 55: # if HAVE_SIGNAL_H
! 56: # include <signal.h>
! 57: # endif
! 58: # if HAVE_SYS_TYPES_H
! 59: # include <sys/types.h>
! 60: # endif
! 61: # include <netdb.h>
! 62: # include <netinet/in.h>
! 63: # if HAVE_ARPA_INET_H
! 64: # include <arpa/inet.h>
! 65: # endif
! 66: #endif
! 67:
! 68: #include "php_ini.h"
! 69: #include "php_mysql_structs.h"
! 70:
! 71: /* True globals, no need for thread safety */
! 72: static int le_result, le_link, le_plink;
! 73:
! 74: #ifdef HAVE_MYSQL_REAL_CONNECT
! 75: # ifdef HAVE_ERRMSG_H
! 76: # include <errmsg.h>
! 77: # endif
! 78: #endif
! 79:
! 80: #define SAFE_STRING(s) ((s)?(s):"")
! 81:
! 82: #if MYSQL_VERSION_ID > 32199 || defined(MYSQL_USE_MYSQLND)
! 83: # define mysql_row_length_type unsigned long
! 84: # define HAVE_MYSQL_ERRNO
! 85: #else
! 86: # define mysql_row_length_type unsigned int
! 87: # ifdef mysql_errno
! 88: # define HAVE_MYSQL_ERRNO
! 89: # endif
! 90: #endif
! 91:
! 92: #if MYSQL_VERSION_ID >= 32032 || defined(MYSQL_USE_MYSQLND)
! 93: #define HAVE_GETINFO_FUNCS
! 94: #endif
! 95:
! 96: #if MYSQL_VERSION_ID > 32133 || defined(FIELD_TYPE_TINY)
! 97: #define MYSQL_HAS_TINY
! 98: #endif
! 99:
! 100: #if MYSQL_VERSION_ID >= 32200
! 101: #define MYSQL_HAS_YEAR
! 102: #endif
! 103:
! 104: #define MYSQL_ASSOC 1<<0
! 105: #define MYSQL_NUM 1<<1
! 106: #define MYSQL_BOTH (MYSQL_ASSOC|MYSQL_NUM)
! 107:
! 108: #define MYSQL_USE_RESULT 0
! 109: #define MYSQL_STORE_RESULT 1
! 110:
! 111: #if MYSQL_VERSION_ID < 32224
! 112: #define PHP_MYSQL_VALID_RESULT(mysql) \
! 113: (mysql_num_fields(mysql)>0)
! 114: #else
! 115: #define PHP_MYSQL_VALID_RESULT(mysql) \
! 116: (mysql_field_count(mysql)>0)
! 117: #endif
! 118:
! 119: ZEND_DECLARE_MODULE_GLOBALS(mysql)
! 120: static PHP_GINIT_FUNCTION(mysql);
! 121:
! 122: typedef struct _php_mysql_conn {
! 123: MYSQL *conn;
! 124: int active_result_id;
! 125: int multi_query;
! 126: } php_mysql_conn;
! 127:
! 128:
! 129: #if MYSQL_VERSION_ID >= 40101
! 130: #define MYSQL_DISABLE_MQ if (mysql->multi_query) { \
! 131: mysql_set_server_option(mysql->conn, MYSQL_OPTION_MULTI_STATEMENTS_OFF); \
! 132: mysql->multi_query = 0; \
! 133: }
! 134: #else
! 135: #define MYSQL_DISABLE_MQ
! 136: #endif
! 137:
! 138: /* {{{ arginfo */
! 139: ZEND_BEGIN_ARG_INFO_EX(arginfo_mysql_connect, 0, 0, 0)
! 140: ZEND_ARG_INFO(0, hostname)
! 141: ZEND_ARG_INFO(0, username)
! 142: ZEND_ARG_INFO(0, password)
! 143: ZEND_ARG_INFO(0, new)
! 144: ZEND_ARG_INFO(0, flags)
! 145: ZEND_END_ARG_INFO()
! 146:
! 147: ZEND_BEGIN_ARG_INFO_EX(arginfo_mysql_pconnect, 0, 0, 0)
! 148: ZEND_ARG_INFO(0, hostname)
! 149: ZEND_ARG_INFO(0, username)
! 150: ZEND_ARG_INFO(0, password)
! 151: ZEND_ARG_INFO(0, flags)
! 152: ZEND_END_ARG_INFO()
! 153:
! 154: ZEND_BEGIN_ARG_INFO_EX(arginfo__optional_mysql_link, 0, 0, 0)
! 155: ZEND_ARG_INFO(0, link_identifier)
! 156: ZEND_END_ARG_INFO()
! 157:
! 158: ZEND_BEGIN_ARG_INFO_EX(arginfo_mysql_select_db, 0, 0, 1)
! 159: ZEND_ARG_INFO(0, database_name)
! 160: ZEND_ARG_INFO(0, link_identifier)
! 161: ZEND_END_ARG_INFO()
! 162:
! 163: ZEND_BEGIN_ARG_INFO(arginfo__void_mysql_arg, 0)
! 164: ZEND_END_ARG_INFO()
! 165:
! 166: ZEND_BEGIN_ARG_INFO_EX(arginfo_mysql_set_charset, 0, 0, 1)
! 167: ZEND_ARG_INFO(0, charset_name)
! 168: ZEND_ARG_INFO(0, link_identifier)
! 169: ZEND_END_ARG_INFO()
! 170:
! 171: ZEND_BEGIN_ARG_INFO_EX(arginfo_mysql_query, 0, 0, 1)
! 172: ZEND_ARG_INFO(0, query)
! 173: ZEND_ARG_INFO(0, link_identifier)
! 174: ZEND_END_ARG_INFO()
! 175:
! 176: ZEND_BEGIN_ARG_INFO_EX(arginfo_mysql_db_query, 0, 0, 2)
! 177: ZEND_ARG_INFO(0, database_name)
! 178: ZEND_ARG_INFO(0, query)
! 179: ZEND_ARG_INFO(0, link_identifier)
! 180: ZEND_END_ARG_INFO()
! 181:
! 182: ZEND_BEGIN_ARG_INFO_EX(arginfo_mysql_list_fields, 0, 0, 2)
! 183: ZEND_ARG_INFO(0, database_name)
! 184: ZEND_ARG_INFO(0, table_name)
! 185: ZEND_ARG_INFO(0, link_identifier)
! 186: ZEND_END_ARG_INFO()
! 187:
! 188: ZEND_BEGIN_ARG_INFO_EX(arginfo_mysql_escape_string, 0, 0, 1)
! 189: ZEND_ARG_INFO(0, string)
! 190: ZEND_END_ARG_INFO()
! 191:
! 192: ZEND_BEGIN_ARG_INFO_EX(arginfo_mysql_real_escape_string, 0, 0, 1)
! 193: ZEND_ARG_INFO(0, string)
! 194: ZEND_ARG_INFO(0, link_identifier)
! 195: ZEND_END_ARG_INFO()
! 196:
! 197: ZEND_BEGIN_ARG_INFO_EX(arginfo_mysql_result, 0, 0, 2)
! 198: ZEND_ARG_INFO(0, result)
! 199: ZEND_ARG_INFO(0, row)
! 200: ZEND_ARG_INFO(0, field)
! 201: ZEND_END_ARG_INFO()
! 202:
! 203: ZEND_BEGIN_ARG_INFO_EX(arginfo__result_mysql_arg, 0, 0, 1)
! 204: ZEND_ARG_INFO(0, result)
! 205: ZEND_END_ARG_INFO()
! 206:
! 207: ZEND_BEGIN_ARG_INFO_EX(arginfo_mysql_fetch_object, 0, 0, 1)
! 208: ZEND_ARG_INFO(0, result)
! 209: ZEND_ARG_INFO(0, class_name)
! 210: ZEND_ARG_INFO(0, ctor_params)
! 211: ZEND_END_ARG_INFO()
! 212:
! 213: ZEND_BEGIN_ARG_INFO_EX(arginfo_mysql_fetch_array, 0, 0, 1)
! 214: ZEND_ARG_INFO(0, result)
! 215: ZEND_ARG_INFO(0, result_type)
! 216: ZEND_END_ARG_INFO()
! 217:
! 218: ZEND_BEGIN_ARG_INFO_EX(arginfo_mysql_data_seek, 0, 0, 2)
! 219: ZEND_ARG_INFO(0, result)
! 220: ZEND_ARG_INFO(0, row_number)
! 221: ZEND_END_ARG_INFO()
! 222:
! 223: ZEND_BEGIN_ARG_INFO_EX(arginfo_mysql_fetch_field, 0, 0, 1)
! 224: ZEND_ARG_INFO(0, result)
! 225: ZEND_ARG_INFO(0, field_offset)
! 226: ZEND_END_ARG_INFO()
! 227:
! 228: ZEND_BEGIN_ARG_INFO_EX(arginfo_mysql_field_seek, 0, 0, 2)
! 229: ZEND_ARG_INFO(0, result)
! 230: ZEND_ARG_INFO(0, field_offset)
! 231: ZEND_END_ARG_INFO()
! 232:
! 233: ZEND_BEGIN_ARG_INFO_EX(arginfo_mysql_field_name, 0, 0, 2)
! 234: ZEND_ARG_INFO(0, result)
! 235: ZEND_ARG_INFO(0, field_index)
! 236: ZEND_END_ARG_INFO()
! 237: /* }}} */
! 238:
! 239: /* {{{ mysql_functions[]
! 240: */
! 241: static const zend_function_entry mysql_functions[] = {
! 242: PHP_FE(mysql_connect, arginfo_mysql_connect)
! 243: PHP_FE(mysql_pconnect, arginfo_mysql_pconnect)
! 244: PHP_FE(mysql_close, arginfo__optional_mysql_link)
! 245: PHP_FE(mysql_select_db, arginfo_mysql_select_db)
! 246: #ifndef NETWARE /* The below two functions not supported on NetWare */
! 247: #if MYSQL_VERSION_ID < 40000
! 248: PHP_DEP_FE(mysql_create_db, arginfo_mysql_select_db)
! 249: PHP_DEP_FE(mysql_drop_db, arginfo_mysql_select_db)
! 250: #endif
! 251: #endif /* NETWARE */
! 252: PHP_FE(mysql_query, arginfo_mysql_query)
! 253: PHP_FE(mysql_unbuffered_query, arginfo_mysql_query)
! 254: PHP_DEP_FE(mysql_db_query, arginfo_mysql_db_query)
! 255: PHP_FE(mysql_list_dbs, arginfo__optional_mysql_link)
! 256: PHP_DEP_FE(mysql_list_tables, arginfo_mysql_select_db)
! 257: PHP_FE(mysql_list_fields, arginfo_mysql_list_fields)
! 258: PHP_FE(mysql_list_processes, arginfo__optional_mysql_link)
! 259: PHP_FE(mysql_error, arginfo__optional_mysql_link)
! 260: #ifdef HAVE_MYSQL_ERRNO
! 261: PHP_FE(mysql_errno, arginfo__optional_mysql_link)
! 262: #endif
! 263: PHP_FE(mysql_affected_rows, arginfo__optional_mysql_link)
! 264: PHP_FE(mysql_insert_id, arginfo__optional_mysql_link)
! 265: PHP_FE(mysql_result, arginfo_mysql_result)
! 266: PHP_FE(mysql_num_rows, arginfo__result_mysql_arg)
! 267: PHP_FE(mysql_num_fields, arginfo__result_mysql_arg)
! 268: PHP_FE(mysql_fetch_row, arginfo__result_mysql_arg)
! 269: PHP_FE(mysql_fetch_array, arginfo_mysql_fetch_array)
! 270: PHP_FE(mysql_fetch_assoc, arginfo__result_mysql_arg)
! 271: PHP_FE(mysql_fetch_object, arginfo_mysql_fetch_object)
! 272: PHP_FE(mysql_data_seek, arginfo_mysql_data_seek)
! 273: PHP_FE(mysql_fetch_lengths, arginfo__result_mysql_arg)
! 274: PHP_FE(mysql_fetch_field, arginfo_mysql_fetch_field)
! 275: PHP_FE(mysql_field_seek, arginfo_mysql_field_seek)
! 276: PHP_FE(mysql_free_result, arginfo__result_mysql_arg)
! 277: PHP_FE(mysql_field_name, arginfo_mysql_field_name)
! 278: PHP_FE(mysql_field_table, arginfo_mysql_field_seek)
! 279: PHP_FE(mysql_field_len, arginfo_mysql_field_seek)
! 280: PHP_FE(mysql_field_type, arginfo_mysql_field_seek)
! 281: PHP_FE(mysql_field_flags, arginfo_mysql_field_seek)
! 282: PHP_FE(mysql_escape_string, arginfo_mysql_escape_string)
! 283: PHP_FE(mysql_real_escape_string, arginfo_mysql_real_escape_string)
! 284: PHP_FE(mysql_stat, arginfo__optional_mysql_link)
! 285: PHP_FE(mysql_thread_id, arginfo__optional_mysql_link)
! 286: PHP_FE(mysql_client_encoding, arginfo__optional_mysql_link)
! 287: PHP_FE(mysql_ping, arginfo__optional_mysql_link)
! 288: #ifdef HAVE_GETINFO_FUNCS
! 289: PHP_FE(mysql_get_client_info, arginfo__void_mysql_arg)
! 290: PHP_FE(mysql_get_host_info, arginfo__optional_mysql_link)
! 291: PHP_FE(mysql_get_proto_info, arginfo__optional_mysql_link)
! 292: PHP_FE(mysql_get_server_info, arginfo__optional_mysql_link)
! 293: #endif
! 294:
! 295: PHP_FE(mysql_info, arginfo__optional_mysql_link)
! 296: #ifdef MYSQL_HAS_SET_CHARSET
! 297: PHP_FE(mysql_set_charset, arginfo_mysql_set_charset)
! 298: #endif
! 299: /* for downwards compatability */
! 300: PHP_FALIAS(mysql, mysql_db_query, arginfo_mysql_db_query)
! 301: PHP_FALIAS(mysql_fieldname, mysql_field_name, arginfo_mysql_field_name)
! 302: PHP_FALIAS(mysql_fieldtable, mysql_field_table, arginfo_mysql_field_seek)
! 303: PHP_FALIAS(mysql_fieldlen, mysql_field_len, arginfo_mysql_field_seek)
! 304: PHP_FALIAS(mysql_fieldtype, mysql_field_type, arginfo_mysql_field_seek)
! 305: PHP_FALIAS(mysql_fieldflags, mysql_field_flags, arginfo_mysql_field_seek)
! 306: PHP_FALIAS(mysql_selectdb, mysql_select_db, arginfo_mysql_select_db)
! 307: #ifndef NETWARE /* The below two functions not supported on NetWare */
! 308: #if MYSQL_VERSION_ID < 40000
! 309: PHP_DEP_FALIAS(mysql_createdb, mysql_create_db, arginfo_mysql_select_db)
! 310: PHP_DEP_FALIAS(mysql_dropdb, mysql_drop_db, arginfo_mysql_select_db)
! 311: #endif
! 312: #endif /* NETWARE */
! 313: PHP_FALIAS(mysql_freeresult, mysql_free_result, arginfo__result_mysql_arg)
! 314: PHP_FALIAS(mysql_numfields, mysql_num_fields, arginfo__result_mysql_arg)
! 315: PHP_FALIAS(mysql_numrows, mysql_num_rows, arginfo__result_mysql_arg)
! 316: PHP_FALIAS(mysql_listdbs, mysql_list_dbs, arginfo__optional_mysql_link)
! 317: PHP_DEP_FALIAS(mysql_listtables,mysql_list_tables, arginfo_mysql_select_db)
! 318: PHP_FALIAS(mysql_listfields, mysql_list_fields, arginfo_mysql_list_fields)
! 319: PHP_FALIAS(mysql_db_name, mysql_result, arginfo_mysql_result)
! 320: PHP_FALIAS(mysql_dbname, mysql_result, arginfo_mysql_result)
! 321: PHP_FALIAS(mysql_tablename, mysql_result, arginfo_mysql_result)
! 322: PHP_FALIAS(mysql_table_name, mysql_result, arginfo_mysql_result)
! 323: PHP_FE_END
! 324: };
! 325: /* }}} */
! 326:
! 327: /* Dependancies */
! 328: static const zend_module_dep mysql_deps[] = {
! 329: #if defined(MYSQL_USE_MYSQLND)
! 330: ZEND_MOD_REQUIRED("mysqlnd")
! 331: #endif
! 332: ZEND_MOD_END
! 333: };
! 334:
! 335: /* {{{ mysql_module_entry
! 336: */
! 337: zend_module_entry mysql_module_entry = {
! 338: #if ZEND_MODULE_API_NO >= 20050922
! 339: STANDARD_MODULE_HEADER_EX, NULL,
! 340: mysql_deps,
! 341: #elif ZEND_MODULE_API_NO >= 20010901
! 342: STANDARD_MODULE_HEADER,
! 343: #endif
! 344: "mysql",
! 345: mysql_functions,
! 346: ZEND_MODULE_STARTUP_N(mysql),
! 347: PHP_MSHUTDOWN(mysql),
! 348: PHP_RINIT(mysql),
! 349: PHP_RSHUTDOWN(mysql),
! 350: PHP_MINFO(mysql),
! 351: "1.0",
! 352: PHP_MODULE_GLOBALS(mysql),
! 353: PHP_GINIT(mysql),
! 354: NULL,
! 355: NULL,
! 356: STANDARD_MODULE_PROPERTIES_EX
! 357: };
! 358: /* }}} */
! 359:
! 360: #ifdef COMPILE_DL_MYSQL
! 361: ZEND_GET_MODULE(mysql)
! 362: #endif
! 363:
! 364: void timeout(int sig);
! 365:
! 366: #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; } }
! 367:
! 368: #if defined(MYSQL_USE_MYSQLND)
! 369: #define PHPMY_UNBUFFERED_QUERY_CHECK() \
! 370: {\
! 371: if (mysql->active_result_id) { \
! 372: do { \
! 373: int type; \
! 374: MYSQL_RES *_mysql_result; \
! 375: \
! 376: _mysql_result = (MYSQL_RES *) zend_list_find(mysql->active_result_id, &type); \
! 377: if (_mysql_result && type==le_result) { \
! 378: if (mysql_result_is_unbuffered(_mysql_result) && !mysql_eof(_mysql_result)) { \
! 379: php_error_docref(NULL TSRMLS_CC, E_NOTICE, "Function called without first fetching all rows from a previous unbuffered query"); \
! 380: } \
! 381: zend_list_delete(mysql->active_result_id); \
! 382: mysql->active_result_id = 0; \
! 383: } \
! 384: } while(0); \
! 385: }\
! 386: }
! 387: #else
! 388: #define PHPMY_UNBUFFERED_QUERY_CHECK() \
! 389: { \
! 390: if (mysql->active_result_id) { \
! 391: do { \
! 392: int type; \
! 393: MYSQL_RES *mysql_result; \
! 394: \
! 395: mysql_result = (MYSQL_RES *) zend_list_find(mysql->active_result_id, &type); \
! 396: if (mysql_result && type==le_result) { \
! 397: if (!mysql_eof(mysql_result)) { \
! 398: php_error_docref(NULL TSRMLS_CC, E_NOTICE, "Function called without first fetching all rows from a previous unbuffered query"); \
! 399: while (mysql_fetch_row(mysql_result)); \
! 400: } \
! 401: zend_list_delete(mysql->active_result_id); \
! 402: mysql->active_result_id = 0; \
! 403: } \
! 404: } while(0); \
! 405: } \
! 406: }
! 407: #endif
! 408:
! 409: /* {{{ _free_mysql_result
! 410: * This wrapper is required since mysql_free_result() returns an integer, and
! 411: * thus, cannot be used directly
! 412: */
! 413: static void _free_mysql_result(zend_rsrc_list_entry *rsrc TSRMLS_DC)
! 414: {
! 415: MYSQL_RES *mysql_result = (MYSQL_RES *)rsrc->ptr;
! 416:
! 417: mysql_free_result(mysql_result);
! 418: MySG(result_allocated)--;
! 419: }
! 420: /* }}} */
! 421:
! 422: /* {{{ php_mysql_set_default_link
! 423: */
! 424: static void php_mysql_set_default_link(int id TSRMLS_DC)
! 425: {
! 426: if (MySG(default_link) != -1) {
! 427: zend_list_delete(MySG(default_link));
! 428: }
! 429: MySG(default_link) = id;
! 430: zend_list_addref(id);
! 431: }
! 432: /* }}} */
! 433:
! 434: /* {{{ php_mysql_select_db
! 435: */
! 436: static int php_mysql_select_db(php_mysql_conn *mysql, char *db TSRMLS_DC)
! 437: {
! 438: PHPMY_UNBUFFERED_QUERY_CHECK();
! 439:
! 440: if (mysql_select_db(mysql->conn, db) != 0) {
! 441: return 0;
! 442: } else {
! 443: return 1;
! 444: }
! 445: }
! 446: /* }}} */
! 447:
! 448: /* {{{ _close_mysql_link
! 449: */
! 450: static void _close_mysql_link(zend_rsrc_list_entry *rsrc TSRMLS_DC)
! 451: {
! 452: php_mysql_conn *link = (php_mysql_conn *)rsrc->ptr;
! 453: void (*handler) (int);
! 454:
! 455: handler = signal(SIGPIPE, SIG_IGN);
! 456: mysql_close(link->conn);
! 457: signal(SIGPIPE, handler);
! 458: efree(link);
! 459: MySG(num_links)--;
! 460: }
! 461: /* }}} */
! 462:
! 463: /* {{{ _close_mysql_plink
! 464: */
! 465: static void _close_mysql_plink(zend_rsrc_list_entry *rsrc TSRMLS_DC)
! 466: {
! 467: php_mysql_conn *link = (php_mysql_conn *)rsrc->ptr;
! 468: void (*handler) (int);
! 469:
! 470: handler = signal(SIGPIPE, SIG_IGN);
! 471: mysql_close(link->conn);
! 472: signal(SIGPIPE, handler);
! 473:
! 474: free(link);
! 475: MySG(num_persistent)--;
! 476: MySG(num_links)--;
! 477: }
! 478: /* }}} */
! 479:
! 480: /* {{{ PHP_INI_MH
! 481: */
! 482: static PHP_INI_MH(OnMySQLPort)
! 483: {
! 484: if (new_value != NULL) { /* default port */
! 485: MySG(default_port) = atoi(new_value);
! 486: } else {
! 487: MySG(default_port) = -1;
! 488: }
! 489:
! 490: return SUCCESS;
! 491: }
! 492: /* }}} */
! 493:
! 494: /* {{{ PHP_INI */
! 495: PHP_INI_BEGIN()
! 496: STD_PHP_INI_BOOLEAN("mysql.allow_persistent", "1", PHP_INI_SYSTEM, OnUpdateLong, allow_persistent, zend_mysql_globals, mysql_globals)
! 497: STD_PHP_INI_ENTRY_EX("mysql.max_persistent", "-1", PHP_INI_SYSTEM, OnUpdateLong, max_persistent, zend_mysql_globals, mysql_globals, display_link_numbers)
! 498: STD_PHP_INI_ENTRY_EX("mysql.max_links", "-1", PHP_INI_SYSTEM, OnUpdateLong, max_links, zend_mysql_globals, mysql_globals, display_link_numbers)
! 499: STD_PHP_INI_ENTRY("mysql.default_host", NULL, PHP_INI_ALL, OnUpdateString, default_host, zend_mysql_globals, mysql_globals)
! 500: STD_PHP_INI_ENTRY("mysql.default_user", NULL, PHP_INI_ALL, OnUpdateString, default_user, zend_mysql_globals, mysql_globals)
! 501: STD_PHP_INI_ENTRY("mysql.default_password", NULL, PHP_INI_ALL, OnUpdateString, default_password, zend_mysql_globals, mysql_globals)
! 502: PHP_INI_ENTRY("mysql.default_port", NULL, PHP_INI_ALL, OnMySQLPort)
! 503: #ifdef MYSQL_UNIX_ADDR
! 504: STD_PHP_INI_ENTRY("mysql.default_socket", MYSQL_UNIX_ADDR,PHP_INI_ALL,OnUpdateStringUnempty, default_socket, zend_mysql_globals, mysql_globals)
! 505: #else
! 506: STD_PHP_INI_ENTRY("mysql.default_socket", NULL, PHP_INI_ALL, OnUpdateStringUnempty, default_socket, zend_mysql_globals, mysql_globals)
! 507: #endif
! 508: STD_PHP_INI_ENTRY("mysql.connect_timeout", "60", PHP_INI_ALL, OnUpdateLong, connect_timeout, zend_mysql_globals, mysql_globals)
! 509: STD_PHP_INI_BOOLEAN("mysql.trace_mode", "0", PHP_INI_ALL, OnUpdateLong, trace_mode, zend_mysql_globals, mysql_globals)
! 510: STD_PHP_INI_BOOLEAN("mysql.allow_local_infile", "1", PHP_INI_SYSTEM, OnUpdateLong, allow_local_infile, zend_mysql_globals, mysql_globals)
! 511: PHP_INI_END()
! 512: /* }}} */
! 513:
! 514: /* {{{ PHP_GINIT_FUNCTION
! 515: */
! 516: static PHP_GINIT_FUNCTION(mysql)
! 517: {
! 518: mysql_globals->num_persistent = 0;
! 519: mysql_globals->default_socket = NULL;
! 520: mysql_globals->default_host = NULL;
! 521: mysql_globals->default_user = NULL;
! 522: mysql_globals->default_password = NULL;
! 523: mysql_globals->connect_errno = 0;
! 524: mysql_globals->connect_error = NULL;
! 525: mysql_globals->connect_timeout = 0;
! 526: mysql_globals->trace_mode = 0;
! 527: mysql_globals->allow_local_infile = 1;
! 528: mysql_globals->result_allocated = 0;
! 529: }
! 530: /* }}} */
! 531:
! 532: /* {{{ PHP_MINIT_FUNCTION
! 533: */
! 534: ZEND_MODULE_STARTUP_D(mysql)
! 535: {
! 536: REGISTER_INI_ENTRIES();
! 537: le_result = zend_register_list_destructors_ex(_free_mysql_result, NULL, "mysql result", module_number);
! 538: le_link = zend_register_list_destructors_ex(_close_mysql_link, NULL, "mysql link", module_number);
! 539: le_plink = zend_register_list_destructors_ex(NULL, _close_mysql_plink, "mysql link persistent", module_number);
! 540: Z_TYPE(mysql_module_entry) = type;
! 541:
! 542: REGISTER_LONG_CONSTANT("MYSQL_ASSOC", MYSQL_ASSOC, CONST_CS | CONST_PERSISTENT);
! 543: REGISTER_LONG_CONSTANT("MYSQL_NUM", MYSQL_NUM, CONST_CS | CONST_PERSISTENT);
! 544: REGISTER_LONG_CONSTANT("MYSQL_BOTH", MYSQL_BOTH, CONST_CS | CONST_PERSISTENT);
! 545: REGISTER_LONG_CONSTANT("MYSQL_CLIENT_COMPRESS", CLIENT_COMPRESS, CONST_CS | CONST_PERSISTENT);
! 546: #if MYSQL_VERSION_ID >= 40000
! 547: REGISTER_LONG_CONSTANT("MYSQL_CLIENT_SSL", CLIENT_SSL, CONST_CS | CONST_PERSISTENT);
! 548: #endif
! 549: REGISTER_LONG_CONSTANT("MYSQL_CLIENT_INTERACTIVE", CLIENT_INTERACTIVE, CONST_CS | CONST_PERSISTENT);
! 550: REGISTER_LONG_CONSTANT("MYSQL_CLIENT_IGNORE_SPACE", CLIENT_IGNORE_SPACE, CONST_CS | CONST_PERSISTENT);
! 551:
! 552: #ifndef MYSQL_USE_MYSQLND
! 553: #if MYSQL_VERSION_ID >= 40000
! 554: if (mysql_server_init(0, NULL, NULL)) {
! 555: return FAILURE;
! 556: }
! 557: #endif
! 558: #endif
! 559:
! 560: return SUCCESS;
! 561: }
! 562: /* }}} */
! 563:
! 564: /* {{{ PHP_MSHUTDOWN_FUNCTION
! 565: */
! 566: PHP_MSHUTDOWN_FUNCTION(mysql)
! 567: {
! 568: #ifndef MYSQL_USE_MYSQLND
! 569: #if MYSQL_VERSION_ID >= 40000
! 570: #ifdef PHP_WIN32
! 571: unsigned long client_ver = mysql_get_client_version();
! 572: /*
! 573: Can't call mysql_server_end() multiple times prior to 5.0.46 on Windows.
! 574: PHP bug#41350 MySQL bug#25621
! 575: */
! 576: if ((client_ver >= 50046 && client_ver < 50100) || client_ver > 50122) {
! 577: mysql_server_end();
! 578: }
! 579: #else
! 580: mysql_server_end();
! 581: #endif
! 582: #endif
! 583: #endif
! 584:
! 585: UNREGISTER_INI_ENTRIES();
! 586: return SUCCESS;
! 587: }
! 588: /* }}} */
! 589:
! 590: /* {{{ PHP_RINIT_FUNCTION
! 591: */
! 592: PHP_RINIT_FUNCTION(mysql)
! 593: {
! 594: #if !defined(MYSQL_USE_MYSQLND) && defined(ZTS) && MYSQL_VERSION_ID >= 40000
! 595: if (mysql_thread_init()) {
! 596: return FAILURE;
! 597: }
! 598: #endif
! 599: MySG(default_link)=-1;
! 600: MySG(num_links) = MySG(num_persistent);
! 601: /* Reset connect error/errno on every request */
! 602: MySG(connect_error) = NULL;
! 603: MySG(connect_errno) =0;
! 604: MySG(result_allocated) = 0;
! 605:
! 606: return SUCCESS;
! 607: }
! 608: /* }}} */
! 609:
! 610:
! 611: #if defined(A0) && defined(MYSQL_USE_MYSQLND)
! 612: static int php_mysql_persistent_helper(zend_rsrc_list_entry *le TSRMLS_DC)
! 613: {
! 614: if (le->type == le_plink) {
! 615: mysqlnd_end_psession(((php_mysql_conn *) le->ptr)->conn);
! 616: }
! 617: return ZEND_HASH_APPLY_KEEP;
! 618: } /* }}} */
! 619: #endif
! 620:
! 621:
! 622: /* {{{ PHP_RSHUTDOWN_FUNCTION
! 623: */
! 624: PHP_RSHUTDOWN_FUNCTION(mysql)
! 625: {
! 626: #if !defined(MYSQL_USE_MYSQLND) && defined(ZTS) && MYSQL_VERSION_ID >= 40000
! 627: mysql_thread_end();
! 628: #endif
! 629:
! 630: if (MySG(trace_mode)) {
! 631: if (MySG(result_allocated)){
! 632: php_error_docref("function.mysql-free-result" TSRMLS_CC, E_WARNING, "%lu result set(s) not freed. Use mysql_free_result to free result sets which were requested using mysql_query()", MySG(result_allocated));
! 633: }
! 634: }
! 635:
! 636: if (MySG(connect_error)!=NULL) {
! 637: efree(MySG(connect_error));
! 638: }
! 639:
! 640: #if defined(A0) && defined(MYSQL_USE_MYSQLND)
! 641: zend_hash_apply(&EG(persistent_list), (apply_func_t) php_mysql_persistent_helper TSRMLS_CC);
! 642: #endif
! 643:
! 644: return SUCCESS;
! 645: }
! 646: /* }}} */
! 647:
! 648: /* {{{ PHP_MINFO_FUNCTION
! 649: */
! 650: PHP_MINFO_FUNCTION(mysql)
! 651: {
! 652: char buf[32];
! 653:
! 654: php_info_print_table_start();
! 655: php_info_print_table_header(2, "MySQL Support", "enabled");
! 656: snprintf(buf, sizeof(buf), "%ld", MySG(num_persistent));
! 657: php_info_print_table_row(2, "Active Persistent Links", buf);
! 658: snprintf(buf, sizeof(buf), "%ld", MySG(num_links));
! 659: php_info_print_table_row(2, "Active Links", buf);
! 660: php_info_print_table_row(2, "Client API version", mysql_get_client_info());
! 661: #if !defined (PHP_WIN32) && !defined (NETWARE) && !defined(MYSQL_USE_MYSQLND)
! 662: php_info_print_table_row(2, "MYSQL_MODULE_TYPE", PHP_MYSQL_TYPE);
! 663: php_info_print_table_row(2, "MYSQL_SOCKET", MYSQL_UNIX_ADDR);
! 664: php_info_print_table_row(2, "MYSQL_INCLUDE", PHP_MYSQL_INCLUDE);
! 665: php_info_print_table_row(2, "MYSQL_LIBS", PHP_MYSQL_LIBS);
! 666: #endif
! 667:
! 668: php_info_print_table_end();
! 669:
! 670: DISPLAY_INI_ENTRIES();
! 671:
! 672: }
! 673: /* }}} */
! 674:
! 675: /* {{{ php_mysql_do_connect
! 676: */
! 677: #define MYSQL_DO_CONNECT_CLEANUP() \
! 678: if (free_host) { \
! 679: efree(host); \
! 680: }
! 681:
! 682: #define MYSQL_DO_CONNECT_RETURN_FALSE() \
! 683: MYSQL_DO_CONNECT_CLEANUP(); \
! 684: RETURN_FALSE;
! 685:
! 686: #ifdef MYSQL_USE_MYSQLND
! 687: #define MYSQL_PORT 0
! 688: #endif
! 689:
! 690: static void php_mysql_do_connect(INTERNAL_FUNCTION_PARAMETERS, int persistent)
! 691: {
! 692: char *user=NULL, *passwd=NULL, *host_and_port=NULL, *socket=NULL, *tmp=NULL, *host=NULL;
! 693: int user_len, passwd_len, host_len;
! 694: char *hashed_details=NULL;
! 695: int hashed_details_length, port = MYSQL_PORT;
! 696: long client_flags = 0;
! 697: php_mysql_conn *mysql=NULL;
! 698: #if MYSQL_VERSION_ID <= 32230
! 699: void (*handler) (int);
! 700: #endif
! 701: zend_bool free_host=0, new_link=0;
! 702: long connect_timeout;
! 703:
! 704: #if !defined(MYSQL_USE_MYSQLND)
! 705: if ((MYSQL_VERSION_ID / 100) != (mysql_get_client_version() / 100)) {
! 706: php_error_docref(NULL TSRMLS_CC, E_WARNING,
! 707: "Headers and client library minor version mismatch. Headers:%d Library:%ld",
! 708: MYSQL_VERSION_ID, mysql_get_client_version());
! 709: }
! 710: #endif
! 711:
! 712: connect_timeout = MySG(connect_timeout);
! 713:
! 714: socket = MySG(default_socket);
! 715:
! 716: if (MySG(default_port) < 0) {
! 717: #if !defined(PHP_WIN32) && !defined(NETWARE)
! 718: struct servent *serv_ptr;
! 719: char *env;
! 720:
! 721: MySG(default_port) = MYSQL_PORT;
! 722: if ((serv_ptr = getservbyname("mysql", "tcp"))) {
! 723: MySG(default_port) = (uint) ntohs((ushort) serv_ptr->s_port);
! 724: }
! 725: if ((env = getenv("MYSQL_TCP_PORT"))) {
! 726: MySG(default_port) = (uint) atoi(env);
! 727: }
! 728: #else
! 729: MySG(default_port) = MYSQL_PORT;
! 730: #endif
! 731: }
! 732:
! 733: if (PG(sql_safe_mode)) {
! 734: if (ZEND_NUM_ARGS()>0) {
! 735: php_error_docref(NULL TSRMLS_CC, E_NOTICE, "SQL safe mode in effect - ignoring host/user/password information");
! 736: }
! 737: host_and_port=passwd=NULL;
! 738: user=php_get_current_user();
! 739: hashed_details_length = spprintf(&hashed_details, 0, "mysql__%s_", user);
! 740: client_flags = CLIENT_INTERACTIVE;
! 741: } else {
! 742: /* mysql_pconnect does not support new_link parameter */
! 743: if (persistent) {
! 744: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|s!s!s!l", &host_and_port, &host_len,
! 745: &user, &user_len, &passwd, &passwd_len,
! 746: &client_flags)==FAILURE) {
! 747: return;
! 748: }
! 749: } else {
! 750: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|s!s!s!bl", &host_and_port, &host_len,
! 751: &user, &user_len, &passwd, &passwd_len,
! 752: &new_link, &client_flags)==FAILURE) {
! 753: return;
! 754: }
! 755: }
! 756:
! 757: if (!host_and_port) {
! 758: host_and_port = MySG(default_host);
! 759: }
! 760: if (!user) {
! 761: user = MySG(default_user);
! 762: }
! 763: if (!passwd) {
! 764: passwd = MySG(default_password);
! 765: passwd_len = passwd? strlen(passwd):0;
! 766: }
! 767:
! 768: /* disable local infile option for open_basedir */
! 769: #if PHP_API_VERSION < 20100412
! 770: if (((PG(open_basedir) && PG(open_basedir)[0] != '\0') || PG(safe_mode)) && (client_flags & CLIENT_LOCAL_FILES)) {
! 771: #else
! 772: if ((PG(open_basedir) && PG(open_basedir)[0] != '\0') && (client_flags & CLIENT_LOCAL_FILES)) {
! 773: #endif
! 774: client_flags ^= CLIENT_LOCAL_FILES;
! 775: }
! 776:
! 777: #ifdef CLIENT_MULTI_RESULTS
! 778: client_flags |= CLIENT_MULTI_RESULTS; /* compatibility with 5.2, see bug#50416 */
! 779: #endif
! 780: #ifdef CLIENT_MULTI_STATEMENTS
! 781: client_flags &= ~CLIENT_MULTI_STATEMENTS; /* don't allow multi_queries via connect parameter */
! 782: #endif
! 783: hashed_details_length = spprintf(&hashed_details, 0, "mysql_%s_%s_%s_%ld", SAFE_STRING(host_and_port), SAFE_STRING(user), SAFE_STRING(passwd), client_flags);
! 784: }
! 785:
! 786: /* We cannot use mysql_port anymore in windows, need to use
! 787: * mysql_real_connect() to set the port.
! 788: */
! 789: if (host_and_port && (tmp=strchr(host_and_port, ':'))) {
! 790: host = estrndup(host_and_port, tmp-host_and_port);
! 791: free_host = 1;
! 792: tmp++;
! 793: if (tmp[0] != '/') {
! 794: port = atoi(tmp);
! 795: if ((tmp=strchr(tmp, ':'))) {
! 796: tmp++;
! 797: socket=tmp;
! 798: }
! 799: } else {
! 800: socket = tmp;
! 801: }
! 802: } else {
! 803: host = host_and_port;
! 804: port = MySG(default_port);
! 805: }
! 806:
! 807: #if MYSQL_VERSION_ID < 32200
! 808: mysql_port = port;
! 809: #endif
! 810:
! 811: if (!MySG(allow_persistent)) {
! 812: persistent=0;
! 813: }
! 814: if (persistent) {
! 815: zend_rsrc_list_entry *le;
! 816:
! 817: /* try to find if we already have this link in our persistent list */
! 818: if (zend_hash_find(&EG(persistent_list), hashed_details, hashed_details_length+1, (void **) &le)==FAILURE) { /* we don't */
! 819: zend_rsrc_list_entry new_le;
! 820:
! 821: if (MySG(max_links) != -1 && MySG(num_links) >= MySG(max_links)) {
! 822: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Too many open links (%ld)", MySG(num_links));
! 823: efree(hashed_details);
! 824: MYSQL_DO_CONNECT_RETURN_FALSE();
! 825: }
! 826: if (MySG(max_persistent) != -1 && MySG(num_persistent) >= MySG(max_persistent)) {
! 827: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Too many open persistent links (%ld)", MySG(num_persistent));
! 828: efree(hashed_details);
! 829: MYSQL_DO_CONNECT_RETURN_FALSE();
! 830: }
! 831: /* create the link */
! 832: mysql = (php_mysql_conn *) malloc(sizeof(php_mysql_conn));
! 833: if (!mysql) {
! 834: php_error_docref(NULL TSRMLS_CC, E_ERROR, "Out of memory while allocating memory for a persistent link");
! 835: }
! 836: mysql->active_result_id = 0;
! 837: #ifdef CLIENT_MULTI_STATEMENTS
! 838: mysql->multi_query = client_flags & CLIENT_MULTI_STATEMENTS? 1:0;
! 839: #else
! 840: mysql->multi_query = 0;
! 841: #endif
! 842:
! 843: #ifndef MYSQL_USE_MYSQLND
! 844: mysql->conn = mysql_init(NULL);
! 845: #else
! 846: mysql->conn = mysql_init(persistent);
! 847: #endif
! 848:
! 849: if (connect_timeout != -1) {
! 850: mysql_options(mysql->conn, MYSQL_OPT_CONNECT_TIMEOUT, (const char *)&connect_timeout);
! 851: }
! 852: #ifndef MYSQL_USE_MYSQLND
! 853: if (mysql_real_connect(mysql->conn, host, user, passwd, NULL, port, socket, client_flags)==NULL)
! 854: #else
! 855: if (mysqlnd_connect(mysql->conn, host, user, passwd, passwd_len, NULL, 0, port, socket, client_flags TSRMLS_CC) == NULL)
! 856: #endif
! 857: {
! 858: /* Populate connect error globals so that the error functions can read them */
! 859: if (MySG(connect_error) != NULL) {
! 860: efree(MySG(connect_error));
! 861: }
! 862: MySG(connect_error) = estrdup(mysql_error(mysql->conn));
! 863: php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s", MySG(connect_error));
! 864: #if defined(HAVE_MYSQL_ERRNO)
! 865: MySG(connect_errno) = mysql_errno(mysql->conn);
! 866: #endif
! 867: free(mysql);
! 868: efree(hashed_details);
! 869: MYSQL_DO_CONNECT_RETURN_FALSE();
! 870: }
! 871: mysql_options(mysql->conn, MYSQL_OPT_LOCAL_INFILE, (char *)&MySG(allow_local_infile));
! 872:
! 873: /* hash it up */
! 874: Z_TYPE(new_le) = le_plink;
! 875: new_le.ptr = mysql;
! 876: if (zend_hash_update(&EG(persistent_list), hashed_details, hashed_details_length+1, (void *) &new_le, sizeof(zend_rsrc_list_entry), NULL)==FAILURE) {
! 877: free(mysql);
! 878: efree(hashed_details);
! 879: MYSQL_DO_CONNECT_RETURN_FALSE();
! 880: }
! 881: MySG(num_persistent)++;
! 882: MySG(num_links)++;
! 883: } else { /* The link is in our list of persistent connections */
! 884: if (Z_TYPE_P(le) != le_plink) {
! 885: MYSQL_DO_CONNECT_RETURN_FALSE();
! 886: }
! 887: mysql = (php_mysql_conn *) le->ptr;
! 888: mysql->active_result_id = 0;
! 889: #ifdef CLIENT_MULTI_STATEMENTS
! 890: mysql->multi_query = client_flags & CLIENT_MULTI_STATEMENTS? 1:0;
! 891: #else
! 892: mysql->multi_query = 0;
! 893: #endif
! 894: /* ensure that the link did not die */
! 895: #if defined(A0) && MYSQL_USE_MYSQLND
! 896: mysqlnd_end_psession(mysql->conn);
! 897: #endif
! 898: if (mysql_ping(mysql->conn)) {
! 899: if (mysql_errno(mysql->conn) == 2006) {
! 900: #ifndef MYSQL_USE_MYSQLND
! 901: if (mysql_real_connect(mysql->conn, host, user, passwd, NULL, port, socket, client_flags)==NULL)
! 902: #else
! 903: if (mysqlnd_connect(mysql->conn, host, user, passwd, passwd_len, NULL, 0, port, socket, client_flags TSRMLS_CC) == NULL)
! 904: #endif
! 905: {
! 906: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Link to server lost, unable to reconnect");
! 907: zend_hash_del(&EG(persistent_list), hashed_details, hashed_details_length+1);
! 908: efree(hashed_details);
! 909: MYSQL_DO_CONNECT_RETURN_FALSE();
! 910: }
! 911: mysql_options(mysql->conn, MYSQL_OPT_LOCAL_INFILE, (char *)&MySG(allow_local_infile));
! 912: }
! 913: } else {
! 914: #ifdef MYSQL_USE_MYSQLND
! 915: mysqlnd_restart_psession(mysql->conn);
! 916: #endif
! 917: }
! 918: }
! 919: ZEND_REGISTER_RESOURCE(return_value, mysql, le_plink);
! 920: } else { /* non persistent */
! 921: zend_rsrc_list_entry *index_ptr, new_index_ptr;
! 922:
! 923: /* first we check the hash for the hashed_details key. if it exists,
! 924: * it should point us to the right offset where the actual mysql link sits.
! 925: * if it doesn't, open a new mysql link, add it to the resource list,
! 926: * and add a pointer to it with hashed_details as the key.
! 927: */
! 928: if (!new_link && zend_hash_find(&EG(regular_list), hashed_details, hashed_details_length+1,(void **) &index_ptr)==SUCCESS) {
! 929: int type;
! 930: long link;
! 931: void *ptr;
! 932:
! 933: if (Z_TYPE_P(index_ptr) != le_index_ptr) {
! 934: MYSQL_DO_CONNECT_RETURN_FALSE();
! 935: }
! 936: link = (long) index_ptr->ptr;
! 937: ptr = zend_list_find(link,&type); /* check if the link is still there */
! 938: if (ptr && (type==le_link || type==le_plink)) {
! 939: zend_list_addref(link);
! 940: Z_LVAL_P(return_value) = link;
! 941: php_mysql_set_default_link(link TSRMLS_CC);
! 942: Z_TYPE_P(return_value) = IS_RESOURCE;
! 943: efree(hashed_details);
! 944: MYSQL_DO_CONNECT_CLEANUP();
! 945: return;
! 946: } else {
! 947: zend_hash_del(&EG(regular_list), hashed_details, hashed_details_length+1);
! 948: }
! 949: }
! 950: if (MySG(max_links) != -1 && MySG(num_links) >= MySG(max_links)) {
! 951: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Too many open links (%ld)", MySG(num_links));
! 952: efree(hashed_details);
! 953: MYSQL_DO_CONNECT_RETURN_FALSE();
! 954: }
! 955:
! 956: mysql = (php_mysql_conn *) emalloc(sizeof(php_mysql_conn));
! 957: mysql->active_result_id = 0;
! 958: #ifdef CLIENT_MULTI_STATEMENTS
! 959: mysql->multi_query = 1;
! 960: #endif
! 961:
! 962: #ifndef MYSQL_USE_MYSQLND
! 963: mysql->conn = mysql_init(NULL);
! 964: #else
! 965: mysql->conn = mysql_init(persistent);
! 966: #endif
! 967: if (!mysql->conn) {
! 968: MySG(connect_error) = estrdup("OOM");
! 969: php_error_docref(NULL TSRMLS_CC, E_WARNING, "OOM");
! 970: efree(hashed_details);
! 971: efree(mysql);
! 972: MYSQL_DO_CONNECT_RETURN_FALSE();
! 973: }
! 974:
! 975: if (connect_timeout != -1) {
! 976: mysql_options(mysql->conn, MYSQL_OPT_CONNECT_TIMEOUT, (const char *)&connect_timeout);
! 977: }
! 978:
! 979: #ifndef MYSQL_USE_MYSQLND
! 980: if (mysql_real_connect(mysql->conn, host, user, passwd, NULL, port, socket, client_flags)==NULL)
! 981: #else
! 982: if (mysqlnd_connect(mysql->conn, host, user, passwd, passwd_len, NULL, 0, port, socket, client_flags TSRMLS_CC) == NULL)
! 983: #endif
! 984: {
! 985: /* Populate connect error globals so that the error functions can read them */
! 986: if (MySG(connect_error) != NULL) {
! 987: efree(MySG(connect_error));
! 988: }
! 989: MySG(connect_error) = estrdup(mysql_error(mysql->conn));
! 990: php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s", MySG(connect_error));
! 991: #if defined(HAVE_MYSQL_ERRNO)
! 992: MySG(connect_errno) = mysql_errno(mysql->conn);
! 993: #endif
! 994: /* free mysql structure */
! 995: #ifdef MYSQL_USE_MYSQLND
! 996: mysqlnd_close(mysql->conn, MYSQLND_CLOSE_DISCONNECTED);
! 997: #endif
! 998: efree(hashed_details);
! 999: efree(mysql);
! 1000: MYSQL_DO_CONNECT_RETURN_FALSE();
! 1001: }
! 1002: mysql_options(mysql->conn, MYSQL_OPT_LOCAL_INFILE, (char *)&MySG(allow_local_infile));
! 1003:
! 1004: /* add it to the list */
! 1005: ZEND_REGISTER_RESOURCE(return_value, mysql, le_link);
! 1006:
! 1007: /* add it to the hash */
! 1008: new_index_ptr.ptr = (void *) Z_LVAL_P(return_value);
! 1009: Z_TYPE(new_index_ptr) = le_index_ptr;
! 1010: if (zend_hash_update(&EG(regular_list), hashed_details, hashed_details_length+1,(void *) &new_index_ptr, sizeof(zend_rsrc_list_entry), NULL)==FAILURE) {
! 1011: efree(hashed_details);
! 1012: MYSQL_DO_CONNECT_RETURN_FALSE();
! 1013: }
! 1014: MySG(num_links)++;
! 1015: }
! 1016:
! 1017: efree(hashed_details);
! 1018: php_mysql_set_default_link(Z_LVAL_P(return_value) TSRMLS_CC);
! 1019: MYSQL_DO_CONNECT_CLEANUP();
! 1020: }
! 1021: /* }}} */
! 1022:
! 1023: /* {{{ php_mysql_get_default_link
! 1024: */
! 1025: static int php_mysql_get_default_link(INTERNAL_FUNCTION_PARAMETERS)
! 1026: {
! 1027: if (MySG(default_link)==-1) { /* no link opened yet, implicitly open one */
! 1028: ht = 0;
! 1029: php_mysql_do_connect(INTERNAL_FUNCTION_PARAM_PASSTHRU, 0);
! 1030: }
! 1031: return MySG(default_link);
! 1032: }
! 1033: /* }}} */
! 1034:
! 1035: /* {{{ proto resource mysql_connect([string hostname[:port][:/path/to/socket] [, string username [, string password [, bool new [, int flags]]]]])
! 1036: Opens a connection to a MySQL Server */
! 1037: PHP_FUNCTION(mysql_connect)
! 1038: {
! 1039: php_mysql_do_connect(INTERNAL_FUNCTION_PARAM_PASSTHRU, 0);
! 1040: }
! 1041: /* }}} */
! 1042:
! 1043: /* {{{ proto resource mysql_pconnect([string hostname[:port][:/path/to/socket] [, string username [, string password [, int flags]]]])
! 1044: Opens a persistent connection to a MySQL Server */
! 1045: PHP_FUNCTION(mysql_pconnect)
! 1046: {
! 1047: php_mysql_do_connect(INTERNAL_FUNCTION_PARAM_PASSTHRU, 1);
! 1048: }
! 1049: /* }}} */
! 1050:
! 1051: /* {{{ proto bool mysql_close([int link_identifier])
! 1052: Close a MySQL connection */
! 1053: PHP_FUNCTION(mysql_close)
! 1054: {
! 1055: int resource_id;
! 1056: zval *mysql_link=NULL;
! 1057: php_mysql_conn *mysql;
! 1058:
! 1059: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
! 1060: return;
! 1061: }
! 1062:
! 1063: if (mysql_link) {
! 1064: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, -1, "MySQL-Link", le_link, le_plink);
! 1065: } else {
! 1066: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, NULL, MySG(default_link), "MySQL-Link", le_link, le_plink);
! 1067: }
! 1068:
! 1069: resource_id = mysql_link ? Z_RESVAL_P(mysql_link) : MySG(default_link);
! 1070: PHPMY_UNBUFFERED_QUERY_CHECK();
! 1071: #ifdef MYSQL_USE_MYSQLND
! 1072: {
! 1073: int tmp;
! 1074: if ((mysql = zend_list_find(resource_id, &tmp)) && tmp == le_plink) {
! 1075: mysqlnd_end_psession(mysql->conn);
! 1076: }
! 1077: }
! 1078: #endif
! 1079: zend_list_delete(resource_id);
! 1080:
! 1081: if (!mysql_link
! 1082: || (mysql_link && Z_RESVAL_P(mysql_link)==MySG(default_link))) {
! 1083: MySG(default_link) = -1;
! 1084: if (mysql_link) {
! 1085: /* on an explicit close of the default connection it had a refcount of 2 so we need one more call */
! 1086: zend_list_delete(resource_id);
! 1087: }
! 1088: }
! 1089:
! 1090: RETURN_TRUE;
! 1091: }
! 1092: /* }}} */
! 1093:
! 1094: /* {{{ proto bool mysql_select_db(string database_name [, int link_identifier])
! 1095: Selects a MySQL database */
! 1096: PHP_FUNCTION(mysql_select_db)
! 1097: {
! 1098: char *db;
! 1099: int db_len;
! 1100: zval *mysql_link = NULL;
! 1101: int id = -1;
! 1102: php_mysql_conn *mysql;
! 1103:
! 1104: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|r", &db, &db_len, &mysql_link) == FAILURE) {
! 1105: return;
! 1106: }
! 1107:
! 1108: if (!mysql_link) {
! 1109: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1110: CHECK_LINK(id);
! 1111: }
! 1112:
! 1113: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1114:
! 1115: if (php_mysql_select_db(mysql, db TSRMLS_CC)) {
! 1116: RETURN_TRUE;
! 1117: } else {
! 1118: RETURN_FALSE;
! 1119: }
! 1120: }
! 1121: /* }}} */
! 1122:
! 1123: #ifdef HAVE_GETINFO_FUNCS
! 1124:
! 1125: /* {{{ proto string mysql_get_client_info(void)
! 1126: Returns a string that represents the client library version */
! 1127: PHP_FUNCTION(mysql_get_client_info)
! 1128: {
! 1129: if (zend_parse_parameters_none() == FAILURE) {
! 1130: return;
! 1131: }
! 1132:
! 1133: RETURN_STRING((char *)mysql_get_client_info(),1);
! 1134: }
! 1135: /* }}} */
! 1136:
! 1137: /* {{{ proto string mysql_get_host_info([int link_identifier])
! 1138: Returns a string describing the type of connection in use, including the server host name */
! 1139: PHP_FUNCTION(mysql_get_host_info)
! 1140: {
! 1141: zval *mysql_link = NULL;
! 1142: int id = -1;
! 1143: php_mysql_conn *mysql;
! 1144:
! 1145: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
! 1146: return;
! 1147: }
! 1148:
! 1149: if (!mysql_link) {
! 1150: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1151: CHECK_LINK(id);
! 1152: }
! 1153:
! 1154: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1155:
! 1156: RETURN_STRING((char *)mysql_get_host_info(mysql->conn),1);
! 1157: }
! 1158: /* }}} */
! 1159:
! 1160: /* {{{ proto int mysql_get_proto_info([int link_identifier])
! 1161: Returns the protocol version used by current connection */
! 1162: PHP_FUNCTION(mysql_get_proto_info)
! 1163: {
! 1164: zval *mysql_link = NULL;
! 1165: int id = -1;
! 1166: php_mysql_conn *mysql;
! 1167:
! 1168: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
! 1169: return;
! 1170: }
! 1171:
! 1172: if (!mysql_link) {
! 1173: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1174: CHECK_LINK(id);
! 1175: }
! 1176:
! 1177: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1178:
! 1179: RETURN_LONG(mysql_get_proto_info(mysql->conn));
! 1180: }
! 1181: /* }}} */
! 1182:
! 1183: /* {{{ proto string mysql_get_server_info([int link_identifier])
! 1184: Returns a string that represents the server version number */
! 1185: PHP_FUNCTION(mysql_get_server_info)
! 1186: {
! 1187: zval *mysql_link = NULL;
! 1188: int id = -1;
! 1189: php_mysql_conn *mysql;
! 1190:
! 1191: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
! 1192: return;
! 1193: }
! 1194:
! 1195: if (!mysql_link) {
! 1196: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1197: CHECK_LINK(id);
! 1198: }
! 1199:
! 1200: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1201:
! 1202: RETURN_STRING((char *)mysql_get_server_info(mysql->conn),1);
! 1203: }
! 1204: /* }}} */
! 1205:
! 1206: /* {{{ proto string mysql_info([int link_identifier])
! 1207: Returns a string containing information about the most recent query */
! 1208: PHP_FUNCTION(mysql_info)
! 1209: {
! 1210: zval *mysql_link = NULL;
! 1211: int id = -1;
! 1212: char *str;
! 1213: php_mysql_conn *mysql;
! 1214:
! 1215: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
! 1216: return;
! 1217: }
! 1218:
! 1219: if (ZEND_NUM_ARGS() == 0) {
! 1220: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1221: CHECK_LINK(id);
! 1222: }
! 1223:
! 1224: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1225:
! 1226: if ((str = (char *)mysql_info(mysql->conn))) {
! 1227: RETURN_STRING(str,1);
! 1228: } else {
! 1229: RETURN_FALSE;
! 1230: }
! 1231: }
! 1232: /* }}} */
! 1233:
! 1234: /* {{{ proto int mysql_thread_id([int link_identifier])
! 1235: Returns the thread id of current connection */
! 1236: PHP_FUNCTION(mysql_thread_id)
! 1237: {
! 1238: zval *mysql_link = NULL;
! 1239: int id = -1;
! 1240: php_mysql_conn *mysql;
! 1241:
! 1242: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
! 1243: return;
! 1244: }
! 1245:
! 1246: if (ZEND_NUM_ARGS() == 0) {
! 1247: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1248: CHECK_LINK(id);
! 1249: }
! 1250: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1251:
! 1252: RETURN_LONG((long) mysql_thread_id(mysql->conn));
! 1253: }
! 1254: /* }}} */
! 1255:
! 1256: /* {{{ proto string mysql_stat([int link_identifier])
! 1257: Returns a string containing status information */
! 1258: PHP_FUNCTION(mysql_stat)
! 1259: {
! 1260: zval *mysql_link = NULL;
! 1261: int id = -1;
! 1262: php_mysql_conn *mysql;
! 1263: char *stat;
! 1264: #ifdef MYSQL_USE_MYSQLND
! 1265: uint stat_len;
! 1266: #endif
! 1267:
! 1268: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
! 1269: return;
! 1270: }
! 1271:
! 1272: if (ZEND_NUM_ARGS() == 0) {
! 1273: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1274: CHECK_LINK(id);
! 1275: }
! 1276: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1277:
! 1278: PHPMY_UNBUFFERED_QUERY_CHECK();
! 1279: #ifndef MYSQL_USE_MYSQLND
! 1280: if ((stat = (char *)mysql_stat(mysql->conn))) {
! 1281: RETURN_STRING(stat, 1);
! 1282: #else
! 1283: if (mysqlnd_stat(mysql->conn, &stat, &stat_len) == PASS) {
! 1284: RETURN_STRINGL(stat, stat_len, 0);
! 1285: #endif
! 1286: } else {
! 1287: RETURN_FALSE;
! 1288: }
! 1289: }
! 1290: /* }}} */
! 1291:
! 1292: /* {{{ proto string mysql_client_encoding([int link_identifier])
! 1293: Returns the default character set for the current connection */
! 1294: PHP_FUNCTION(mysql_client_encoding)
! 1295: {
! 1296: zval *mysql_link = NULL;
! 1297: int id = -1;
! 1298: php_mysql_conn *mysql;
! 1299:
! 1300: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
! 1301: return;
! 1302: }
! 1303:
! 1304: if (ZEND_NUM_ARGS() == 0) {
! 1305: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1306: CHECK_LINK(id);
! 1307: }
! 1308:
! 1309: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1310: RETURN_STRING((char *)mysql_character_set_name(mysql->conn), 1);
! 1311: }
! 1312: /* }}} */
! 1313: #endif
! 1314:
! 1315: #ifdef MYSQL_HAS_SET_CHARSET
! 1316: /* {{{ proto bool mysql_set_charset(string csname [, int link_identifier])
! 1317: sets client character set */
! 1318: PHP_FUNCTION(mysql_set_charset)
! 1319: {
! 1320: zval *mysql_link = NULL;
! 1321: char *csname;
! 1322: int id = -1, csname_len;
! 1323: php_mysql_conn *mysql;
! 1324:
! 1325: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|r", &csname, &csname_len, &mysql_link) == FAILURE) {
! 1326: return;
! 1327: }
! 1328:
! 1329: if (ZEND_NUM_ARGS() == 1) {
! 1330: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1331: CHECK_LINK(id);
! 1332: }
! 1333:
! 1334: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1335:
! 1336: if (!mysql_set_character_set(mysql->conn, csname)) {
! 1337: RETURN_TRUE;
! 1338: } else {
! 1339: RETURN_FALSE;
! 1340: }
! 1341: }
! 1342: /* }}} */
! 1343: #endif
! 1344:
! 1345: #ifndef NETWARE /* The below two functions not supported on NetWare */
! 1346: #if MYSQL_VERSION_ID < 40000
! 1347: /* {{{ proto bool mysql_create_db(string database_name [, int link_identifier])
! 1348: Create a MySQL database */
! 1349: PHP_FUNCTION(mysql_create_db)
! 1350: {
! 1351: char *db;
! 1352: int db_len;
! 1353: zval *mysql_link = NULL;
! 1354: int id = -1;
! 1355: php_mysql_conn *mysql;
! 1356:
! 1357: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|r", &db, &db_len, &mysql_link) == FAILURE) {
! 1358: return;
! 1359: }
! 1360:
! 1361: if (!mysql_link) {
! 1362: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1363: CHECK_LINK(id);
! 1364: }
! 1365:
! 1366: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1367:
! 1368: PHPMY_UNBUFFERED_QUERY_CHECK();
! 1369:
! 1370: if (mysql_create_db(mysql->conn, db)==0) {
! 1371: RETURN_TRUE;
! 1372: } else {
! 1373: RETURN_FALSE;
! 1374: }
! 1375: }
! 1376: /* }}} */
! 1377:
! 1378: /* {{{ proto bool mysql_drop_db(string database_name [, int link_identifier])
! 1379: Drops (delete) a MySQL database */
! 1380: PHP_FUNCTION(mysql_drop_db)
! 1381: {
! 1382: char *db;
! 1383: int db_len;
! 1384: zval *mysql_link = NULL;
! 1385: int id = -1;
! 1386: php_mysql_conn *mysql;
! 1387:
! 1388: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|r", &db, &db_len, &mysql_link) == FAILURE) {
! 1389: return;
! 1390: }
! 1391:
! 1392: if (!mysql_link) {
! 1393: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1394: CHECK_LINK(id);
! 1395: }
! 1396:
! 1397: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1398:
! 1399: if (mysql_drop_db(mysql->conn, db)==0) {
! 1400: RETURN_TRUE;
! 1401: } else {
! 1402: RETURN_FALSE;
! 1403: }
! 1404: }
! 1405: /* }}} */
! 1406: #endif
! 1407: #endif /* NETWARE */
! 1408:
! 1409: /* {{{ php_mysql_do_query_general
! 1410: */
! 1411: static void php_mysql_do_query_general(char *query, int query_len, zval *mysql_link, int link_id, char *db, int use_store, zval *return_value TSRMLS_DC)
! 1412: {
! 1413: php_mysql_conn *mysql;
! 1414: MYSQL_RES *mysql_result;
! 1415:
! 1416: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, link_id, "MySQL-Link", le_link, le_plink);
! 1417:
! 1418: if (db) {
! 1419: if (!php_mysql_select_db(mysql, db TSRMLS_CC)) {
! 1420: RETURN_FALSE;
! 1421: }
! 1422: }
! 1423:
! 1424: PHPMY_UNBUFFERED_QUERY_CHECK();
! 1425:
! 1426: MYSQL_DISABLE_MQ;
! 1427:
! 1428: #ifndef MYSQL_USE_MYSQLND
! 1429: /* check explain */
! 1430: if (MySG(trace_mode)) {
! 1431: if (!strncasecmp("select", query, 6)){
! 1432: MYSQL_ROW row;
! 1433:
! 1434: char *newquery;
! 1435: int newql = spprintf (&newquery, 0, "EXPLAIN %s", query);
! 1436: mysql_real_query(mysql->conn, newquery, newql);
! 1437: efree (newquery);
! 1438: if (mysql_errno(mysql->conn)) {
! 1439: php_error_docref("http://www.mysql.com/doc" TSRMLS_CC, E_WARNING, "%s", mysql_error(mysql->conn));
! 1440: RETURN_FALSE;
! 1441: }
! 1442: else {
! 1443: mysql_result = mysql_use_result(mysql->conn);
! 1444: while ((row = mysql_fetch_row(mysql_result))) {
! 1445: if (!strcmp("ALL", row[1])) {
! 1446: php_error_docref("http://www.mysql.com/doc" TSRMLS_CC, E_WARNING, "Your query requires a full tablescan (table %s, %s rows affected). Use EXPLAIN to optimize your query.", row[0], row[6]);
! 1447: } else if (!strcmp("INDEX", row[1])) {
! 1448: php_error_docref("http://www.mysql.com/doc" TSRMLS_CC, E_WARNING, "Your query requires a full indexscan (table %s, %s rows affected). Use EXPLAIN to optimize your query.", row[0], row[6]);
! 1449: }
! 1450: }
! 1451: mysql_free_result(mysql_result);
! 1452: }
! 1453: }
! 1454: } /* end explain */
! 1455: #endif
! 1456:
! 1457: /* mysql_query is binary unsafe, use mysql_real_query */
! 1458: #if MYSQL_VERSION_ID > 32199
! 1459: if (mysql_real_query(mysql->conn, query, query_len)!=0) {
! 1460: /* check possible error */
! 1461: if (MySG(trace_mode)){
! 1462: if (mysql_errno(mysql->conn)){
! 1463: php_error_docref("http://www.mysql.com/doc" TSRMLS_CC, E_WARNING, "%s", mysql_error(mysql->conn));
! 1464: }
! 1465: }
! 1466: RETURN_FALSE;
! 1467: }
! 1468: #else
! 1469: if (mysql_query(mysql->conn, query)!=0) {
! 1470: /* check possible error */
! 1471: if (MySG(trace_mode)){
! 1472: if (mysql_errno(mysql->conn)){
! 1473: php_error_docref("http://www.mysql.com/doc" TSRMLS_CC, E_WARNING, "%s", mysql_error(mysql->conn));
! 1474: }
! 1475: }
! 1476: RETURN_FALSE;
! 1477: }
! 1478: #endif
! 1479: if(use_store == MYSQL_USE_RESULT) {
! 1480: mysql_result=mysql_use_result(mysql->conn);
! 1481: } else {
! 1482: mysql_result=mysql_store_result(mysql->conn);
! 1483: }
! 1484: if (!mysql_result) {
! 1485: if (PHP_MYSQL_VALID_RESULT(mysql->conn)) { /* query should have returned rows */
! 1486: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to save result set");
! 1487: RETURN_FALSE;
! 1488: } else {
! 1489: RETURN_TRUE;
! 1490: }
! 1491: }
! 1492: MySG(result_allocated)++;
! 1493: ZEND_REGISTER_RESOURCE(return_value, mysql_result, le_result);
! 1494: if (use_store == MYSQL_USE_RESULT) {
! 1495: mysql->active_result_id = Z_LVAL_P(return_value);
! 1496: }
! 1497: }
! 1498: /* }}} */
! 1499:
! 1500: /* {{{ php_mysql_do_query
! 1501: */
! 1502: static void php_mysql_do_query(INTERNAL_FUNCTION_PARAMETERS, int use_store)
! 1503: {
! 1504: char *query;
! 1505: int query_len;
! 1506: zval *mysql_link = NULL;
! 1507: int id = -1;
! 1508:
! 1509: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|r", &query, &query_len, &mysql_link) == FAILURE) {
! 1510: return;
! 1511: }
! 1512:
! 1513: if (!mysql_link) {
! 1514: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1515: CHECK_LINK(id);
! 1516: }
! 1517:
! 1518: php_mysql_do_query_general(query, query_len, mysql_link, id, NULL, use_store, return_value TSRMLS_CC);
! 1519: }
! 1520: /* }}} */
! 1521:
! 1522: /* {{{ proto resource mysql_query(string query [, int link_identifier])
! 1523: Sends an SQL query to MySQL */
! 1524: PHP_FUNCTION(mysql_query)
! 1525: {
! 1526: php_mysql_do_query(INTERNAL_FUNCTION_PARAM_PASSTHRU, MYSQL_STORE_RESULT);
! 1527: }
! 1528: /* }}} */
! 1529:
! 1530:
! 1531: /* {{{ proto resource mysql_unbuffered_query(string query [, int link_identifier])
! 1532: Sends an SQL query to MySQL, without fetching and buffering the result rows */
! 1533: PHP_FUNCTION(mysql_unbuffered_query)
! 1534: {
! 1535: php_mysql_do_query(INTERNAL_FUNCTION_PARAM_PASSTHRU, MYSQL_USE_RESULT);
! 1536: }
! 1537: /* }}} */
! 1538:
! 1539:
! 1540: /* {{{ proto resource mysql_db_query(string database_name, string query [, int link_identifier])
! 1541: Sends an SQL query to MySQL */
! 1542: PHP_FUNCTION(mysql_db_query)
! 1543: {
! 1544: char *db, *query;
! 1545: int db_len, query_len;
! 1546: zval *mysql_link = NULL;
! 1547: int id = -1;
! 1548:
! 1549: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "ss|r", &db, &db_len, &query, &query_len, &mysql_link) == FAILURE) {
! 1550: return;
! 1551: }
! 1552:
! 1553: if (!mysql_link) {
! 1554: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1555: CHECK_LINK(id);
! 1556: }
! 1557:
! 1558: php_error_docref(NULL TSRMLS_CC, E_DEPRECATED, "This function is deprecated; use mysql_query() instead");
! 1559:
! 1560: php_mysql_do_query_general(query, query_len, mysql_link, id, db, MYSQL_STORE_RESULT, return_value TSRMLS_CC);
! 1561: }
! 1562: /* }}} */
! 1563:
! 1564:
! 1565: /* {{{ proto resource mysql_list_dbs([int link_identifier])
! 1566: List databases available on a MySQL server */
! 1567: PHP_FUNCTION(mysql_list_dbs)
! 1568: {
! 1569: zval *mysql_link = NULL;
! 1570: int id = -1;
! 1571: php_mysql_conn *mysql;
! 1572: MYSQL_RES *mysql_result;
! 1573:
! 1574: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
! 1575: return;
! 1576: }
! 1577:
! 1578: if (!mysql_link) {
! 1579: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1580: CHECK_LINK(id);
! 1581: }
! 1582:
! 1583: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1584:
! 1585: PHPMY_UNBUFFERED_QUERY_CHECK();
! 1586:
! 1587: if ((mysql_result=mysql_list_dbs(mysql->conn, NULL))==NULL) {
! 1588: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to save MySQL query result");
! 1589: RETURN_FALSE;
! 1590: }
! 1591: MySG(result_allocated)++;
! 1592: ZEND_REGISTER_RESOURCE(return_value, mysql_result, le_result);
! 1593: }
! 1594: /* }}} */
! 1595:
! 1596:
! 1597: /* {{{ proto resource mysql_list_tables(string database_name [, int link_identifier])
! 1598: List tables in a MySQL database */
! 1599: PHP_FUNCTION(mysql_list_tables)
! 1600: {
! 1601: char *db;
! 1602: int db_len;
! 1603: zval *mysql_link = NULL;
! 1604: int id = -1;
! 1605: php_mysql_conn *mysql;
! 1606: MYSQL_RES *mysql_result;
! 1607:
! 1608: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|r", &db, &db_len, &mysql_link) == FAILURE) {
! 1609: return;
! 1610: }
! 1611:
! 1612: if (!mysql_link) {
! 1613: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1614: CHECK_LINK(id);
! 1615: }
! 1616:
! 1617: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1618:
! 1619: if (!php_mysql_select_db(mysql, db TSRMLS_CC)) {
! 1620: RETURN_FALSE;
! 1621: }
! 1622:
! 1623: PHPMY_UNBUFFERED_QUERY_CHECK();
! 1624:
! 1625: if ((mysql_result=mysql_list_tables(mysql->conn, NULL))==NULL) {
! 1626: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to save MySQL query result");
! 1627: RETURN_FALSE;
! 1628: }
! 1629: MySG(result_allocated)++;
! 1630: ZEND_REGISTER_RESOURCE(return_value, mysql_result, le_result);
! 1631: }
! 1632: /* }}} */
! 1633:
! 1634:
! 1635: /* {{{ proto resource mysql_list_fields(string database_name, string table_name [, int link_identifier])
! 1636: List MySQL result fields */
! 1637: PHP_FUNCTION(mysql_list_fields)
! 1638: {
! 1639: char *db, *table;
! 1640: int db_len, table_len;
! 1641: zval *mysql_link = NULL;
! 1642: int id = -1;
! 1643: php_mysql_conn *mysql;
! 1644: MYSQL_RES *mysql_result;
! 1645:
! 1646: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "ss|r", &db, &db_len, &table, &table_len, &mysql_link) == FAILURE) {
! 1647: return;
! 1648: }
! 1649:
! 1650: if (!mysql_link) {
! 1651: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1652: CHECK_LINK(id);
! 1653: }
! 1654:
! 1655: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1656:
! 1657: if (!php_mysql_select_db(mysql, db TSRMLS_CC)) {
! 1658: RETURN_FALSE;
! 1659: }
! 1660:
! 1661: PHPMY_UNBUFFERED_QUERY_CHECK();
! 1662:
! 1663: if ((mysql_result=mysql_list_fields(mysql->conn, table, NULL))==NULL) {
! 1664: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to save MySQL query result");
! 1665: RETURN_FALSE;
! 1666: }
! 1667: MySG(result_allocated)++;
! 1668: ZEND_REGISTER_RESOURCE(return_value, mysql_result, le_result);
! 1669: }
! 1670: /* }}} */
! 1671:
! 1672: /* {{{ proto resource mysql_list_processes([int link_identifier])
! 1673: Returns a result set describing the current server threads */
! 1674: PHP_FUNCTION(mysql_list_processes)
! 1675: {
! 1676: zval *mysql_link = NULL;
! 1677: int id = -1;
! 1678: php_mysql_conn *mysql;
! 1679: MYSQL_RES *mysql_result;
! 1680:
! 1681: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
! 1682: return;
! 1683: }
! 1684:
! 1685: if (ZEND_NUM_ARGS() == 0) {
! 1686: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1687: CHECK_LINK(id);
! 1688: }
! 1689:
! 1690: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1691:
! 1692: PHPMY_UNBUFFERED_QUERY_CHECK();
! 1693:
! 1694: mysql_result = mysql_list_processes(mysql->conn);
! 1695: if (mysql_result == NULL) {
! 1696: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to save MySQL query result");
! 1697: RETURN_FALSE;
! 1698: }
! 1699:
! 1700: MySG(result_allocated)++;
! 1701: ZEND_REGISTER_RESOURCE(return_value, mysql_result, le_result);
! 1702: }
! 1703: /* }}} */
! 1704:
! 1705:
! 1706: /* {{{ proto string mysql_error([int link_identifier])
! 1707: Returns the text of the error message from previous MySQL operation */
! 1708: PHP_FUNCTION(mysql_error)
! 1709: {
! 1710: zval *mysql_link = NULL;
! 1711: int id = -1;
! 1712: php_mysql_conn *mysql;
! 1713:
! 1714: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
! 1715: return;
! 1716: }
! 1717:
! 1718: if (!mysql_link) {
! 1719: id = MySG(default_link);
! 1720: if (id==-1) {
! 1721: if (MySG(connect_error)!=NULL){
! 1722: RETURN_STRING(MySG(connect_error),1);
! 1723: } else {
! 1724: RETURN_FALSE;
! 1725: }
! 1726: }
! 1727: }
! 1728:
! 1729: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1730:
! 1731: RETURN_STRING((char *)mysql_error(mysql->conn), 1);
! 1732: }
! 1733: /* }}} */
! 1734:
! 1735:
! 1736: /* {{{ proto int mysql_errno([int link_identifier])
! 1737: Returns the number of the error message from previous MySQL operation */
! 1738: #ifdef HAVE_MYSQL_ERRNO
! 1739: PHP_FUNCTION(mysql_errno)
! 1740: {
! 1741: zval *mysql_link = NULL;
! 1742: int id = -1;
! 1743: php_mysql_conn *mysql;
! 1744:
! 1745: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
! 1746: return;
! 1747: }
! 1748:
! 1749: if (!mysql_link) {
! 1750: id = MySG(default_link);
! 1751: if (id==-1) {
! 1752: if (MySG(connect_errno)!=0){
! 1753: RETURN_LONG(MySG(connect_errno));
! 1754: } else {
! 1755: RETURN_FALSE;
! 1756: }
! 1757: }
! 1758: }
! 1759:
! 1760: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1761:
! 1762: RETURN_LONG(mysql_errno(mysql->conn));
! 1763: }
! 1764: #endif
! 1765: /* }}} */
! 1766:
! 1767:
! 1768: /* {{{ proto int mysql_affected_rows([int link_identifier])
! 1769: Gets number of affected rows in previous MySQL operation */
! 1770: PHP_FUNCTION(mysql_affected_rows)
! 1771: {
! 1772: zval *mysql_link = NULL;
! 1773: int id = -1;
! 1774: php_mysql_conn *mysql;
! 1775:
! 1776: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
! 1777: return;
! 1778: }
! 1779:
! 1780: if (!mysql_link) {
! 1781: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1782: CHECK_LINK(id);
! 1783: }
! 1784:
! 1785: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1786:
! 1787: /* conversion from int64 to long happing here */
! 1788: Z_LVAL_P(return_value) = (long) mysql_affected_rows(mysql->conn);
! 1789: Z_TYPE_P(return_value) = IS_LONG;
! 1790: }
! 1791: /* }}} */
! 1792:
! 1793:
! 1794: /* {{{ proto string mysql_escape_string(string to_be_escaped)
! 1795: Escape string for mysql query */
! 1796: PHP_FUNCTION(mysql_escape_string)
! 1797: {
! 1798: char *str;
! 1799: int str_len;
! 1800:
! 1801: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &str, &str_len) == FAILURE) {
! 1802: return;
! 1803: }
! 1804:
! 1805: /* assume worst case situation, which is 2x of the original string.
! 1806: * we don't realloc() down to the real size since it'd most probably not
! 1807: * be worth it
! 1808: */
! 1809:
! 1810: Z_STRVAL_P(return_value) = (char *) safe_emalloc(str_len, 2, 1);
! 1811: Z_STRLEN_P(return_value) = mysql_escape_string(Z_STRVAL_P(return_value), str, str_len);
! 1812: Z_TYPE_P(return_value) = IS_STRING;
! 1813:
! 1814: if (MySG(trace_mode)){
! 1815: php_error_docref("function.mysql-real-escape-string" TSRMLS_CC, E_DEPRECATED, "This function is deprecated; use mysql_real_escape_string() instead.");
! 1816: }
! 1817: }
! 1818: /* }}} */
! 1819:
! 1820: /* {{{ proto string mysql_real_escape_string(string to_be_escaped [, int link_identifier])
! 1821: Escape special characters in a string for use in a SQL statement, taking into account the current charset of the connection */
! 1822: PHP_FUNCTION(mysql_real_escape_string)
! 1823: {
! 1824: zval *mysql_link = NULL;
! 1825: char *str;
! 1826: char *new_str;
! 1827: int id = -1, str_len, new_str_len;
! 1828: php_mysql_conn *mysql;
! 1829:
! 1830:
! 1831: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|r", &str, &str_len, &mysql_link) == FAILURE) {
! 1832: return;
! 1833: }
! 1834:
! 1835: if (ZEND_NUM_ARGS() == 1) {
! 1836: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1837: CHECK_LINK(id);
! 1838: }
! 1839:
! 1840: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1841:
! 1842: new_str = safe_emalloc(str_len, 2, 1);
! 1843: new_str_len = mysql_real_escape_string(mysql->conn, new_str, str, str_len);
! 1844: new_str = erealloc(new_str, new_str_len + 1);
! 1845:
! 1846: RETURN_STRINGL(new_str, new_str_len, 0);
! 1847: }
! 1848: /* }}} */
! 1849:
! 1850: /* {{{ proto int mysql_insert_id([int link_identifier])
! 1851: Gets the ID generated from the previous INSERT operation */
! 1852: PHP_FUNCTION(mysql_insert_id)
! 1853: {
! 1854: zval *mysql_link = NULL;
! 1855: int id = -1;
! 1856: php_mysql_conn *mysql;
! 1857:
! 1858: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
! 1859: return;
! 1860: }
! 1861:
! 1862: if (!mysql_link) {
! 1863: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 1864: CHECK_LINK(id);
! 1865: }
! 1866:
! 1867: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 1868:
! 1869: /* conversion from int64 to long happing here */
! 1870: Z_LVAL_P(return_value) = (long) mysql_insert_id(mysql->conn);
! 1871: Z_TYPE_P(return_value) = IS_LONG;
! 1872: }
! 1873: /* }}} */
! 1874:
! 1875:
! 1876: /* {{{ proto mixed mysql_result(resource result, int row [, mixed field])
! 1877: Gets result data */
! 1878: PHP_FUNCTION(mysql_result)
! 1879: {
! 1880: zval *result, *field=NULL;
! 1881: long row;
! 1882: MYSQL_RES *mysql_result;
! 1883: #ifndef MYSQL_USE_MYSQLND
! 1884: MYSQL_ROW sql_row;
! 1885: mysql_row_length_type *sql_row_lengths;
! 1886: #endif
! 1887: int field_offset=0;
! 1888:
! 1889: /*
! 1890: johannes TODO:
! 1891: Do 2 zend_parse_paramters calls instead of type "z" and switch below
! 1892: Q: String or long first?
! 1893: */
! 1894: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rl|z", &result, &row, &field) == FAILURE) {
! 1895: return;
! 1896: }
! 1897:
! 1898: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
! 1899:
! 1900: if (row<0 || row>=(int)mysql_num_rows(mysql_result)) {
! 1901: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to jump to row %ld on MySQL result index %ld", row, Z_LVAL_P(result));
! 1902: RETURN_FALSE;
! 1903: }
! 1904: mysql_data_seek(mysql_result, row);
! 1905:
! 1906: if (field) {
! 1907: switch(Z_TYPE_P(field)) {
! 1908: case IS_STRING: {
! 1909: int i=0;
! 1910: const MYSQL_FIELD *tmp_field;
! 1911: char *table_name, *field_name, *tmp;
! 1912:
! 1913: if ((tmp=strchr(Z_STRVAL_P(field), '.'))) {
! 1914: table_name = estrndup(Z_STRVAL_P(field), tmp-Z_STRVAL_P(field));
! 1915: field_name = estrdup(tmp+1);
! 1916: } else {
! 1917: table_name = NULL;
! 1918: field_name = estrndup(Z_STRVAL_P(field),Z_STRLEN_P(field));
! 1919: }
! 1920: mysql_field_seek(mysql_result, 0);
! 1921: while ((tmp_field=mysql_fetch_field(mysql_result))) {
! 1922: if ((!table_name || !strcasecmp(tmp_field->table, table_name)) && !strcasecmp(tmp_field->name, field_name)) {
! 1923: field_offset = i;
! 1924: break;
! 1925: }
! 1926: i++;
! 1927: }
! 1928: if (!tmp_field) { /* no match found */
! 1929: php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s%s%s not found in MySQL result index %ld",
! 1930: (table_name?table_name:""), (table_name?".":""), field_name, Z_LVAL_P(result));
! 1931: efree(field_name);
! 1932: if (table_name) {
! 1933: efree(table_name);
! 1934: }
! 1935: RETURN_FALSE;
! 1936: }
! 1937: efree(field_name);
! 1938: if (table_name) {
! 1939: efree(table_name);
! 1940: }
! 1941: }
! 1942: break;
! 1943: default:
! 1944: convert_to_long_ex(&field);
! 1945: field_offset = Z_LVAL_P(field);
! 1946: if (field_offset<0 || field_offset>=(int)mysql_num_fields(mysql_result)) {
! 1947: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Bad column offset specified");
! 1948: RETURN_FALSE;
! 1949: }
! 1950: break;
! 1951: }
! 1952: }
! 1953:
! 1954: #ifndef MYSQL_USE_MYSQLND
! 1955: if ((sql_row=mysql_fetch_row(mysql_result))==NULL
! 1956: || (sql_row_lengths=mysql_fetch_lengths(mysql_result))==NULL) { /* shouldn't happen? */
! 1957: RETURN_FALSE;
! 1958: }
! 1959: if (sql_row[field_offset]) {
! 1960: Z_TYPE_P(return_value) = IS_STRING;
! 1961:
! 1962: if (PG(magic_quotes_runtime)) {
! 1963: Z_STRVAL_P(return_value) = php_addslashes(sql_row[field_offset], sql_row_lengths[field_offset],&Z_STRLEN_P(return_value), 0 TSRMLS_CC);
! 1964: } else {
! 1965: Z_STRLEN_P(return_value) = sql_row_lengths[field_offset];
! 1966: Z_STRVAL_P(return_value) = (char *) safe_estrndup(sql_row[field_offset], Z_STRLEN_P(return_value));
! 1967: }
! 1968: } else {
! 1969: Z_TYPE_P(return_value) = IS_NULL;
! 1970: }
! 1971: #else
! 1972: mysqlnd_result_fetch_field_data(mysql_result, field_offset, return_value);
! 1973: #endif
! 1974: }
! 1975: /* }}} */
! 1976:
! 1977:
! 1978: /* {{{ proto int mysql_num_rows(resource result)
! 1979: Gets number of rows in a result */
! 1980: PHP_FUNCTION(mysql_num_rows)
! 1981: {
! 1982: zval *result;
! 1983: MYSQL_RES *mysql_result;
! 1984:
! 1985: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &result) == FAILURE) {
! 1986: return;
! 1987: }
! 1988:
! 1989: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
! 1990:
! 1991: /* conversion from int64 to long happing here */
! 1992: Z_LVAL_P(return_value) = (long) mysql_num_rows(mysql_result);
! 1993: Z_TYPE_P(return_value) = IS_LONG;
! 1994: }
! 1995: /* }}} */
! 1996:
! 1997: /* {{{ proto int mysql_num_fields(resource result)
! 1998: Gets number of fields in a result */
! 1999: PHP_FUNCTION(mysql_num_fields)
! 2000: {
! 2001: zval *result;
! 2002: MYSQL_RES *mysql_result;
! 2003:
! 2004: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &result) == FAILURE) {
! 2005: return;
! 2006: }
! 2007:
! 2008: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
! 2009:
! 2010: Z_LVAL_P(return_value) = mysql_num_fields(mysql_result);
! 2011: Z_TYPE_P(return_value) = IS_LONG;
! 2012: }
! 2013: /* }}} */
! 2014:
! 2015: /* {{{ php_mysql_fetch_hash
! 2016: */
! 2017: static void php_mysql_fetch_hash(INTERNAL_FUNCTION_PARAMETERS, long result_type, int expected_args, int into_object)
! 2018: {
! 2019: MYSQL_RES *mysql_result;
! 2020: zval *res, *ctor_params = NULL;
! 2021: zend_class_entry *ce = NULL;
! 2022: #ifndef MYSQL_USE_MYSQLND
! 2023: int i;
! 2024: MYSQL_FIELD *mysql_field;
! 2025: MYSQL_ROW mysql_row;
! 2026: mysql_row_length_type *mysql_row_lengths;
! 2027: #endif
! 2028:
! 2029: #ifdef ZEND_ENGINE_2
! 2030: if (into_object) {
! 2031: char *class_name = NULL;
! 2032: int class_name_len = 0;
! 2033:
! 2034: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "z|sz", &res, &class_name, &class_name_len, &ctor_params) == FAILURE) {
! 2035: return;
! 2036: }
! 2037:
! 2038: if (ZEND_NUM_ARGS() < 2) {
! 2039: ce = zend_standard_class_def;
! 2040: } else {
! 2041: ce = zend_fetch_class(class_name, class_name_len, ZEND_FETCH_CLASS_AUTO TSRMLS_CC);
! 2042: }
! 2043: if (!ce) {
! 2044: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Could not find class '%s'", class_name);
! 2045: return;
! 2046: }
! 2047: result_type = MYSQL_ASSOC;
! 2048: } else
! 2049: #endif
! 2050: {
! 2051: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r|l", &res, &result_type) == FAILURE) {
! 2052: return;
! 2053: }
! 2054: if (!result_type) {
! 2055: /* result_type might have been set outside, so only overwrite when not set */
! 2056: result_type = MYSQL_BOTH;
! 2057: }
! 2058: }
! 2059:
! 2060: if (result_type & ~MYSQL_BOTH) {
! 2061: php_error_docref(NULL TSRMLS_CC, E_WARNING, "The result type should be either MYSQL_NUM, MYSQL_ASSOC or MYSQL_BOTH");
! 2062: result_type = MYSQL_BOTH;
! 2063: }
! 2064:
! 2065: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &res, -1, "MySQL result", le_result);
! 2066:
! 2067: #ifndef MYSQL_USE_MYSQLND
! 2068: if ((mysql_row = mysql_fetch_row(mysql_result)) == NULL ||
! 2069: (mysql_row_lengths = mysql_fetch_lengths(mysql_result)) == NULL) {
! 2070: RETURN_FALSE;
! 2071: }
! 2072:
! 2073: array_init(return_value);
! 2074:
! 2075: mysql_field_seek(mysql_result, 0);
! 2076: for (mysql_field = mysql_fetch_field(mysql_result), i = 0;
! 2077: mysql_field;
! 2078: mysql_field = mysql_fetch_field(mysql_result), i++)
! 2079: {
! 2080: if (mysql_row[i]) {
! 2081: zval *data;
! 2082:
! 2083: MAKE_STD_ZVAL(data);
! 2084:
! 2085: if (PG(magic_quotes_runtime)) {
! 2086: Z_TYPE_P(data) = IS_STRING;
! 2087: Z_STRVAL_P(data) = php_addslashes(mysql_row[i], mysql_row_lengths[i], &Z_STRLEN_P(data), 0 TSRMLS_CC);
! 2088: } else {
! 2089: ZVAL_STRINGL(data, mysql_row[i], mysql_row_lengths[i], 1);
! 2090: }
! 2091:
! 2092: if (result_type & MYSQL_NUM) {
! 2093: add_index_zval(return_value, i, data);
! 2094: }
! 2095: if (result_type & MYSQL_ASSOC) {
! 2096: if (result_type & MYSQL_NUM) {
! 2097: Z_ADDREF_P(data);
! 2098: }
! 2099: add_assoc_zval(return_value, mysql_field->name, data);
! 2100: }
! 2101: } else {
! 2102: /* NULL value. */
! 2103: if (result_type & MYSQL_NUM) {
! 2104: add_index_null(return_value, i);
! 2105: }
! 2106:
! 2107: if (result_type & MYSQL_ASSOC) {
! 2108: add_assoc_null(return_value, mysql_field->name);
! 2109: }
! 2110: }
! 2111: }
! 2112: #else
! 2113: mysqlnd_fetch_into(mysql_result, ((result_type & MYSQL_NUM)? MYSQLND_FETCH_NUM:0) | ((result_type & MYSQL_ASSOC)? MYSQLND_FETCH_ASSOC:0), return_value, MYSQLND_MYSQL);
! 2114: #endif
! 2115:
! 2116: #ifdef ZEND_ENGINE_2
! 2117: /* mysqlnd might return FALSE if no more rows */
! 2118: if (into_object && Z_TYPE_P(return_value) != IS_BOOL) {
! 2119: zval dataset = *return_value;
! 2120: zend_fcall_info fci;
! 2121: zend_fcall_info_cache fcc;
! 2122: zval *retval_ptr;
! 2123:
! 2124: object_and_properties_init(return_value, ce, NULL);
! 2125: zend_merge_properties(return_value, Z_ARRVAL(dataset), 1 TSRMLS_CC);
! 2126:
! 2127: if (ce->constructor) {
! 2128: fci.size = sizeof(fci);
! 2129: fci.function_table = &ce->function_table;
! 2130: fci.function_name = NULL;
! 2131: fci.symbol_table = NULL;
! 2132: fci.object_ptr = return_value;
! 2133: fci.retval_ptr_ptr = &retval_ptr;
! 2134: if (ctor_params && Z_TYPE_P(ctor_params) != IS_NULL) {
! 2135: if (Z_TYPE_P(ctor_params) == IS_ARRAY) {
! 2136: HashTable *htl = Z_ARRVAL_P(ctor_params);
! 2137: Bucket *p;
! 2138:
! 2139: fci.param_count = 0;
! 2140: fci.params = safe_emalloc(sizeof(zval*), htl->nNumOfElements, 0);
! 2141: p = htl->pListHead;
! 2142: while (p != NULL) {
! 2143: fci.params[fci.param_count++] = (zval**)p->pData;
! 2144: p = p->pListNext;
! 2145: }
! 2146: } else {
! 2147: /* Two problems why we throw exceptions here: PHP is typeless
! 2148: * and hence passing one argument that's not an array could be
! 2149: * by mistake and the other way round is possible, too. The
! 2150: * single value is an array. Also we'd have to make that one
! 2151: * argument passed by reference.
! 2152: */
! 2153: zend_throw_exception(zend_exception_get_default(TSRMLS_C), "Parameter ctor_params must be an array", 0 TSRMLS_CC);
! 2154: return;
! 2155: }
! 2156: } else {
! 2157: fci.param_count = 0;
! 2158: fci.params = NULL;
! 2159: }
! 2160: fci.no_separation = 1;
! 2161:
! 2162: fcc.initialized = 1;
! 2163: fcc.function_handler = ce->constructor;
! 2164: fcc.calling_scope = EG(scope);
! 2165: fcc.called_scope = Z_OBJCE_P(return_value);
! 2166: fcc.object_ptr = return_value;
! 2167:
! 2168: if (zend_call_function(&fci, &fcc TSRMLS_CC) == FAILURE) {
! 2169: zend_throw_exception_ex(zend_exception_get_default(TSRMLS_C), 0 TSRMLS_CC, "Could not execute %s::%s()", ce->name, ce->constructor->common.function_name);
! 2170: } else {
! 2171: if (retval_ptr) {
! 2172: zval_ptr_dtor(&retval_ptr);
! 2173: }
! 2174: }
! 2175: if (fci.params) {
! 2176: efree(fci.params);
! 2177: }
! 2178: } else if (ctor_params) {
! 2179: zend_throw_exception_ex(zend_exception_get_default(TSRMLS_C), 0 TSRMLS_CC, "Class %s does not have a constructor hence you cannot use ctor_params", ce->name);
! 2180: }
! 2181: }
! 2182: #endif
! 2183:
! 2184: }
! 2185: /* }}} */
! 2186:
! 2187: /* {{{ proto array mysql_fetch_row(resource result)
! 2188: Gets a result row as an enumerated array */
! 2189: PHP_FUNCTION(mysql_fetch_row)
! 2190: {
! 2191: php_mysql_fetch_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, MYSQL_NUM, 1, 0);
! 2192: }
! 2193: /* }}} */
! 2194:
! 2195:
! 2196: /* {{{ proto object mysql_fetch_object(resource result [, string class_name [, NULL|array ctor_params]])
! 2197: Fetch a result row as an object */
! 2198: PHP_FUNCTION(mysql_fetch_object)
! 2199: {
! 2200: php_mysql_fetch_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, MYSQL_ASSOC, 2, 1);
! 2201:
! 2202: if (Z_TYPE_P(return_value) == IS_ARRAY) {
! 2203: object_and_properties_init(return_value, ZEND_STANDARD_CLASS_DEF_PTR, Z_ARRVAL_P(return_value));
! 2204: }
! 2205: }
! 2206: /* }}} */
! 2207:
! 2208:
! 2209: /* {{{ proto array mysql_fetch_array(resource result [, int result_type])
! 2210: Fetch a result row as an array (associative, numeric or both) */
! 2211: PHP_FUNCTION(mysql_fetch_array)
! 2212: {
! 2213: php_mysql_fetch_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, 0, 2, 0);
! 2214: }
! 2215: /* }}} */
! 2216:
! 2217:
! 2218: /* {{{ proto array mysql_fetch_assoc(resource result)
! 2219: Fetch a result row as an associative array */
! 2220: PHP_FUNCTION(mysql_fetch_assoc)
! 2221: {
! 2222: php_mysql_fetch_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, MYSQL_ASSOC, 1, 0);
! 2223: }
! 2224: /* }}} */
! 2225:
! 2226: /* {{{ proto bool mysql_data_seek(resource result, int row_number)
! 2227: Move internal result pointer */
! 2228: PHP_FUNCTION(mysql_data_seek)
! 2229: {
! 2230: zval *result;
! 2231: long offset;
! 2232: MYSQL_RES *mysql_result;
! 2233:
! 2234: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rl", &result, &offset)) {
! 2235: return;
! 2236: }
! 2237:
! 2238: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
! 2239:
! 2240: if (offset<0 || offset>=(int)mysql_num_rows(mysql_result)) {
! 2241: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Offset %ld is invalid for MySQL result index %ld (or the query data is unbuffered)", offset, Z_LVAL_P(result));
! 2242: RETURN_FALSE;
! 2243: }
! 2244: mysql_data_seek(mysql_result, offset);
! 2245: RETURN_TRUE;
! 2246: }
! 2247: /* }}} */
! 2248:
! 2249:
! 2250: /* {{{ proto array mysql_fetch_lengths(resource result)
! 2251: Gets max data size of each column in a result */
! 2252: PHP_FUNCTION(mysql_fetch_lengths)
! 2253: {
! 2254: zval *result;
! 2255: MYSQL_RES *mysql_result;
! 2256: mysql_row_length_type *lengths;
! 2257: int num_fields;
! 2258: int i;
! 2259:
! 2260: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &result) == FAILURE) {
! 2261: return;
! 2262: }
! 2263:
! 2264: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
! 2265:
! 2266: if ((lengths=mysql_fetch_lengths(mysql_result))==NULL) {
! 2267: RETURN_FALSE;
! 2268: }
! 2269: array_init(return_value);
! 2270: num_fields = mysql_num_fields(mysql_result);
! 2271:
! 2272: for (i=0; i<num_fields; i++) {
! 2273: add_index_long(return_value, i, lengths[i]);
! 2274: }
! 2275: }
! 2276: /* }}} */
! 2277:
! 2278: /* {{{ php_mysql_get_field_name
! 2279: */
! 2280: static char *php_mysql_get_field_name(int field_type)
! 2281: {
! 2282: switch(field_type) {
! 2283: case FIELD_TYPE_STRING:
! 2284: case FIELD_TYPE_VAR_STRING:
! 2285: return "string";
! 2286: break;
! 2287: #if MYSQL_VERSION_ID > 50002 || defined(MYSQL_USE_MYSQLND)
! 2288: case MYSQL_TYPE_BIT:
! 2289: #endif
! 2290: #ifdef MYSQL_HAS_TINY
! 2291: case FIELD_TYPE_TINY:
! 2292: #endif
! 2293: case FIELD_TYPE_SHORT:
! 2294: case FIELD_TYPE_LONG:
! 2295: case FIELD_TYPE_LONGLONG:
! 2296: case FIELD_TYPE_INT24:
! 2297: return "int";
! 2298: break;
! 2299: case FIELD_TYPE_FLOAT:
! 2300: case FIELD_TYPE_DOUBLE:
! 2301: case FIELD_TYPE_DECIMAL:
! 2302: #ifdef FIELD_TYPE_NEWDECIMAL
! 2303: case FIELD_TYPE_NEWDECIMAL:
! 2304: #endif
! 2305: return "real";
! 2306: break;
! 2307: case FIELD_TYPE_TIMESTAMP:
! 2308: return "timestamp";
! 2309: break;
! 2310: #ifdef MYSQL_HAS_YEAR
! 2311: case FIELD_TYPE_YEAR:
! 2312: return "year";
! 2313: break;
! 2314: #endif
! 2315: case FIELD_TYPE_DATE:
! 2316: #ifdef FIELD_TYPE_NEWDATE
! 2317: case FIELD_TYPE_NEWDATE:
! 2318: #endif
! 2319: return "date";
! 2320: break;
! 2321: case FIELD_TYPE_TIME:
! 2322: return "time";
! 2323: break;
! 2324: case FIELD_TYPE_SET:
! 2325: return "set";
! 2326: break;
! 2327: case FIELD_TYPE_ENUM:
! 2328: return "enum";
! 2329: break;
! 2330: #ifdef FIELD_TYPE_GEOMETRY
! 2331: case FIELD_TYPE_GEOMETRY:
! 2332: return "geometry";
! 2333: break;
! 2334: #endif
! 2335: case FIELD_TYPE_DATETIME:
! 2336: return "datetime";
! 2337: break;
! 2338: case FIELD_TYPE_TINY_BLOB:
! 2339: case FIELD_TYPE_MEDIUM_BLOB:
! 2340: case FIELD_TYPE_LONG_BLOB:
! 2341: case FIELD_TYPE_BLOB:
! 2342: return "blob";
! 2343: break;
! 2344: case FIELD_TYPE_NULL:
! 2345: return "null";
! 2346: break;
! 2347: default:
! 2348: return "unknown";
! 2349: break;
! 2350: }
! 2351: }
! 2352: /* }}} */
! 2353:
! 2354: /* {{{ proto object mysql_fetch_field(resource result [, int field_offset])
! 2355: Gets column information from a result and return as an object */
! 2356: PHP_FUNCTION(mysql_fetch_field)
! 2357: {
! 2358: zval *result;
! 2359: long field=0;
! 2360: MYSQL_RES *mysql_result;
! 2361: const MYSQL_FIELD *mysql_field;
! 2362:
! 2363: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r|l", &result, &field) == FAILURE) {
! 2364: return;
! 2365: }
! 2366:
! 2367: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
! 2368:
! 2369: if (ZEND_NUM_ARGS() > 1) {
! 2370: if (field<0 || field>=(int)mysql_num_fields(mysql_result)) {
! 2371: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Bad field offset");
! 2372: RETURN_FALSE;
! 2373: }
! 2374: mysql_field_seek(mysql_result, field);
! 2375: }
! 2376: if ((mysql_field=mysql_fetch_field(mysql_result))==NULL) {
! 2377: RETURN_FALSE;
! 2378: }
! 2379: object_init(return_value);
! 2380:
! 2381: add_property_string(return_value, "name", (char *) (mysql_field->name?mysql_field->name:""), 1);
! 2382: add_property_string(return_value, "table",(char *) (mysql_field->table?mysql_field->table:""), 1);
! 2383: add_property_string(return_value, "def",(mysql_field->def?mysql_field->def:""), 1);
! 2384: add_property_long(return_value, "max_length", mysql_field->max_length);
! 2385: add_property_long(return_value, "not_null", IS_NOT_NULL(mysql_field->flags)?1:0);
! 2386: add_property_long(return_value, "primary_key", IS_PRI_KEY(mysql_field->flags)?1:0);
! 2387: add_property_long(return_value, "multiple_key",(mysql_field->flags&MULTIPLE_KEY_FLAG?1:0));
! 2388: add_property_long(return_value, "unique_key",(mysql_field->flags&UNIQUE_KEY_FLAG?1:0));
! 2389: add_property_long(return_value, "numeric", IS_NUM(Z_TYPE_P(mysql_field))?1:0);
! 2390: add_property_long(return_value, "blob", IS_BLOB(mysql_field->flags)?1:0);
! 2391: add_property_string(return_value, "type", php_mysql_get_field_name(Z_TYPE_P(mysql_field)), 1);
! 2392: add_property_long(return_value, "unsigned",(mysql_field->flags&UNSIGNED_FLAG?1:0));
! 2393: add_property_long(return_value, "zerofill",(mysql_field->flags&ZEROFILL_FLAG?1:0));
! 2394: }
! 2395: /* }}} */
! 2396:
! 2397:
! 2398: /* {{{ proto bool mysql_field_seek(resource result, int field_offset)
! 2399: Sets result pointer to a specific field offset */
! 2400: PHP_FUNCTION(mysql_field_seek)
! 2401: {
! 2402: zval *result;
! 2403: long offset;
! 2404: MYSQL_RES *mysql_result;
! 2405:
! 2406: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rl", &result, &offset) == FAILURE) {
! 2407: return;
! 2408: }
! 2409: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
! 2410:
! 2411: if (offset<0 || offset>=(int)mysql_num_fields(mysql_result)) {
! 2412: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Field %ld is invalid for MySQL result index %ld", offset, Z_LVAL_P(result));
! 2413: RETURN_FALSE;
! 2414: }
! 2415: mysql_field_seek(mysql_result, offset);
! 2416: RETURN_TRUE;
! 2417: }
! 2418: /* }}} */
! 2419:
! 2420:
! 2421: #define PHP_MYSQL_FIELD_NAME 1
! 2422: #define PHP_MYSQL_FIELD_TABLE 2
! 2423: #define PHP_MYSQL_FIELD_LEN 3
! 2424: #define PHP_MYSQL_FIELD_TYPE 4
! 2425: #define PHP_MYSQL_FIELD_FLAGS 5
! 2426:
! 2427: /* {{{ php_mysql_field_info
! 2428: */
! 2429: static void php_mysql_field_info(INTERNAL_FUNCTION_PARAMETERS, int entry_type)
! 2430: {
! 2431: zval *result;
! 2432: long field;
! 2433: MYSQL_RES *mysql_result;
! 2434: const MYSQL_FIELD *mysql_field = {0};
! 2435: char buf[512];
! 2436: int len;
! 2437:
! 2438: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rl", &result, &field) == FAILURE) {
! 2439: return;
! 2440: }
! 2441:
! 2442: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
! 2443:
! 2444: if (field<0 || field>=(int)mysql_num_fields(mysql_result)) {
! 2445: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Field %ld is invalid for MySQL result index %ld", field, Z_LVAL_P(result));
! 2446: RETURN_FALSE;
! 2447: }
! 2448: mysql_field_seek(mysql_result, field);
! 2449: if ((mysql_field=mysql_fetch_field(mysql_result))==NULL) {
! 2450: RETURN_FALSE;
! 2451: }
! 2452:
! 2453: switch (entry_type) {
! 2454: case PHP_MYSQL_FIELD_NAME:
! 2455: Z_STRLEN_P(return_value) = strlen(mysql_field->name);
! 2456: Z_STRVAL_P(return_value) = estrndup(mysql_field->name, Z_STRLEN_P(return_value));
! 2457: Z_TYPE_P(return_value) = IS_STRING;
! 2458: break;
! 2459: case PHP_MYSQL_FIELD_TABLE:
! 2460: Z_STRLEN_P(return_value) = strlen(mysql_field->table);
! 2461: Z_STRVAL_P(return_value) = estrndup(mysql_field->table, Z_STRLEN_P(return_value));
! 2462: Z_TYPE_P(return_value) = IS_STRING;
! 2463: break;
! 2464: case PHP_MYSQL_FIELD_LEN:
! 2465: Z_LVAL_P(return_value) = mysql_field->length;
! 2466: Z_TYPE_P(return_value) = IS_LONG;
! 2467: break;
! 2468: case PHP_MYSQL_FIELD_TYPE:
! 2469: Z_STRVAL_P(return_value) = php_mysql_get_field_name(Z_TYPE_P(mysql_field));
! 2470: Z_STRLEN_P(return_value) = strlen(Z_STRVAL_P(return_value));
! 2471: Z_STRVAL_P(return_value) = estrndup(Z_STRVAL_P(return_value), Z_STRLEN_P(return_value));
! 2472: Z_TYPE_P(return_value) = IS_STRING;
! 2473: break;
! 2474: case PHP_MYSQL_FIELD_FLAGS:
! 2475: memcpy(buf, "", sizeof(""));
! 2476: #ifdef IS_NOT_NULL
! 2477: if (IS_NOT_NULL(mysql_field->flags)) {
! 2478: strcat(buf, "not_null ");
! 2479: }
! 2480: #endif
! 2481: #ifdef IS_PRI_KEY
! 2482: if (IS_PRI_KEY(mysql_field->flags)) {
! 2483: strcat(buf, "primary_key ");
! 2484: }
! 2485: #endif
! 2486: #ifdef UNIQUE_KEY_FLAG
! 2487: if (mysql_field->flags&UNIQUE_KEY_FLAG) {
! 2488: strcat(buf, "unique_key ");
! 2489: }
! 2490: #endif
! 2491: #ifdef MULTIPLE_KEY_FLAG
! 2492: if (mysql_field->flags&MULTIPLE_KEY_FLAG) {
! 2493: strcat(buf, "multiple_key ");
! 2494: }
! 2495: #endif
! 2496: #ifdef IS_BLOB
! 2497: if (IS_BLOB(mysql_field->flags)) {
! 2498: strcat(buf, "blob ");
! 2499: }
! 2500: #endif
! 2501: #ifdef UNSIGNED_FLAG
! 2502: if (mysql_field->flags&UNSIGNED_FLAG) {
! 2503: strcat(buf, "unsigned ");
! 2504: }
! 2505: #endif
! 2506: #ifdef ZEROFILL_FLAG
! 2507: if (mysql_field->flags&ZEROFILL_FLAG) {
! 2508: strcat(buf, "zerofill ");
! 2509: }
! 2510: #endif
! 2511: #ifdef BINARY_FLAG
! 2512: if (mysql_field->flags&BINARY_FLAG) {
! 2513: strcat(buf, "binary ");
! 2514: }
! 2515: #endif
! 2516: #ifdef ENUM_FLAG
! 2517: if (mysql_field->flags&ENUM_FLAG) {
! 2518: strcat(buf, "enum ");
! 2519: }
! 2520: #endif
! 2521: #ifdef SET_FLAG
! 2522: if (mysql_field->flags&SET_FLAG) {
! 2523: strcat(buf, "set ");
! 2524: }
! 2525: #endif
! 2526: #ifdef AUTO_INCREMENT_FLAG
! 2527: if (mysql_field->flags&AUTO_INCREMENT_FLAG) {
! 2528: strcat(buf, "auto_increment ");
! 2529: }
! 2530: #endif
! 2531: #ifdef TIMESTAMP_FLAG
! 2532: if (mysql_field->flags&TIMESTAMP_FLAG) {
! 2533: strcat(buf, "timestamp ");
! 2534: }
! 2535: #endif
! 2536: len = strlen(buf);
! 2537: /* remove trailing space, if present */
! 2538: if (len && buf[len-1] == ' ') {
! 2539: buf[len-1] = 0;
! 2540: len--;
! 2541: }
! 2542:
! 2543: Z_STRLEN_P(return_value) = len;
! 2544: Z_STRVAL_P(return_value) = estrndup(buf, len);
! 2545: Z_TYPE_P(return_value) = IS_STRING;
! 2546: break;
! 2547:
! 2548: default:
! 2549: RETURN_FALSE;
! 2550: }
! 2551: }
! 2552: /* }}} */
! 2553:
! 2554: /* {{{ proto string mysql_field_name(resource result, int field_index)
! 2555: Gets the name of the specified field in a result */
! 2556: PHP_FUNCTION(mysql_field_name)
! 2557: {
! 2558: php_mysql_field_info(INTERNAL_FUNCTION_PARAM_PASSTHRU, PHP_MYSQL_FIELD_NAME);
! 2559: }
! 2560: /* }}} */
! 2561:
! 2562:
! 2563: /* {{{ proto string mysql_field_table(resource result, int field_offset)
! 2564: Gets name of the table the specified field is in */
! 2565: PHP_FUNCTION(mysql_field_table)
! 2566: {
! 2567: php_mysql_field_info(INTERNAL_FUNCTION_PARAM_PASSTHRU, PHP_MYSQL_FIELD_TABLE);
! 2568: }
! 2569: /* }}} */
! 2570:
! 2571:
! 2572: /* {{{ proto int mysql_field_len(resource result, int field_offset)
! 2573: Returns the length of the specified field */
! 2574: PHP_FUNCTION(mysql_field_len)
! 2575: {
! 2576: php_mysql_field_info(INTERNAL_FUNCTION_PARAM_PASSTHRU, PHP_MYSQL_FIELD_LEN);
! 2577: }
! 2578: /* }}} */
! 2579:
! 2580:
! 2581: /* {{{ proto string mysql_field_type(resource result, int field_offset)
! 2582: Gets the type of the specified field in a result */
! 2583: PHP_FUNCTION(mysql_field_type)
! 2584: {
! 2585: php_mysql_field_info(INTERNAL_FUNCTION_PARAM_PASSTHRU, PHP_MYSQL_FIELD_TYPE);
! 2586: }
! 2587: /* }}} */
! 2588:
! 2589:
! 2590: /* {{{ proto string mysql_field_flags(resource result, int field_offset)
! 2591: Gets the flags associated with the specified field in a result */
! 2592: PHP_FUNCTION(mysql_field_flags)
! 2593: {
! 2594: php_mysql_field_info(INTERNAL_FUNCTION_PARAM_PASSTHRU, PHP_MYSQL_FIELD_FLAGS);
! 2595: }
! 2596: /* }}} */
! 2597:
! 2598:
! 2599: /* {{{ proto bool mysql_free_result(resource result)
! 2600: Free result memory */
! 2601: PHP_FUNCTION(mysql_free_result)
! 2602: {
! 2603: zval *result;
! 2604: MYSQL_RES *mysql_result;
! 2605:
! 2606: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &result) == FAILURE) {
! 2607: return;
! 2608: }
! 2609:
! 2610: if (Z_LVAL_P(result)==0) {
! 2611: RETURN_FALSE;
! 2612: }
! 2613:
! 2614: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
! 2615:
! 2616: zend_list_delete(Z_LVAL_P(result));
! 2617: RETURN_TRUE;
! 2618: }
! 2619: /* }}} */
! 2620:
! 2621: /* {{{ proto bool mysql_ping([int link_identifier])
! 2622: Ping a server connection. If no connection then reconnect. */
! 2623: PHP_FUNCTION(mysql_ping)
! 2624: {
! 2625: zval *mysql_link = NULL;
! 2626: int id = -1;
! 2627: php_mysql_conn *mysql;
! 2628:
! 2629: if (0 == ZEND_NUM_ARGS()) {
! 2630: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
! 2631: CHECK_LINK(id);
! 2632: } else if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &mysql_link)==FAILURE) {
! 2633: return;
! 2634: }
! 2635:
! 2636: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
! 2637:
! 2638: PHPMY_UNBUFFERED_QUERY_CHECK();
! 2639:
! 2640: RETURN_BOOL(! mysql_ping(mysql->conn));
! 2641: }
! 2642: /* }}} */
! 2643:
! 2644: #endif
! 2645:
! 2646: /*
! 2647: * Local variables:
! 2648: * tab-width: 4
! 2649: * c-basic-offset: 4
! 2650: * End:
! 2651: * vim600: sw=4 ts=4 fdm=marker
! 2652: * vim<600: sw=4 ts=4
! 2653: */
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to php_mysql.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 / mysql