1 /*
2 +----------------------------------------------------------------------+
3 | Copyright (c) The PHP Group |
4 +----------------------------------------------------------------------+
5 | This source file is subject to version 3.01 of the PHP license, |
6 | that is bundled with this package in the file LICENSE, and is |
7 | available through the world-wide-web at the following url: |
8 | http://www.php.net/license/3_01.txt |
9 | If you did not receive a copy of the PHP license and are unable to |
10 | obtain it through the world-wide-web, please send a note to |
11 | license@php.net so we can mail you a copy immediately. |
12 +----------------------------------------------------------------------+
13 | Authors: Georg Richter <georg@php.net> |
14 | Andrey Hristov <andrey@php.net> |
15 | Ulf Wendel <uw@php.net> |
16 +----------------------------------------------------------------------+
17 */
18
19 #ifdef HAVE_CONFIG_H
20 #include "config.h"
21 #endif
22
23 #include <signal.h>
24
25 #include "php.h"
26 #include "php_ini.h"
27 #include "ext/standard/info.h"
28 #include "zend_smart_str.h"
29 #include "php_mysqli_structs.h"
30 #include "mysqli_priv.h"
31 #define ERROR_ARG_POS(arg_num) (getThis() ? (arg_num-1) : (arg_num))
32
33 #define SAFE_STR(a) ((a)?a:"")
34
35 /* {{{ php_mysqli_set_error */
php_mysqli_set_error(zend_long mysql_errno,char * mysql_err)36 static void php_mysqli_set_error(zend_long mysql_errno, char *mysql_err)
37 {
38 MyG(error_no) = mysql_errno;
39 if (MyG(error_msg)) {
40 efree(MyG(error_msg));
41 }
42 if(mysql_err && *mysql_err) {
43 MyG(error_msg) = estrdup(mysql_err);
44 } else {
45 MyG(error_msg) = NULL;
46 }
47 }
48 /* }}} */
49
mysqli_common_connect(INTERNAL_FUNCTION_PARAMETERS,zend_bool is_real_connect,zend_bool in_ctor)50 void mysqli_common_connect(INTERNAL_FUNCTION_PARAMETERS, zend_bool is_real_connect, zend_bool in_ctor) /* {{{ */
51 {
52 MY_MYSQL *mysql = NULL;
53 MYSQLI_RESOURCE *mysqli_resource = NULL;
54 zval *object = getThis();
55 char *hostname = NULL, *username=NULL, *passwd=NULL, *dbname=NULL, *socket=NULL,
56 *ssl_key = NULL, *ssl_cert = NULL, *ssl_ca = NULL, *ssl_capath = NULL,
57 *ssl_cipher = NULL;
58 size_t hostname_len = 0, username_len = 0, passwd_len = 0, dbname_len = 0, socket_len = 0;
59 zend_bool persistent = FALSE, ssl = FALSE;
60 zend_long port = 0, flags = 0;
61 zend_bool port_is_null = 1;
62 zend_string *hash_key = NULL;
63 zend_bool new_connection = FALSE;
64 zend_resource *le;
65 mysqli_plist_entry *plist = NULL;
66 zend_bool self_alloced = 0;
67
68
69 #if !defined(MYSQL_USE_MYSQLND)
70 if ((MYSQL_VERSION_ID / 100) != (mysql_get_client_version() / 100)) {
71 php_error_docref(NULL, E_WARNING,
72 "Headers and client library minor version mismatch. Headers:%d Library:%ld",
73 MYSQL_VERSION_ID, mysql_get_client_version());
74 }
75 #endif
76
77 if (getThis() && !ZEND_NUM_ARGS() && in_ctor) {
78 php_mysqli_init(INTERNAL_FUNCTION_PARAM_PASSTHRU, in_ctor);
79 return;
80 }
81 hostname = username = dbname = passwd = socket = NULL;
82
83 if (!is_real_connect) {
84 if (zend_parse_parameters(ZEND_NUM_ARGS(), "|s!s!s!s!l!s!", &hostname, &hostname_len, &username, &username_len,
85 &passwd, &passwd_len, &dbname, &dbname_len, &port, &port_is_null, &socket, &socket_len) == FAILURE) {
86 RETURN_THROWS();
87 }
88
89 if (object && instanceof_function(Z_OBJCE_P(object), mysqli_link_class_entry)) {
90 mysqli_resource = (Z_MYSQLI_P(object))->ptr;
91 if (mysqli_resource && mysqli_resource->ptr) {
92 mysql = (MY_MYSQL*) mysqli_resource->ptr;
93 }
94 }
95 if (!mysql) {
96 mysql = (MY_MYSQL *) ecalloc(1, sizeof(MY_MYSQL));
97 self_alloced = 1;
98 }
99 flags |= CLIENT_MULTI_RESULTS; /* needed for mysql_multi_query() */
100 } else {
101 /* We have flags too */
102 if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O|s!s!s!s!l!s!l", &object, mysqli_link_class_entry,
103 &hostname, &hostname_len, &username, &username_len, &passwd, &passwd_len, &dbname, &dbname_len, &port, &port_is_null, &socket, &socket_len, &flags) == FAILURE) {
104 RETURN_THROWS();
105 }
106
107 mysqli_resource = (Z_MYSQLI_P(object))->ptr;
108 MYSQLI_FETCH_RESOURCE_CONN(mysql, object, MYSQLI_STATUS_INITIALIZED);
109
110 /* set some required options */
111 flags |= CLIENT_MULTI_RESULTS; /* needed for mysql_multi_query() */
112 /* remove some insecure options */
113 flags &= ~CLIENT_MULTI_STATEMENTS; /* don't allow multi_queries via connect parameter */
114 #ifndef MYSQLI_USE_MYSQLND
115 if (PG(open_basedir) && PG(open_basedir)[0] != '\0') {
116 flags &= ~CLIENT_LOCAL_FILES;
117 }
118 #endif
119 }
120
121 if (!socket_len || !socket) {
122 socket = MyG(default_socket);
123 }
124 if (port_is_null || !port) {
125 port = MyG(default_port);
126 }
127 if (!passwd) {
128 passwd = MyG(default_pw);
129 passwd_len = strlen(SAFE_STR(passwd));
130 }
131 if (!username){
132 username = MyG(default_user);
133 }
134 if (!hostname || !hostname_len) {
135 hostname = MyG(default_host);
136 }
137
138 if (mysql->mysql && mysqli_resource &&
139 (mysqli_resource->status > MYSQLI_STATUS_INITIALIZED))
140 {
141 /* already connected, we should close the connection */
142 php_mysqli_close(mysql, MYSQLI_CLOSE_IMPLICIT, mysqli_resource->status);
143 }
144
145 if (strlen(SAFE_STR(hostname)) > 2 && !strncasecmp(hostname, "p:", 2)) {
146 hostname += 2;
147 if (!MyG(allow_persistent)) {
148 php_error_docref(NULL, E_WARNING, "Persistent connections are disabled. Downgrading to normal");
149 } else {
150 mysql->persistent = persistent = TRUE;
151
152 hash_key = strpprintf(0, "mysqli_%s_%s" ZEND_LONG_FMT "%s%s%s", SAFE_STR(hostname), SAFE_STR(socket),
153 port, SAFE_STR(username), SAFE_STR(dbname),
154 SAFE_STR(passwd));
155
156 mysql->hash_key = hash_key;
157
158 /* check if we can reuse existing connection ... */
159 if ((le = zend_hash_find_ptr(&EG(persistent_list), hash_key)) != NULL) {
160 if (le->type == php_le_pmysqli()) {
161 plist = (mysqli_plist_entry *) le->ptr;
162
163 do {
164 if (zend_ptr_stack_num_elements(&plist->free_links)) {
165 /* If we have an initialized (but unconnected) mysql resource,
166 * close it before we reuse an existing persistent resource. */
167 if (mysql->mysql) {
168 mysqli_close(mysql->mysql, MYSQLI_CLOSE_IMPLICIT);
169 }
170
171 mysql->mysql = zend_ptr_stack_pop(&plist->free_links);
172
173 MyG(num_inactive_persistent)--;
174 /* reset variables */
175
176 #ifndef MYSQLI_NO_CHANGE_USER_ON_PCONNECT
177 if (!mysqli_change_user_silent(mysql->mysql, username, passwd, dbname, passwd_len)) {
178 #else
179 if (!mysql_ping(mysql->mysql)) {
180 #endif
181 #ifdef MYSQLI_USE_MYSQLND
182 mysqlnd_restart_psession(mysql->mysql);
183 #endif
184 MyG(num_active_persistent)++;
185
186 /* clear error */
187 php_mysqli_set_error(mysql_errno(mysql->mysql), (char *) mysql_error(mysql->mysql));
188
189 goto end;
190 } else {
191 #ifdef MYSQLI_USE_MYSQLND
192 if (mysql->mysql->data->vio->data->ssl) {
193 /* copy over pre-existing ssl settings so we can reuse them when reconnecting */
194 ssl = TRUE;
195
196 ssl_key = mysql->mysql->data->vio->data->options.ssl_key ? estrdup(mysql->mysql->data->vio->data->options.ssl_key) : NULL;
197 ssl_cert = mysql->mysql->data->vio->data->options.ssl_cert ? estrdup(mysql->mysql->data->vio->data->options.ssl_cert) : NULL;
198 ssl_ca = mysql->mysql->data->vio->data->options.ssl_ca ? estrdup(mysql->mysql->data->vio->data->options.ssl_ca) : NULL;
199 ssl_capath = mysql->mysql->data->vio->data->options.ssl_capath ? estrdup(mysql->mysql->data->vio->data->options.ssl_capath) : NULL;
200 ssl_cipher = mysql->mysql->data->vio->data->options.ssl_cipher ? estrdup(mysql->mysql->data->vio->data->options.ssl_cipher) : NULL;
201 }
202 #else
203 if (mysql->mysql->options.ssl_key
204 || mysql->mysql->options.ssl_cert
205 || mysql->mysql->options.ssl_ca
206 || mysql->mysql->options.ssl_capath
207 || mysql->mysql->options.ssl_cipher) {
208 /* copy over pre-existing ssl settings so we can reuse them when reconnecting */
209 ssl = TRUE;
210
211 ssl_key = mysql->mysql->options.ssl_key ? estrdup(mysql->mysql->options.ssl_key) : NULL;
212 ssl_cert = mysql->mysql->options.ssl_cert ? estrdup(mysql->mysql->options.ssl_cert) : NULL;
213 ssl_ca = mysql->mysql->options.ssl_ca ? estrdup(mysql->mysql->options.ssl_ca) : NULL;
214 ssl_capath = mysql->mysql->options.ssl_capath ? estrdup(mysql->mysql->options.ssl_capath) : NULL;
215 ssl_cipher = mysql->mysql->options.ssl_cipher ? estrdup(mysql->mysql->options.ssl_cipher) : NULL;
216 }
217 #endif
218 mysqli_close(mysql->mysql, MYSQLI_CLOSE_IMPLICIT);
219 mysql->mysql = NULL;
220 }
221 }
222 } while (0);
223 }
224 } else {
225 plist = calloc(1, sizeof(mysqli_plist_entry));
226
227 zend_ptr_stack_init_ex(&plist->free_links, 1);
228 zend_register_persistent_resource(ZSTR_VAL(hash_key), ZSTR_LEN(hash_key), plist, php_le_pmysqli());
229 }
230 }
231 }
232 if (MyG(max_links) != -1 && MyG(num_links) >= MyG(max_links)) {
233 php_error_docref(NULL, E_WARNING, "Too many open links (" ZEND_LONG_FMT ")", MyG(num_links));
234 goto err;
235 }
236
237 if (persistent && MyG(max_persistent) != -1 &&
238 (MyG(num_active_persistent) + MyG(num_inactive_persistent))>= MyG(max_persistent))
239 {
240 php_error_docref(NULL, E_WARNING, "Too many open persistent links (" ZEND_LONG_FMT ")",
241 MyG(num_active_persistent) + MyG(num_inactive_persistent));
242 goto err;
243 }
244 if (!mysql->mysql) {
245 #ifndef MYSQLI_USE_MYSQLND
246 if (!(mysql->mysql = mysql_init(NULL))) {
247 #else
248 if (!(mysql->mysql = mysqlnd_init(MYSQLND_CLIENT_KNOWS_RSET_COPY_DATA, persistent))) {
249 #endif
250 goto err;
251 }
252 new_connection = TRUE;
253 }
254
255 #ifndef MYSQLI_USE_MYSQLND
256 /* BC for prior to bug fix #53425 */
257 flags |= CLIENT_MULTI_RESULTS;
258
259 if (ssl) {
260 /* if we're here, this means previous conn was ssl, repopulate settings */
261 mysql_ssl_set(mysql->mysql, ssl_key, ssl_cert, ssl_ca, ssl_capath, ssl_cipher);
262
263 if (ssl_key) {
264 efree(ssl_key);
265 }
266
267 if (ssl_cert) {
268 efree(ssl_cert);
269 }
270
271 if (ssl_ca) {
272 efree(ssl_ca);
273 }
274
275 if (ssl_capath) {
276 efree(ssl_capath);
277 }
278
279 if (ssl_cipher) {
280 efree(ssl_cipher);
281 }
282 }
283 if (mysql_real_connect(mysql->mysql, hostname, username, passwd, dbname, port, socket, flags) == NULL)
284 #else
285 if (ssl) {
286 /* if we're here, this means previous conn was ssl, repopulate settings */
287 mysql_ssl_set(mysql->mysql, ssl_key, ssl_cert, ssl_ca, ssl_capath, ssl_cipher);
288
289 if (ssl_key) {
290 efree(ssl_key);
291 }
292
293 if (ssl_cert) {
294 efree(ssl_cert);
295 }
296
297 if (ssl_ca) {
298 efree(ssl_ca);
299 }
300
301 if (ssl_capath) {
302 efree(ssl_capath);
303 }
304
305 if (ssl_cipher) {
306 efree(ssl_cipher);
307 }
308 }
309 if (mysqlnd_connect(mysql->mysql, hostname, username, passwd, passwd_len, dbname, dbname_len,
310 port, socket, flags, MYSQLND_CLIENT_KNOWS_RSET_COPY_DATA) == NULL)
311 #endif
312 {
313 /* Save error messages - for mysqli_connect_error() & mysqli_connect_errno() */
314 php_mysqli_set_error(mysql_errno(mysql->mysql), (char *) mysql_error(mysql->mysql));
315 php_mysqli_throw_sql_exception((char *)mysql_sqlstate(mysql->mysql), mysql_errno(mysql->mysql),
316 "%s", mysql_error(mysql->mysql));
317 if (!is_real_connect) {
318 /* free mysql structure */
319 mysqli_close(mysql->mysql, MYSQLI_CLOSE_DISCONNECTED);
320 mysql->mysql = NULL;
321 }
322 goto err;
323 }
324
325 /* clear error */
326 php_mysqli_set_error(mysql_errno(mysql->mysql), (char *) mysql_error(mysql->mysql));
327
328 #ifndef MYSQLI_USE_MYSQLND
329 char reconnect = MyG(reconnect);
330 mysql_options(mysql->mysql, MYSQL_OPT_RECONNECT, (char *)&reconnect);
331 #endif
332 unsigned int allow_local_infile = MyG(allow_local_infile);
333 mysql_options(mysql->mysql, MYSQL_OPT_LOCAL_INFILE, (char *)&allow_local_infile);
334
335 end:
336 if (!mysqli_resource) {
337 mysqli_resource = (MYSQLI_RESOURCE *)ecalloc (1, sizeof(MYSQLI_RESOURCE));
338 mysqli_resource->ptr = (void *)mysql;
339 }
340 mysqli_resource->status = MYSQLI_STATUS_VALID;
341
342 /* store persistent connection */
343 if (persistent && (new_connection || is_real_connect)) {
344 MyG(num_active_persistent)++;
345 }
346
347 MyG(num_links)++;
348
349 mysql->multi_query = 0;
350
351 if (!object || !instanceof_function(Z_OBJCE_P(object), mysqli_link_class_entry)) {
352 MYSQLI_RETURN_RESOURCE(mysqli_resource, mysqli_link_class_entry);
353 } else {
354 (Z_MYSQLI_P(object))->ptr = mysqli_resource;
355 }
356 if (!is_real_connect) {
357 return;
358 } else {
359 RETURN_TRUE;
360 }
361
362 err:
363 if (mysql->hash_key) {
364 zend_string_release_ex(mysql->hash_key, 0);
365 mysql->hash_key = NULL;
366 mysql->persistent = FALSE;
367 }
368 if (!is_real_connect && self_alloced) {
369 efree(mysql);
370 }
371 RETVAL_FALSE;
372 } /* }}} */
373
374 /* {{{ Open a connection to a mysql server */
375 PHP_FUNCTION(mysqli_connect)
376 {
377 mysqli_common_connect(INTERNAL_FUNCTION_PARAM_PASSTHRU, FALSE, FALSE);
378 }
379 /* }}} */
380
381 PHP_METHOD(mysqli, __construct)
382 {
383 mysqli_common_connect(INTERNAL_FUNCTION_PARAM_PASSTHRU, FALSE, TRUE);
384 }
385
386 /* {{{ Initialize mysqli and return a resource for use with mysql_real_connect */
387 PHP_METHOD(mysqli, init)
388 {
389 php_mysqli_init(INTERNAL_FUNCTION_PARAM_PASSTHRU, TRUE);
390 }
391 /* }}} */
392
393 /* {{{ Returns the numerical value of the error message from last connect command */
394 PHP_FUNCTION(mysqli_connect_errno)
395 {
396 if (zend_parse_parameters_none() == FAILURE) {
397 RETURN_THROWS();
398 }
399
400 RETURN_LONG(MyG(error_no));
401 }
402 /* }}} */
403
404 /* {{{ Returns the text of the error message from previous MySQL operation */
405 PHP_FUNCTION(mysqli_connect_error)
406 {
407 if (zend_parse_parameters_none() == FAILURE) {
408 RETURN_THROWS();
409 }
410
411 if (MyG(error_msg)) {
412 RETURN_STRING(MyG(error_msg));
413 } else {
414 RETURN_NULL();
415 }
416 }
417 /* }}} */
418
419 /* {{{ Fetch a result row as an associative array, a numeric array, or both */
420 PHP_FUNCTION(mysqli_fetch_array)
421 {
422 php_mysqli_fetch_into_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, 0, 0);
423 }
424 /* }}} */
425
426 /* {{{ Fetch a result row as an associative array */
427 PHP_FUNCTION(mysqli_fetch_assoc)
428 {
429 php_mysqli_fetch_into_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, MYSQLI_ASSOC, 0);
430 }
431 /* }}} */
432
433 /* {{{ Fetches all result rows as an associative array, a numeric array, or both */
434 #ifdef MYSQLI_USE_MYSQLND
435 PHP_FUNCTION(mysqli_fetch_all)
436 {
437 MYSQL_RES *result;
438 zval *mysql_result;
439 zend_long mode = MYSQLND_FETCH_NUM;
440
441 if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O|l", &mysql_result, mysqli_result_class_entry, &mode) == FAILURE) {
442 RETURN_THROWS();
443 }
444 MYSQLI_FETCH_RESOURCE(result, MYSQL_RES *, mysql_result, "mysqli_result", MYSQLI_STATUS_VALID);
445
446 if (!mode || (mode & ~MYSQLND_FETCH_BOTH)) {
447 zend_argument_value_error(ERROR_ARG_POS(2), "must be one of MYSQLI_FETCH_NUM, "
448 "MYSQLI_FETCH_ASSOC, or MYSQLI_FETCH_BOTH");
449 RETURN_THROWS();
450 }
451
452 mysqlnd_fetch_all(result, mode, return_value);
453 }
454 /* }}} */
455
456 /* {{{ Returns statistics about the zval cache */
457 PHP_FUNCTION(mysqli_get_client_stats)
458 {
459 if (zend_parse_parameters_none() == FAILURE) {
460 RETURN_THROWS();
461 }
462 mysqlnd_get_client_stats(return_value);
463 }
464 /* }}} */
465
466 /* {{{ Returns statistics about the zval cache */
467 PHP_FUNCTION(mysqli_get_connection_stats)
468 {
469 MY_MYSQL *mysql;
470 zval *mysql_link;
471
472 if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O",
473 &mysql_link, mysqli_link_class_entry) == FAILURE) {
474 RETURN_THROWS();
475 }
476 MYSQLI_FETCH_RESOURCE_CONN(mysql, mysql_link, MYSQLI_STATUS_VALID);
477
478 mysqlnd_get_connection_stats(mysql->mysql, return_value);
479 }
480 #endif
481 /* }}} */
482
483 /* {{{ Fetches all client errors */
484 PHP_FUNCTION(mysqli_error_list)
485 {
486 MY_MYSQL *mysql;
487 zval *mysql_link;
488
489 if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O", &mysql_link, mysqli_link_class_entry) == FAILURE) {
490 RETURN_THROWS();
491 }
492 MYSQLI_FETCH_RESOURCE_CONN(mysql, mysql_link, MYSQLI_STATUS_VALID);
493 #ifdef MYSQLI_USE_MYSQLND
494 if (1) {
495 MYSQLND_ERROR_LIST_ELEMENT * message;
496 zend_llist_position pos;
497 array_init(return_value);
498 for (message = (MYSQLND_ERROR_LIST_ELEMENT *) zend_llist_get_first_ex(&mysql->mysql->data->error_info->error_list, &pos);
499 message;
500 message = (MYSQLND_ERROR_LIST_ELEMENT *) zend_llist_get_next_ex(&mysql->mysql->data->error_info->error_list, &pos))
501 {
502 zval single_error;
503 array_init(&single_error);
504 add_assoc_long_ex(&single_error, "errno", sizeof("errno") - 1, message->error_no);
505 add_assoc_string_ex(&single_error, "sqlstate", sizeof("sqlstate") - 1, message->sqlstate);
506 add_assoc_string_ex(&single_error, "error", sizeof("error") - 1, message->error);
507 add_next_index_zval(return_value, &single_error);
508 }
509 } else {
510 RETURN_EMPTY_ARRAY();
511 }
512 #else
513 if (mysql_errno(mysql->mysql)) {
514 zval single_error;
515 array_init(return_value);
516 array_init(&single_error);
517 add_assoc_long_ex(&single_error, "errno", sizeof("errno") - 1, mysql_errno(mysql->mysql));
518 add_assoc_string_ex(&single_error, "sqlstate", sizeof("sqlstate") - 1, mysql_sqlstate(mysql->mysql));
519 add_assoc_string_ex(&single_error, "error", sizeof("error") - 1, mysql_error(mysql->mysql));
520 add_next_index_zval(return_value, &single_error);
521 } else {
522 RETURN_EMPTY_ARRAY();
523 }
524 #endif
525 }
526 /* }}} */
527
528 /* {{{ */
529 PHP_FUNCTION(mysqli_stmt_error_list)
530 {
531 MY_STMT *stmt;
532 zval *mysql_stmt;
533
534 if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O", &mysql_stmt, mysqli_stmt_class_entry) == FAILURE) {
535 RETURN_THROWS();
536 }
537 MYSQLI_FETCH_RESOURCE_STMT(stmt, mysql_stmt, MYSQLI_STATUS_INITIALIZED);
538 #ifdef MYSQLI_USE_MYSQLND
539 if (stmt->stmt && stmt->stmt->data && stmt->stmt->data->error_info) {
540 MYSQLND_ERROR_LIST_ELEMENT * message;
541 zend_llist_position pos;
542 array_init(return_value);
543 for (message = (MYSQLND_ERROR_LIST_ELEMENT *) zend_llist_get_first_ex(&stmt->stmt->data->error_info->error_list, &pos);
544 message;
545 message = (MYSQLND_ERROR_LIST_ELEMENT *) zend_llist_get_next_ex(&stmt->stmt->data->error_info->error_list, &pos))
546 {
547 zval single_error;
548 array_init(&single_error);
549 add_assoc_long_ex(&single_error, "errno", sizeof("errno") - 1, message->error_no);
550 add_assoc_string_ex(&single_error, "sqlstate", sizeof("sqlstate") - 1, message->sqlstate);
551 add_assoc_string_ex(&single_error, "error", sizeof("error") - 1, message->error);
552 add_next_index_zval(return_value, &single_error);
553 }
554 } else {
555 RETURN_EMPTY_ARRAY();
556 }
557 #else
558 if (mysql_stmt_errno(stmt->stmt)) {
559 zval single_error;
560 array_init(return_value);
561 array_init(&single_error);
562 add_assoc_long_ex(&single_error, "errno", sizeof("errno") - 1, mysql_stmt_errno(stmt->stmt));
563 add_assoc_string_ex(&single_error, "sqlstate", sizeof("sqlstate") - 1, mysql_stmt_sqlstate(stmt->stmt));
564 add_assoc_string_ex(&single_error, "error", sizeof("error") - 1, mysql_stmt_error(stmt->stmt));
565 add_next_index_zval(return_value, &single_error);
566 } else {
567 RETURN_EMPTY_ARRAY();
568 }
569 #endif
570 }
571 /* }}} */
572
573 /* {{{ Fetch a result row as an object */
574 PHP_FUNCTION(mysqli_fetch_object)
575 {
576 php_mysqli_fetch_into_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, MYSQLI_ASSOC, 1);
577 }
578 /* }}} */
579
580 /* {{{ allows to execute multiple queries */
581 PHP_FUNCTION(mysqli_multi_query)
582 {
583 MY_MYSQL *mysql;
584 zval *mysql_link;
585 char *query = NULL;
586 size_t query_len;
587
588 if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "Os", &mysql_link, mysqli_link_class_entry, &query, &query_len) == FAILURE) {
589 RETURN_THROWS();
590 }
591 MYSQLI_FETCH_RESOURCE_CONN(mysql, mysql_link, MYSQLI_STATUS_VALID);
592
593 MYSQLI_ENABLE_MQ;
594 if (mysql_real_query(mysql->mysql, query, query_len)) {
595 #ifndef MYSQLI_USE_MYSQLND
596 char s_error[MYSQL_ERRMSG_SIZE], s_sqlstate[SQLSTATE_LENGTH+1];
597 unsigned int s_errno;
598 /* we have to save error information, cause
599 MYSQLI_DISABLE_MQ will reset error information */
600 strcpy(s_error, mysql_error(mysql->mysql));
601 strcpy(s_sqlstate, mysql_sqlstate(mysql->mysql));
602 s_errno = mysql_errno(mysql->mysql);
603 #else
604 MYSQLND_ERROR_INFO error_info = *mysql->mysql->data->error_info;
605 mysql->mysql->data->error_info->error_list.head = NULL;
606 mysql->mysql->data->error_info->error_list.tail = NULL;
607 mysql->mysql->data->error_info->error_list.count = 0;
608 #endif
609 MYSQLI_REPORT_MYSQL_ERROR(mysql->mysql);
610 MYSQLI_DISABLE_MQ;
611
612 #ifndef MYSQLI_USE_MYSQLND
613 /* restore error information */
614 strcpy(mysql->mysql->net.last_error, s_error);
615 strcpy(mysql->mysql->net.sqlstate, s_sqlstate);
616 mysql->mysql->net.last_errno = s_errno;
617 #else
618 zend_llist_clean(&mysql->mysql->data->error_info->error_list);
619 *mysql->mysql->data->error_info = error_info;
620 #endif
621 RETURN_FALSE;
622 }
623 RETURN_TRUE;
624 }
625 /* }}} */
626
627 /* {{{ */
628 PHP_FUNCTION(mysqli_query)
629 {
630 MY_MYSQL *mysql;
631 zval *mysql_link;
632 MYSQLI_RESOURCE *mysqli_resource;
633 MYSQL_RES *result = NULL;
634 char *query = NULL;
635 size_t query_len;
636 zend_long resultmode = MYSQLI_STORE_RESULT;
637
638 if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "Os|l", &mysql_link, mysqli_link_class_entry, &query, &query_len, &resultmode) == FAILURE) {
639 RETURN_THROWS();
640 }
641
642 if (!query_len) {
643 zend_argument_value_error(ERROR_ARG_POS(2), "cannot be empty");
644 RETURN_THROWS();
645 }
646 if ((resultmode & ~MYSQLI_ASYNC) != MYSQLI_USE_RESULT &&
647 MYSQLI_STORE_RESULT != (resultmode & ~(MYSQLI_ASYNC | MYSQLI_STORE_RESULT_COPY_DATA))
648 ) {
649 zend_argument_value_error(ERROR_ARG_POS(3), "must be either MYSQLI_USE_RESULT or MYSQLI_STORE_RESULT"
650 #ifdef MYSQLI_USE_MYSQLND
651 " with MYSQLI_ASYNC as an optional bitmask flag"
652 #endif
653 );
654 RETURN_THROWS();
655 }
656
657 MYSQLI_FETCH_RESOURCE_CONN(mysql, mysql_link, MYSQLI_STATUS_VALID);
658
659 MYSQLI_DISABLE_MQ;
660
661
662 #ifdef MYSQLI_USE_MYSQLND
663 if (resultmode & MYSQLI_ASYNC) {
664 if (mysqli_async_query(mysql->mysql, query, query_len)) {
665 MYSQLI_REPORT_MYSQL_ERROR(mysql->mysql);
666 RETURN_FALSE;
667 }
668 mysql->async_result_fetch_type = resultmode & ~MYSQLI_ASYNC;
669 RETURN_TRUE;
670 }
671 #endif
672
673 if (mysql_real_query(mysql->mysql, query, query_len)) {
674 MYSQLI_REPORT_MYSQL_ERROR(mysql->mysql);
675 RETURN_FALSE;
676 }
677
678 if (!mysql_field_count(mysql->mysql)) {
679 /* no result set - not a SELECT */
680 if (MyG(report_mode) & MYSQLI_REPORT_INDEX) {
681 php_mysqli_report_index(query, mysqli_server_status(mysql->mysql));
682 }
683 RETURN_TRUE;
684 }
685
686 #ifdef MYSQLI_USE_MYSQLND
687 switch (resultmode & ~(MYSQLI_ASYNC | MYSQLI_STORE_RESULT_COPY_DATA)) {
688 #else
689 switch (resultmode & ~MYSQLI_ASYNC) {
690 #endif
691 case MYSQLI_STORE_RESULT:
692 #ifdef MYSQLI_USE_MYSQLND
693 if (resultmode & MYSQLI_STORE_RESULT_COPY_DATA) {
694 result = mysqlnd_store_result_ofs(mysql->mysql);
695 } else
696 #endif
697 result = mysql_store_result(mysql->mysql);
698 break;
699 case MYSQLI_USE_RESULT:
700 result = mysql_use_result(mysql->mysql);
701 break;
702 }
703 if (!result) {
704 MYSQLI_REPORT_MYSQL_ERROR(mysql->mysql);
705 RETURN_FALSE;
706 }
707
708 if (MyG(report_mode) & MYSQLI_REPORT_INDEX) {
709 php_mysqli_report_index(query, mysqli_server_status(mysql->mysql));
710 }
711
712 mysqli_resource = (MYSQLI_RESOURCE *)ecalloc (1, sizeof(MYSQLI_RESOURCE));
713 mysqli_resource->ptr = (void *)result;
714 mysqli_resource->status = MYSQLI_STATUS_VALID;
715 MYSQLI_RETURN_RESOURCE(mysqli_resource, mysqli_result_class_entry);
716 }
717 /* }}} */
718
719 #ifdef MYSQLI_USE_MYSQLND
720 #include "php_network.h"
721 /* {{{ mysqlnd_zval_array_to_mysqlnd_array functions */
722 static int mysqlnd_zval_array_to_mysqlnd_array(zval *in_array, MYSQLND ***out_array)
723 {
724 zval *elem;
725 int i = 0, current = 0;
726
727 if (Z_TYPE_P(in_array) != IS_ARRAY) {
728 return SUCCESS;
729 }
730 *out_array = ecalloc(zend_hash_num_elements(Z_ARRVAL_P(in_array)) + 1, sizeof(MYSQLND *));
731 ZEND_HASH_FOREACH_VAL(Z_ARRVAL_P(in_array), elem) {
732 i++;
733 if (Z_TYPE_P(elem) != IS_OBJECT ||
734 !instanceof_function(Z_OBJCE_P(elem), mysqli_link_class_entry)) {
735 zend_argument_type_error(i, "must be an instance of mysqli, %s given", zend_zval_type_name(elem));
736 return FAILURE;
737 } else {
738 MY_MYSQL *mysql;
739 MYSQLI_RESOURCE *my_res;
740 mysqli_object *intern = Z_MYSQLI_P(elem);
741 if (!(my_res = (MYSQLI_RESOURCE *)intern->ptr)) {
742 zend_throw_error(NULL, "%s object is already closed", ZSTR_VAL(intern->zo.ce->name));
743 return FAILURE;
744 }
745 mysql = (MY_MYSQL*) my_res->ptr;
746 if (my_res->status < MYSQLI_STATUS_VALID) {
747 zend_throw_error(NULL, "%s object is not fully initialized", ZSTR_VAL(intern->zo.ce->name));
748 return FAILURE;
749 }
750 (*out_array)[current++] = mysql->mysql;
751 }
752 } ZEND_HASH_FOREACH_END();
753 return SUCCESS;
754 }
755 /* }}} */
756
757 /* {{{ mysqlnd_zval_array_from_mysqlnd_array */
758 static int mysqlnd_zval_array_from_mysqlnd_array(MYSQLND **in_array, zval *out_array)
759 {
760 MYSQLND **p = in_array;
761 zval dest_array;
762 zval *elem, *dest_elem;
763 int ret = 0;
764
765 array_init_size(&dest_array, zend_hash_num_elements(Z_ARRVAL_P(out_array)));
766
767 ZEND_HASH_FOREACH_VAL(Z_ARRVAL_P(out_array), elem) {
768 if (Z_TYPE_P(elem) != IS_OBJECT ||
769 !instanceof_function(Z_OBJCE_P(elem), mysqli_link_class_entry)) {
770 continue;
771 }
772 {
773 MY_MYSQL *mysql;
774 MYSQLI_RESOURCE *my_res;
775 mysqli_object *intern = Z_MYSQLI_P(elem);
776 if (!(my_res = (MYSQLI_RESOURCE *)intern->ptr)) {
777 zend_throw_error(NULL, "%s object is already closed", ZSTR_VAL(intern->zo.ce->name));
778 return FAILURE;
779 }
780 mysql = (MY_MYSQL *) my_res->ptr;
781 if (mysql->mysql == *p) {
782 dest_elem = zend_hash_next_index_insert(Z_ARRVAL(dest_array), elem);
783 if (dest_elem) {
784 zval_add_ref(dest_elem);
785 }
786 ret++;
787 p++;
788 }
789 }
790 } ZEND_HASH_FOREACH_END();
791
792 /* destroy old array and add new one */
793 zval_ptr_dtor(out_array);
794 ZVAL_COPY_VALUE(out_array, &dest_array);
795
796 return 0;
797 }
798 /* }}} */
799
800 /* {{{ mysqlnd_dont_poll_zval_array_from_mysqlnd_array */
801 static int mysqlnd_dont_poll_zval_array_from_mysqlnd_array(MYSQLND **in_array, zval *in_zval_array, zval *out_array)
802 {
803 MYSQLND **p = in_array;
804 zval proxy, *elem, *dest_elem;
805 int ret = 0;
806
807 array_init(&proxy);
808 if (in_array) {
809 ZEND_HASH_FOREACH_VAL(Z_ARRVAL_P(in_zval_array), elem) {
810 MY_MYSQL *mysql;
811 mysqli_object *intern = Z_MYSQLI_P(elem);
812 mysql = (MY_MYSQL *)((MYSQLI_RESOURCE *)intern->ptr)->ptr;
813 if (mysql->mysql == *p) {
814 dest_elem = zend_hash_next_index_insert(Z_ARRVAL(proxy), elem);
815 if (dest_elem) {
816 zval_add_ref(dest_elem);
817 }
818 ret++;
819 p++;
820 }
821 } ZEND_HASH_FOREACH_END();
822 }
823
824 /* destroy old array and add new one */
825 zval_ptr_dtor(out_array);
826 ZVAL_COPY_VALUE(out_array, &proxy);
827
828 return 0;
829 }
830 /* }}} */
831
832 /* {{{ Poll connections */
833 PHP_FUNCTION(mysqli_poll)
834 {
835 zval *r_array, *e_array, *dont_poll_array;
836 MYSQLND **new_r_array = NULL, **new_e_array = NULL, **new_dont_poll_array = NULL;
837 zend_long sec = 0, usec = 0;
838 enum_func_status ret;
839 int desc_num;
840
841 if (zend_parse_parameters(ZEND_NUM_ARGS(), "a!a!al|l", &r_array, &e_array, &dont_poll_array, &sec, &usec) == FAILURE) {
842 RETURN_THROWS();
843 }
844 if (sec < 0) {
845 zend_argument_value_error(4, "must be greater than or equal to 0");
846 RETURN_THROWS();
847 }
848 if (usec < 0) {
849 zend_argument_value_error(5, "must be greater than or equal to 0");
850 RETURN_THROWS();
851 }
852
853 // TODO Error promotion
854 if (!r_array && !e_array) {
855 php_error_docref(NULL, E_WARNING, "No stream arrays were passed");
856 RETURN_FALSE;
857 }
858
859 if (r_array != NULL) {
860 if (mysqlnd_zval_array_to_mysqlnd_array(r_array, &new_r_array) == FAILURE) {
861 efree(new_r_array);
862 RETURN_THROWS();
863 }
864 }
865 if (e_array != NULL) {
866 if (mysqlnd_zval_array_to_mysqlnd_array(e_array, &new_e_array) == FAILURE) {
867 efree(new_e_array);
868 efree(new_r_array);
869 RETURN_THROWS();
870 }
871 }
872
873 ret = mysqlnd_poll(new_r_array, new_e_array, &new_dont_poll_array, sec, usec, &desc_num);
874
875 mysqlnd_dont_poll_zval_array_from_mysqlnd_array(r_array != NULL ? new_dont_poll_array:NULL, r_array, dont_poll_array);
876
877 if (r_array != NULL) {
878 mysqlnd_zval_array_from_mysqlnd_array(new_r_array, r_array);
879 }
880 if (e_array != NULL) {
881 mysqlnd_zval_array_from_mysqlnd_array(new_e_array, e_array);
882 }
883
884 if (new_dont_poll_array) {
885 efree(new_dont_poll_array);
886 }
887 if (new_r_array) {
888 efree(new_r_array);
889 }
890 if (new_e_array) {
891 efree(new_e_array);
892 }
893 if (ret == PASS) {
894 RETURN_LONG(desc_num);
895 } else {
896 RETURN_FALSE;
897 }
898 }
899 /* }}} */
900
901 /* {{{ Poll connections */
902 PHP_FUNCTION(mysqli_reap_async_query)
903 {
904 MY_MYSQL *mysql;
905 zval *mysql_link;
906 MYSQLI_RESOURCE *mysqli_resource;
907 MYSQL_RES *result = NULL;
908
909 if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O", &mysql_link, mysqli_link_class_entry) == FAILURE) {
910 RETURN_THROWS();
911 }
912
913 MYSQLI_FETCH_RESOURCE_CONN(mysql, mysql_link, MYSQLI_STATUS_VALID);
914
915 if (FAIL == mysqlnd_reap_async_query(mysql->mysql)) {
916 RETURN_FALSE;
917 }
918
919 if (!mysql_field_count(mysql->mysql)) {
920 /* no result set - not a SELECT */
921 if (MyG(report_mode) & MYSQLI_REPORT_INDEX) {
922 /* php_mysqli_report_index("n/a", mysqli_server_status(mysql->mysql)); */
923 }
924 RETURN_TRUE;
925 }
926
927 switch (mysql->async_result_fetch_type) {
928 case MYSQLI_STORE_RESULT:
929 result = mysql_store_result(mysql->mysql);
930 break;
931 case MYSQLI_USE_RESULT:
932 result = mysql_use_result(mysql->mysql);
933 break;
934 }
935
936 if (!result) {
937 MYSQLI_REPORT_MYSQL_ERROR(mysql->mysql);
938 RETURN_FALSE;
939 }
940
941 if (MyG(report_mode) & MYSQLI_REPORT_INDEX) {
942 /* php_mysqli_report_index("n/a", mysqli_server_status(mysql->mysql)); */
943 }
944
945 mysqli_resource = (MYSQLI_RESOURCE *)ecalloc (1, sizeof(MYSQLI_RESOURCE));
946 mysqli_resource->ptr = (void *)result;
947 mysqli_resource->status = MYSQLI_STATUS_VALID;
948 MYSQLI_RETURN_RESOURCE(mysqli_resource, mysqli_result_class_entry);
949 }
950 /* }}} */
951
952 /* {{{ Buffer result set on client */
953 PHP_FUNCTION(mysqli_stmt_get_result)
954 {
955 MYSQL_RES *result;
956 MYSQLI_RESOURCE *mysqli_resource;
957 MY_STMT *stmt;
958 zval *mysql_stmt;
959
960 if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O", &mysql_stmt, mysqli_stmt_class_entry) == FAILURE) {
961 RETURN_THROWS();
962 }
963 MYSQLI_FETCH_RESOURCE_STMT(stmt, mysql_stmt, MYSQLI_STATUS_VALID);
964
965 if (!(result = mysqlnd_stmt_get_result(stmt->stmt))) {
966 MYSQLI_REPORT_STMT_ERROR(stmt->stmt);
967 RETURN_FALSE;
968 }
969
970 mysqli_resource = (MYSQLI_RESOURCE *)ecalloc (1, sizeof(MYSQLI_RESOURCE));
971 mysqli_resource->ptr = (void *)result;
972 mysqli_resource->status = MYSQLI_STATUS_VALID;
973 MYSQLI_RETURN_RESOURCE(mysqli_resource, mysqli_result_class_entry);
974 }
975 /* }}} */
976 #endif
977
978 /* {{{ */
979 PHP_FUNCTION(mysqli_get_warnings)
980 {
981 MY_MYSQL *mysql;
982 zval *mysql_link;
983 MYSQLI_RESOURCE *mysqli_resource;
984 MYSQLI_WARNING *w = NULL;
985
986 if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O", &mysql_link, mysqli_link_class_entry) == FAILURE) {
987 RETURN_THROWS();
988 }
989 MYSQLI_FETCH_RESOURCE_CONN(mysql, mysql_link, MYSQLI_STATUS_VALID);
990
991 if (mysql_warning_count(mysql->mysql)) {
992 #ifdef MYSQLI_USE_MYSQLND
993 w = php_get_warnings(mysql->mysql->data);
994 #else
995 w = php_get_warnings(mysql->mysql);
996 #endif
997 }
998 if (!w) {
999 RETURN_FALSE;
1000 }
1001 mysqli_resource = (MYSQLI_RESOURCE *)ecalloc (1, sizeof(MYSQLI_RESOURCE));
1002 mysqli_resource->ptr = mysqli_resource->info = (void *)w;
1003 mysqli_resource->status = MYSQLI_STATUS_VALID;
1004 MYSQLI_RETURN_RESOURCE(mysqli_resource, mysqli_warning_class_entry);
1005 }
1006 /* }}} */
1007
1008 /* {{{ */
1009 PHP_FUNCTION(mysqli_stmt_get_warnings)
1010 {
1011 MY_STMT *stmt;
1012 zval *stmt_link;
1013 MYSQLI_RESOURCE *mysqli_resource;
1014 MYSQLI_WARNING *w = NULL;
1015
1016 if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O", &stmt_link, mysqli_stmt_class_entry) == FAILURE) {
1017 RETURN_THROWS();
1018 }
1019 MYSQLI_FETCH_RESOURCE_STMT(stmt, stmt_link, MYSQLI_STATUS_VALID);
1020
1021 if (mysqli_stmt_warning_count(stmt->stmt)) {
1022 w = php_get_warnings(mysqli_stmt_get_connection(stmt->stmt));
1023 }
1024 if (!w) {
1025 RETURN_FALSE;
1026 }
1027 mysqli_resource = (MYSQLI_RESOURCE *)ecalloc (1, sizeof(MYSQLI_RESOURCE));
1028 mysqli_resource->ptr = mysqli_resource->info = (void *)w;
1029 mysqli_resource->status = MYSQLI_STATUS_VALID;
1030 MYSQLI_RETURN_RESOURCE(mysqli_resource, mysqli_warning_class_entry);
1031 }
1032 /* }}} */
1033
1034 /* {{{ sets client character set */
1035 PHP_FUNCTION(mysqli_set_charset)
1036 {
1037 MY_MYSQL *mysql;
1038 zval *mysql_link;
1039 char *cs_name;
1040 size_t csname_len;
1041
1042 if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "Os", &mysql_link, mysqli_link_class_entry, &cs_name, &csname_len) == FAILURE) {
1043 RETURN_THROWS();
1044 }
1045 MYSQLI_FETCH_RESOURCE_CONN(mysql, mysql_link, MYSQLI_STATUS_VALID);
1046
1047 if (mysql_set_character_set(mysql->mysql, cs_name)) {
1048 MYSQLI_REPORT_MYSQL_ERROR(mysql->mysql);
1049 RETURN_FALSE;
1050 }
1051 RETURN_TRUE;
1052 }
1053 /* }}} */
1054
1055 /* {{{ returns a character set object */
1056 PHP_FUNCTION(mysqli_get_charset)
1057 {
1058 MY_MYSQL *mysql;
1059 zval *mysql_link;
1060 const char *name = NULL, *collation = NULL, *dir = NULL, *comment = NULL;
1061 uint32_t minlength, maxlength, number, state;
1062 #ifndef MYSQLI_USE_MYSQLND
1063 MY_CHARSET_INFO cs;
1064 #else
1065 const MYSQLND_CHARSET *cs;
1066 #endif
1067
1068 if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O", &mysql_link, mysqli_link_class_entry) == FAILURE) {
1069 RETURN_THROWS();
1070 }
1071 MYSQLI_FETCH_RESOURCE_CONN(mysql, mysql_link, MYSQLI_STATUS_VALID);
1072
1073
1074 #ifndef MYSQLI_USE_MYSQLND
1075 mysql_get_character_set_info(mysql->mysql, &cs);
1076 name = (char *)cs.csname;
1077 collation = (char *)cs.name;
1078 dir = (char *)cs.dir;
1079 minlength = cs.mbminlen;
1080 maxlength = cs.mbmaxlen;
1081 number = cs.number;
1082 state = cs.state;
1083 comment = cs.comment;
1084 #else
1085 cs = mysql->mysql->data->charset;
1086 if (!cs) {
1087 php_error_docref(NULL, E_WARNING, "The connection has no charset associated");
1088 RETURN_NULL();
1089 }
1090 name = cs->name;
1091 collation = cs->collation;
1092 minlength = cs->char_minlen;
1093 maxlength = cs->char_maxlen;
1094 number = cs->nr;
1095 comment = cs->comment;
1096 state = 1; /* all charsets are compiled in */
1097 #endif
1098 object_init(return_value);
1099
1100 add_property_string(return_value, "charset", (name) ? (char *)name : "");
1101 add_property_string(return_value, "collation",(collation) ? (char *)collation : "");
1102 add_property_string(return_value, "dir", (dir) ? (char *)dir : "");
1103 add_property_long(return_value, "min_length", minlength);
1104 add_property_long(return_value, "max_length", maxlength);
1105 add_property_long(return_value, "number", number);
1106 add_property_long(return_value, "state", state);
1107 add_property_string(return_value, "comment", (comment) ? (char *)comment : "");
1108 }
1109 /* }}} */
1110
1111 #ifndef MYSQLI_USE_MYSQLND
1112 extern char * mysqli_escape_string_for_tx_name_in_comment(const char * const name);
1113
1114 /* {{{ */
1115 static int mysqli_begin_transaction_libmysql(MYSQL * conn, const unsigned int mode, const char * const name)
1116 {
1117 int ret;
1118 smart_str tmp_str = {0};
1119 char * name_esc;
1120 char * query;
1121 unsigned int query_len;
1122 if (mode & TRANS_START_WITH_CONSISTENT_SNAPSHOT) {
1123 if (tmp_str.s) {
1124 smart_str_appendl(&tmp_str, ", ", sizeof(", ") - 1);
1125 }
1126 smart_str_appendl(&tmp_str, "WITH CONSISTENT SNAPSHOT", sizeof("WITH CONSISTENT SNAPSHOT") - 1);
1127 }
1128 if (mode & TRANS_START_READ_WRITE) {
1129 if (tmp_str.s) {
1130 smart_str_appendl(&tmp_str, ", ", sizeof(", ") - 1);
1131 }
1132 smart_str_appendl(&tmp_str, "READ WRITE", sizeof("READ WRITE") - 1);
1133 } else if (mode & TRANS_START_READ_ONLY) {
1134 if (tmp_str.s) {
1135 smart_str_appendl(&tmp_str, ", ", sizeof(", ") - 1);
1136 }
1137 smart_str_appendl(&tmp_str, "READ ONLY", sizeof("READ ONLY") - 1);
1138 }
1139 smart_str_0(&tmp_str);
1140
1141 name_esc = mysqli_escape_string_for_tx_name_in_comment(name);
1142 query_len = spprintf(&query, 0, "START TRANSACTION%s %s",
1143 name_esc? name_esc:"", tmp_str.s? ZSTR_VAL(tmp_str.s):"");
1144
1145 smart_str_free(&tmp_str);
1146 if (name_esc) {
1147 efree(name_esc);
1148 }
1149
1150 ret = mysql_real_query(conn, query, query_len);
1151 efree(query);
1152
1153 if (ret && mode & (TRANS_START_READ_WRITE | TRANS_START_READ_ONLY) && mysql_errno(conn) == 1064) {
1154 php_error_docref(NULL, E_WARNING, "This server version doesn't support 'READ WRITE' and 'READ ONLY'. Minimum 5.6.5 is required");
1155 }
1156 return ret;
1157 }
1158 /* }}} */
1159 #endif
1160
1161 /* {{{ Starts a transaction */
1162 PHP_FUNCTION(mysqli_begin_transaction)
1163 {
1164 MY_MYSQL *mysql;
1165 zval *mysql_link;
1166 zend_long flags = TRANS_START_NO_OPT;
1167 char * name = NULL;
1168 size_t name_len = 0;
1169
1170 if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O|ls!", &mysql_link, mysqli_link_class_entry, &flags, &name, &name_len) == FAILURE) {
1171 RETURN_THROWS();
1172 }
1173 MYSQLI_FETCH_RESOURCE_CONN(mysql, mysql_link, MYSQLI_STATUS_VALID);
1174 if (flags < 0) {
1175 zend_argument_value_error(ERROR_ARG_POS(2), "must be one of the MYSQLI_TRANS_* constants");
1176 RETURN_THROWS();
1177 }
1178 if (name && !name_len) {
1179 zend_argument_value_error(ERROR_ARG_POS(3), "cannot be empty");
1180 RETURN_THROWS();
1181 }
1182
1183 #ifndef MYSQLI_USE_MYSQLND
1184 if (mysqli_begin_transaction_libmysql(mysql->mysql, flags, name)) {
1185 RETURN_FALSE;
1186 }
1187 #else
1188 if (FAIL == mysqlnd_begin_transaction(mysql->mysql, flags, name)) {
1189 RETURN_FALSE;
1190 }
1191 #endif
1192 RETURN_TRUE;
1193 }
1194 /* }}} */
1195
1196 #ifndef MYSQLI_USE_MYSQLND
1197 /* {{{ */
1198 static int mysqli_savepoint_libmysql(MYSQL * conn, const char * const name, zend_bool release)
1199 {
1200 int ret;
1201 char * query;
1202 unsigned int query_len = spprintf(&query, 0, release? "RELEASE SAVEPOINT `%s`":"SAVEPOINT `%s`", name);
1203 ret = mysql_real_query(conn, query, query_len);
1204 efree(query);
1205 return ret;
1206 }
1207 /* }}} */
1208 #endif
1209
1210 /* {{{ Starts a transaction */
1211 PHP_FUNCTION(mysqli_savepoint)
1212 {
1213 MY_MYSQL *mysql;
1214 zval *mysql_link;
1215 char * name = NULL;
1216 size_t name_len;
1217
1218 if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "Os", &mysql_link, mysqli_link_class_entry, &name, &name_len) == FAILURE) {
1219 RETURN_THROWS();
1220 }
1221 MYSQLI_FETCH_RESOURCE_CONN(mysql, mysql_link, MYSQLI_STATUS_VALID);
1222 if (name_len == 0) {
1223 zend_argument_value_error(ERROR_ARG_POS(2), "cannot be empty");
1224 RETURN_THROWS();
1225 }
1226
1227 #ifndef MYSQLI_USE_MYSQLND
1228 if (mysqli_savepoint_libmysql(mysql->mysql, name, FALSE)) {
1229 #else
1230 if (FAIL == mysqlnd_savepoint(mysql->mysql, name)) {
1231 #endif
1232 RETURN_FALSE;
1233 }
1234 RETURN_TRUE;
1235 }
1236 /* }}} */
1237
1238 /* {{{ Starts a transaction */
1239 PHP_FUNCTION(mysqli_release_savepoint)
1240 {
1241 MY_MYSQL *mysql;
1242 zval *mysql_link;
1243 char * name = NULL;
1244 size_t name_len;
1245
1246 if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "Os", &mysql_link, mysqli_link_class_entry, &name, &name_len) == FAILURE) {
1247 RETURN_THROWS();
1248 }
1249 MYSQLI_FETCH_RESOURCE_CONN(mysql, mysql_link, MYSQLI_STATUS_VALID);
1250 if (name_len == 0) {
1251 zend_argument_value_error(ERROR_ARG_POS(2), "cannot be empty");
1252 RETURN_THROWS();
1253 }
1254 #ifndef MYSQLI_USE_MYSQLND
1255 if (mysqli_savepoint_libmysql(mysql->mysql, name, TRUE)) {
1256 #else
1257 if (FAIL == mysqlnd_release_savepoint(mysql->mysql, name)) {
1258 #endif
1259 RETURN_FALSE;
1260 }
1261 RETURN_TRUE;
1262 }
1263 /* }}} */
1264
1265 /* {{{ Returns information about open and cached links */
1266 PHP_FUNCTION(mysqli_get_links_stats)
1267 {
1268 if (zend_parse_parameters_none() == FAILURE) {
1269 RETURN_THROWS();
1270 }
1271
1272 array_init(return_value);
1273 add_assoc_long_ex(return_value, "total", sizeof("total") - 1, MyG(num_links));
1274 add_assoc_long_ex(return_value, "active_plinks", sizeof("active_plinks") - 1, MyG(num_active_persistent));
1275 add_assoc_long_ex(return_value, "cached_plinks", sizeof("cached_plinks") - 1, MyG(num_inactive_persistent));
1276 }
1277 /* }}} */
1278
