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