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,v 1.1.1.2 2012/05/29 12:34:41 misho Exp $ */
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_DEP_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: #ifdef MYSQL_USE_MYSQLND
533: #include "ext/mysqlnd/mysqlnd_reverse_api.h"
534: static MYSQLND * mysql_convert_zv_to_mysqlnd(zval * zv TSRMLS_DC)
535: {
536: php_mysql_conn *mysql;
537:
538: if (Z_TYPE_P(zv) != IS_RESOURCE) {
539: /* Might be nicer to check resource type, too, but ext/mysql is the only one using resources so emitting an error is not to bad, while usually this hook should be silent */
540: return NULL;
541: }
542:
543: mysql = (php_mysql_conn *)zend_fetch_resource(&zv TSRMLS_CC, -1, "MySQL-Link", NULL, 2, le_link, le_plink);
544:
545: if (!mysql) {
546: return NULL;
547: }
548:
549: return mysql->conn;
550: }
551:
552: static MYSQLND_REVERSE_API mysql_reverse_api = {
553: &mysql_module_entry,
554: mysql_convert_zv_to_mysqlnd
555: };
556: #endif
557:
558: /* {{{ PHP_MINIT_FUNCTION
559: */
560: ZEND_MODULE_STARTUP_D(mysql)
561: {
562: REGISTER_INI_ENTRIES();
563: le_result = zend_register_list_destructors_ex(_free_mysql_result, NULL, "mysql result", module_number);
564: le_link = zend_register_list_destructors_ex(_close_mysql_link, NULL, "mysql link", module_number);
565: le_plink = zend_register_list_destructors_ex(NULL, _close_mysql_plink, "mysql link persistent", module_number);
566: Z_TYPE(mysql_module_entry) = type;
567:
568: REGISTER_LONG_CONSTANT("MYSQL_ASSOC", MYSQL_ASSOC, CONST_CS | CONST_PERSISTENT);
569: REGISTER_LONG_CONSTANT("MYSQL_NUM", MYSQL_NUM, CONST_CS | CONST_PERSISTENT);
570: REGISTER_LONG_CONSTANT("MYSQL_BOTH", MYSQL_BOTH, CONST_CS | CONST_PERSISTENT);
571: REGISTER_LONG_CONSTANT("MYSQL_CLIENT_COMPRESS", CLIENT_COMPRESS, CONST_CS | CONST_PERSISTENT);
572: #if MYSQL_VERSION_ID >= 40000
573: REGISTER_LONG_CONSTANT("MYSQL_CLIENT_SSL", CLIENT_SSL, CONST_CS | CONST_PERSISTENT);
574: #endif
575: REGISTER_LONG_CONSTANT("MYSQL_CLIENT_INTERACTIVE", CLIENT_INTERACTIVE, CONST_CS | CONST_PERSISTENT);
576: REGISTER_LONG_CONSTANT("MYSQL_CLIENT_IGNORE_SPACE", CLIENT_IGNORE_SPACE, CONST_CS | CONST_PERSISTENT);
577:
578: #ifndef MYSQL_USE_MYSQLND
579: #if MYSQL_VERSION_ID >= 40000
580: if (mysql_server_init(0, NULL, NULL)) {
581: return FAILURE;
582: }
583: #endif
584: #endif
585:
586: #ifdef MYSQL_USE_MYSQLND
587: mysqlnd_reverse_api_register_api(&mysql_reverse_api TSRMLS_CC);
588: #endif
589:
590: return SUCCESS;
591: }
592: /* }}} */
593:
594: /* {{{ PHP_MSHUTDOWN_FUNCTION
595: */
596: PHP_MSHUTDOWN_FUNCTION(mysql)
597: {
598: #ifndef MYSQL_USE_MYSQLND
599: #if MYSQL_VERSION_ID >= 40000
600: #ifdef PHP_WIN32
601: unsigned long client_ver = mysql_get_client_version();
602: /*
603: Can't call mysql_server_end() multiple times prior to 5.0.46 on Windows.
604: PHP bug#41350 MySQL bug#25621
605: */
606: if ((client_ver >= 50046 && client_ver < 50100) || client_ver > 50122) {
607: mysql_server_end();
608: }
609: #else
610: mysql_server_end();
611: #endif
612: #endif
613: #endif
614:
615: UNREGISTER_INI_ENTRIES();
616: return SUCCESS;
617: }
618: /* }}} */
619:
620: /* {{{ PHP_RINIT_FUNCTION
621: */
622: PHP_RINIT_FUNCTION(mysql)
623: {
624: #if !defined(MYSQL_USE_MYSQLND) && defined(ZTS) && MYSQL_VERSION_ID >= 40000
625: if (mysql_thread_init()) {
626: return FAILURE;
627: }
628: #endif
629: MySG(default_link)=-1;
630: MySG(num_links) = MySG(num_persistent);
631: /* Reset connect error/errno on every request */
632: MySG(connect_error) = NULL;
633: MySG(connect_errno) =0;
634: MySG(result_allocated) = 0;
635:
636: return SUCCESS;
637: }
638: /* }}} */
639:
640:
641: #if defined(A0) && defined(MYSQL_USE_MYSQLND)
642: static int php_mysql_persistent_helper(zend_rsrc_list_entry *le TSRMLS_DC)
643: {
644: if (le->type == le_plink) {
645: mysqlnd_end_psession(((php_mysql_conn *) le->ptr)->conn);
646: }
647: return ZEND_HASH_APPLY_KEEP;
648: } /* }}} */
649: #endif
650:
651:
652: /* {{{ PHP_RSHUTDOWN_FUNCTION
653: */
654: PHP_RSHUTDOWN_FUNCTION(mysql)
655: {
656: #if !defined(MYSQL_USE_MYSQLND) && defined(ZTS) && MYSQL_VERSION_ID >= 40000
657: mysql_thread_end();
658: #endif
659:
660: if (MySG(trace_mode)) {
661: if (MySG(result_allocated)){
662: 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));
663: }
664: }
665:
666: if (MySG(connect_error)!=NULL) {
667: efree(MySG(connect_error));
668: }
669:
670: #if defined(A0) && defined(MYSQL_USE_MYSQLND)
671: zend_hash_apply(&EG(persistent_list), (apply_func_t) php_mysql_persistent_helper TSRMLS_CC);
672: #endif
673:
674: return SUCCESS;
675: }
676: /* }}} */
677:
678: /* {{{ PHP_MINFO_FUNCTION
679: */
680: PHP_MINFO_FUNCTION(mysql)
681: {
682: char buf[32];
683:
684: php_info_print_table_start();
685: php_info_print_table_header(2, "MySQL Support", "enabled");
686: snprintf(buf, sizeof(buf), "%ld", MySG(num_persistent));
687: php_info_print_table_row(2, "Active Persistent Links", buf);
688: snprintf(buf, sizeof(buf), "%ld", MySG(num_links));
689: php_info_print_table_row(2, "Active Links", buf);
690: php_info_print_table_row(2, "Client API version", mysql_get_client_info());
691: #if !defined (PHP_WIN32) && !defined (NETWARE) && !defined(MYSQL_USE_MYSQLND)
692: php_info_print_table_row(2, "MYSQL_MODULE_TYPE", PHP_MYSQL_TYPE);
693: php_info_print_table_row(2, "MYSQL_SOCKET", MYSQL_UNIX_ADDR);
694: php_info_print_table_row(2, "MYSQL_INCLUDE", PHP_MYSQL_INCLUDE);
695: php_info_print_table_row(2, "MYSQL_LIBS", PHP_MYSQL_LIBS);
696: #endif
697:
698: php_info_print_table_end();
699:
700: DISPLAY_INI_ENTRIES();
701:
702: }
703: /* }}} */
704:
705: /* {{{ php_mysql_do_connect
706: */
707: #define MYSQL_DO_CONNECT_CLEANUP() \
708: if (free_host) { \
709: efree(host); \
710: }
711:
712: #define MYSQL_DO_CONNECT_RETURN_FALSE() \
713: MYSQL_DO_CONNECT_CLEANUP(); \
714: RETURN_FALSE;
715:
716: #ifdef MYSQL_USE_MYSQLND
717: #define MYSQL_PORT 0
718: #endif
719:
720: static void php_mysql_do_connect(INTERNAL_FUNCTION_PARAMETERS, int persistent)
721: {
722: char *user=NULL, *passwd=NULL, *host_and_port=NULL, *socket=NULL, *tmp=NULL, *host=NULL;
723: int user_len, passwd_len, host_len;
724: char *hashed_details=NULL;
725: int hashed_details_length, port = MYSQL_PORT;
726: long client_flags = 0;
727: php_mysql_conn *mysql=NULL;
728: #if MYSQL_VERSION_ID <= 32230
729: void (*handler) (int);
730: #endif
731: zend_bool free_host=0, new_link=0;
732: long connect_timeout;
733:
734: #if !defined(MYSQL_USE_MYSQLND)
735: if ((MYSQL_VERSION_ID / 100) != (mysql_get_client_version() / 100)) {
736: php_error_docref(NULL TSRMLS_CC, E_WARNING,
737: "Headers and client library minor version mismatch. Headers:%d Library:%ld",
738: MYSQL_VERSION_ID, mysql_get_client_version());
739: }
740: #endif
741:
742: connect_timeout = MySG(connect_timeout);
743:
744: socket = MySG(default_socket);
745:
746: if (MySG(default_port) < 0) {
747: #if !defined(PHP_WIN32) && !defined(NETWARE)
748: struct servent *serv_ptr;
749: char *env;
750:
751: MySG(default_port) = MYSQL_PORT;
752: if ((serv_ptr = getservbyname("mysql", "tcp"))) {
753: MySG(default_port) = (uint) ntohs((ushort) serv_ptr->s_port);
754: }
755: if ((env = getenv("MYSQL_TCP_PORT"))) {
756: MySG(default_port) = (uint) atoi(env);
757: }
758: #else
759: MySG(default_port) = MYSQL_PORT;
760: #endif
761: }
762:
763: if (PG(sql_safe_mode)) {
764: if (ZEND_NUM_ARGS()>0) {
765: php_error_docref(NULL TSRMLS_CC, E_NOTICE, "SQL safe mode in effect - ignoring host/user/password information");
766: }
767: host_and_port=passwd=NULL;
768: user=php_get_current_user(TSRMLS_C);
769: hashed_details_length = spprintf(&hashed_details, 0, "mysql__%s_", user);
770: client_flags = CLIENT_INTERACTIVE;
771: } else {
772: /* mysql_pconnect does not support new_link parameter */
773: if (persistent) {
774: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|s!s!s!l", &host_and_port, &host_len,
775: &user, &user_len, &passwd, &passwd_len,
776: &client_flags)==FAILURE) {
777: return;
778: }
779: } else {
780: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|s!s!s!bl", &host_and_port, &host_len,
781: &user, &user_len, &passwd, &passwd_len,
782: &new_link, &client_flags)==FAILURE) {
783: return;
784: }
785: }
786:
787: if (!host_and_port) {
788: host_and_port = MySG(default_host);
789: }
790: if (!user) {
791: user = MySG(default_user);
792: }
793: if (!passwd) {
794: passwd = MySG(default_password);
795: passwd_len = passwd? strlen(passwd):0;
796: }
797:
798: /* disable local infile option for open_basedir */
799: #if PHP_API_VERSION < 20100412
800: if (((PG(open_basedir) && PG(open_basedir)[0] != '\0') || PG(safe_mode)) && (client_flags & CLIENT_LOCAL_FILES)) {
801: #else
802: if ((PG(open_basedir) && PG(open_basedir)[0] != '\0') && (client_flags & CLIENT_LOCAL_FILES)) {
803: #endif
804: client_flags ^= CLIENT_LOCAL_FILES;
805: }
806:
807: #ifdef CLIENT_MULTI_RESULTS
808: client_flags |= CLIENT_MULTI_RESULTS; /* compatibility with 5.2, see bug#50416 */
809: #endif
810: #ifdef CLIENT_MULTI_STATEMENTS
811: client_flags &= ~CLIENT_MULTI_STATEMENTS; /* don't allow multi_queries via connect parameter */
812: #endif
813: 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);
814: }
815:
816: /* We cannot use mysql_port anymore in windows, need to use
817: * mysql_real_connect() to set the port.
818: */
819: if (host_and_port && (tmp=strchr(host_and_port, ':'))) {
820: host = estrndup(host_and_port, tmp-host_and_port);
821: free_host = 1;
822: tmp++;
823: if (tmp[0] != '/') {
824: port = atoi(tmp);
825: if ((tmp=strchr(tmp, ':'))) {
826: tmp++;
827: socket=tmp;
828: }
829: } else {
830: socket = tmp;
831: }
832: } else {
833: host = host_and_port;
834: port = MySG(default_port);
835: }
836:
837: #if MYSQL_VERSION_ID < 32200
838: mysql_port = port;
839: #endif
840:
841: if (!MySG(allow_persistent)) {
842: persistent=0;
843: }
844: if (persistent) {
845: zend_rsrc_list_entry *le;
846:
847: /* try to find if we already have this link in our persistent list */
848: if (zend_hash_find(&EG(persistent_list), hashed_details, hashed_details_length+1, (void **) &le)==FAILURE) { /* we don't */
849: zend_rsrc_list_entry new_le;
850:
851: if (MySG(max_links) != -1 && MySG(num_links) >= MySG(max_links)) {
852: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Too many open links (%ld)", MySG(num_links));
853: efree(hashed_details);
854: MYSQL_DO_CONNECT_RETURN_FALSE();
855: }
856: if (MySG(max_persistent) != -1 && MySG(num_persistent) >= MySG(max_persistent)) {
857: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Too many open persistent links (%ld)", MySG(num_persistent));
858: efree(hashed_details);
859: MYSQL_DO_CONNECT_RETURN_FALSE();
860: }
861: /* create the link */
862: mysql = (php_mysql_conn *) malloc(sizeof(php_mysql_conn));
863: if (!mysql) {
864: php_error_docref(NULL TSRMLS_CC, E_ERROR, "Out of memory while allocating memory for a persistent link");
865: }
866: mysql->active_result_id = 0;
867: #ifdef CLIENT_MULTI_STATEMENTS
868: mysql->multi_query = client_flags & CLIENT_MULTI_STATEMENTS? 1:0;
869: #else
870: mysql->multi_query = 0;
871: #endif
872:
873: #ifndef MYSQL_USE_MYSQLND
874: mysql->conn = mysql_init(NULL);
875: #else
876: mysql->conn = mysql_init(persistent);
877: #endif
878:
879: if (connect_timeout != -1) {
880: mysql_options(mysql->conn, MYSQL_OPT_CONNECT_TIMEOUT, (const char *)&connect_timeout);
881: }
882: #ifndef MYSQL_USE_MYSQLND
883: if (mysql_real_connect(mysql->conn, host, user, passwd, NULL, port, socket, client_flags)==NULL)
884: #else
885: if (mysqlnd_connect(mysql->conn, host, user, passwd, passwd_len, NULL, 0, port, socket, client_flags TSRMLS_CC) == NULL)
886: #endif
887: {
888: /* Populate connect error globals so that the error functions can read them */
889: if (MySG(connect_error) != NULL) {
890: efree(MySG(connect_error));
891: }
892: MySG(connect_error) = estrdup(mysql_error(mysql->conn));
893: php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s", MySG(connect_error));
894: #if defined(HAVE_MYSQL_ERRNO)
895: MySG(connect_errno) = mysql_errno(mysql->conn);
896: #endif
897: free(mysql);
898: efree(hashed_details);
899: MYSQL_DO_CONNECT_RETURN_FALSE();
900: }
901: mysql_options(mysql->conn, MYSQL_OPT_LOCAL_INFILE, (char *)&MySG(allow_local_infile));
902:
903: /* hash it up */
904: Z_TYPE(new_le) = le_plink;
905: new_le.ptr = mysql;
906: if (zend_hash_update(&EG(persistent_list), hashed_details, hashed_details_length+1, (void *) &new_le, sizeof(zend_rsrc_list_entry), NULL)==FAILURE) {
907: free(mysql);
908: efree(hashed_details);
909: MYSQL_DO_CONNECT_RETURN_FALSE();
910: }
911: MySG(num_persistent)++;
912: MySG(num_links)++;
913: } else { /* The link is in our list of persistent connections */
914: if (Z_TYPE_P(le) != le_plink) {
915: MYSQL_DO_CONNECT_RETURN_FALSE();
916: }
917: mysql = (php_mysql_conn *) le->ptr;
918: mysql->active_result_id = 0;
919: #ifdef CLIENT_MULTI_STATEMENTS
920: mysql->multi_query = client_flags & CLIENT_MULTI_STATEMENTS? 1:0;
921: #else
922: mysql->multi_query = 0;
923: #endif
924: /* ensure that the link did not die */
925: #if defined(A0) && MYSQL_USE_MYSQLND
926: mysqlnd_end_psession(mysql->conn);
927: #endif
928: if (mysql_ping(mysql->conn)) {
929: if (mysql_errno(mysql->conn) == 2006) {
930: #ifndef MYSQL_USE_MYSQLND
931: if (mysql_real_connect(mysql->conn, host, user, passwd, NULL, port, socket, client_flags)==NULL)
932: #else
933: if (mysqlnd_connect(mysql->conn, host, user, passwd, passwd_len, NULL, 0, port, socket, client_flags TSRMLS_CC) == NULL)
934: #endif
935: {
936: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Link to server lost, unable to reconnect");
937: zend_hash_del(&EG(persistent_list), hashed_details, hashed_details_length+1);
938: efree(hashed_details);
939: MYSQL_DO_CONNECT_RETURN_FALSE();
940: }
941: mysql_options(mysql->conn, MYSQL_OPT_LOCAL_INFILE, (char *)&MySG(allow_local_infile));
942: }
943: } else {
944: #ifdef MYSQL_USE_MYSQLND
945: mysqlnd_restart_psession(mysql->conn);
946: #endif
947: }
948: }
949: ZEND_REGISTER_RESOURCE(return_value, mysql, le_plink);
950: } else { /* non persistent */
951: zend_rsrc_list_entry *index_ptr, new_index_ptr;
952:
953: /* first we check the hash for the hashed_details key. if it exists,
954: * it should point us to the right offset where the actual mysql link sits.
955: * if it doesn't, open a new mysql link, add it to the resource list,
956: * and add a pointer to it with hashed_details as the key.
957: */
958: if (!new_link && zend_hash_find(&EG(regular_list), hashed_details, hashed_details_length+1,(void **) &index_ptr)==SUCCESS) {
959: int type;
960: long link;
961: void *ptr;
962:
963: if (Z_TYPE_P(index_ptr) != le_index_ptr) {
964: MYSQL_DO_CONNECT_RETURN_FALSE();
965: }
966: link = (long) index_ptr->ptr;
967: ptr = zend_list_find(link,&type); /* check if the link is still there */
968: if (ptr && (type==le_link || type==le_plink)) {
969: zend_list_addref(link);
970: Z_LVAL_P(return_value) = link;
971: php_mysql_set_default_link(link TSRMLS_CC);
972: Z_TYPE_P(return_value) = IS_RESOURCE;
973: efree(hashed_details);
974: MYSQL_DO_CONNECT_CLEANUP();
975: return;
976: } else {
977: zend_hash_del(&EG(regular_list), hashed_details, hashed_details_length+1);
978: }
979: }
980: if (MySG(max_links) != -1 && MySG(num_links) >= MySG(max_links)) {
981: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Too many open links (%ld)", MySG(num_links));
982: efree(hashed_details);
983: MYSQL_DO_CONNECT_RETURN_FALSE();
984: }
985:
986: mysql = (php_mysql_conn *) emalloc(sizeof(php_mysql_conn));
987: mysql->active_result_id = 0;
988: #ifdef CLIENT_MULTI_STATEMENTS
989: mysql->multi_query = 1;
990: #endif
991:
992: #ifndef MYSQL_USE_MYSQLND
993: mysql->conn = mysql_init(NULL);
994: #else
995: mysql->conn = mysql_init(persistent);
996: #endif
997: if (!mysql->conn) {
998: MySG(connect_error) = estrdup("OOM");
999: php_error_docref(NULL TSRMLS_CC, E_WARNING, "OOM");
1000: efree(hashed_details);
1001: efree(mysql);
1002: MYSQL_DO_CONNECT_RETURN_FALSE();
1003: }
1004:
1005: if (connect_timeout != -1) {
1006: mysql_options(mysql->conn, MYSQL_OPT_CONNECT_TIMEOUT, (const char *)&connect_timeout);
1007: }
1008:
1009: #ifndef MYSQL_USE_MYSQLND
1010: if (mysql_real_connect(mysql->conn, host, user, passwd, NULL, port, socket, client_flags)==NULL)
1011: #else
1012: if (mysqlnd_connect(mysql->conn, host, user, passwd, passwd_len, NULL, 0, port, socket, client_flags TSRMLS_CC) == NULL)
1013: #endif
1014: {
1015: /* Populate connect error globals so that the error functions can read them */
1016: if (MySG(connect_error) != NULL) {
1017: efree(MySG(connect_error));
1018: }
1019: MySG(connect_error) = estrdup(mysql_error(mysql->conn));
1020: php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s", MySG(connect_error));
1021: #if defined(HAVE_MYSQL_ERRNO)
1022: MySG(connect_errno) = mysql_errno(mysql->conn);
1023: #endif
1024: /* free mysql structure */
1025: #ifdef MYSQL_USE_MYSQLND
1026: mysqlnd_close(mysql->conn, MYSQLND_CLOSE_DISCONNECTED);
1027: #endif
1028: efree(hashed_details);
1029: efree(mysql);
1030: MYSQL_DO_CONNECT_RETURN_FALSE();
1031: }
1032: mysql_options(mysql->conn, MYSQL_OPT_LOCAL_INFILE, (char *)&MySG(allow_local_infile));
1033:
1034: /* add it to the list */
1035: ZEND_REGISTER_RESOURCE(return_value, mysql, le_link);
1036:
1037: /* add it to the hash */
1038: new_index_ptr.ptr = (void *) Z_LVAL_P(return_value);
1039: Z_TYPE(new_index_ptr) = le_index_ptr;
1040: if (zend_hash_update(&EG(regular_list), hashed_details, hashed_details_length+1,(void *) &new_index_ptr, sizeof(zend_rsrc_list_entry), NULL)==FAILURE) {
1041: efree(hashed_details);
1042: MYSQL_DO_CONNECT_RETURN_FALSE();
1043: }
1044: MySG(num_links)++;
1045: }
1046:
1047: efree(hashed_details);
1048: php_mysql_set_default_link(Z_LVAL_P(return_value) TSRMLS_CC);
1049: MYSQL_DO_CONNECT_CLEANUP();
1050: }
1051: /* }}} */
1052:
1053: /* {{{ php_mysql_get_default_link
1054: */
1055: static int php_mysql_get_default_link(INTERNAL_FUNCTION_PARAMETERS)
1056: {
1057: if (MySG(default_link)==-1) { /* no link opened yet, implicitly open one */
1058: ht = 0;
1059: php_mysql_do_connect(INTERNAL_FUNCTION_PARAM_PASSTHRU, 0);
1060: }
1061: return MySG(default_link);
1062: }
1063: /* }}} */
1064:
1065: /* {{{ proto resource mysql_connect([string hostname[:port][:/path/to/socket] [, string username [, string password [, bool new [, int flags]]]]])
1066: Opens a connection to a MySQL Server */
1067: PHP_FUNCTION(mysql_connect)
1068: {
1069: php_mysql_do_connect(INTERNAL_FUNCTION_PARAM_PASSTHRU, 0);
1070: }
1071: /* }}} */
1072:
1073: /* {{{ proto resource mysql_pconnect([string hostname[:port][:/path/to/socket] [, string username [, string password [, int flags]]]])
1074: Opens a persistent connection to a MySQL Server */
1075: PHP_FUNCTION(mysql_pconnect)
1076: {
1077: php_mysql_do_connect(INTERNAL_FUNCTION_PARAM_PASSTHRU, 1);
1078: }
1079: /* }}} */
1080:
1081: /* {{{ proto bool mysql_close([int link_identifier])
1082: Close a MySQL connection */
1083: PHP_FUNCTION(mysql_close)
1084: {
1085: int resource_id;
1086: zval *mysql_link=NULL;
1087: php_mysql_conn *mysql;
1088:
1089: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
1090: return;
1091: }
1092:
1093: if (mysql_link) {
1094: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, -1, "MySQL-Link", le_link, le_plink);
1095: } else {
1096: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, NULL, MySG(default_link), "MySQL-Link", le_link, le_plink);
1097: }
1098:
1099: resource_id = mysql_link ? Z_RESVAL_P(mysql_link) : MySG(default_link);
1100: PHPMY_UNBUFFERED_QUERY_CHECK();
1101: #ifdef MYSQL_USE_MYSQLND
1102: {
1103: int tmp;
1104: if ((mysql = zend_list_find(resource_id, &tmp)) && tmp == le_plink) {
1105: mysqlnd_end_psession(mysql->conn);
1106: }
1107: }
1108: #endif
1109: zend_list_delete(resource_id);
1110:
1111: if (!mysql_link
1112: || (mysql_link && Z_RESVAL_P(mysql_link)==MySG(default_link))) {
1113: MySG(default_link) = -1;
1114: if (mysql_link) {
1115: /* on an explicit close of the default connection it had a refcount of 2 so we need one more call */
1116: zend_list_delete(resource_id);
1117: }
1118: }
1119:
1120: RETURN_TRUE;
1121: }
1122: /* }}} */
1123:
1124: /* {{{ proto bool mysql_select_db(string database_name [, int link_identifier])
1125: Selects a MySQL database */
1126: PHP_FUNCTION(mysql_select_db)
1127: {
1128: char *db;
1129: int db_len;
1130: zval *mysql_link = NULL;
1131: int id = -1;
1132: php_mysql_conn *mysql;
1133:
1134: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|r", &db, &db_len, &mysql_link) == FAILURE) {
1135: return;
1136: }
1137:
1138: if (!mysql_link) {
1139: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1140: CHECK_LINK(id);
1141: }
1142:
1143: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1144:
1145: if (php_mysql_select_db(mysql, db TSRMLS_CC)) {
1146: RETURN_TRUE;
1147: } else {
1148: RETURN_FALSE;
1149: }
1150: }
1151: /* }}} */
1152:
1153: #ifdef HAVE_GETINFO_FUNCS
1154:
1155: /* {{{ proto string mysql_get_client_info(void)
1156: Returns a string that represents the client library version */
1157: PHP_FUNCTION(mysql_get_client_info)
1158: {
1159: if (zend_parse_parameters_none() == FAILURE) {
1160: return;
1161: }
1162:
1163: RETURN_STRING((char *)mysql_get_client_info(),1);
1164: }
1165: /* }}} */
1166:
1167: /* {{{ proto string mysql_get_host_info([int link_identifier])
1168: Returns a string describing the type of connection in use, including the server host name */
1169: PHP_FUNCTION(mysql_get_host_info)
1170: {
1171: zval *mysql_link = NULL;
1172: int id = -1;
1173: php_mysql_conn *mysql;
1174:
1175: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
1176: return;
1177: }
1178:
1179: if (!mysql_link) {
1180: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1181: CHECK_LINK(id);
1182: }
1183:
1184: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1185:
1186: RETURN_STRING((char *)mysql_get_host_info(mysql->conn),1);
1187: }
1188: /* }}} */
1189:
1190: /* {{{ proto int mysql_get_proto_info([int link_identifier])
1191: Returns the protocol version used by current connection */
1192: PHP_FUNCTION(mysql_get_proto_info)
1193: {
1194: zval *mysql_link = NULL;
1195: int id = -1;
1196: php_mysql_conn *mysql;
1197:
1198: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
1199: return;
1200: }
1201:
1202: if (!mysql_link) {
1203: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1204: CHECK_LINK(id);
1205: }
1206:
1207: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1208:
1209: RETURN_LONG(mysql_get_proto_info(mysql->conn));
1210: }
1211: /* }}} */
1212:
1213: /* {{{ proto string mysql_get_server_info([int link_identifier])
1214: Returns a string that represents the server version number */
1215: PHP_FUNCTION(mysql_get_server_info)
1216: {
1217: zval *mysql_link = NULL;
1218: int id = -1;
1219: php_mysql_conn *mysql;
1220:
1221: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
1222: return;
1223: }
1224:
1225: if (!mysql_link) {
1226: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1227: CHECK_LINK(id);
1228: }
1229:
1230: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1231:
1232: RETURN_STRING((char *)mysql_get_server_info(mysql->conn),1);
1233: }
1234: /* }}} */
1235:
1236: /* {{{ proto string mysql_info([int link_identifier])
1237: Returns a string containing information about the most recent query */
1238: PHP_FUNCTION(mysql_info)
1239: {
1240: zval *mysql_link = NULL;
1241: int id = -1;
1242: char *str;
1243: php_mysql_conn *mysql;
1244:
1245: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
1246: return;
1247: }
1248:
1249: if (ZEND_NUM_ARGS() == 0) {
1250: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1251: CHECK_LINK(id);
1252: }
1253:
1254: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1255:
1256: if ((str = (char *)mysql_info(mysql->conn))) {
1257: RETURN_STRING(str,1);
1258: } else {
1259: RETURN_FALSE;
1260: }
1261: }
1262: /* }}} */
1263:
1264: /* {{{ proto int mysql_thread_id([int link_identifier])
1265: Returns the thread id of current connection */
1266: PHP_FUNCTION(mysql_thread_id)
1267: {
1268: zval *mysql_link = NULL;
1269: int id = -1;
1270: php_mysql_conn *mysql;
1271:
1272: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
1273: return;
1274: }
1275:
1276: if (ZEND_NUM_ARGS() == 0) {
1277: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1278: CHECK_LINK(id);
1279: }
1280: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1281:
1282: RETURN_LONG((long) mysql_thread_id(mysql->conn));
1283: }
1284: /* }}} */
1285:
1286: /* {{{ proto string mysql_stat([int link_identifier])
1287: Returns a string containing status information */
1288: PHP_FUNCTION(mysql_stat)
1289: {
1290: zval *mysql_link = NULL;
1291: int id = -1;
1292: php_mysql_conn *mysql;
1293: char *stat;
1294: #ifdef MYSQL_USE_MYSQLND
1295: uint stat_len;
1296: #endif
1297:
1298: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
1299: return;
1300: }
1301:
1302: if (ZEND_NUM_ARGS() == 0) {
1303: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1304: CHECK_LINK(id);
1305: }
1306: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1307:
1308: PHPMY_UNBUFFERED_QUERY_CHECK();
1309: #ifndef MYSQL_USE_MYSQLND
1310: if ((stat = (char *)mysql_stat(mysql->conn))) {
1311: RETURN_STRING(stat, 1);
1312: #else
1313: if (mysqlnd_stat(mysql->conn, &stat, &stat_len) == PASS) {
1314: RETURN_STRINGL(stat, stat_len, 0);
1315: #endif
1316: } else {
1317: RETURN_FALSE;
1318: }
1319: }
1320: /* }}} */
1321:
1322: /* {{{ proto string mysql_client_encoding([int link_identifier])
1323: Returns the default character set for the current connection */
1324: PHP_FUNCTION(mysql_client_encoding)
1325: {
1326: zval *mysql_link = NULL;
1327: int id = -1;
1328: php_mysql_conn *mysql;
1329:
1330: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
1331: return;
1332: }
1333:
1334: if (ZEND_NUM_ARGS() == 0) {
1335: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1336: CHECK_LINK(id);
1337: }
1338:
1339: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1340: RETURN_STRING((char *)mysql_character_set_name(mysql->conn), 1);
1341: }
1342: /* }}} */
1343: #endif
1344:
1345: #ifdef MYSQL_HAS_SET_CHARSET
1346: /* {{{ proto bool mysql_set_charset(string csname [, int link_identifier])
1347: sets client character set */
1348: PHP_FUNCTION(mysql_set_charset)
1349: {
1350: zval *mysql_link = NULL;
1351: char *csname;
1352: int id = -1, csname_len;
1353: php_mysql_conn *mysql;
1354:
1355: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|r", &csname, &csname_len, &mysql_link) == FAILURE) {
1356: return;
1357: }
1358:
1359: if (ZEND_NUM_ARGS() == 1) {
1360: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1361: CHECK_LINK(id);
1362: }
1363:
1364: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1365:
1366: if (!mysql_set_character_set(mysql->conn, csname)) {
1367: RETURN_TRUE;
1368: } else {
1369: RETURN_FALSE;
1370: }
1371: }
1372: /* }}} */
1373: #endif
1374:
1375: #ifndef NETWARE /* The below two functions not supported on NetWare */
1376: #if MYSQL_VERSION_ID < 40000
1377: /* {{{ proto bool mysql_create_db(string database_name [, int link_identifier])
1378: Create a MySQL database */
1379: PHP_FUNCTION(mysql_create_db)
1380: {
1381: char *db;
1382: int db_len;
1383: zval *mysql_link = NULL;
1384: int id = -1;
1385: php_mysql_conn *mysql;
1386:
1387: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|r", &db, &db_len, &mysql_link) == FAILURE) {
1388: return;
1389: }
1390:
1391: if (!mysql_link) {
1392: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1393: CHECK_LINK(id);
1394: }
1395:
1396: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1397:
1398: PHPMY_UNBUFFERED_QUERY_CHECK();
1399:
1400: if (mysql_create_db(mysql->conn, db)==0) {
1401: RETURN_TRUE;
1402: } else {
1403: RETURN_FALSE;
1404: }
1405: }
1406: /* }}} */
1407:
1408: /* {{{ proto bool mysql_drop_db(string database_name [, int link_identifier])
1409: Drops (delete) a MySQL database */
1410: PHP_FUNCTION(mysql_drop_db)
1411: {
1412: char *db;
1413: int db_len;
1414: zval *mysql_link = NULL;
1415: int id = -1;
1416: php_mysql_conn *mysql;
1417:
1418: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|r", &db, &db_len, &mysql_link) == FAILURE) {
1419: return;
1420: }
1421:
1422: if (!mysql_link) {
1423: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1424: CHECK_LINK(id);
1425: }
1426:
1427: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1428:
1429: if (mysql_drop_db(mysql->conn, db)==0) {
1430: RETURN_TRUE;
1431: } else {
1432: RETURN_FALSE;
1433: }
1434: }
1435: /* }}} */
1436: #endif
1437: #endif /* NETWARE */
1438:
1439: /* {{{ php_mysql_do_query_general
1440: */
1441: 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)
1442: {
1443: php_mysql_conn *mysql;
1444: MYSQL_RES *mysql_result;
1445:
1446: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, link_id, "MySQL-Link", le_link, le_plink);
1447:
1448: if (db) {
1449: if (!php_mysql_select_db(mysql, db TSRMLS_CC)) {
1450: RETURN_FALSE;
1451: }
1452: }
1453:
1454: PHPMY_UNBUFFERED_QUERY_CHECK();
1455:
1456: MYSQL_DISABLE_MQ;
1457:
1458: #ifndef MYSQL_USE_MYSQLND
1459: /* check explain */
1460: if (MySG(trace_mode)) {
1461: if (!strncasecmp("select", query, 6)){
1462: MYSQL_ROW row;
1463:
1464: char *newquery;
1465: int newql = spprintf (&newquery, 0, "EXPLAIN %s", query);
1466: mysql_real_query(mysql->conn, newquery, newql);
1467: efree (newquery);
1468: if (mysql_errno(mysql->conn)) {
1469: php_error_docref("http://www.mysql.com/doc" TSRMLS_CC, E_WARNING, "%s", mysql_error(mysql->conn));
1470: RETURN_FALSE;
1471: }
1472: else {
1473: mysql_result = mysql_use_result(mysql->conn);
1474: while ((row = mysql_fetch_row(mysql_result))) {
1475: if (!strcmp("ALL", row[1])) {
1476: 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]);
1477: } else if (!strcmp("INDEX", row[1])) {
1478: 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]);
1479: }
1480: }
1481: mysql_free_result(mysql_result);
1482: }
1483: }
1484: } /* end explain */
1485: #endif
1486:
1487: /* mysql_query is binary unsafe, use mysql_real_query */
1488: #if MYSQL_VERSION_ID > 32199
1489: if (mysql_real_query(mysql->conn, query, query_len)!=0) {
1490: /* check possible error */
1491: if (MySG(trace_mode)){
1492: if (mysql_errno(mysql->conn)){
1493: php_error_docref("http://www.mysql.com/doc" TSRMLS_CC, E_WARNING, "%s", mysql_error(mysql->conn));
1494: }
1495: }
1496: RETURN_FALSE;
1497: }
1498: #else
1499: if (mysql_query(mysql->conn, query)!=0) {
1500: /* check possible error */
1501: if (MySG(trace_mode)){
1502: if (mysql_errno(mysql->conn)){
1503: php_error_docref("http://www.mysql.com/doc" TSRMLS_CC, E_WARNING, "%s", mysql_error(mysql->conn));
1504: }
1505: }
1506: RETURN_FALSE;
1507: }
1508: #endif
1509: if(use_store == MYSQL_USE_RESULT) {
1510: mysql_result=mysql_use_result(mysql->conn);
1511: } else {
1512: mysql_result=mysql_store_result(mysql->conn);
1513: }
1514: if (!mysql_result) {
1515: if (PHP_MYSQL_VALID_RESULT(mysql->conn)) { /* query should have returned rows */
1516: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to save result set");
1517: RETURN_FALSE;
1518: } else {
1519: RETURN_TRUE;
1520: }
1521: }
1522: MySG(result_allocated)++;
1523: ZEND_REGISTER_RESOURCE(return_value, mysql_result, le_result);
1524: if (use_store == MYSQL_USE_RESULT) {
1525: mysql->active_result_id = Z_LVAL_P(return_value);
1526: }
1527: }
1528: /* }}} */
1529:
1530: /* {{{ php_mysql_do_query
1531: */
1532: static void php_mysql_do_query(INTERNAL_FUNCTION_PARAMETERS, int use_store)
1533: {
1534: char *query;
1535: int query_len;
1536: zval *mysql_link = NULL;
1537: int id = -1;
1538:
1539: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|r", &query, &query_len, &mysql_link) == FAILURE) {
1540: return;
1541: }
1542:
1543: if (!mysql_link) {
1544: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1545: CHECK_LINK(id);
1546: }
1547:
1548: php_mysql_do_query_general(query, query_len, mysql_link, id, NULL, use_store, return_value TSRMLS_CC);
1549: }
1550: /* }}} */
1551:
1552: /* {{{ proto resource mysql_query(string query [, int link_identifier])
1553: Sends an SQL query to MySQL */
1554: PHP_FUNCTION(mysql_query)
1555: {
1556: php_mysql_do_query(INTERNAL_FUNCTION_PARAM_PASSTHRU, MYSQL_STORE_RESULT);
1557: }
1558: /* }}} */
1559:
1560:
1561: /* {{{ proto resource mysql_unbuffered_query(string query [, int link_identifier])
1562: Sends an SQL query to MySQL, without fetching and buffering the result rows */
1563: PHP_FUNCTION(mysql_unbuffered_query)
1564: {
1565: php_mysql_do_query(INTERNAL_FUNCTION_PARAM_PASSTHRU, MYSQL_USE_RESULT);
1566: }
1567: /* }}} */
1568:
1569:
1570: /* {{{ proto resource mysql_db_query(string database_name, string query [, int link_identifier])
1571: Sends an SQL query to MySQL */
1572: PHP_FUNCTION(mysql_db_query)
1573: {
1574: char *db, *query;
1575: int db_len, query_len;
1576: zval *mysql_link = NULL;
1577: int id = -1;
1578:
1579: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "ss|r", &db, &db_len, &query, &query_len, &mysql_link) == FAILURE) {
1580: return;
1581: }
1582:
1583: if (!mysql_link) {
1584: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1585: CHECK_LINK(id);
1586: }
1587:
1588: php_error_docref(NULL TSRMLS_CC, E_DEPRECATED, "This function is deprecated; use mysql_query() instead");
1589:
1590: php_mysql_do_query_general(query, query_len, mysql_link, id, db, MYSQL_STORE_RESULT, return_value TSRMLS_CC);
1591: }
1592: /* }}} */
1593:
1594:
1595: /* {{{ proto resource mysql_list_dbs([int link_identifier])
1596: List databases available on a MySQL server */
1597: PHP_FUNCTION(mysql_list_dbs)
1598: {
1599: zval *mysql_link = NULL;
1600: int id = -1;
1601: php_mysql_conn *mysql;
1602: MYSQL_RES *mysql_result;
1603:
1604: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
1605: return;
1606: }
1607:
1608: if (!mysql_link) {
1609: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1610: CHECK_LINK(id);
1611: }
1612: php_error_docref(NULL TSRMLS_CC, E_DEPRECATED, "This function is deprecated; use mysql_query() with SHOW DATABASES instead");
1613:
1614: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1615:
1616: PHPMY_UNBUFFERED_QUERY_CHECK();
1617:
1618:
1619: if ((mysql_result=mysql_list_dbs(mysql->conn, NULL))==NULL) {
1620: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to save MySQL query result");
1621: RETURN_FALSE;
1622: }
1623: MySG(result_allocated)++;
1624: ZEND_REGISTER_RESOURCE(return_value, mysql_result, le_result);
1625: }
1626: /* }}} */
1627:
1628:
1629: /* {{{ proto resource mysql_list_tables(string database_name [, int link_identifier])
1630: List tables in a MySQL database */
1631: PHP_FUNCTION(mysql_list_tables)
1632: {
1633: char *db;
1634: int db_len;
1635: zval *mysql_link = NULL;
1636: int id = -1;
1637: php_mysql_conn *mysql;
1638: MYSQL_RES *mysql_result;
1639:
1640: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|r", &db, &db_len, &mysql_link) == FAILURE) {
1641: return;
1642: }
1643:
1644: if (!mysql_link) {
1645: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1646: CHECK_LINK(id);
1647: }
1648:
1649: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1650:
1651: if (!php_mysql_select_db(mysql, db TSRMLS_CC)) {
1652: RETURN_FALSE;
1653: }
1654:
1655: PHPMY_UNBUFFERED_QUERY_CHECK();
1656:
1657: if ((mysql_result=mysql_list_tables(mysql->conn, NULL))==NULL) {
1658: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to save MySQL query result");
1659: RETURN_FALSE;
1660: }
1661: MySG(result_allocated)++;
1662: ZEND_REGISTER_RESOURCE(return_value, mysql_result, le_result);
1663: }
1664: /* }}} */
1665:
1666:
1667: /* {{{ proto resource mysql_list_fields(string database_name, string table_name [, int link_identifier])
1668: List MySQL result fields */
1669: PHP_FUNCTION(mysql_list_fields)
1670: {
1671: char *db, *table;
1672: int db_len, table_len;
1673: zval *mysql_link = NULL;
1674: int id = -1;
1675: php_mysql_conn *mysql;
1676: MYSQL_RES *mysql_result;
1677:
1678: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "ss|r", &db, &db_len, &table, &table_len, &mysql_link) == FAILURE) {
1679: return;
1680: }
1681:
1682: if (!mysql_link) {
1683: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1684: CHECK_LINK(id);
1685: }
1686:
1687: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1688:
1689: if (!php_mysql_select_db(mysql, db TSRMLS_CC)) {
1690: RETURN_FALSE;
1691: }
1692:
1693: PHPMY_UNBUFFERED_QUERY_CHECK();
1694:
1695: if ((mysql_result=mysql_list_fields(mysql->conn, table, NULL))==NULL) {
1696: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to save MySQL query result");
1697: RETURN_FALSE;
1698: }
1699: MySG(result_allocated)++;
1700: ZEND_REGISTER_RESOURCE(return_value, mysql_result, le_result);
1701: }
1702: /* }}} */
1703:
1704: /* {{{ proto resource mysql_list_processes([int link_identifier])
1705: Returns a result set describing the current server threads */
1706: PHP_FUNCTION(mysql_list_processes)
1707: {
1708: zval *mysql_link = NULL;
1709: int id = -1;
1710: php_mysql_conn *mysql;
1711: MYSQL_RES *mysql_result;
1712:
1713: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
1714: return;
1715: }
1716:
1717: if (ZEND_NUM_ARGS() == 0) {
1718: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1719: CHECK_LINK(id);
1720: }
1721:
1722: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1723:
1724: PHPMY_UNBUFFERED_QUERY_CHECK();
1725:
1726: mysql_result = mysql_list_processes(mysql->conn);
1727: if (mysql_result == NULL) {
1728: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to save MySQL query result");
1729: RETURN_FALSE;
1730: }
1731:
1732: MySG(result_allocated)++;
1733: ZEND_REGISTER_RESOURCE(return_value, mysql_result, le_result);
1734: }
1735: /* }}} */
1736:
1737:
1738: /* {{{ proto string mysql_error([int link_identifier])
1739: Returns the text of the error message from previous MySQL operation */
1740: PHP_FUNCTION(mysql_error)
1741: {
1742: zval *mysql_link = NULL;
1743: int id = -1;
1744: php_mysql_conn *mysql;
1745:
1746: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
1747: return;
1748: }
1749:
1750: if (!mysql_link) {
1751: id = MySG(default_link);
1752: if (id==-1) {
1753: if (MySG(connect_error)!=NULL){
1754: RETURN_STRING(MySG(connect_error),1);
1755: } else {
1756: RETURN_FALSE;
1757: }
1758: }
1759: }
1760:
1761: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1762:
1763: RETURN_STRING((char *)mysql_error(mysql->conn), 1);
1764: }
1765: /* }}} */
1766:
1767:
1768: /* {{{ proto int mysql_errno([int link_identifier])
1769: Returns the number of the error message from previous MySQL operation */
1770: #ifdef HAVE_MYSQL_ERRNO
1771: PHP_FUNCTION(mysql_errno)
1772: {
1773: zval *mysql_link = NULL;
1774: int id = -1;
1775: php_mysql_conn *mysql;
1776:
1777: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
1778: return;
1779: }
1780:
1781: if (!mysql_link) {
1782: id = MySG(default_link);
1783: if (id==-1) {
1784: if (MySG(connect_errno)!=0){
1785: RETURN_LONG(MySG(connect_errno));
1786: } else {
1787: RETURN_FALSE;
1788: }
1789: }
1790: }
1791:
1792: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1793:
1794: RETURN_LONG(mysql_errno(mysql->conn));
1795: }
1796: #endif
1797: /* }}} */
1798:
1799:
1800: /* {{{ proto int mysql_affected_rows([int link_identifier])
1801: Gets number of affected rows in previous MySQL operation */
1802: PHP_FUNCTION(mysql_affected_rows)
1803: {
1804: zval *mysql_link = NULL;
1805: int id = -1;
1806: php_mysql_conn *mysql;
1807:
1808: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
1809: return;
1810: }
1811:
1812: if (!mysql_link) {
1813: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1814: CHECK_LINK(id);
1815: }
1816:
1817: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1818:
1819: /* conversion from int64 to long happing here */
1820: Z_LVAL_P(return_value) = (long) mysql_affected_rows(mysql->conn);
1821: Z_TYPE_P(return_value) = IS_LONG;
1822: }
1823: /* }}} */
1824:
1825:
1826: /* {{{ proto string mysql_escape_string(string to_be_escaped)
1827: Escape string for mysql query */
1828: PHP_FUNCTION(mysql_escape_string)
1829: {
1830: char *str;
1831: int str_len;
1832:
1833: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &str, &str_len) == FAILURE) {
1834: return;
1835: }
1836:
1837: /* assume worst case situation, which is 2x of the original string.
1838: * we don't realloc() down to the real size since it'd most probably not
1839: * be worth it
1840: */
1841:
1842: Z_STRVAL_P(return_value) = (char *) safe_emalloc(str_len, 2, 1);
1843: Z_STRLEN_P(return_value) = mysql_escape_string(Z_STRVAL_P(return_value), str, str_len);
1844: Z_TYPE_P(return_value) = IS_STRING;
1845:
1846: php_error_docref("function.mysql-real-escape-string" TSRMLS_CC, E_DEPRECATED, "This function is deprecated; use mysql_real_escape_string() instead.");
1847: }
1848: /* }}} */
1849:
1850: /* {{{ proto string mysql_real_escape_string(string to_be_escaped [, int link_identifier])
1851: Escape special characters in a string for use in a SQL statement, taking into account the current charset of the connection */
1852: PHP_FUNCTION(mysql_real_escape_string)
1853: {
1854: zval *mysql_link = NULL;
1855: char *str;
1856: char *new_str;
1857: int id = -1, str_len, new_str_len;
1858: php_mysql_conn *mysql;
1859:
1860:
1861: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|r", &str, &str_len, &mysql_link) == FAILURE) {
1862: return;
1863: }
1864:
1865: if (ZEND_NUM_ARGS() == 1) {
1866: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1867: CHECK_LINK(id);
1868: }
1869:
1870: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1871:
1872: new_str = safe_emalloc(str_len, 2, 1);
1873: new_str_len = mysql_real_escape_string(mysql->conn, new_str, str, str_len);
1874: new_str = erealloc(new_str, new_str_len + 1);
1875:
1876: RETURN_STRINGL(new_str, new_str_len, 0);
1877: }
1878: /* }}} */
1879:
1880: /* {{{ proto int mysql_insert_id([int link_identifier])
1881: Gets the ID generated from the previous INSERT operation */
1882: PHP_FUNCTION(mysql_insert_id)
1883: {
1884: zval *mysql_link = NULL;
1885: int id = -1;
1886: php_mysql_conn *mysql;
1887:
1888: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mysql_link) == FAILURE) {
1889: return;
1890: }
1891:
1892: if (!mysql_link) {
1893: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
1894: CHECK_LINK(id);
1895: }
1896:
1897: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
1898:
1899: /* conversion from int64 to long happing here */
1900: Z_LVAL_P(return_value) = (long) mysql_insert_id(mysql->conn);
1901: Z_TYPE_P(return_value) = IS_LONG;
1902: }
1903: /* }}} */
1904:
1905:
1906: /* {{{ proto mixed mysql_result(resource result, int row [, mixed field])
1907: Gets result data */
1908: PHP_FUNCTION(mysql_result)
1909: {
1910: zval *result, *field=NULL;
1911: long row;
1912: MYSQL_RES *mysql_result;
1913: #ifndef MYSQL_USE_MYSQLND
1914: MYSQL_ROW sql_row;
1915: mysql_row_length_type *sql_row_lengths;
1916: #endif
1917: int field_offset=0;
1918:
1919: /*
1920: johannes TODO:
1921: Do 2 zend_parse_paramters calls instead of type "z" and switch below
1922: Q: String or long first?
1923: */
1924: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rl|z", &result, &row, &field) == FAILURE) {
1925: return;
1926: }
1927:
1928: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
1929:
1930: if (row<0 || row>=(int)mysql_num_rows(mysql_result)) {
1931: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to jump to row %ld on MySQL result index %ld", row, Z_LVAL_P(result));
1932: RETURN_FALSE;
1933: }
1934: mysql_data_seek(mysql_result, row);
1935:
1936: if (field) {
1937: switch(Z_TYPE_P(field)) {
1938: case IS_STRING: {
1939: int i=0;
1940: const MYSQL_FIELD *tmp_field;
1941: char *table_name, *field_name, *tmp;
1942:
1943: if ((tmp=strchr(Z_STRVAL_P(field), '.'))) {
1944: table_name = estrndup(Z_STRVAL_P(field), tmp-Z_STRVAL_P(field));
1945: field_name = estrdup(tmp+1);
1946: } else {
1947: table_name = NULL;
1948: field_name = estrndup(Z_STRVAL_P(field),Z_STRLEN_P(field));
1949: }
1950: mysql_field_seek(mysql_result, 0);
1951: while ((tmp_field=mysql_fetch_field(mysql_result))) {
1952: if ((!table_name || !strcasecmp(tmp_field->table, table_name)) && !strcasecmp(tmp_field->name, field_name)) {
1953: field_offset = i;
1954: break;
1955: }
1956: i++;
1957: }
1958: if (!tmp_field) { /* no match found */
1959: php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s%s%s not found in MySQL result index %ld",
1960: (table_name?table_name:""), (table_name?".":""), field_name, Z_LVAL_P(result));
1961: efree(field_name);
1962: if (table_name) {
1963: efree(table_name);
1964: }
1965: RETURN_FALSE;
1966: }
1967: efree(field_name);
1968: if (table_name) {
1969: efree(table_name);
1970: }
1971: }
1972: break;
1973: default:
1974: convert_to_long_ex(&field);
1975: field_offset = Z_LVAL_P(field);
1976: if (field_offset<0 || field_offset>=(int)mysql_num_fields(mysql_result)) {
1977: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Bad column offset specified");
1978: RETURN_FALSE;
1979: }
1980: break;
1981: }
1982: }
1983:
1984: #ifndef MYSQL_USE_MYSQLND
1985: if ((sql_row=mysql_fetch_row(mysql_result))==NULL
1986: || (sql_row_lengths=mysql_fetch_lengths(mysql_result))==NULL) { /* shouldn't happen? */
1987: RETURN_FALSE;
1988: }
1989: if (sql_row[field_offset]) {
1990: Z_TYPE_P(return_value) = IS_STRING;
1991:
1992: #if PHP_API_VERSION < 20100412
1993: if (PG(magic_quotes_runtime)) {
1994: Z_STRVAL_P(return_value) = php_addslashes(sql_row[field_offset], sql_row_lengths[field_offset],&Z_STRLEN_P(return_value), 0 TSRMLS_CC);
1995: } else {
1996: #endif
1997: Z_STRLEN_P(return_value) = sql_row_lengths[field_offset];
1998: Z_STRVAL_P(return_value) = (char *) safe_estrndup(sql_row[field_offset], Z_STRLEN_P(return_value));
1999: #if PHP_API_VERSION < 20100412
2000: }
2001: #endif
2002: } else {
2003: Z_TYPE_P(return_value) = IS_NULL;
2004: }
2005: #else
2006: mysqlnd_result_fetch_field_data(mysql_result, field_offset, return_value);
2007: #endif
2008: }
2009: /* }}} */
2010:
2011:
2012: /* {{{ proto int mysql_num_rows(resource result)
2013: Gets number of rows in a result */
2014: PHP_FUNCTION(mysql_num_rows)
2015: {
2016: zval *result;
2017: MYSQL_RES *mysql_result;
2018:
2019: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &result) == FAILURE) {
2020: return;
2021: }
2022:
2023: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
2024:
2025: /* conversion from int64 to long happing here */
2026: Z_LVAL_P(return_value) = (long) mysql_num_rows(mysql_result);
2027: Z_TYPE_P(return_value) = IS_LONG;
2028: }
2029: /* }}} */
2030:
2031: /* {{{ proto int mysql_num_fields(resource result)
2032: Gets number of fields in a result */
2033: PHP_FUNCTION(mysql_num_fields)
2034: {
2035: zval *result;
2036: MYSQL_RES *mysql_result;
2037:
2038: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &result) == FAILURE) {
2039: return;
2040: }
2041:
2042: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
2043:
2044: Z_LVAL_P(return_value) = mysql_num_fields(mysql_result);
2045: Z_TYPE_P(return_value) = IS_LONG;
2046: }
2047: /* }}} */
2048:
2049: /* {{{ php_mysql_fetch_hash
2050: */
2051: static void php_mysql_fetch_hash(INTERNAL_FUNCTION_PARAMETERS, long result_type, int expected_args, int into_object)
2052: {
2053: MYSQL_RES *mysql_result;
2054: zval *res, *ctor_params = NULL;
2055: zend_class_entry *ce = NULL;
2056: #ifndef MYSQL_USE_MYSQLND
2057: int i;
2058: MYSQL_FIELD *mysql_field;
2059: MYSQL_ROW mysql_row;
2060: mysql_row_length_type *mysql_row_lengths;
2061: #endif
2062:
2063: #ifdef ZEND_ENGINE_2
2064: if (into_object) {
2065: char *class_name = NULL;
2066: int class_name_len = 0;
2067:
2068: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "z|sz", &res, &class_name, &class_name_len, &ctor_params) == FAILURE) {
2069: return;
2070: }
2071:
2072: if (ZEND_NUM_ARGS() < 2) {
2073: ce = zend_standard_class_def;
2074: } else {
2075: ce = zend_fetch_class(class_name, class_name_len, ZEND_FETCH_CLASS_AUTO TSRMLS_CC);
2076: }
2077: if (!ce) {
2078: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Could not find class '%s'", class_name);
2079: return;
2080: }
2081: result_type = MYSQL_ASSOC;
2082: } else
2083: #endif
2084: {
2085: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r|l", &res, &result_type) == FAILURE) {
2086: return;
2087: }
2088: if (!result_type) {
2089: /* result_type might have been set outside, so only overwrite when not set */
2090: result_type = MYSQL_BOTH;
2091: }
2092: }
2093:
2094: if (result_type & ~MYSQL_BOTH) {
2095: php_error_docref(NULL TSRMLS_CC, E_WARNING, "The result type should be either MYSQL_NUM, MYSQL_ASSOC or MYSQL_BOTH");
2096: result_type = MYSQL_BOTH;
2097: }
2098:
2099: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &res, -1, "MySQL result", le_result);
2100:
2101: #ifndef MYSQL_USE_MYSQLND
2102: if ((mysql_row = mysql_fetch_row(mysql_result)) == NULL ||
2103: (mysql_row_lengths = mysql_fetch_lengths(mysql_result)) == NULL) {
2104: RETURN_FALSE;
2105: }
2106:
2107: array_init(return_value);
2108:
2109: mysql_field_seek(mysql_result, 0);
2110: for (mysql_field = mysql_fetch_field(mysql_result), i = 0;
2111: mysql_field;
2112: mysql_field = mysql_fetch_field(mysql_result), i++)
2113: {
2114: if (mysql_row[i]) {
2115: zval *data;
2116:
2117: MAKE_STD_ZVAL(data);
2118:
2119: #if PHP_API_VERSION < 20100412
2120: if (PG(magic_quotes_runtime)) {
2121: Z_TYPE_P(data) = IS_STRING;
2122: Z_STRVAL_P(data) = php_addslashes(mysql_row[i], mysql_row_lengths[i], &Z_STRLEN_P(data), 0 TSRMLS_CC);
2123: } else {
2124: #endif
2125: ZVAL_STRINGL(data, mysql_row[i], mysql_row_lengths[i], 1);
2126: #if PHP_API_VERSION < 20100412
2127: }
2128: #endif
2129:
2130: if (result_type & MYSQL_NUM) {
2131: add_index_zval(return_value, i, data);
2132: }
2133: if (result_type & MYSQL_ASSOC) {
2134: if (result_type & MYSQL_NUM) {
2135: Z_ADDREF_P(data);
2136: }
2137: add_assoc_zval(return_value, mysql_field->name, data);
2138: }
2139: } else {
2140: /* NULL value. */
2141: if (result_type & MYSQL_NUM) {
2142: add_index_null(return_value, i);
2143: }
2144:
2145: if (result_type & MYSQL_ASSOC) {
2146: add_assoc_null(return_value, mysql_field->name);
2147: }
2148: }
2149: }
2150: #else
2151: 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);
2152: #endif
2153:
2154: #ifdef ZEND_ENGINE_2
2155: /* mysqlnd might return FALSE if no more rows */
2156: if (into_object && Z_TYPE_P(return_value) != IS_BOOL) {
2157: zval dataset = *return_value;
2158: zend_fcall_info fci;
2159: zend_fcall_info_cache fcc;
2160: zval *retval_ptr;
2161:
2162: object_and_properties_init(return_value, ce, NULL);
2163: zend_merge_properties(return_value, Z_ARRVAL(dataset), 1 TSRMLS_CC);
2164:
2165: if (ce->constructor) {
2166: fci.size = sizeof(fci);
2167: fci.function_table = &ce->function_table;
2168: fci.function_name = NULL;
2169: fci.symbol_table = NULL;
2170: fci.object_ptr = return_value;
2171: fci.retval_ptr_ptr = &retval_ptr;
2172: if (ctor_params && Z_TYPE_P(ctor_params) != IS_NULL) {
2173: if (Z_TYPE_P(ctor_params) == IS_ARRAY) {
2174: HashTable *htl = Z_ARRVAL_P(ctor_params);
2175: Bucket *p;
2176:
2177: fci.param_count = 0;
2178: fci.params = safe_emalloc(sizeof(zval*), htl->nNumOfElements, 0);
2179: p = htl->pListHead;
2180: while (p != NULL) {
2181: fci.params[fci.param_count++] = (zval**)p->pData;
2182: p = p->pListNext;
2183: }
2184: } else {
2185: /* Two problems why we throw exceptions here: PHP is typeless
2186: * and hence passing one argument that's not an array could be
2187: * by mistake and the other way round is possible, too. The
2188: * single value is an array. Also we'd have to make that one
2189: * argument passed by reference.
2190: */
2191: zend_throw_exception(zend_exception_get_default(TSRMLS_C), "Parameter ctor_params must be an array", 0 TSRMLS_CC);
2192: return;
2193: }
2194: } else {
2195: fci.param_count = 0;
2196: fci.params = NULL;
2197: }
2198: fci.no_separation = 1;
2199:
2200: fcc.initialized = 1;
2201: fcc.function_handler = ce->constructor;
2202: fcc.calling_scope = EG(scope);
2203: fcc.called_scope = Z_OBJCE_P(return_value);
2204: fcc.object_ptr = return_value;
2205:
2206: if (zend_call_function(&fci, &fcc TSRMLS_CC) == FAILURE) {
2207: 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);
2208: } else {
2209: if (retval_ptr) {
2210: zval_ptr_dtor(&retval_ptr);
2211: }
2212: }
2213: if (fci.params) {
2214: efree(fci.params);
2215: }
2216: } else if (ctor_params) {
2217: 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);
2218: }
2219: }
2220: #endif
2221:
2222: }
2223: /* }}} */
2224:
2225: /* {{{ proto array mysql_fetch_row(resource result)
2226: Gets a result row as an enumerated array */
2227: PHP_FUNCTION(mysql_fetch_row)
2228: {
2229: php_mysql_fetch_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, MYSQL_NUM, 1, 0);
2230: }
2231: /* }}} */
2232:
2233:
2234: /* {{{ proto object mysql_fetch_object(resource result [, string class_name [, NULL|array ctor_params]])
2235: Fetch a result row as an object */
2236: PHP_FUNCTION(mysql_fetch_object)
2237: {
2238: php_mysql_fetch_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, MYSQL_ASSOC, 2, 1);
2239:
2240: if (Z_TYPE_P(return_value) == IS_ARRAY) {
2241: object_and_properties_init(return_value, ZEND_STANDARD_CLASS_DEF_PTR, Z_ARRVAL_P(return_value));
2242: }
2243: }
2244: /* }}} */
2245:
2246:
2247: /* {{{ proto array mysql_fetch_array(resource result [, int result_type])
2248: Fetch a result row as an array (associative, numeric or both) */
2249: PHP_FUNCTION(mysql_fetch_array)
2250: {
2251: php_mysql_fetch_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, 0, 2, 0);
2252: }
2253: /* }}} */
2254:
2255:
2256: /* {{{ proto array mysql_fetch_assoc(resource result)
2257: Fetch a result row as an associative array */
2258: PHP_FUNCTION(mysql_fetch_assoc)
2259: {
2260: php_mysql_fetch_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, MYSQL_ASSOC, 1, 0);
2261: }
2262: /* }}} */
2263:
2264: /* {{{ proto bool mysql_data_seek(resource result, int row_number)
2265: Move internal result pointer */
2266: PHP_FUNCTION(mysql_data_seek)
2267: {
2268: zval *result;
2269: long offset;
2270: MYSQL_RES *mysql_result;
2271:
2272: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rl", &result, &offset)) {
2273: return;
2274: }
2275:
2276: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
2277:
2278: if (offset<0 || offset>=(int)mysql_num_rows(mysql_result)) {
2279: 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));
2280: RETURN_FALSE;
2281: }
2282: mysql_data_seek(mysql_result, offset);
2283: RETURN_TRUE;
2284: }
2285: /* }}} */
2286:
2287:
2288: /* {{{ proto array mysql_fetch_lengths(resource result)
2289: Gets max data size of each column in a result */
2290: PHP_FUNCTION(mysql_fetch_lengths)
2291: {
2292: zval *result;
2293: MYSQL_RES *mysql_result;
2294: mysql_row_length_type *lengths;
2295: int num_fields;
2296: int i;
2297:
2298: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &result) == FAILURE) {
2299: return;
2300: }
2301:
2302: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
2303:
2304: if ((lengths=mysql_fetch_lengths(mysql_result))==NULL) {
2305: RETURN_FALSE;
2306: }
2307: array_init(return_value);
2308: num_fields = mysql_num_fields(mysql_result);
2309:
2310: for (i=0; i<num_fields; i++) {
2311: add_index_long(return_value, i, lengths[i]);
2312: }
2313: }
2314: /* }}} */
2315:
2316: /* {{{ php_mysql_get_field_name
2317: */
2318: static char *php_mysql_get_field_name(int field_type)
2319: {
2320: switch(field_type) {
2321: case FIELD_TYPE_STRING:
2322: case FIELD_TYPE_VAR_STRING:
2323: return "string";
2324: break;
2325: #if MYSQL_VERSION_ID > 50002 || defined(MYSQL_USE_MYSQLND)
2326: case MYSQL_TYPE_BIT:
2327: #endif
2328: #ifdef MYSQL_HAS_TINY
2329: case FIELD_TYPE_TINY:
2330: #endif
2331: case FIELD_TYPE_SHORT:
2332: case FIELD_TYPE_LONG:
2333: case FIELD_TYPE_LONGLONG:
2334: case FIELD_TYPE_INT24:
2335: return "int";
2336: break;
2337: case FIELD_TYPE_FLOAT:
2338: case FIELD_TYPE_DOUBLE:
2339: case FIELD_TYPE_DECIMAL:
2340: #ifdef FIELD_TYPE_NEWDECIMAL
2341: case FIELD_TYPE_NEWDECIMAL:
2342: #endif
2343: return "real";
2344: break;
2345: case FIELD_TYPE_TIMESTAMP:
2346: return "timestamp";
2347: break;
2348: #ifdef MYSQL_HAS_YEAR
2349: case FIELD_TYPE_YEAR:
2350: return "year";
2351: break;
2352: #endif
2353: case FIELD_TYPE_DATE:
2354: #ifdef FIELD_TYPE_NEWDATE
2355: case FIELD_TYPE_NEWDATE:
2356: #endif
2357: return "date";
2358: break;
2359: case FIELD_TYPE_TIME:
2360: return "time";
2361: break;
2362: case FIELD_TYPE_SET:
2363: return "set";
2364: break;
2365: case FIELD_TYPE_ENUM:
2366: return "enum";
2367: break;
2368: #ifdef FIELD_TYPE_GEOMETRY
2369: case FIELD_TYPE_GEOMETRY:
2370: return "geometry";
2371: break;
2372: #endif
2373: case FIELD_TYPE_DATETIME:
2374: return "datetime";
2375: break;
2376: case FIELD_TYPE_TINY_BLOB:
2377: case FIELD_TYPE_MEDIUM_BLOB:
2378: case FIELD_TYPE_LONG_BLOB:
2379: case FIELD_TYPE_BLOB:
2380: return "blob";
2381: break;
2382: case FIELD_TYPE_NULL:
2383: return "null";
2384: break;
2385: default:
2386: return "unknown";
2387: break;
2388: }
2389: }
2390: /* }}} */
2391:
2392: /* {{{ proto object mysql_fetch_field(resource result [, int field_offset])
2393: Gets column information from a result and return as an object */
2394: PHP_FUNCTION(mysql_fetch_field)
2395: {
2396: zval *result;
2397: long field=0;
2398: MYSQL_RES *mysql_result;
2399: const MYSQL_FIELD *mysql_field;
2400:
2401: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r|l", &result, &field) == FAILURE) {
2402: return;
2403: }
2404:
2405: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
2406:
2407: if (ZEND_NUM_ARGS() > 1) {
2408: if (field<0 || field>=(int)mysql_num_fields(mysql_result)) {
2409: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Bad field offset");
2410: RETURN_FALSE;
2411: }
2412: mysql_field_seek(mysql_result, field);
2413: }
2414: if ((mysql_field=mysql_fetch_field(mysql_result))==NULL) {
2415: RETURN_FALSE;
2416: }
2417: object_init(return_value);
2418:
2419: add_property_string(return_value, "name",(mysql_field->name?mysql_field->name:""), 1);
2420: add_property_string(return_value, "table",(mysql_field->table?mysql_field->table:""), 1);
2421: add_property_string(return_value, "def",(mysql_field->def?mysql_field->def:""), 1);
2422: add_property_long(return_value, "max_length", mysql_field->max_length);
2423: add_property_long(return_value, "not_null", IS_NOT_NULL(mysql_field->flags)?1:0);
2424: add_property_long(return_value, "primary_key", IS_PRI_KEY(mysql_field->flags)?1:0);
2425: add_property_long(return_value, "multiple_key",(mysql_field->flags&MULTIPLE_KEY_FLAG?1:0));
2426: add_property_long(return_value, "unique_key",(mysql_field->flags&UNIQUE_KEY_FLAG?1:0));
2427: add_property_long(return_value, "numeric", IS_NUM(Z_TYPE_P(mysql_field))?1:0);
2428: add_property_long(return_value, "blob", IS_BLOB(mysql_field->flags)?1:0);
2429: add_property_string(return_value, "type", php_mysql_get_field_name(Z_TYPE_P(mysql_field)), 1);
2430: add_property_long(return_value, "unsigned",(mysql_field->flags&UNSIGNED_FLAG?1:0));
2431: add_property_long(return_value, "zerofill",(mysql_field->flags&ZEROFILL_FLAG?1:0));
2432: }
2433: /* }}} */
2434:
2435:
2436: /* {{{ proto bool mysql_field_seek(resource result, int field_offset)
2437: Sets result pointer to a specific field offset */
2438: PHP_FUNCTION(mysql_field_seek)
2439: {
2440: zval *result;
2441: long offset;
2442: MYSQL_RES *mysql_result;
2443:
2444: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rl", &result, &offset) == FAILURE) {
2445: return;
2446: }
2447: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
2448:
2449: if (offset<0 || offset>=(int)mysql_num_fields(mysql_result)) {
2450: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Field %ld is invalid for MySQL result index %ld", offset, Z_LVAL_P(result));
2451: RETURN_FALSE;
2452: }
2453: mysql_field_seek(mysql_result, offset);
2454: RETURN_TRUE;
2455: }
2456: /* }}} */
2457:
2458:
2459: #define PHP_MYSQL_FIELD_NAME 1
2460: #define PHP_MYSQL_FIELD_TABLE 2
2461: #define PHP_MYSQL_FIELD_LEN 3
2462: #define PHP_MYSQL_FIELD_TYPE 4
2463: #define PHP_MYSQL_FIELD_FLAGS 5
2464:
2465: /* {{{ php_mysql_field_info
2466: */
2467: static void php_mysql_field_info(INTERNAL_FUNCTION_PARAMETERS, int entry_type)
2468: {
2469: zval *result;
2470: long field;
2471: MYSQL_RES *mysql_result;
2472: const MYSQL_FIELD *mysql_field = {0};
2473: char buf[512];
2474: int len;
2475:
2476: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rl", &result, &field) == FAILURE) {
2477: return;
2478: }
2479:
2480: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
2481:
2482: if (field<0 || field>=(int)mysql_num_fields(mysql_result)) {
2483: php_error_docref(NULL TSRMLS_CC, E_WARNING, "Field %ld is invalid for MySQL result index %ld", field, Z_LVAL_P(result));
2484: RETURN_FALSE;
2485: }
2486: mysql_field_seek(mysql_result, field);
2487: if ((mysql_field=mysql_fetch_field(mysql_result))==NULL) {
2488: RETURN_FALSE;
2489: }
2490:
2491: switch (entry_type) {
2492: case PHP_MYSQL_FIELD_NAME:
2493: Z_STRLEN_P(return_value) = strlen(mysql_field->name);
2494: Z_STRVAL_P(return_value) = estrndup(mysql_field->name, Z_STRLEN_P(return_value));
2495: Z_TYPE_P(return_value) = IS_STRING;
2496: break;
2497: case PHP_MYSQL_FIELD_TABLE:
2498: Z_STRLEN_P(return_value) = strlen(mysql_field->table);
2499: Z_STRVAL_P(return_value) = estrndup(mysql_field->table, Z_STRLEN_P(return_value));
2500: Z_TYPE_P(return_value) = IS_STRING;
2501: break;
2502: case PHP_MYSQL_FIELD_LEN:
2503: Z_LVAL_P(return_value) = mysql_field->length;
2504: Z_TYPE_P(return_value) = IS_LONG;
2505: break;
2506: case PHP_MYSQL_FIELD_TYPE:
2507: Z_STRVAL_P(return_value) = php_mysql_get_field_name(Z_TYPE_P(mysql_field));
2508: Z_STRLEN_P(return_value) = strlen(Z_STRVAL_P(return_value));
2509: Z_STRVAL_P(return_value) = estrndup(Z_STRVAL_P(return_value), Z_STRLEN_P(return_value));
2510: Z_TYPE_P(return_value) = IS_STRING;
2511: break;
2512: case PHP_MYSQL_FIELD_FLAGS:
2513: memcpy(buf, "", sizeof(""));
2514: #ifdef IS_NOT_NULL
2515: if (IS_NOT_NULL(mysql_field->flags)) {
2516: strcat(buf, "not_null ");
2517: }
2518: #endif
2519: #ifdef IS_PRI_KEY
2520: if (IS_PRI_KEY(mysql_field->flags)) {
2521: strcat(buf, "primary_key ");
2522: }
2523: #endif
2524: #ifdef UNIQUE_KEY_FLAG
2525: if (mysql_field->flags&UNIQUE_KEY_FLAG) {
2526: strcat(buf, "unique_key ");
2527: }
2528: #endif
2529: #ifdef MULTIPLE_KEY_FLAG
2530: if (mysql_field->flags&MULTIPLE_KEY_FLAG) {
2531: strcat(buf, "multiple_key ");
2532: }
2533: #endif
2534: #ifdef IS_BLOB
2535: if (IS_BLOB(mysql_field->flags)) {
2536: strcat(buf, "blob ");
2537: }
2538: #endif
2539: #ifdef UNSIGNED_FLAG
2540: if (mysql_field->flags&UNSIGNED_FLAG) {
2541: strcat(buf, "unsigned ");
2542: }
2543: #endif
2544: #ifdef ZEROFILL_FLAG
2545: if (mysql_field->flags&ZEROFILL_FLAG) {
2546: strcat(buf, "zerofill ");
2547: }
2548: #endif
2549: #ifdef BINARY_FLAG
2550: if (mysql_field->flags&BINARY_FLAG) {
2551: strcat(buf, "binary ");
2552: }
2553: #endif
2554: #ifdef ENUM_FLAG
2555: if (mysql_field->flags&ENUM_FLAG) {
2556: strcat(buf, "enum ");
2557: }
2558: #endif
2559: #ifdef SET_FLAG
2560: if (mysql_field->flags&SET_FLAG) {
2561: strcat(buf, "set ");
2562: }
2563: #endif
2564: #ifdef AUTO_INCREMENT_FLAG
2565: if (mysql_field->flags&AUTO_INCREMENT_FLAG) {
2566: strcat(buf, "auto_increment ");
2567: }
2568: #endif
2569: #ifdef TIMESTAMP_FLAG
2570: if (mysql_field->flags&TIMESTAMP_FLAG) {
2571: strcat(buf, "timestamp ");
2572: }
2573: #endif
2574: len = strlen(buf);
2575: /* remove trailing space, if present */
2576: if (len && buf[len-1] == ' ') {
2577: buf[len-1] = 0;
2578: len--;
2579: }
2580:
2581: Z_STRLEN_P(return_value) = len;
2582: Z_STRVAL_P(return_value) = estrndup(buf, len);
2583: Z_TYPE_P(return_value) = IS_STRING;
2584: break;
2585:
2586: default:
2587: RETURN_FALSE;
2588: }
2589: }
2590: /* }}} */
2591:
2592: /* {{{ proto string mysql_field_name(resource result, int field_index)
2593: Gets the name of the specified field in a result */
2594: PHP_FUNCTION(mysql_field_name)
2595: {
2596: php_mysql_field_info(INTERNAL_FUNCTION_PARAM_PASSTHRU, PHP_MYSQL_FIELD_NAME);
2597: }
2598: /* }}} */
2599:
2600:
2601: /* {{{ proto string mysql_field_table(resource result, int field_offset)
2602: Gets name of the table the specified field is in */
2603: PHP_FUNCTION(mysql_field_table)
2604: {
2605: php_mysql_field_info(INTERNAL_FUNCTION_PARAM_PASSTHRU, PHP_MYSQL_FIELD_TABLE);
2606: }
2607: /* }}} */
2608:
2609:
2610: /* {{{ proto int mysql_field_len(resource result, int field_offset)
2611: Returns the length of the specified field */
2612: PHP_FUNCTION(mysql_field_len)
2613: {
2614: php_mysql_field_info(INTERNAL_FUNCTION_PARAM_PASSTHRU, PHP_MYSQL_FIELD_LEN);
2615: }
2616: /* }}} */
2617:
2618:
2619: /* {{{ proto string mysql_field_type(resource result, int field_offset)
2620: Gets the type of the specified field in a result */
2621: PHP_FUNCTION(mysql_field_type)
2622: {
2623: php_mysql_field_info(INTERNAL_FUNCTION_PARAM_PASSTHRU, PHP_MYSQL_FIELD_TYPE);
2624: }
2625: /* }}} */
2626:
2627:
2628: /* {{{ proto string mysql_field_flags(resource result, int field_offset)
2629: Gets the flags associated with the specified field in a result */
2630: PHP_FUNCTION(mysql_field_flags)
2631: {
2632: php_mysql_field_info(INTERNAL_FUNCTION_PARAM_PASSTHRU, PHP_MYSQL_FIELD_FLAGS);
2633: }
2634: /* }}} */
2635:
2636:
2637: /* {{{ proto bool mysql_free_result(resource result)
2638: Free result memory */
2639: PHP_FUNCTION(mysql_free_result)
2640: {
2641: zval *result;
2642: MYSQL_RES *mysql_result;
2643:
2644: if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &result) == FAILURE) {
2645: return;
2646: }
2647:
2648: if (Z_LVAL_P(result)==0) {
2649: RETURN_FALSE;
2650: }
2651:
2652: ZEND_FETCH_RESOURCE(mysql_result, MYSQL_RES *, &result, -1, "MySQL result", le_result);
2653:
2654: zend_list_delete(Z_LVAL_P(result));
2655: RETURN_TRUE;
2656: }
2657: /* }}} */
2658:
2659: /* {{{ proto bool mysql_ping([int link_identifier])
2660: Ping a server connection. If no connection then reconnect. */
2661: PHP_FUNCTION(mysql_ping)
2662: {
2663: zval *mysql_link = NULL;
2664: int id = -1;
2665: php_mysql_conn *mysql;
2666:
2667: if (0 == ZEND_NUM_ARGS()) {
2668: id = php_mysql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
2669: CHECK_LINK(id);
2670: } else if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &mysql_link)==FAILURE) {
2671: return;
2672: }
2673:
2674: ZEND_FETCH_RESOURCE2(mysql, php_mysql_conn *, &mysql_link, id, "MySQL-Link", le_link, le_plink);
2675:
2676: PHPMY_UNBUFFERED_QUERY_CHECK();
2677:
2678: RETURN_BOOL(! mysql_ping(mysql->conn));
2679: }
2680: /* }}} */
2681:
2682: #endif
2683:
2684: /*
2685: * Local variables:
2686: * tab-width: 4
2687: * c-basic-offset: 4
2688: * End:
2689: * vim600: sw=4 ts=4 fdm=marker
2690: * vim<600: sw=4 ts=4
2691: */
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