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