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