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