1 : /*
2 : +----------------------------------------------------------------------+
3 : | PHP Version 6 |
4 : +----------------------------------------------------------------------+
5 : | Copyright (c) 1997-2009 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: Georg Richter <georg@php.net> |
16 : | Andrey Hristov <andrey@php.net> |
17 : | Ulf Wendel <uw@php.net> |
18 : +----------------------------------------------------------------------+
19 :
20 : $Id: mysqli.c 289672 2009-10-15 15:49:40Z uw $
21 : */
22 :
23 : #ifdef HAVE_CONFIG_H
24 : #include "config.h"
25 : #endif
26 :
27 : #include <signal.h>
28 :
29 : #include "php.h"
30 : #include "php_ini.h"
31 : #include "ext/standard/info.h"
32 : #include "ext/standard/php_string.h"
33 : #include "php_mysqli_structs.h"
34 : #include "zend_exceptions.h"
35 : #include "ext/mysqlnd/mysqlnd_portability.h"
36 :
37 : ZEND_DECLARE_MODULE_GLOBALS(mysqli)
38 : static PHP_GINIT_FUNCTION(mysqli);
39 :
40 : #define MYSQLI_ADD_PROPERTIES(a,b) \
41 : { \
42 : int i = 0; \
43 : while (b[i].pname != NULL) { \
44 : mysqli_add_property((a), (b)[i].pname, (b)[i].pname_length, \
45 : (mysqli_read_t)(b)[i].r_func, (mysqli_write_t)(b)[i].w_func TSRMLS_CC); \
46 : i++; \
47 : }\
48 : }
49 :
50 : #define MYSQLI_ADD_PROPERTIES_INFO(a,b) \
51 : { \
52 : int i = 0; \
53 : while (b[i].name.s != NULL) { \
54 : zend_declare_property_null((a), (b)[i].name.s, (b)[i].name_length, ZEND_ACC_PUBLIC TSRMLS_CC); \
55 : i++; \
56 : }\
57 : }
58 :
59 :
60 :
61 : static zend_object_handlers mysqli_object_handlers;
62 : static HashTable classes;
63 : static HashTable mysqli_driver_properties;
64 : static HashTable mysqli_link_properties;
65 : static HashTable mysqli_result_properties;
66 : static HashTable mysqli_stmt_properties;
67 : static HashTable mysqli_warning_properties;
68 :
69 : zend_class_entry *mysqli_link_class_entry;
70 : zend_class_entry *mysqli_stmt_class_entry;
71 : zend_class_entry *mysqli_result_class_entry;
72 : zend_class_entry *mysqli_driver_class_entry;
73 : zend_class_entry *mysqli_warning_class_entry;
74 : zend_class_entry *mysqli_exception_class_entry;
75 :
76 : #ifdef MYSQLI_USE_MYSQLND
77 : MYSQLND_ZVAL_PCACHE *mysqli_mysqlnd_zval_cache;
78 : MYSQLND_QCACHE *mysqli_mysqlnd_qcache;
79 : #endif
80 :
81 :
82 : typedef int (*mysqli_read_t)(mysqli_object *obj, zval **retval TSRMLS_DC);
83 : typedef int (*mysqli_write_t)(mysqli_object *obj, zval *newval TSRMLS_DC);
84 :
85 : typedef struct _mysqli_prop_handler {
86 : char *name;
87 : size_t name_len;
88 : mysqli_read_t read_func;
89 : mysqli_write_t write_func;
90 : } mysqli_prop_handler;
91 :
92 : static int le_pmysqli;
93 :
94 :
95 : /* Destructor for mysqli entries in free_links/used_links */
96 : void php_mysqli_dtor_p_elements(void *data)
97 34 : {
98 34 : MYSQL *mysql = (MYSQL *) data;
99 : TSRMLS_FETCH();
100 :
101 34 : mysqli_close(mysql, MYSQLI_CLOSE_IMPLICIT);
102 34 : }
103 :
104 :
105 : ZEND_RSRC_DTOR_FUNC(php_mysqli_dtor)
106 11 : {
107 11 : if (rsrc->ptr) {
108 11 : mysqli_plist_entry *plist = (mysqli_plist_entry *) rsrc->ptr;
109 11 : zend_ptr_stack_clean(&plist->free_links, php_mysqli_dtor_p_elements, 0);
110 11 : zend_ptr_stack_destroy(&plist->free_links);
111 11 : free(plist);
112 : }
113 11 : }
114 :
115 :
116 : int php_le_pmysqli(void)
117 486 : {
118 486 : return le_pmysqli;
119 : }
120 :
121 : #ifndef MYSQLI_USE_MYSQLND
122 : /* {{{ php_free_stmt_bind_buffer */
123 : void php_free_stmt_bind_buffer(BIND_BUFFER bbuf, int type)
124 : {
125 : unsigned int i;
126 :
127 : if (!bbuf.var_cnt) {
128 : return;
129 : }
130 :
131 : for (i=0; i < bbuf.var_cnt; i++) {
132 :
133 : /* free temporary bind buffer */
134 : if (type == FETCH_RESULT && bbuf.buf[i].val) {
135 : efree(bbuf.buf[i].val);
136 : }
137 :
138 : if (bbuf.vars[i]) {
139 : zval_ptr_dtor(&bbuf.vars[i]);
140 : }
141 : }
142 :
143 : if (bbuf.vars) {
144 : efree(bbuf.vars);
145 : }
146 :
147 : /*
148 : Don't free bbuf.is_null for FETCH_RESULT since we have allocated
149 : is_null and buf in one block so we free only buf, which is the beginning
150 : of the block. When FETCH_SIMPLE then buf wasn't allocated together with
151 : buf and we have to free it.
152 : */
153 : if (type == FETCH_RESULT) {
154 : efree(bbuf.buf);
155 : } else if (type == FETCH_SIMPLE){
156 : efree(bbuf.is_null);
157 : }
158 :
159 : bbuf.var_cnt = 0;
160 : }
161 : /* }}} */
162 : #endif
163 :
164 : /* {{{ php_clear_stmt_bind */
165 : void php_clear_stmt_bind(MY_STMT *stmt TSRMLS_DC)
166 914 : {
167 914 : if (stmt->stmt) {
168 32 : if (mysqli_stmt_close(stmt->stmt, TRUE)) {
169 0 : php_error_docref(NULL TSRMLS_CC, E_WARNING, "Error occured while closing statement");
170 0 : return;
171 : }
172 : }
173 :
174 : /*
175 : mysqlnd keeps track of the binding and has freed its
176 : structures in stmt_close() above
177 : */
178 : #ifndef MYSQLI_USE_MYSQLND
179 : /* Clean param bind */
180 : php_free_stmt_bind_buffer(stmt->param, FETCH_SIMPLE);
181 : /* Clean output bind */
182 : php_free_stmt_bind_buffer(stmt->result, FETCH_RESULT);
183 : #endif
184 :
185 914 : if (stmt->query) {
186 0 : efree(stmt->query);
187 : }
188 914 : efree(stmt);
189 : }
190 : /* }}} */
191 :
192 : /* {{{ php_clear_mysql */
193 1181 : void php_clear_mysql(MY_MYSQL *mysql) {
194 1181 : if (mysql->hash_key) {
195 81 : efree(mysql->hash_key);
196 81 : mysql->hash_key = NULL;
197 : }
198 1181 : if (mysql->li_read) {
199 0 : zval_ptr_dtor(&(mysql->li_read));
200 0 : mysql->li_read = NULL;
201 : }
202 1181 : }
203 : /* }}} */
204 :
205 : /* {{{ mysqli_objects_free_storage
206 : */
207 : static void mysqli_objects_free_storage(void *object TSRMLS_DC)
208 7031 : {
209 7031 : zend_object *zo = (zend_object *)object;
210 7031 : mysqli_object *intern = (mysqli_object *)zo;
211 7031 : MYSQLI_RESOURCE *my_res = (MYSQLI_RESOURCE *)intern->ptr;
212 :
213 7031 : my_efree(my_res);
214 7031 : zend_object_std_dtor(&intern->zo TSRMLS_CC);
215 7031 : efree(intern);
216 7031 : }
217 : /* }}} */
218 :
219 : /* mysqli_link_free_storage partly doubles the work of PHP_FUNCTION(mysqli_close) */
220 :
221 : /* {{{ mysqli_link_free_storage
222 : */
223 : static void mysqli_link_free_storage(void *object TSRMLS_DC)
224 1066 : {
225 1066 : zend_object *zo = (zend_object *)object;
226 1066 : mysqli_object *intern = (mysqli_object *)zo;
227 1066 : MYSQLI_RESOURCE *my_res = (MYSQLI_RESOURCE *)intern->ptr;
228 :
229 1066 : if (my_res && my_res->ptr) {
230 113 : MY_MYSQL *mysql = (MY_MYSQL *)my_res->ptr;
231 113 : if (mysql->mysql) {
232 113 : php_mysqli_close(mysql, MYSQLI_CLOSE_EXPLICIT TSRMLS_CC);
233 : }
234 113 : php_clear_mysql(mysql);
235 113 : efree(mysql);
236 : }
237 1066 : mysqli_objects_free_storage(object TSRMLS_CC);
238 1066 : }
239 : /* }}} */
240 :
241 : /* {{{ mysql_driver_free_storage */
242 : static void mysqli_driver_free_storage(void *object TSRMLS_DC)
243 1063 : {
244 1063 : mysqli_objects_free_storage(object TSRMLS_CC);
245 1063 : }
246 : /* }}} */
247 :
248 : /* {{{ mysqli_stmt_free_storage
249 : */
250 : static void mysqli_stmt_free_storage(void *object TSRMLS_DC)
251 917 : {
252 917 : zend_object *zo = (zend_object *)object;
253 917 : mysqli_object *intern = (mysqli_object *)zo;
254 917 : MYSQLI_RESOURCE *my_res = (MYSQLI_RESOURCE *)intern->ptr;
255 :
256 917 : if (my_res && my_res->ptr) {
257 32 : MY_STMT *stmt = (MY_STMT *)my_res->ptr;
258 32 : php_clear_stmt_bind(stmt TSRMLS_CC);
259 : }
260 917 : mysqli_objects_free_storage(object TSRMLS_CC);
261 917 : }
262 : /* }}} */
263 :
264 : /* {{{ mysqli_result_free_storage
265 : */
266 : static void mysqli_result_free_storage(void *object TSRMLS_DC)
267 3981 : {
268 3981 : zend_object *zo = (zend_object *)object;
269 3981 : mysqli_object *intern = (mysqli_object *)zo;
270 3981 : MYSQLI_RESOURCE *my_res = (MYSQLI_RESOURCE *)intern->ptr;
271 :
272 3981 : if (my_res && my_res->ptr) {
273 1108 : mysql_free_result(my_res->ptr);
274 : }
275 3981 : mysqli_objects_free_storage(object TSRMLS_CC);
276 3981 : }
277 : /* }}} */
278 :
279 : /* {{{ mysqli_warning_free_storage
280 : */
281 : static void mysqli_warning_free_storage(void *object TSRMLS_DC)
282 4 : {
283 4 : zend_object *zo = (zend_object *)object;
284 4 : mysqli_object *intern = (mysqli_object *)zo;
285 4 : MYSQLI_RESOURCE *my_res = (MYSQLI_RESOURCE *)intern->ptr;
286 :
287 4 : if (my_res && my_res->ptr) {
288 4 : php_clear_warnings((MYSQLI_WARNING *)my_res->info);
289 4 : my_res->ptr = NULL;
290 : }
291 4 : mysqli_objects_free_storage(object TSRMLS_CC);
292 4 : }
293 : /* }}} */
294 :
295 : /* {{{ mysqli_read_na */
296 : static int mysqli_read_na(mysqli_object *obj, zval **retval TSRMLS_DC)
297 0 : {
298 0 : *retval = NULL;
299 0 : php_error_docref(NULL TSRMLS_CC, E_ERROR, "Cannot read property");
300 0 : return FAILURE;
301 : }
302 : /* }}} */
303 :
304 : /* {{{ mysqli_write_na */
305 : static int mysqli_write_na(mysqli_object *obj, zval *newval TSRMLS_DC)
306 0 : {
307 0 : php_error_docref(NULL TSRMLS_CC, E_ERROR, "Cannot write property");
308 0 : return FAILURE;
309 : }
310 : /* }}} */
311 :
312 : /* {{{ mysqli_read_property */
313 : zval *mysqli_read_property(zval *object, zval *member, int type TSRMLS_DC)
314 549 : {
315 : zval tmp_member;
316 : zval *retval;
317 : mysqli_object *obj;
318 : mysqli_prop_handler *hnd;
319 : int ret;
320 :
321 549 : ret = FAILURE;
322 549 : obj = (mysqli_object *)zend_objects_get_address(object TSRMLS_CC);
323 :
324 549 : if (member->type != IS_STRING && member->type != IS_UNICODE) {
325 0 : tmp_member = *member;
326 0 : zval_copy_ctor(&tmp_member);
327 0 : convert_to_unicode(&tmp_member);
328 0 : member = &tmp_member;
329 : }
330 :
331 549 : if (obj->prop_handler != NULL) {
332 549 : ret = zend_u_hash_find(obj->prop_handler, IS_UNICODE, Z_UNIVAL_P(member), Z_UNILEN_P(member)+1, (void **) &hnd);
333 : }
334 :
335 549 : if (ret == SUCCESS) {
336 540 : ret = hnd->read_func(obj, &retval TSRMLS_CC);
337 540 : if (ret == SUCCESS) {
338 : /* ensure we're creating a temporary variable */
339 540 : Z_SET_REFCOUNT_P(retval, 0);
340 : } else {
341 0 : retval = EG(uninitialized_zval_ptr);
342 : }
343 : } else {
344 9 : zend_object_handlers * std_hnd = zend_get_std_object_handlers();
345 9 : retval = std_hnd->read_property(object, member, type TSRMLS_CC);
346 : }
347 :
348 549 : if (member == &tmp_member) {
349 0 : zval_dtor(member);
350 : }
351 549 : return(retval);
352 : }
353 : /* }}} */
354 :
355 : /* {{{ mysqli_write_property */
356 : void mysqli_write_property(zval *object, zval *member, zval *value TSRMLS_DC)
357 11 : {
358 : zval tmp_member;
359 : mysqli_object *obj;
360 : mysqli_prop_handler *hnd;
361 : int ret;
362 :
363 11 : if (member->type != IS_STRING) {
364 11 : tmp_member = *member;
365 11 : zval_copy_ctor(&tmp_member);
366 11 : convert_to_string(&tmp_member);
367 11 : member = &tmp_member;
368 : }
369 :
370 11 : ret = FAILURE;
371 11 : obj = (mysqli_object *)zend_objects_get_address(object TSRMLS_CC);
372 :
373 11 : if (obj->prop_handler != NULL) {
374 11 : ret = zend_u_hash_find((HashTable *)obj->prop_handler, Z_TYPE_P(member), Z_UNIVAL_P(member), Z_UNILEN_P(member)+1, (void **) &hnd);
375 : }
376 11 : if (ret == SUCCESS) {
377 8 : hnd->write_func(obj, value TSRMLS_CC);
378 8 : if (! PZVAL_IS_REF(value) && Z_REFCOUNT_P(value) == 0) {
379 0 : Z_ADDREF_P(value);
380 0 : zval_ptr_dtor(&value);
381 : }
382 : } else {
383 3 : zend_object_handlers * std_hnd = zend_get_std_object_handlers();
384 3 : std_hnd->write_property(object, member, value TSRMLS_CC);
385 : }
386 :
387 11 : if (member == &tmp_member) {
388 11 : zval_dtor(member);
389 : }
390 11 : }
391 : /* }}} */
392 :
393 : /* {{{ void mysqli_add_property(HashTable *h, const char *pname, size_t pname_len, mysqli_read_t r_func, mysqli_write_t w_func TSRMLS_DC) */
394 680280 : void mysqli_add_property(HashTable *h, const char *pname, size_t pname_len, mysqli_read_t r_func, mysqli_write_t w_func TSRMLS_DC) {
395 : mysqli_prop_handler p;
396 :
397 680280 : p.name = (char*) pname;
398 680280 : p.name_len = pname_len;
399 680280 : p.read_func = (r_func) ? r_func : mysqli_read_na;
400 680280 : p.write_func = (w_func) ? w_func : mysqli_write_na;
401 680280 : zend_ascii_hash_add(h, pname, pname_len + 1, &p, sizeof(mysqli_prop_handler), NULL);
402 680280 : }
403 : /* }}} */
404 :
405 : static int mysqli_object_has_property(zval *object, zval *member, int has_set_exists TSRMLS_DC) /* {{{ */
406 1 : {
407 1 : mysqli_object *obj = (mysqli_object *)zend_objects_get_address(object TSRMLS_CC);
408 : mysqli_prop_handler p;
409 : zval tmp_member;
410 1 : int ret = 0;
411 :
412 1 : if (member->type != IS_STRING && member->type != IS_UNICODE) {
413 0 : tmp_member = *member;
414 0 : zval_copy_ctor(&tmp_member);
415 0 : convert_to_unicode(&tmp_member);
416 0 : member = &tmp_member;
417 : }
418 :
419 1 : if (zend_ascii_hash_find(obj->prop_handler, Z_STRVAL_P(member), Z_STRLEN_P(member) + 1, (void **)&p) == SUCCESS) {
420 0 : switch (has_set_exists) {
421 : case 2:
422 0 : ret = 1;
423 0 : break;
424 : case 1: {
425 0 : zval *value = mysqli_read_property(object, member, BP_VAR_IS TSRMLS_CC);
426 0 : if (value != EG(uninitialized_zval_ptr)) {
427 0 : convert_to_boolean(value);
428 0 : ret = Z_BVAL_P(value)? 1:0;
429 : /* refcount is 0 */
430 0 : Z_ADDREF_P(value);
431 0 : zval_ptr_dtor(&value);
432 : }
433 0 : break;
434 : }
435 : case 0:{
436 0 : zval *value = mysqli_read_property(object, member, BP_VAR_IS TSRMLS_CC);
437 0 : if (value != EG(uninitialized_zval_ptr)) {
438 0 : ret = Z_TYPE_P(value) != IS_NULL? 1:0;
439 : /* refcount is 0 */
440 0 : Z_ADDREF_P(value);
441 0 : zval_ptr_dtor(&value);
442 : }
443 0 : break;
444 : }
445 : default:
446 0 : php_error_docref(NULL TSRMLS_CC, E_WARNING, "Invalid value for has_set_exists");
447 : }
448 : } else {
449 1 : zend_object_handlers * std_hnd = zend_get_std_object_handlers();
450 1 : ret = std_hnd->has_property(object, member, has_set_exists TSRMLS_CC);
451 : }
452 1 : if (member == &tmp_member) {
453 0 : zval_dtor(member);
454 : }
455 :
456 1 : return ret;
457 : } /* }}} */
458 :
459 :
460 : HashTable * mysqli_object_get_debug_info(zval *object, int *is_temp TSRMLS_DC)
461 7 : {
462 7 : mysqli_object *obj = (mysqli_object *)zend_objects_get_address(object TSRMLS_CC);
463 7 : HashTable *retval, *props = obj->prop_handler;
464 : HashPosition pos;
465 : mysqli_prop_handler *entry;
466 :
467 7 : ALLOC_HASHTABLE(retval);
468 7 : ZEND_INIT_SYMTABLE_EX(retval, zend_hash_num_elements(props) + 1, 0);
469 :
470 7 : zend_hash_internal_pointer_reset_ex(props, &pos);
471 99 : while (zend_hash_get_current_data_ex(props, (void **)&entry, &pos) == SUCCESS) {
472 : zval member;
473 : zval *value;
474 85 : INIT_ZVAL(member);
475 85 : ZVAL_ASCII_STRINGL(&member, entry->name, entry->name_len, 0);
476 85 : value = mysqli_read_property(object, &member, BP_VAR_IS TSRMLS_CC);
477 85 : if (value != EG(uninitialized_zval_ptr)) {
478 85 : Z_ADDREF_P(value);
479 85 : zend_ascii_hash_add(retval, entry->name, entry->name_len + 1, &value, sizeof(zval *), NULL);
480 : }
481 85 : zend_hash_move_forward_ex(props, &pos);
482 85 : zval_dtor(&member);
483 : }
484 :
485 7 : *is_temp = 1;
486 7 : return retval;
487 : }
488 :
489 :
490 : /* {{{ mysqli_objects_new
491 : */
492 : PHP_MYSQLI_EXPORT(zend_object_value) mysqli_objects_new(zend_class_entry *class_type TSRMLS_DC)
493 7025 : {
494 : zend_object_value retval;
495 : mysqli_object *intern;
496 : zval *tmp;
497 : zend_class_entry *mysqli_base_class;
498 : zend_objects_free_object_storage_t free_storage;
499 :
500 7025 : intern = emalloc(sizeof(mysqli_object));
501 7025 : memset(intern, 0, sizeof(mysqli_object));
502 7025 : intern->ptr = NULL;
503 7025 : intern->prop_handler = NULL;
504 :
505 7025 : mysqli_base_class = class_type;
506 14102 : while (mysqli_base_class->type != ZEND_INTERNAL_CLASS &&
507 : mysqli_base_class->parent != NULL) {
508 52 : mysqli_base_class = mysqli_base_class->parent;
509 : }
510 :
511 7025 : zend_u_hash_find(&classes, IS_UNICODE, mysqli_base_class->name, mysqli_base_class->name_length + 1,
512 : (void **) &intern->prop_handler);
513 :
514 7025 : zend_object_std_init(&intern->zo, class_type TSRMLS_CC);
515 7025 : zend_hash_copy(intern->zo.properties, &class_type->default_properties, (copy_ctor_func_t) zval_add_ref,
516 : (void *) &tmp, sizeof(zval *));
517 :
518 : /* link object */
519 7025 : if (instanceof_function(class_type, mysqli_link_class_entry TSRMLS_CC)) {
520 1064 : free_storage = mysqli_link_free_storage;
521 5961 : } else if (instanceof_function(class_type, mysqli_driver_class_entry TSRMLS_CC)) { /* driver object */
522 1061 : free_storage = mysqli_driver_free_storage;
523 4900 : } else if (instanceof_function(class_type, mysqli_stmt_class_entry TSRMLS_CC)) { /* stmt object */
524 917 : free_storage = mysqli_stmt_free_storage;
525 3983 : } else if (instanceof_function(class_type, mysqli_result_class_entry TSRMLS_CC)) { /* result object */
526 3979 : free_storage = mysqli_result_free_storage;
527 4 : } else if (instanceof_function(class_type, mysqli_warning_class_entry TSRMLS_CC)) { /* warning object */
528 4 : free_storage = mysqli_warning_free_storage;
529 : } else {
530 0 : free_storage = mysqli_objects_free_storage;
531 : }
532 :
533 7025 : retval.handle = zend_objects_store_put(intern, (zend_objects_store_dtor_t) zend_objects_destroy_object, free_storage, NULL TSRMLS_CC);
534 7025 : retval.handlers = &mysqli_object_handlers;
535 :
536 7025 : return retval;
537 : }
538 : /* }}} */
539 :
540 :
541 : /* Dependancies */
542 : static const zend_module_dep mysqli_deps[] = {
543 : #if defined(HAVE_SPL) && ((PHP_MAJOR_VERSION > 5) || (PHP_MAJOR_VERSION == 5 && PHP_MINOR_VERSION >= 1))
544 : ZEND_MOD_REQUIRED("spl")
545 : #endif
546 : #if defined(MYSQLI_USE_MYSQLND)
547 : ZEND_MOD_REQUIRED("mysqlnd")
548 : #endif
549 : {NULL, NULL, NULL}
550 : };
551 :
552 : /* {{{ mysqli_module_entry
553 : */
554 : zend_module_entry mysqli_module_entry = {
555 : #if ZEND_MODULE_API_NO >= 20050922
556 : STANDARD_MODULE_HEADER_EX, NULL,
557 : mysqli_deps,
558 : #elif ZEND_MODULE_API_NO >= 20010901
559 : STANDARD_MODULE_HEADER,
560 : #endif
561 : "mysqli",
562 : mysqli_functions,
563 : PHP_MINIT(mysqli),
564 : PHP_MSHUTDOWN(mysqli),
565 : PHP_RINIT(mysqli),
566 : PHP_RSHUTDOWN(mysqli),
567 : PHP_MINFO(mysqli),
568 : "0.1", /* Replace with version number for your extension */
569 : PHP_MODULE_GLOBALS(mysqli),
570 : PHP_GINIT(mysqli),
571 : NULL,
572 : NULL,
573 : STANDARD_MODULE_PROPERTIES_EX
574 : };
575 : /* }}} */
576 :
577 : #ifdef COMPILE_DL_MYSQLI
578 : ZEND_GET_MODULE(mysqli)
579 : #endif
580 :
581 : /* {{{ PHP_INI_BEGIN
582 : */
583 : PHP_INI_BEGIN()
584 : STD_PHP_INI_ENTRY_EX("mysqli.max_links", "-1", PHP_INI_SYSTEM, OnUpdateLong, max_links, zend_mysqli_globals, mysqli_globals, display_link_numbers)
585 : STD_PHP_INI_ENTRY_EX("mysqli.max_persistent", "-1", PHP_INI_SYSTEM, OnUpdateLong, max_persistent, zend_mysqli_globals, mysqli_globals, display_link_numbers)
586 : STD_PHP_INI_BOOLEAN("mysqli.allow_persistent", "1", PHP_INI_SYSTEM, OnUpdateLong, allow_persistent, zend_mysqli_globals, mysqli_globals)
587 : STD_PHP_INI_ENTRY("mysqli.default_host", NULL, PHP_INI_ALL, OnUpdateString, default_host, zend_mysqli_globals, mysqli_globals)
588 : STD_PHP_INI_ENTRY("mysqli.default_user", NULL, PHP_INI_ALL, OnUpdateString, default_user, zend_mysqli_globals, mysqli_globals)
589 : STD_PHP_INI_ENTRY("mysqli.default_pw", NULL, PHP_INI_ALL, OnUpdateString, default_pw, zend_mysqli_globals, mysqli_globals)
590 : STD_PHP_INI_ENTRY("mysqli.default_port", "3306", PHP_INI_ALL, OnUpdateLong, default_port, zend_mysqli_globals, mysqli_globals)
591 : #ifdef PHP_MYSQL_UNIX_SOCK_ADDR
592 : STD_PHP_INI_ENTRY("mysqli.default_socket", MYSQL_UNIX_ADDR,PHP_INI_ALL,OnUpdateStringUnempty, default_socket, zend_mysqli_globals, mysqli_globals)
593 : #else
594 : STD_PHP_INI_ENTRY("mysqli.default_socket", NULL, PHP_INI_ALL, OnUpdateStringUnempty, default_socket, zend_mysqli_globals, mysqli_globals)
595 : #endif
596 : STD_PHP_INI_BOOLEAN("mysqli.reconnect", "0", PHP_INI_SYSTEM, OnUpdateLong, reconnect, zend_mysqli_globals, mysqli_globals)
597 : STD_PHP_INI_BOOLEAN("mysqli.allow_local_infile", "1", PHP_INI_SYSTEM, OnUpdateLong, allow_local_infile, zend_mysqli_globals, mysqli_globals)
598 : #ifdef MYSQLI_USE_MYSQLND
599 : STD_PHP_INI_ENTRY("mysqli.cache_size", "2000", PHP_INI_SYSTEM, OnUpdateLong, cache_size, zend_mysqli_globals, mysqli_globals)
600 : #endif
601 : PHP_INI_END()
602 : /* }}} */
603 :
604 :
605 : /* {{{ PHP_GINIT_FUNCTION
606 : */
607 : static PHP_GINIT_FUNCTION(mysqli)
608 17007 : {
609 17007 : mysqli_globals->num_links = 0;
610 17007 : mysqli_globals->num_active_persistent = 0;
611 17007 : mysqli_globals->num_inactive_persistent = 0;
612 17007 : mysqli_globals->max_links = -1;
613 17007 : mysqli_globals->max_persistent = -1;
614 17007 : mysqli_globals->allow_persistent = 1;
615 17007 : mysqli_globals->default_port = 0;
616 17007 : mysqli_globals->default_host = NULL;
617 17007 : mysqli_globals->default_user = NULL;
618 17007 : mysqli_globals->default_pw = NULL;
619 17007 : mysqli_globals->default_socket = NULL;
620 17007 : mysqli_globals->reconnect = 0;
621 17007 : mysqli_globals->report_mode = 0;
622 17007 : mysqli_globals->report_ht = 0;
623 17007 : mysqli_globals->allow_local_infile = 1;
624 : #ifdef HAVE_EMBEDDED_MYSQLI
625 : mysqli_globals->embedded = 1;
626 : #else
627 17007 : mysqli_globals->embedded = 0;
628 : #endif
629 : #ifdef MYSQLI_USE_MYSQLND
630 17007 : mysqli_globals->cache_size = 0;
631 17007 : mysqli_globals->mysqlnd_thd_zval_cache = NULL;
632 : #endif
633 17007 : }
634 : /* }}} */
635 :
636 : /* {{{ PHP_MINIT_FUNCTION
637 : */
638 : PHP_MINIT_FUNCTION(mysqli)
639 17007 : {
640 : zend_class_entry *ce,cex;
641 17007 : zend_object_handlers *std_hnd = zend_get_std_object_handlers();
642 :
643 17007 : REGISTER_INI_ENTRIES();
644 : #ifndef MYSQLI_USE_MYSQLND
645 : #if MYSQL_VERSION_ID >= 40000
646 : if (mysql_server_init(0, NULL, NULL)) {
647 : return FAILURE;
648 : }
649 : #endif
650 : #else
651 17007 : mysqli_mysqlnd_zval_cache = mysqlnd_palloc_init_cache(MyG(cache_size));
652 17007 : mysqli_mysqlnd_qcache = mysqlnd_qcache_init_cache();
653 : #endif
654 :
655 17007 : memcpy(&mysqli_object_handlers, zend_get_std_object_handlers(), sizeof(zend_object_handlers));
656 17007 : mysqli_object_handlers.clone_obj = NULL;
657 17007 : mysqli_object_handlers.read_property = mysqli_read_property;
658 17007 : mysqli_object_handlers.write_property = mysqli_write_property;
659 17007 : mysqli_object_handlers.get_property_ptr_ptr = std_hnd->get_property_ptr_ptr;
660 17007 : mysqli_object_handlers.has_property = mysqli_object_has_property;
661 17007 : mysqli_object_handlers.get_debug_info = mysqli_object_get_debug_info;
662 :
663 17007 : zend_u_hash_init(&classes, 0, NULL, NULL, 1, 1);
664 :
665 : /* persistent connections */
666 17007 : le_pmysqli = zend_register_list_destructors_ex(NULL, php_mysqli_dtor,
667 : "MySqli persistent connection", module_number);
668 :
669 17007 : INIT_CLASS_ENTRY(cex, "mysqli_sql_exception", mysqli_exception_methods);
670 : #ifdef HAVE_SPL
671 17007 : mysqli_exception_class_entry = zend_register_internal_class_ex(&cex, spl_ce_RuntimeException, NULL TSRMLS_CC);
672 : #else
673 : mysqli_exception_class_entry = zend_register_internal_class_ex(&cex, zend_exception_get_default(TSRMLS_C), NULL TSRMLS_CC);
674 : #endif
675 17007 : mysqli_exception_class_entry->ce_flags |= ZEND_ACC_FINAL;
676 17007 : zend_declare_property_long(mysqli_exception_class_entry, "code", sizeof("code")-1, 0, ZEND_ACC_PROTECTED TSRMLS_CC);
677 17007 : zend_declare_property_string(mysqli_exception_class_entry, "sqlstate", sizeof("sqlstate")-1, "00000", ZEND_ACC_PROTECTED TSRMLS_CC);
678 :
679 17007 : REGISTER_MYSQLI_CLASS_ENTRY("mysqli_driver", mysqli_driver_class_entry, mysqli_driver_methods);
680 17007 : ce = mysqli_driver_class_entry;
681 17007 : zend_u_hash_init(&mysqli_driver_properties, 0, NULL, NULL, 1, 1);
682 17007 : MYSQLI_ADD_PROPERTIES(&mysqli_driver_properties, mysqli_driver_property_entries);
683 17007 : MYSQLI_ADD_PROPERTIES_INFO(ce, mysqli_driver_property_info_entries);
684 17007 : zend_u_hash_add(&classes, IS_UNICODE, ce->name, ce->name_length+1, &mysqli_driver_properties, sizeof(mysqli_driver_properties), NULL);
685 17007 : ce->ce_flags |= ZEND_ACC_FINAL_CLASS;
686 :
687 17007 : REGISTER_MYSQLI_CLASS_ENTRY("mysqli", mysqli_link_class_entry, mysqli_link_methods);
688 17007 : ce = mysqli_link_class_entry;
689 17007 : zend_u_hash_init(&mysqli_link_properties, 0, NULL, NULL, 1, 1);
690 17007 : MYSQLI_ADD_PROPERTIES(&mysqli_link_properties, mysqli_link_property_entries);
691 17007 : MYSQLI_ADD_PROPERTIES_INFO(ce, mysqli_link_property_info_entries);
692 17007 : zend_u_hash_add(&classes, IS_UNICODE, ce->name, ce->name_length+1, &mysqli_link_properties, sizeof(mysqli_link_properties), NULL);
693 :
694 17007 : REGISTER_MYSQLI_CLASS_ENTRY("mysqli_warning", mysqli_warning_class_entry, mysqli_warning_methods);
695 17007 : ce = mysqli_warning_class_entry;
696 17007 : ce->ce_flags |= ZEND_ACC_FINAL_CLASS | ZEND_ACC_PROTECTED;
697 17007 : zend_u_hash_init(&mysqli_warning_properties, 0, NULL, NULL, 1, 1);
698 17007 : MYSQLI_ADD_PROPERTIES(&mysqli_warning_properties, mysqli_warning_property_entries);
699 17007 : MYSQLI_ADD_PROPERTIES_INFO(ce, mysqli_warning_property_info_entries);
700 17007 : zend_u_hash_add(&classes, IS_UNICODE, ce->name, ce->name_length+1, &mysqli_warning_properties, sizeof(mysqli_warning_properties), NULL);
701 :
702 17007 : REGISTER_MYSQLI_CLASS_ENTRY("mysqli_result", mysqli_result_class_entry, mysqli_result_methods);
703 17007 : ce = mysqli_result_class_entry;
704 17007 : zend_u_hash_init(&mysqli_result_properties, 0, NULL, NULL, 1, 1);
705 17007 : MYSQLI_ADD_PROPERTIES(&mysqli_result_properties, mysqli_result_property_entries);
706 17007 : MYSQLI_ADD_PROPERTIES_INFO(ce, mysqli_result_property_info_entries);
707 17007 : zend_u_hash_add(&classes, IS_UNICODE, ce->name, ce->name_length+1, &mysqli_result_properties, sizeof(mysqli_result_properties), NULL);
708 :
709 17007 : REGISTER_MYSQLI_CLASS_ENTRY("mysqli_stmt", mysqli_stmt_class_entry, mysqli_stmt_methods);
710 17007 : ce = mysqli_stmt_class_entry;
711 17007 : zend_u_hash_init(&mysqli_stmt_properties, 0, NULL, NULL, 1, 1);
712 17007 : MYSQLI_ADD_PROPERTIES(&mysqli_stmt_properties, mysqli_stmt_property_entries);
713 17007 : MYSQLI_ADD_PROPERTIES_INFO(ce, mysqli_stmt_property_info_entries);
714 17007 : zend_u_hash_add(&classes, IS_UNICODE, ce->name, ce->name_length+1, &mysqli_stmt_properties, sizeof(mysqli_stmt_properties), NULL);
715 :
716 :
717 : /* mysqli_options */
718 17007 : REGISTER_LONG_CONSTANT("MYSQLI_READ_DEFAULT_GROUP", MYSQL_READ_DEFAULT_GROUP, CONST_CS | CONST_PERSISTENT);
719 17007 : REGISTER_LONG_CONSTANT("MYSQLI_READ_DEFAULT_FILE", MYSQL_READ_DEFAULT_FILE, CONST_CS | CONST_PERSISTENT);
720 17007 : REGISTER_LONG_CONSTANT("MYSQLI_OPT_CONNECT_TIMEOUT", MYSQL_OPT_CONNECT_TIMEOUT, CONST_CS | CONST_PERSISTENT);
721 17007 : REGISTER_LONG_CONSTANT("MYSQLI_OPT_LOCAL_INFILE", MYSQL_OPT_LOCAL_INFILE, CONST_CS | CONST_PERSISTENT);
722 17007 : REGISTER_LONG_CONSTANT("MYSQLI_INIT_COMMAND", MYSQL_INIT_COMMAND, CONST_CS | CONST_PERSISTENT);
723 : #if defined(MYSQLI_USE_MYSQLND)
724 17007 : REGISTER_LONG_CONSTANT("MYSQLI_OPT_NUMERIC_AND_DATETIME_AS_UNICODE", MYSQLND_OPT_NUMERIC_AND_DATETIME_AS_UNICODE, CONST_CS | CONST_PERSISTENT);
725 17007 : REGISTER_LONG_CONSTANT("MYSQLI_OPT_NET_CMD_BUFFER_SIZE", MYSQLND_OPT_NET_CMD_BUFFER_SIZE, CONST_CS | CONST_PERSISTENT);
726 17007 : REGISTER_LONG_CONSTANT("MYSQLI_OPT_NET_READ_BUFFER_SIZE", MYSQLND_OPT_NET_READ_BUFFER_SIZE, CONST_CS | CONST_PERSISTENT);
727 : #endif
728 : #ifdef MYSQLND_STRING_TO_INT_CONVERSION
729 17007 : REGISTER_LONG_CONSTANT("MYSQLI_OPT_INT_AND_FLOAT_NATIVE", MYSQLND_OPT_INT_AND_FLOAT_NATIVE, CONST_CS | CONST_PERSISTENT);
730 : #endif
731 :
732 : /* mysqli_real_connect flags */
733 17007 : REGISTER_LONG_CONSTANT("MYSQLI_CLIENT_SSL", CLIENT_SSL, CONST_CS | CONST_PERSISTENT);
734 17007 : REGISTER_LONG_CONSTANT("MYSQLI_CLIENT_COMPRESS",CLIENT_COMPRESS, CONST_CS | CONST_PERSISTENT);
735 17007 : REGISTER_LONG_CONSTANT("MYSQLI_CLIENT_INTERACTIVE", CLIENT_INTERACTIVE, CONST_CS | CONST_PERSISTENT);
736 17007 : REGISTER_LONG_CONSTANT("MYSQLI_CLIENT_IGNORE_SPACE", CLIENT_IGNORE_SPACE, CONST_CS | CONST_PERSISTENT);
737 17007 : REGISTER_LONG_CONSTANT("MYSQLI_CLIENT_NO_SCHEMA", CLIENT_NO_SCHEMA, CONST_CS | CONST_PERSISTENT);
738 17007 : REGISTER_LONG_CONSTANT("MYSQLI_CLIENT_FOUND_ROWS", CLIENT_FOUND_ROWS, CONST_CS | CONST_PERSISTENT);
739 :
740 : /* for mysqli_query */
741 17007 : REGISTER_LONG_CONSTANT("MYSQLI_STORE_RESULT", MYSQLI_STORE_RESULT, CONST_CS | CONST_PERSISTENT);
742 17007 : REGISTER_LONG_CONSTANT("MYSQLI_USE_RESULT", MYSQLI_USE_RESULT, CONST_CS | CONST_PERSISTENT);
743 : #if defined(MYSQLI_USE_MYSQLND) && defined(MYSQLND_THREADED)
744 : REGISTER_LONG_CONSTANT("MYSQLI_BG_STORE_RESULT", MYSQLI_BG_STORE_RESULT, CONST_CS | CONST_PERSISTENT);
745 : #endif
746 : #if defined (MYSQLI_USE_MYSQLND)
747 17007 : REGISTER_LONG_CONSTANT("MYSQLI_ASYNC", MYSQLI_ASYNC, CONST_CS | CONST_PERSISTENT);
748 : #endif
749 :
750 : /* for mysqli_fetch_assoc */
751 17007 : REGISTER_LONG_CONSTANT("MYSQLI_ASSOC", MYSQLI_ASSOC, CONST_CS | CONST_PERSISTENT);
752 17007 : REGISTER_LONG_CONSTANT("MYSQLI_NUM", MYSQLI_NUM, CONST_CS | CONST_PERSISTENT);
753 17007 : REGISTER_LONG_CONSTANT("MYSQLI_BOTH", MYSQLI_BOTH, CONST_CS | CONST_PERSISTENT);
754 :
755 : /* for mysqli_stmt_set_attr */
756 17007 : REGISTER_LONG_CONSTANT("MYSQLI_STMT_ATTR_UPDATE_MAX_LENGTH", STMT_ATTR_UPDATE_MAX_LENGTH, CONST_CS | CONST_PERSISTENT);
757 :
758 : #if MYSQL_VERSION_ID > 50003 || defined(MYSQLI_USE_MYSQLND)
759 17007 : REGISTER_LONG_CONSTANT("MYSQLI_STMT_ATTR_CURSOR_TYPE", STMT_ATTR_CURSOR_TYPE, CONST_CS | CONST_PERSISTENT);
760 17007 : REGISTER_LONG_CONSTANT("MYSQLI_CURSOR_TYPE_NO_CURSOR", CURSOR_TYPE_NO_CURSOR, CONST_CS | CONST_PERSISTENT);
761 17007 : REGISTER_LONG_CONSTANT("MYSQLI_CURSOR_TYPE_READ_ONLY", CURSOR_TYPE_READ_ONLY, CONST_CS | CONST_PERSISTENT);
762 17007 : REGISTER_LONG_CONSTANT("MYSQLI_CURSOR_TYPE_FOR_UPDATE", CURSOR_TYPE_FOR_UPDATE, CONST_CS | CONST_PERSISTENT);
763 17007 : REGISTER_LONG_CONSTANT("MYSQLI_CURSOR_TYPE_SCROLLABLE", CURSOR_TYPE_SCROLLABLE, CONST_CS | CONST_PERSISTENT);
764 : #endif
765 :
766 : #if MYSQL_VERSION_ID > 50007 || defined(MYSQLI_USE_MYSQLND)
767 17007 : REGISTER_LONG_CONSTANT("MYSQLI_STMT_ATTR_PREFETCH_ROWS", STMT_ATTR_PREFETCH_ROWS, CONST_CS | CONST_PERSISTENT);
768 : #endif
769 :
770 : /* column information */
771 17007 : REGISTER_LONG_CONSTANT("MYSQLI_NOT_NULL_FLAG", NOT_NULL_FLAG, CONST_CS | CONST_PERSISTENT);
772 17007 : REGISTER_LONG_CONSTANT("MYSQLI_PRI_KEY_FLAG", PRI_KEY_FLAG, CONST_CS | CONST_PERSISTENT);
773 17007 : REGISTER_LONG_CONSTANT("MYSQLI_UNIQUE_KEY_FLAG", UNIQUE_KEY_FLAG, CONST_CS | CONST_PERSISTENT);
774 17007 : REGISTER_LONG_CONSTANT("MYSQLI_MULTIPLE_KEY_FLAG", MULTIPLE_KEY_FLAG, CONST_CS | CONST_PERSISTENT);
775 17007 : REGISTER_LONG_CONSTANT("MYSQLI_BLOB_FLAG", BLOB_FLAG, CONST_CS | CONST_PERSISTENT);
776 17007 : REGISTER_LONG_CONSTANT("MYSQLI_UNSIGNED_FLAG", UNSIGNED_FLAG, CONST_CS | CONST_PERSISTENT);
777 17007 : REGISTER_LONG_CONSTANT("MYSQLI_ZEROFILL_FLAG", ZEROFILL_FLAG, CONST_CS | CONST_PERSISTENT);
778 17007 : REGISTER_LONG_CONSTANT("MYSQLI_AUTO_INCREMENT_FLAG", AUTO_INCREMENT_FLAG, CONST_CS | CONST_PERSISTENT);
779 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TIMESTAMP_FLAG", TIMESTAMP_FLAG, CONST_CS | CONST_PERSISTENT);
780 17007 : REGISTER_LONG_CONSTANT("MYSQLI_SET_FLAG", SET_FLAG, CONST_CS | CONST_PERSISTENT);
781 17007 : REGISTER_LONG_CONSTANT("MYSQLI_NUM_FLAG", NUM_FLAG, CONST_CS | CONST_PERSISTENT);
782 17007 : REGISTER_LONG_CONSTANT("MYSQLI_PART_KEY_FLAG", PART_KEY_FLAG, CONST_CS | CONST_PERSISTENT);
783 17007 : REGISTER_LONG_CONSTANT("MYSQLI_GROUP_FLAG", GROUP_FLAG, CONST_CS | CONST_PERSISTENT);
784 17007 : REGISTER_LONG_CONSTANT("MYSQLI_ENUM_FLAG", ENUM_FLAG, CONST_CS | CONST_PERSISTENT);
785 17007 : REGISTER_LONG_CONSTANT("MYSQLI_BINARY_FLAG", BINARY_FLAG, CONST_CS | CONST_PERSISTENT);
786 : #if MYSQL_VERSION_ID > 50001 || defined(MYSQLI_USE_MYSQLND)
787 17007 : REGISTER_LONG_CONSTANT("MYSQLI_NO_DEFAULT_VALUE_FLAG", NO_DEFAULT_VALUE_FLAG, CONST_CS | CONST_PERSISTENT);
788 : #endif
789 :
790 : #if (MYSQL_VERSION_ID > 51122 && MYSQL_VERSION_ID < 60000) || (MYSQL_VERSION_ID > 60003) || defined(MYSQLI_USE_MYSQLND)
791 17007 : REGISTER_LONG_CONSTANT("MYSQLI_ON_UPDATE_NOW_FLAG", ON_UPDATE_NOW_FLAG, CONST_CS | CONST_PERSISTENT);
792 : #endif
793 :
794 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_DECIMAL", FIELD_TYPE_DECIMAL, CONST_CS | CONST_PERSISTENT);
795 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_TINY", FIELD_TYPE_TINY, CONST_CS | CONST_PERSISTENT);
796 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_SHORT", FIELD_TYPE_SHORT, CONST_CS | CONST_PERSISTENT);
797 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_LONG", FIELD_TYPE_LONG, CONST_CS | CONST_PERSISTENT);
798 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_FLOAT", FIELD_TYPE_FLOAT, CONST_CS | CONST_PERSISTENT);
799 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_DOUBLE", FIELD_TYPE_DOUBLE, CONST_CS | CONST_PERSISTENT);
800 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_NULL", FIELD_TYPE_NULL, CONST_CS | CONST_PERSISTENT);
801 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_TIMESTAMP", FIELD_TYPE_TIMESTAMP, CONST_CS | CONST_PERSISTENT);
802 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_LONGLONG", FIELD_TYPE_LONGLONG, CONST_CS | CONST_PERSISTENT);
803 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_INT24", FIELD_TYPE_INT24, CONST_CS | CONST_PERSISTENT);
804 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_DATE", FIELD_TYPE_DATE, CONST_CS | CONST_PERSISTENT);
805 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_TIME", FIELD_TYPE_TIME, CONST_CS | CONST_PERSISTENT);
806 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_DATETIME", FIELD_TYPE_DATETIME , CONST_CS | CONST_PERSISTENT);
807 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_YEAR", FIELD_TYPE_YEAR, CONST_CS | CONST_PERSISTENT);
808 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_NEWDATE", FIELD_TYPE_NEWDATE, CONST_CS | CONST_PERSISTENT);
809 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_ENUM", FIELD_TYPE_ENUM, CONST_CS | CONST_PERSISTENT);
810 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_SET", FIELD_TYPE_SET, CONST_CS | CONST_PERSISTENT);
811 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_TINY_BLOB", FIELD_TYPE_TINY_BLOB, CONST_CS | CONST_PERSISTENT);
812 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_MEDIUM_BLOB", FIELD_TYPE_MEDIUM_BLOB, CONST_CS | CONST_PERSISTENT);
813 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_LONG_BLOB", FIELD_TYPE_LONG_BLOB, CONST_CS | CONST_PERSISTENT);
814 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_BLOB", FIELD_TYPE_BLOB, CONST_CS | CONST_PERSISTENT);
815 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_VAR_STRING", FIELD_TYPE_VAR_STRING, CONST_CS | CONST_PERSISTENT);
816 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_STRING", FIELD_TYPE_STRING, CONST_CS | CONST_PERSISTENT);
817 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_CHAR", FIELD_TYPE_CHAR, CONST_CS | CONST_PERSISTENT);
818 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_INTERVAL", FIELD_TYPE_INTERVAL, CONST_CS | CONST_PERSISTENT);
819 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_GEOMETRY", FIELD_TYPE_GEOMETRY, CONST_CS | CONST_PERSISTENT);
820 :
821 : #if MYSQL_VERSION_ID > 50002 || defined(MYSQLI_USE_MYSQLND)
822 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_NEWDECIMAL", FIELD_TYPE_NEWDECIMAL, CONST_CS | CONST_PERSISTENT);
823 17007 : REGISTER_LONG_CONSTANT("MYSQLI_TYPE_BIT", FIELD_TYPE_BIT, CONST_CS | CONST_PERSISTENT);
824 : #endif
825 :
826 17007 : REGISTER_LONG_CONSTANT("MYSQLI_SET_CHARSET_NAME", MYSQL_SET_CHARSET_NAME, CONST_CS | CONST_PERSISTENT);
827 :
828 : /* bind support */
829 17007 : REGISTER_LONG_CONSTANT("MYSQLI_NO_DATA", MYSQL_NO_DATA, CONST_CS | CONST_PERSISTENT);
830 : #ifdef MYSQL_DATA_TRUNCATED
831 17007 : REGISTER_LONG_CONSTANT("MYSQLI_DATA_TRUNCATED", MYSQL_DATA_TRUNCATED, CONST_CS | CONST_PERSISTENT);
832 : #endif
833 :
834 : /* reporting */
835 17007 : REGISTER_LONG_CONSTANT("MYSQLI_REPORT_INDEX", MYSQLI_REPORT_INDEX, CONST_CS | CONST_PERSISTENT);
836 17007 : REGISTER_LONG_CONSTANT("MYSQLI_REPORT_ERROR", MYSQLI_REPORT_ERROR, CONST_CS | CONST_PERSISTENT);
837 17007 : REGISTER_LONG_CONSTANT("MYSQLI_REPORT_STRICT", MYSQLI_REPORT_STRICT, CONST_CS | CONST_PERSISTENT);
838 17007 : REGISTER_LONG_CONSTANT("MYSQLI_REPORT_ALL", MYSQLI_REPORT_ALL, CONST_CS | CONST_PERSISTENT);
839 17007 : REGISTER_LONG_CONSTANT("MYSQLI_REPORT_OFF", 0, CONST_CS | CONST_PERSISTENT);
840 :
841 : /* We use non-nested macros with expansion, as VC has problems */
842 : #ifdef MYSQLI_USE_MYSQLND
843 17007 : REGISTER_LONG_CONSTANT("MYSQLI_DEBUG_TRACE_ENABLED", MYSQLND_DBG_ENABLED, CONST_CS | CONST_PERSISTENT);
844 : #else
845 : #ifndef DBUG_OFF
846 : REGISTER_LONG_CONSTANT("MYSQLI_DEBUG_TRACE_ENABLED", 0, CONST_CS | CONST_PERSISTENT);
847 : #else
848 : REGISTER_LONG_CONSTANT("MYSQLI_DEBUG_TRACE_ENABLED", 1, CONST_CS | CONST_PERSISTENT);
849 : #endif
850 : #endif
851 :
852 17007 : REGISTER_LONG_CONSTANT("MYSQLI_SERVER_QUERY_NO_GOOD_INDEX_USED", SERVER_QUERY_NO_GOOD_INDEX_USED, CONST_CS | CONST_PERSISTENT);
853 17007 : REGISTER_LONG_CONSTANT("MYSQLI_SERVER_QUERY_NO_INDEX_USED", SERVER_QUERY_NO_INDEX_USED, CONST_CS | CONST_PERSISTENT);
854 : #ifdef SERVER_QUERY_WAS_SLOW
855 17007 : REGISTER_LONG_CONSTANT("MYSQLI_SERVER_QUERY_WAS_SLOW", SERVER_QUERY_WAS_SLOW, CONST_CS | CONST_PERSISTENT);
856 : #endif
857 :
858 17007 : REGISTER_LONG_CONSTANT("MYSQLI_REFRESH_GRANT", REFRESH_GRANT, CONST_CS | CONST_PERSISTENT);
859 17007 : REGISTER_LONG_CONSTANT("MYSQLI_REFRESH_LOG", REFRESH_LOG, CONST_CS | CONST_PERSISTENT);
860 17007 : REGISTER_LONG_CONSTANT("MYSQLI_REFRESH_TABLES", REFRESH_TABLES, CONST_CS | CONST_PERSISTENT);
861 17007 : REGISTER_LONG_CONSTANT("MYSQLI_REFRESH_HOSTS", REFRESH_HOSTS, CONST_CS | CONST_PERSISTENT);
862 17007 : REGISTER_LONG_CONSTANT("MYSQLI_REFRESH_STATUS", REFRESH_STATUS, CONST_CS | CONST_PERSISTENT);
863 17007 : REGISTER_LONG_CONSTANT("MYSQLI_REFRESH_THREADS", REFRESH_THREADS, CONST_CS | CONST_PERSISTENT);
864 17007 : REGISTER_LONG_CONSTANT("MYSQLI_REFRESH_SLAVE", REFRESH_SLAVE, CONST_CS | CONST_PERSISTENT);
865 17007 : REGISTER_LONG_CONSTANT("MYSQLI_REFRESH_MASTER", REFRESH_MASTER, CONST_CS | CONST_PERSISTENT);
866 : #ifdef REFRESH_BACKUP_LOG
867 17007 : REGISTER_LONG_CONSTANT("MYSQLI_REFRESH_BACKUP_LOG", REFRESH_BACKUP_LOG, CONST_CS | CONST_PERSISTENT);
868 : #endif
869 :
870 17007 : return SUCCESS;
871 : }
872 : /* }}} */
873 :
874 : /* {{{ PHP_MSHUTDOWN_FUNCTION
875 : */
876 : PHP_MSHUTDOWN_FUNCTION(mysqli)
877 17039 : {
878 : #ifndef MYSQLI_USE_MYSQLND
879 : #if MYSQL_VERSION_ID >= 40000
880 : #ifdef PHP_WIN32
881 : unsigned long client_ver = mysql_get_client_version();
882 : /*
883 : Can't call mysql_server_end() multiple times prior to 5.0.46 on Windows.
884 : PHP bug#41350 MySQL bug#25621
885 : */
886 : if ((client_ver >= 50046 && client_ver < 50100) || client_ver > 50122) {
887 : mysql_server_end();
888 : }
889 : #else
890 : mysql_server_end();
891 : #endif
892 : #endif
893 : #else
894 17039 : mysqlnd_palloc_free_cache(mysqli_mysqlnd_zval_cache);
895 17039 : mysqlnd_qcache_free_cache_reference(&mysqli_mysqlnd_qcache);
896 : #endif
897 :
898 17039 : zend_hash_destroy(&mysqli_driver_properties);
899 17039 : zend_hash_destroy(&mysqli_result_properties);
900 17039 : zend_hash_destroy(&mysqli_stmt_properties);
901 17039 : zend_hash_destroy(&mysqli_warning_properties);
902 17039 : zend_hash_destroy(&mysqli_link_properties);
903 17039 : zend_hash_destroy(&classes);
904 :
905 17039 : UNREGISTER_INI_ENTRIES();
906 17039 : return SUCCESS;
907 : }
908 : /* }}} */
909 :
910 : /* {{{ PHP_RINIT_FUNCTION
911 : */
912 : PHP_RINIT_FUNCTION(mysqli)
913 16993 : {
914 : #if !defined(MYSQLI_USE_MYSQLND) && defined(ZTS) && MYSQL_VERSION_ID >= 40000
915 : if (mysql_thread_init()) {
916 : return FAILURE;
917 : }
918 : #endif
919 16993 : MyG(error_msg) = NULL;
920 16993 : MyG(error_no) = 0;
921 : #ifdef MYSQLI_USE_MYSQLND
922 16993 : MyG(mysqlnd_thd_zval_cache) = mysqlnd_palloc_rinit(mysqli_mysqlnd_zval_cache);
923 : #endif
924 :
925 16993 : return SUCCESS;
926 : }
927 : /* }}} */
928 :
929 :
930 : #ifdef MYSQLI_USE_MYSQLND
931 : static void php_mysqli_persistent_helper_for_every(void *p)
932 34 : {
933 : TSRMLS_FETCH();
934 34 : mysqlnd_end_psession((MYSQLND *) p);
935 34 : } /* }}} */
936 :
937 :
938 : static int php_mysqli_persistent_helper_once(zend_rsrc_list_entry *le TSRMLS_DC)
939 323 : {
940 323 : if (le->type == php_le_pmysqli()) {
941 11 : mysqli_plist_entry *plist = (mysqli_plist_entry *) le->ptr;
942 11 : zend_ptr_stack_apply(&plist->free_links, php_mysqli_persistent_helper_for_every);
943 : }
944 323 : return ZEND_HASH_APPLY_KEEP;
945 : } /* }}} */
946 : #endif
947 :
948 :
949 : /* {{{ PHP_RSHUTDOWN_FUNCTION
950 : */
951 : PHP_RSHUTDOWN_FUNCTION(mysqli)
952 17025 : {
953 : /* check persistent connections, move used to free */
954 :
955 : #if !defined(MYSQLI_USE_MYSQLND) && defined(ZTS) && MYSQL_VERSION_ID >= 40000
956 : mysql_thread_end();
957 : #endif
958 17025 : if (MyG(error_msg)) {
959 7 : efree(MyG(error_msg));
960 : }
961 : #ifdef MYSQLI_USE_MYSQLND
962 17025 : zend_hash_apply(&EG(persistent_list), (apply_func_t) php_mysqli_persistent_helper_once TSRMLS_CC);
963 17025 : mysqlnd_palloc_rshutdown(MyG(mysqlnd_thd_zval_cache));
964 : #endif
965 17025 : return SUCCESS;
966 : }
967 : /* }}} */
968 :
969 :
970 : /* {{{ PHP_MINFO_FUNCTION
971 : */
972 : PHP_MINFO_FUNCTION(mysqli)
973 43 : {
974 : char buf[32];
975 :
976 43 : php_info_print_table_start();
977 43 : php_info_print_table_header(2, "MysqlI Support", "enabled");
978 43 : php_info_print_table_row(2, "Client API library version", mysql_get_client_info());
979 43 : snprintf(buf, sizeof(buf), "%ld", MyG(num_active_persistent));
980 43 : php_info_print_table_row(2, "Active Persistent Links", buf);
981 43 : snprintf(buf, sizeof(buf), "%ld", MyG(num_inactive_persistent));
982 43 : php_info_print_table_row(2, "Inactive Persistent Links", buf);
983 43 : snprintf(buf, sizeof(buf), "%ld", MyG(num_links));
984 43 : php_info_print_table_row(2, "Active Links", buf);
985 : #if !defined(MYSQLI_USE_MYSQLND)
986 : php_info_print_table_row(2, "Client API header version", MYSQL_SERVER_VERSION);
987 : php_info_print_table_row(2, "MYSQLI_SOCKET", MYSQL_UNIX_ADDR);
988 : #else
989 : {
990 : zval values;
991 :
992 43 : php_info_print_table_header(2, "Persistent cache", mysqli_mysqlnd_zval_cache? "enabled":"disabled");
993 :
994 43 : if (mysqli_mysqlnd_zval_cache) {
995 : /* Now report cache status */
996 43 : mysqlnd_palloc_stats(mysqli_mysqlnd_zval_cache, &values);
997 43 : mysqlnd_minfo_print_hash(&values);
998 43 : zval_dtor(&values);
999 : }
1000 : }
1001 : #endif
1002 43 : php_info_print_table_end();
1003 :
1004 43 : DISPLAY_INI_ENTRIES();
1005 43 : }
1006 : /* }}} */
1007 :
1008 : /* {{{ mixed mysqli_stmt_construct() U
1009 : constructor for statement object.
1010 : Parameters:
1011 : object -> mysqli_stmt_init
1012 : object, query -> mysqli_prepare
1013 : */
1014 : PHP_FUNCTION(mysqli_stmt_construct)
1015 8 : {
1016 : MY_MYSQL *mysql;
1017 : zval *mysql_link;
1018 : MY_STMT *stmt;
1019 : MYSQLI_RESOURCE *mysqli_resource;
1020 : char *statement;
1021 : int statement_len;
1022 :
1023 8 : switch (ZEND_NUM_ARGS())
1024 : {
1025 : case 1: /* mysql_stmt_init */
1026 2 : if (zend_parse_parameters(1 TSRMLS_CC, "O", &mysql_link, mysqli_link_class_entry)==FAILURE) {
1027 1 : return;
1028 : }
1029 1 : MYSQLI_FETCH_RESOURCE(mysql, MY_MYSQL *, &mysql_link, "mysqli_link", MYSQLI_STATUS_VALID);
1030 :
1031 1 : stmt = (MY_STMT *)ecalloc(1,sizeof(MY_STMT));
1032 :
1033 1 : stmt->stmt = mysql_stmt_init(mysql->mysql);
1034 1 : break;
1035 : case 2:
1036 5 : if (zend_parse_parameters(2 TSRMLS_CC, "Os&", &mysql_link, mysqli_link_class_entry, &statement, &statement_len, UG(utf8_conv))==FAILURE) {
1037 1 : return;
1038 : }
1039 4 : MYSQLI_FETCH_RESOURCE(mysql, MY_MYSQL *, &mysql_link, "mysqli_link", MYSQLI_STATUS_VALID);
1040 :
1041 4 : stmt = (MY_STMT *)ecalloc(1,sizeof(MY_STMT));
1042 :
1043 4 : if ((stmt->stmt = mysql_stmt_init(mysql->mysql))) {
1044 4 : mysql_stmt_prepare(stmt->stmt, (char *)statement, statement_len);
1045 : }
1046 4 : break;
1047 : default:
1048 1 : WRONG_PARAM_COUNT;
1049 : break;
1050 : }
1051 :
1052 5 : if (!stmt->stmt) {
1053 0 : efree(stmt);
1054 0 : RETURN_FALSE;
1055 : }
1056 :
1057 5 : mysqli_resource = (MYSQLI_RESOURCE *)ecalloc (1, sizeof(MYSQLI_RESOURCE));
1058 5 : mysqli_resource->ptr = (void *)stmt;
1059 5 : mysqli_resource->status = (ZEND_NUM_ARGS() == 1) ? MYSQLI_STATUS_INITIALIZED : MYSQLI_STATUS_VALID;
1060 :
1061 5 : ((mysqli_object *) zend_object_store_get_object(getThis() TSRMLS_CC))->ptr = mysqli_resource;
1062 : }
1063 : /* }}} */
1064 :
1065 : /* {{{ mixed mysqli_result_construct() U
1066 : constructor for result object.
1067 : Parameters:
1068 : object [, mode] -> mysqli_store/use_result
1069 : */
1070 : PHP_FUNCTION(mysqli_result_construct)
1071 15 : {
1072 : MY_MYSQL *mysql;
1073 15 : MYSQL_RES *result = NULL;
1074 : zval *mysql_link;
1075 : MYSQLI_RESOURCE *mysqli_resource;
1076 15 : long resmode = MYSQLI_STORE_RESULT;
1077 :
1078 15 : switch (ZEND_NUM_ARGS()) {
1079 : case 1:
1080 9 : if (zend_parse_parameters(1 TSRMLS_CC, "O", &mysql_link, mysqli_link_class_entry)==FAILURE) {
1081 1 : return;
1082 : }
1083 8 : break;
1084 : case 2:
1085 5 : if (zend_parse_parameters(2 TSRMLS_CC, "Ol", &mysql_link, mysqli_link_class_entry, &resmode)==FAILURE) {
1086 1 : return;
1087 : }
1088 4 : break;
1089 : default:
1090 1 : WRONG_PARAM_COUNT;
1091 : }
1092 :
1093 12 : MYSQLI_FETCH_RESOURCE(mysql, MY_MYSQL *, &mysql_link, "mysqli_link", MYSQLI_STATUS_VALID);
1094 :
1095 8 : switch (resmode) {
1096 : case MYSQLI_STORE_RESULT:
1097 6 : result = mysql_store_result(mysql->mysql);
1098 6 : break;
1099 : case MYSQLI_USE_RESULT:
1100 1 : result = mysql_use_result(mysql->mysql);
1101 1 : break;
1102 : #if defined(MYSQLI_USE_MYSQLND) && defined(MYSQLND_THREADED)
1103 : case MYSQLI_BG_STORE_RESULT:
1104 : result = mysqli_bg_store_result(mysql->mysql);
1105 : break;
1106 : #endif
1107 : default:
1108 1 : php_error_docref(NULL TSRMLS_CC, E_WARNING, "Invalid value for resultmode");
1109 : }
1110 :
1111 8 : if (!result) {
1112 6 : RETURN_FALSE;
1113 : }
1114 :
1115 2 : mysqli_resource = (MYSQLI_RESOURCE *)ecalloc (1, sizeof(MYSQLI_RESOURCE));
1116 2 : mysqli_resource->ptr = (void *)result;
1117 2 : mysqli_resource->status = MYSQLI_STATUS_VALID;
1118 :
1119 2 : ((mysqli_object *) zend_object_store_get_object(getThis() TSRMLS_CC))->ptr = mysqli_resource;
1120 :
1121 : }
1122 : /* }}} */
1123 :
1124 : #define MYSQL_BINARY_CHARSET_NR 63
1125 :
1126 : #define IS_BINARY_DATA(f) (((f).type == MYSQL_TYPE_TINY_BLOB || (f).type == MYSQL_TYPE_BLOB || \
1127 : (f).type == MYSQL_TYPE_MEDIUM_BLOB || (f).type == MYSQL_TYPE_LONG_BLOB || \
1128 : (f).type == MYSQL_TYPE_BIT || (f).type == MYSQL_TYPE_VAR_STRING || (f).type == MYSQL_TYPE_VARCHAR ||\
1129 : (f).type == MYSQL_TYPE_STRING) && (f).charsetnr == MYSQL_BINARY_CHARSET_NR)
1130 :
1131 :
1132 : /* {{{ php_mysqli_fetch_into_hash
1133 : */
1134 : void php_mysqli_fetch_into_hash(INTERNAL_FUNCTION_PARAMETERS, int override_flags, int into_object)
1135 32 : {
1136 : MYSQL_RES *result;
1137 : zval *mysql_result;
1138 : long fetchtype;
1139 32 : zval *ctor_params = NULL;
1140 32 : zend_class_entry *ce = NULL;
1141 : #if !defined(MYSQLI_USE_MYSQLND)
1142 : unsigned int i;
1143 : MYSQL_FIELD *fields;
1144 : MYSQL_ROW row;
1145 : unsigned long *field_len;
1146 : #endif
1147 :
1148 32 : if (into_object) {
1149 : void *classname;
1150 : int classname_len;
1151 : zend_uchar classname_type;
1152 :
1153 32 : if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "O|Tz", &mysql_result, mysqli_result_class_entry,
1154 : &classname, &classname_len, &classname_type, &ctor_params) == FAILURE) {
1155 5 : return;
1156 : }
1157 27 : if (ZEND_NUM_ARGS() < (getThis() ? 1 : 2)) {
1158 11 : ce = zend_standard_class_def;
1159 : } else {
1160 16 : ce = zend_u_fetch_class(classname_type, ZSTR(classname), classname_len, ZEND_FETCH_CLASS_AUTO TSRMLS_CC);
1161 : }
1162 25 : if (!ce) {
1163 0 : php_error_docref(NULL TSRMLS_CC, E_WARNING, "Could not find class '%R'", classname_type, ZSTR(classname));
1164 0 : return;
1165 : }
1166 25 : fetchtype = MYSQLI_ASSOC;
1167 : } else {
1168 0 : if (override_flags) {
1169 0 : if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "O", &mysql_result, mysqli_result_class_entry) == FAILURE) {
1170 0 : return;
1171 : }
1172 0 : fetchtype = override_flags;
1173 : } else {
1174 0 : fetchtype = MYSQLI_BOTH;
1175 0 : if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "O|l", &mysql_result, mysqli_result_class_entry, &fetchtype) == FAILURE) {
1176 0 : return;
1177 : }
1178 : }
1179 : }
1180 25 : MYSQLI_FETCH_RESOURCE(result, MYSQL_RES *, &mysql_result, "mysqli_result", MYSQLI_STATUS_VALID);
1181 :
1182 22 : if (fetchtype < MYSQLI_ASSOC || fetchtype > MYSQLI_BOTH) {
1183 0 : php_error_docref(NULL TSRMLS_CC, E_WARNING, "The result type should be either MYSQLI_NUM, MYSQLI_ASSOC or MYSQLI_BOTH");
1184 0 : RETURN_FALSE;
1185 : }
1186 :
1187 : #if !defined(MYSQLI_USE_MYSQLND)
1188 : if (!(row = mysql_fetch_row(result))) {
1189 : RETURN_NULL();
1190 : }
1191 :
1192 : /*
1193 : It's needed to call fetch_fields because we need info whether
1194 : the field is binary. In 5_3 this is not needed as the latter
1195 : doesn't know about Unicode.
1196 : */
1197 : fields = mysql_fetch_fields(result);
1198 :
1199 : array_init(return_value);
1200 : field_len = mysql_fetch_lengths(result);
1201 :
1202 : for (i = 0; i < mysql_num_fields(result); i++) {
1203 : if (row[i]) {
1204 : zval *res;
1205 :
1206 : MAKE_STD_ZVAL(res);
1207 :
1208 : #if MYSQL_VERSION_ID > 50002
1209 : if (mysql_fetch_field_direct(result, i)->type == MYSQL_TYPE_BIT) {
1210 : my_ulonglong llval;
1211 : char tmp[22];
1212 : switch (field_len[i]) {
1213 : case 8:llval = (my_ulonglong) bit_uint8korr(row[i]);break;
1214 : case 7:llval = (my_ulonglong) bit_uint7korr(row[i]);break;
1215 : case 6:llval = (my_ulonglong) bit_uint6korr(row[i]);break;
1216 : case 5:llval = (my_ulonglong) bit_uint5korr(row[i]);break;
1217 : case 4:llval = (my_ulonglong) bit_uint4korr(row[i]);break;
1218 : case 3:llval = (my_ulonglong) bit_uint3korr(row[i]);break;
1219 : case 2:llval = (my_ulonglong) bit_uint2korr(row[i]);break;
1220 : case 1:llval = (my_ulonglong) uint1korr(row[i]);break;
1221 : }
1222 : /* even though lval is declared as unsigned, the value
1223 : * may be negative. Therefor we cannot use MYSQLI_LLU_SPEC and must
1224 : * use MYSQLI_LL_SPEC.
1225 : */
1226 : snprintf(tmp, sizeof(tmp), (mysql_fetch_field_direct(result, i)->flags & UNSIGNED_FLAG)? MYSQLI_LLU_SPEC : MYSQLI_LL_SPEC, llval);
1227 : /* numbers are latin1 and thus utf8, so no need to convert them with zend_string_to_unicode */
1228 : ZVAL_STRING(res, tmp, 1);
1229 : } else
1230 : #endif
1231 : {
1232 : if (!IS_BINARY_DATA(fields[i])) {
1233 : UChar *ustr;
1234 : int ulen;
1235 :
1236 : zend_string_to_unicode(UG(utf8_conv), &ustr, &ulen, row[i], field_len[i] TSRMLS_CC);
1237 : ZVAL_UNICODEL(res, ustr, ulen, 0);
1238 : } else {
1239 : ZVAL_STRINGL(res, row[i], field_len[i], 1);
1240 : }
1241 : }
1242 :
1243 : if (fetchtype & MYSQLI_NUM) {
1244 : add_index_zval(return_value, i, res);
1245 : }
1246 : if (fetchtype & MYSQLI_ASSOC) {
1247 : UChar *ustr;
1248 : int ulen;
1249 :
1250 : if (fetchtype & MYSQLI_NUM) {
1251 : Z_ADDREF_P(res);
1252 : }
1253 :
1254 : zend_string_to_unicode(UG(utf8_conv), &ustr, &ulen, fields[i].name, strlen(fields[i].name) TSRMLS_CC);
1255 : add_u_assoc_zval_ex(return_value, IS_UNICODE, ZSTR(ustr), ulen + 1, res);
1256 : efree(ustr);
1257 : }
1258 : } else {
1259 : if (fetchtype & MYSQLI_NUM) {
1260 : add_index_null(return_value, i);
1261 : }
1262 : if (fetchtype & MYSQLI_ASSOC) {
1263 : UChar *ustr;
1264 : int ulen;
1265 :
1266 : zend_string_to_unicode(UG(utf8_conv), &ustr, &ulen, fields[i].name, strlen(fields[i].name) TSRMLS_CC);
1267 : add_u_assoc_null(return_value, IS_UNICODE, ZSTR(ustr));
1268 : efree(ustr);
1269 : }
1270 : }
1271 : }
1272 : #else
1273 22 : mysqlnd_fetch_into(result, MYSQLND_FETCH_ASSOC, return_value, MYSQLND_MYSQLI);
1274 : #endif
1275 :
1276 22 : if (into_object && Z_TYPE_P(return_value) != IS_NULL) {
1277 18 : zval dataset = *return_value;
1278 : zend_fcall_info fci;
1279 : zend_fcall_info_cache fcc;
1280 : zval *retval_ptr;
1281 :
1282 18 : object_and_properties_init(return_value, ce, NULL);
1283 18 : zend_merge_properties(return_value, Z_ARRVAL(dataset), 1 TSRMLS_CC);
1284 :
1285 18 : if (ce->constructor) {
1286 9 : fci.size = sizeof(fci);
1287 9 : fci.function_table = &ce->function_table;
1288 9 : fci.function_name = NULL;
1289 9 : fci.symbol_table = NULL;
1290 9 : fci.object_ptr = return_value;
1291 9 : fci.retval_ptr_ptr = &retval_ptr;
1292 15 : if (ctor_params && Z_TYPE_P(ctor_params) != IS_NULL) {
1293 7 : if (Z_TYPE_P(ctor_params) == IS_ARRAY) {
1294 6 : HashTable *ht = Z_ARRVAL_P(ctor_params);
1295 : Bucket *p;
1296 :
1297 6 : fci.param_count = 0;
1298 6 : fci.params = safe_emalloc(sizeof(zval*), ht->nNumOfElements, 0);
1299 6 : p = ht->pListHead;
1300 22 : while (p != NULL) {
1301 10 : fci.params[fci.param_count++] = (zval**)p->pData;
1302 10 : p = p->pListNext;
1303 : }
1304 : } else {
1305 : /* Two problems why we throw exceptions here: PHP is typeless
1306 : * and hence passing one argument that's not an array could be
1307 : * by mistake and the other way round is possible, too. The
1308 : * single value is an array. Also we'd have to make that one
1309 : * argument passed by reference.
1310 : */
1311 1 : zend_throw_exception(zend_exception_get_default(TSRMLS_C), "Parameter ctor_params must be an array", 0 TSRMLS_CC);
1312 1 : return;
1313 : }
1314 : } else {
1315 2 : fci.param_count = 0;
1316 2 : fci.params = NULL;
1317 : }
1318 8 : fci.no_separation = 1;
1319 :
1320 8 : fcc.initialized = 1;
1321 8 : fcc.function_handler = ce->constructor;
1322 8 : fcc.calling_scope = EG(scope);
1323 8 : fcc.called_scope = Z_OBJCE_P(return_value);
1324 8 : fcc.object_ptr = return_value;
1325 :
1326 8 : if (zend_call_function(&fci, &fcc TSRMLS_CC) == FAILURE) {
1327 0 : zend_throw_exception_ex(zend_exception_get_default(TSRMLS_C), 0 TSRMLS_CC, "Could not execute %v::%v()", ce->name, ce->constructor->common.function_name);
1328 : } else {
1329 8 : if (retval_ptr) {
1330 8 : zval_ptr_dtor(&retval_ptr);
1331 : }
1332 : }
1333 8 : if (fci.params) {
1334 6 : efree(fci.params);
1335 : }
1336 9 : } else if (ctor_params) {
1337 1 : zend_throw_exception_ex(zend_exception_get_default(TSRMLS_C), 0 TSRMLS_CC, "Class %v does not have a constructor hence you cannot use ctor_params", ce->name);
1338 : }
1339 : }
1340 : }
1341 : /* }}} */
1342 :
1343 :
1344 : #if !defined(MYSQLI_USE_MYSQLND)
1345 :
1346 : #define ALLOC_CALLBACK_ARGS(a, b, c)\
1347 : if (c) {\
1348 : a = (zval ***)safe_emalloc(c, sizeof(zval **), 0);\
1349 : for (i = b; i < c; i++) {\
1350 : a[i] = emalloc(sizeof(zval *));\
1351 : MAKE_STD_ZVAL(*a[i]);\
1352 : }\
1353 : }
1354 :
1355 : #define FREE_CALLBACK_ARGS(a, b, c)\
1356 : if (a) {\
1357 : for (i=b; i < c; i++) {\
1358 : zval_ptr_dtor(a[i]);\
1359 : efree(a[i]);\
1360 : }\
1361 : efree(a);\
1362 : }
1363 :
1364 : #define LOCAL_INFILE_ERROR_MSG(source,dest)\
1365 : memset(source, 0, LOCAL_INFILE_ERROR_LEN);\
1366 : memcpy(source, dest, MIN(strlen(dest), LOCAL_INFILE_ERROR_LEN-1));\
1367 : php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s", dest);
1368 :
1369 :
1370 : /* {{{ php_local_infile_init
1371 : */
1372 : static int php_local_infile_init(void **ptr, const char *filename, void *userdata)
1373 : {
1374 : mysqli_local_infile *data;
1375 : MY_MYSQL *mysql;
1376 : php_stream_context *context = NULL;
1377 :
1378 : TSRMLS_FETCH();
1379 :
1380 : /* save pointer to MY_MYSQL structure (userdata) */
1381 : if (!(*ptr= data= ((mysqli_local_infile *)calloc(1, sizeof(mysqli_local_infile))))) {
1382 : return 1;
1383 : }
1384 :
1385 : if (!(mysql = (MY_MYSQL *)userdata)) {
1386 : LOCAL_INFILE_ERROR_MSG(data->error_msg, ER(CR_UNKNOWN_ERROR));
1387 : return 1;
1388 : }
1389 :
1390 : /* check open_basedir */
1391 : if (PG(open_basedir)) {
1392 : if (php_check_open_basedir_ex(filename, 0 TSRMLS_CC) == -1) {
1393 : LOCAL_INFILE_ERROR_MSG(data->error_msg, "open_basedir restriction in effect. Unable to open file");
1394 : return 1;
1395 : }
1396 : }
1397 :
1398 : mysql->li_stream = php_stream_open_wrapper_ex((char *)filename, "r", 0, NULL, context);
1399 :
1400 : if (mysql->li_stream == NULL) {
1401 : snprintf((char *)data->error_msg, sizeof(data->error_msg), "Can't find file '%-.64s'.", filename);
1402 : return 1;
1403 : }
1404 :
1405 : data->userdata = mysql;
1406 :
1407 : return 0;
1408 : }
1409 : /* }}} */
1410 :
1411 : /* {{{ int php_local_infile_read */
1412 : static int php_local_infile_read(void *ptr, char *buf, uint buf_len)
1413 : {
1414 : mysqli_local_infile *data;
1415 : MY_MYSQL *mysql;
1416 : zval ***callback_args;
1417 : zval *retval;
1418 : zval *fp;
1419 : int argc = 4;
1420 : int i;
1421 : long rc;
1422 :
1423 : TSRMLS_FETCH();
1424 :
1425 : data= (mysqli_local_infile *)ptr;
1426 : mysql = data->userdata;
1427 :
1428 : /* default processing */
1429 : if (!mysql->li_read) {
1430 : int count = (int)php_stream_read(mysql->li_stream, buf, buf_len);
1431 :
1432 : if (count < 0) {
1433 : LOCAL_INFILE_ERROR_MSG(data->error_msg, ER(2));
1434 : }
1435 :
1436 : return count;
1437 : }
1438 :
1439 : ALLOC_CALLBACK_ARGS(callback_args, 1, argc);
1440 :
1441 : /* set parameters: filepointer, buffer, buffer_len, errormsg */
1442 :
1443 : MAKE_STD_ZVAL(fp);
1444 : php_stream_to_zval(mysql->li_stream, fp);
1445 : callback_args[0] = &fp;
1446 : ZVAL_STRING(*callback_args[1], "", 1);
1447 : ZVAL_LONG(*callback_args[2], buf_len);
1448 : ZVAL_STRING(*callback_args[3], "", 1);
1449 :
1450 : if (call_user_function_ex(EG(function_table),
1451 : NULL,
1452 : mysql->li_read,
1453 : &retval,
1454 : argc,
1455 : callback_args,
1456 : 0,
1457 : NULL TSRMLS_CC) == SUCCESS) {
1458 :
1459 : rc = Z_LVAL_P(retval);
1460 : zval_ptr_dtor(&retval);
1461 :
1462 : if (rc > 0) {
1463 : if (rc >= 0 && rc != Z_STRLEN_P(*callback_args[1])) {
1464 : LOCAL_INFILE_ERROR_MSG(data->error_msg,
1465 : "Mismatch between the return value of the callback and the content "
1466 : "length of the buffer.");
1467 : rc = -1;
1468 : } else if (rc > buf_len) {
1469 : /* check buffer overflow */
1470 : LOCAL_INFILE_ERROR_MSG(data->error_msg, "Too much data returned");
1471 : rc = -1;
1472 : } else {
1473 : memcpy(buf, Z_STRVAL_P(*callback_args[1]), MIN(rc, Z_STRLEN_P(*callback_args[1])));
1474 : }
1475 : } else if (rc < 0) {
1476 : LOCAL_INFILE_ERROR_MSG(data->error_msg, Z_STRVAL_P(*callback_args[3]));
1477 : }
1478 : } else {
1479 : LOCAL_INFILE_ERROR_MSG(data->error_msg, "Can't execute load data local init callback function");
1480 : rc = -1;
1481 : }
1482 : /*
1483 : If the (ab)user has closed the file handle we should
1484 : not try to use it anymore or even close it
1485 : */
1486 : if (!zend_rsrc_list_get_rsrc_type(Z_LVAL_P(fp) TSRMLS_CC)) {
1487 : LOCAL_INFILE_ERROR_MSG(data->error_msg, "File handle closed");
1488 : rc = -1;
1489 : /* Thus the end handler won't try to free already freed memory */
1490 : mysql->li_stream = NULL;
1491 : }
1492 :
1493 : FREE_CALLBACK_ARGS(callback_args, 1, argc);
1494 : efree(fp);
1495 : return rc;
1496 : }
1497 : /* }}} */
1498 :
1499 : /* {{{ php_local_infile_error
1500 : */
1501 : static int php_local_infile_error(void *ptr, char *error_msg, uint error_msg_len)
1502 : {
1503 : mysqli_local_infile *data = (mysqli_local_infile *) ptr;
1504 :
1505 : if (data) {
1506 : strlcpy(error_msg, data->error_msg, error_msg_len);
1507 : return 2000;
1508 : }
1509 : strlcpy(error_msg, ER(CR_OUT_OF_MEMORY), error_msg_len);
1510 : return CR_OUT_OF_MEMORY;
1511 : }
1512 : /* }}} */
1513 :
1514 : /* {{{ php_local_infile_end
1515 : */
1516 : static void php_local_infile_end(void *ptr)
1517 : {
1518 : mysqli_local_infile *data;
1519 : MY_MYSQL *mysql;
1520 :
1521 : TSRMLS_FETCH();
1522 :
1523 : data= (mysqli_local_infile *)ptr;
1524 :
1525 : if (!data || !(mysql = data->userdata)) {
1526 : if (data) {
1527 : free(data);
1528 : }
1529 : return;
1530 : }
1531 :
1532 : if (mysql->li_stream) {
1533 : php_stream_close(mysql->li_stream);
1534 : }
1535 : free(data);
1536 : return;
1537 : }
1538 : /* }}} */
1539 :
1540 :
1541 : /* {{{ void php_set_local_infile_handler_default
1542 : */
1543 : void php_set_local_infile_handler_default(MY_MYSQL *mysql) {
1544 : /* register internal callback functions */
1545 : mysql_set_local_infile_handler(mysql->mysql, &php_local_infile_init, &php_local_infile_read,
1546 : &php_local_infile_end, &php_local_infile_error, (void *)mysql);
1547 : if (mysql->li_read) {
1548 : zval_ptr_dtor(&mysql->li_read);
1549 : mysql->li_read = NULL;
1550 : }
1551 : }
1552 : /* }}} */
1553 : #endif
1554 :
1555 : /*
1556 : * Local variables:
1557 : * tab-width: 4
1558 : * c-basic-offset: 4
1559 : * End:
1560 : * vim600: noet sw=4 ts=4 fdm=marker
1561 : * vim<600: noet sw=4 ts=4
1562 : */
|
