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