1 /*
2 +----------------------------------------------------------------------+
3 | PHP Version 7 |
4 +----------------------------------------------------------------------+
5 | Copyright (c) The PHP Group |
6 +----------------------------------------------------------------------+
7 | This source file is subject to version 3.01 of the PHP license, |
8 | that is bundled with this package in the file LICENSE, and is |
9 | available through the world-wide-web at the following url: |
10 | http://www.php.net/license/3_01.txt |
11 | If you did not receive a copy of the PHP license and are unable to |
12 | obtain it through the world-wide-web, please send a note to |
13 | license@php.net so we can mail you a copy immediately. |
14 +----------------------------------------------------------------------+
15 | Author: Georg Richter <georg@php.net> |
16 | Andrey Hristov <andrey@php.net> |
17 +----------------------------------------------------------------------+
18 */
19
20 #ifdef HAVE_CONFIG_H
21 #include "config.h"
22 #endif
23
24 #include <signal.h>
25
26 #include "php.h"
27 #include "php_ini.h"
28 #include "ext/standard/info.h"
29 #if defined(MYSQLI_USE_MYSQLND)
30 #include "php_mysqli_structs.h"
31 #endif
32 #include "mysqli_priv.h"
33
34 #define CHECK_STATUS(value, quiet) \
35 if (!obj->ptr || ((MYSQLI_RESOURCE *)obj->ptr)->status < value ) { \
36 if (!quiet) { \
37 php_error_docref(NULL, E_WARNING, "Property access is not allowed yet"); \
38 } \
39 ZVAL_FALSE(retval); \
40 return FAILURE; \
41 } \
42
43 #define MYSQLI_GET_MYSQL(statusval) \
44 MYSQL *p; \
45 if (!obj->ptr || !(MY_MYSQL *)((MYSQLI_RESOURCE *)(obj->ptr))->ptr) { \
46 if (!quiet) { \
47 php_error_docref(NULL, E_WARNING, "Couldn't fetch %s", ZSTR_VAL(obj->zo.ce->name)); \
48 } \
49 ZVAL_FALSE(retval);\
50 return FAILURE; \
51 } else { \
52 CHECK_STATUS(statusval, quiet);\
53 p = (MYSQL *)((MY_MYSQL *)((MYSQLI_RESOURCE *)(obj->ptr))->ptr)->mysql;\
54 }
55
56 #define MYSQLI_GET_RESULT(statusval) \
57 MYSQL_RES *p; \
58 if (!obj->ptr) { \
59 if (!quiet) { \
60 php_error_docref(NULL, E_WARNING, "Couldn't fetch %s", ZSTR_VAL(obj->zo.ce->name)); \
61 } \
62 ZVAL_NULL(retval);\
63 return FAILURE; \
64 } else { \
65 CHECK_STATUS(statusval, quiet);\
66 p = (MYSQL_RES *)((MYSQLI_RESOURCE *)(obj->ptr))->ptr; \
67 }
68
69 #define MYSQLI_GET_STMT(statusval) \
70 MYSQL_STMT *p; \
71 if (!obj->ptr) { \
72 if (!quiet) { \
73 php_error_docref(NULL, E_WARNING, "Couldn't fetch %s", ZSTR_VAL(obj->zo.ce->name)); \
74 } \
75 ZVAL_NULL(retval);\
76 return FAILURE; \
77 } else { \
78 CHECK_STATUS(statusval, quiet); \
79 p = (MYSQL_STMT *)((MY_STMT *)((MYSQLI_RESOURCE *)(obj->ptr))->ptr)->stmt; \
80 }
81
82 #define MYSQLI_MAP_PROPERTY_FUNC_LONG( __func, __int_func, __get_type, __ret_type, __ret_type_sprint_mod)\
83 static int __func(mysqli_object *obj, zval *retval, zend_bool quiet) \
84 {\
85 __ret_type l;\
86 __get_type;\
87 if (!p) {\
88 ZVAL_NULL(retval);\
89 } else {\
90 l = (__ret_type)__int_func(p);\
91 if (l < ZEND_LONG_MAX) {\
92 ZVAL_LONG(retval, (zend_long) l);\
93 } else { \
94 ZVAL_NEW_STR(retval, strpprintf(0, __ret_type_sprint_mod, l)); \
95 } \
96 } \
97 return SUCCESS; \
98 }
99
100 #define MYSQLI_MAP_PROPERTY_FUNC_STRING(__func, __int_func, __get_type)\
101 static int __func(mysqli_object *obj, zval *retval, zend_bool quiet)\
102 {\
103 char *c;\
104 __get_type;\
105 if (!p) {\
106 ZVAL_NULL(retval);\
107 } else {\
108 c = (char *)__int_func(p);\
109 if (!c) {\
110 ZVAL_NULL(retval);\
111 } else {\
112 ZVAL_STRING(retval, c);\
113 }\
114 }\
115 return SUCCESS; \
116 }
117
118 /* {{{ property link_client_version_read */
link_client_version_read(mysqli_object * obj,zval * retval,zend_bool quiet)119 static int link_client_version_read(mysqli_object *obj, zval *retval, zend_bool quiet)
120 {
121 ZVAL_LONG(retval, MYSQL_VERSION_ID);
122
123 return SUCCESS;
124 }
125 /* }}} */
126
127 /* {{{ property link_client_info_read */
link_client_info_read(mysqli_object * obj,zval * retval,zend_bool quiet)128 static int link_client_info_read(mysqli_object *obj, zval *retval, zend_bool quiet)
129 {
130 CHECK_STATUS(MYSQLI_STATUS_INITIALIZED, quiet);
131 ZVAL_STRING(retval, MYSQL_SERVER_VERSION);
132
133 return SUCCESS;
134 }
135 /* }}} */
136
137 /* {{{ property link_connect_errno_read */
link_connect_errno_read(mysqli_object * obj,zval * retval,zend_bool quiet)138 static int link_connect_errno_read(mysqli_object *obj, zval *retval, zend_bool quiet)
139 {
140 ZVAL_LONG(retval, (zend_long)MyG(error_no));
141
142 return SUCCESS;
143 }
144 /* }}} */
145
146 /* {{{ property link_connect_error_read */
link_connect_error_read(mysqli_object * obj,zval * retval,zend_bool quiet)147 static int link_connect_error_read(mysqli_object *obj, zval *retval, zend_bool quiet)
148 {
149 if (MyG(error_msg)) {
150 ZVAL_STRING(retval, MyG(error_msg));
151 } else {
152 ZVAL_NULL(retval);
153 }
154
155 return SUCCESS;
156 }
157 /* }}} */
158
159 /* {{{ property link_affected_rows_read */
link_affected_rows_read(mysqli_object * obj,zval * retval,zend_bool quiet)160 static int link_affected_rows_read(mysqli_object *obj, zval *retval, zend_bool quiet)
161 {
162 MY_MYSQL *mysql;
163 my_ulonglong rc;
164
165 CHECK_STATUS(MYSQLI_STATUS_INITIALIZED, quiet);
166
167 mysql = (MY_MYSQL *)((MYSQLI_RESOURCE *)(obj->ptr))->ptr;
168
169 if (!mysql) {
170 ZVAL_NULL(retval);
171 } else {
172 CHECK_STATUS(MYSQLI_STATUS_VALID, quiet);
173
174 rc = mysql_affected_rows(mysql->mysql);
175
176 if (rc == (my_ulonglong) -1) {
177 ZVAL_LONG(retval, -1);
178 return SUCCESS;
179 }
180
181 if (rc < ZEND_LONG_MAX) {
182 ZVAL_LONG(retval, (zend_long) rc);
183 } else {
184 ZVAL_NEW_STR(retval, strpprintf(0, MYSQLI_LLU_SPEC, rc));
185 }
186 }
187
188 return SUCCESS;
189 }
190 /* }}} */
191
192 /* {{{ property link_error_list_read */
link_error_list_read(mysqli_object * obj,zval * retval,zend_bool quiet)193 static int link_error_list_read(mysqli_object *obj, zval *retval, zend_bool quiet)
194 {
195 MY_MYSQL *mysql;
196
197 CHECK_STATUS(MYSQLI_STATUS_VALID, quiet);
198
199 mysql = (MY_MYSQL *)((MYSQLI_RESOURCE *)(obj->ptr))->ptr;
200
201 if (mysql) {
202 array_init(retval);
203 #if defined(MYSQLI_USE_MYSQLND)
204 if (1) {
205 MYSQLND_ERROR_LIST_ELEMENT * message;
206 zend_llist_position pos;
207 for (message = (MYSQLND_ERROR_LIST_ELEMENT *) zend_llist_get_first_ex(&mysql->mysql->data->error_info->error_list, &pos);
208 message;
209 message = (MYSQLND_ERROR_LIST_ELEMENT *) zend_llist_get_next_ex(&mysql->mysql->data->error_info->error_list, &pos))
210 {
211 zval single_error;
212 array_init(&single_error);
213 add_assoc_long_ex(&single_error, "errno", sizeof("errno") - 1, message->error_no);
214 add_assoc_string_ex(&single_error, "sqlstate", sizeof("sqlstate") - 1, message->sqlstate);
215 add_assoc_string_ex(&single_error, "error", sizeof("error") - 1, message->error);
216 add_next_index_zval(retval, &single_error);
217 }
218 }
219 #else
220 if (mysql_errno(mysql->mysql)) {
221 zval single_error;
222 array_init(&single_error);
223 add_assoc_long_ex(&single_error, "errno", sizeof("errno") - 1, mysql_errno(mysql->mysql));
224 add_assoc_string_ex(&single_error, "sqlstate", sizeof("sqlstate") - 1, mysql_sqlstate(mysql->mysql));
225 add_assoc_string_ex(&single_error, "error", sizeof("error") - 1, mysql_error(mysql->mysql));
226 add_next_index_zval(retval, &single_error);
227 }
228 #endif
229 } else {
230 ZVAL_EMPTY_ARRAY(retval);
231 }
232
233 return SUCCESS;
234 }
235 /* }}} */
236
237 /* link properties */
MYSQLI_MAP_PROPERTY_FUNC_LONG(link_errno_read,mysql_errno,MYSQLI_GET_MYSQL (MYSQLI_STATUS_INITIALIZED),zend_ulong,ZEND_ULONG_FMT)238 MYSQLI_MAP_PROPERTY_FUNC_LONG(link_errno_read, mysql_errno, MYSQLI_GET_MYSQL(MYSQLI_STATUS_INITIALIZED), zend_ulong, ZEND_ULONG_FMT)
239 MYSQLI_MAP_PROPERTY_FUNC_STRING(link_error_read, mysql_error, MYSQLI_GET_MYSQL(MYSQLI_STATUS_INITIALIZED))
240 MYSQLI_MAP_PROPERTY_FUNC_LONG(link_field_count_read, mysql_field_count, MYSQLI_GET_MYSQL(MYSQLI_STATUS_VALID), zend_ulong, ZEND_ULONG_FMT)
241 MYSQLI_MAP_PROPERTY_FUNC_STRING(link_host_info_read, mysql_get_host_info, MYSQLI_GET_MYSQL(MYSQLI_STATUS_VALID))
242 MYSQLI_MAP_PROPERTY_FUNC_STRING(link_info_read, mysql_info, MYSQLI_GET_MYSQL(MYSQLI_STATUS_VALID))
243 MYSQLI_MAP_PROPERTY_FUNC_LONG(link_insert_id_read, mysql_insert_id, MYSQLI_GET_MYSQL(MYSQLI_STATUS_VALID), my_ulonglong, MYSQLI_LLU_SPEC)
244 MYSQLI_MAP_PROPERTY_FUNC_LONG(link_protocol_version_read, mysql_get_proto_info, MYSQLI_GET_MYSQL(MYSQLI_STATUS_VALID), zend_ulong, ZEND_ULONG_FMT)
245 MYSQLI_MAP_PROPERTY_FUNC_STRING(link_server_info_read, mysql_get_server_info, MYSQLI_GET_MYSQL(MYSQLI_STATUS_VALID))
246 MYSQLI_MAP_PROPERTY_FUNC_LONG(link_server_version_read, mysql_get_server_version, MYSQLI_GET_MYSQL(MYSQLI_STATUS_VALID), zend_ulong, ZEND_ULONG_FMT)
247 MYSQLI_MAP_PROPERTY_FUNC_STRING(link_sqlstate_read, mysql_sqlstate, MYSQLI_GET_MYSQL(MYSQLI_STATUS_VALID))
248 MYSQLI_MAP_PROPERTY_FUNC_LONG(link_thread_id_read, mysql_thread_id, MYSQLI_GET_MYSQL(MYSQLI_STATUS_VALID), zend_ulong, ZEND_ULONG_FMT)
249 MYSQLI_MAP_PROPERTY_FUNC_LONG(link_warning_count_read, mysql_warning_count, MYSQLI_GET_MYSQL(MYSQLI_STATUS_VALID), zend_ulong, ZEND_ULONG_FMT)
250
251 /* result properties */
252
253 /* {{{ property result_type_read */
254 static int result_type_read(mysqli_object *obj, zval *retval, zend_bool quiet)
255 {
256 MYSQL_RES *p;
257
258 CHECK_STATUS(MYSQLI_STATUS_VALID, quiet);
259 p = (MYSQL_RES *)((MYSQLI_RESOURCE *)(obj->ptr))->ptr;
260
261 if (!p) {
262 ZVAL_NULL(retval);
263 } else {
264 ZVAL_LONG(retval, mysqli_result_is_unbuffered(p) ? MYSQLI_USE_RESULT:MYSQLI_STORE_RESULT);
265 }
266
267 return SUCCESS;
268 }
269 /* }}} */
270
271 /* {{{ property result_lengths_read */
result_lengths_read(mysqli_object * obj,zval * retval,zend_bool quiet)272 static int result_lengths_read(mysqli_object *obj, zval *retval, zend_bool quiet)
273 {
274 MYSQL_RES *p;
275 #if defined(MYSQLI_USE_MYSQLND)
276 const size_t *ret;
277 #else
278 const zend_ulong *ret;
279 #endif
280 uint32_t field_count;
281
282 CHECK_STATUS(MYSQLI_STATUS_VALID, quiet);
283 p = (MYSQL_RES *)((MYSQLI_RESOURCE *)(obj->ptr))->ptr;
284 field_count = mysql_num_fields(p);
285 if (!p || !field_count || !(ret = mysql_fetch_lengths(p))) {
286 ZVAL_NULL(retval);
287 } else {
288 zend_ulong i;
289
290 array_init(retval);
291
292 for (i = 0; i < field_count; i++) {
293 add_index_long(retval, i, ret[i]);
294 }
295 }
296
297 return SUCCESS;
298 }
299 /* }}} */
300
MYSQLI_MAP_PROPERTY_FUNC_LONG(result_current_field_read,mysql_field_tell,MYSQLI_GET_RESULT (MYSQLI_STATUS_VALID),zend_ulong,ZEND_ULONG_FMT)301 MYSQLI_MAP_PROPERTY_FUNC_LONG(result_current_field_read, mysql_field_tell, MYSQLI_GET_RESULT(MYSQLI_STATUS_VALID), zend_ulong, ZEND_ULONG_FMT)
302 MYSQLI_MAP_PROPERTY_FUNC_LONG(result_field_count_read, mysql_num_fields, MYSQLI_GET_RESULT(MYSQLI_STATUS_VALID), zend_ulong, ZEND_ULONG_FMT)
303 MYSQLI_MAP_PROPERTY_FUNC_LONG(result_num_rows_read, mysql_num_rows, MYSQLI_GET_RESULT(MYSQLI_STATUS_VALID), my_ulonglong, MYSQLI_LLU_SPEC)
304
305 /* statement properties */
306
307 /* {{{ property stmt_id_read */
308 static int stmt_id_read(mysqli_object *obj, zval *retval, zend_bool quiet)
309 {
310 MY_STMT *p;
311
312 CHECK_STATUS(MYSQLI_STATUS_VALID, quiet);
313
314 p = (MY_STMT*)((MYSQLI_RESOURCE *)(obj->ptr))->ptr;
315
316 if (!p) {
317 ZVAL_NULL(retval);
318 } else {
319 ZVAL_LONG(retval, mysqli_stmt_get_id(p->stmt));
320 }
321
322 return SUCCESS;
323 }
324 /* }}} */
325
326 /* {{{ property stmt_affected_rows_read */
stmt_affected_rows_read(mysqli_object * obj,zval * retval,zend_bool quiet)327 static int stmt_affected_rows_read(mysqli_object *obj, zval *retval, zend_bool quiet)
328 {
329 MY_STMT *p;
330 my_ulonglong rc;
331
332 CHECK_STATUS(MYSQLI_STATUS_VALID, quiet);
333
334 p = (MY_STMT *)((MYSQLI_RESOURCE *)(obj->ptr))->ptr;
335
336 if (!p) {
337 ZVAL_NULL(retval);
338 } else {
339 rc = mysql_stmt_affected_rows(p->stmt);
340
341 if (rc == (my_ulonglong) -1) {
342 ZVAL_LONG(retval, -1);
343 return SUCCESS;
344 }
345
346 if (rc < ZEND_LONG_MAX) {
347 ZVAL_LONG(retval, (zend_long) rc);
348 } else {
349 ZVAL_NEW_STR(retval, strpprintf(0, MYSQLI_LLU_SPEC, rc));
350 }
351 }
352
353 return SUCCESS;
354 }
355 /* }}} */
356
357 /* {{{ property stmt_error_list_read */
stmt_error_list_read(mysqli_object * obj,zval * retval,zend_bool quiet)358 static int stmt_error_list_read(mysqli_object *obj, zval *retval, zend_bool quiet)
359 {
360 MY_STMT * stmt;
361
362 CHECK_STATUS(MYSQLI_STATUS_INITIALIZED, quiet);
363
364 stmt = (MY_STMT *)((MYSQLI_RESOURCE *)(obj->ptr))->ptr;
365 if (stmt && stmt->stmt) {
366 array_init(retval);
367 #if defined(MYSQLI_USE_MYSQLND)
368 if (stmt->stmt->data && stmt->stmt->data->error_info) {
369 MYSQLND_ERROR_LIST_ELEMENT * message;
370 zend_llist_position pos;
371 for (message = (MYSQLND_ERROR_LIST_ELEMENT *) zend_llist_get_first_ex(&stmt->stmt->data->error_info->error_list, &pos);
372 message;
373 message = (MYSQLND_ERROR_LIST_ELEMENT *) zend_llist_get_next_ex(&stmt->stmt->data->error_info->error_list, &pos))
374 {
375 zval single_error;
376 array_init(&single_error);
377 add_assoc_long_ex(&single_error, "errno", sizeof("errno") - 1, message->error_no);
378 add_assoc_string_ex(&single_error, "sqlstate", sizeof("sqlstate") - 1, message->sqlstate);
379 add_assoc_string_ex(&single_error, "error", sizeof("error") - 1, message->error);
380 add_next_index_zval(retval, &single_error);
381 }
382 }
383 #else
384 if (mysql_stmt_errno(stmt->stmt)) {
385 zval single_error;
386 array_init(&single_error);
387 add_assoc_long_ex(&single_error, "errno", sizeof("errno") - 1, mysql_stmt_errno(stmt->stmt));
388 add_assoc_string_ex(&single_error, "sqlstate", sizeof("sqlstate") - 1, mysql_stmt_sqlstate(stmt->stmt));
389 add_assoc_string_ex(&single_error, "error", sizeof("error") - 1, mysql_stmt_error(stmt->stmt));
390 add_next_index_zval(retval, &single_error);
391 }
392 #endif
393 } else {
394 ZVAL_EMPTY_ARRAY(retval);
395 }
396
397 return SUCCESS;
398 }
399 /* }}} */
400
401 MYSQLI_MAP_PROPERTY_FUNC_LONG(stmt_insert_id_read, mysql_stmt_insert_id, MYSQLI_GET_STMT(MYSQLI_STATUS_VALID), my_ulonglong, MYSQLI_LLU_SPEC)
402 MYSQLI_MAP_PROPERTY_FUNC_LONG(stmt_num_rows_read, mysql_stmt_num_rows, MYSQLI_GET_STMT(MYSQLI_STATUS_VALID), my_ulonglong, MYSQLI_LLU_SPEC)
403 MYSQLI_MAP_PROPERTY_FUNC_LONG(stmt_param_count_read, mysql_stmt_param_count, MYSQLI_GET_STMT(MYSQLI_STATUS_VALID), zend_ulong, ZEND_ULONG_FMT)
404 MYSQLI_MAP_PROPERTY_FUNC_LONG(stmt_field_count_read, mysql_stmt_field_count, MYSQLI_GET_STMT(MYSQLI_STATUS_VALID), zend_ulong, ZEND_ULONG_FMT)
405 MYSQLI_MAP_PROPERTY_FUNC_LONG(stmt_errno_read, mysql_stmt_errno, MYSQLI_GET_STMT(MYSQLI_STATUS_INITIALIZED), zend_ulong, ZEND_ULONG_FMT)
406 MYSQLI_MAP_PROPERTY_FUNC_STRING(stmt_error_read, mysql_stmt_error, MYSQLI_GET_STMT(MYSQLI_STATUS_INITIALIZED))
407 MYSQLI_MAP_PROPERTY_FUNC_STRING(stmt_sqlstate_read, mysql_stmt_sqlstate, MYSQLI_GET_STMT(MYSQLI_STATUS_INITIALIZED))
408
409 /* }}} */
410 const mysqli_property_entry mysqli_link_property_entries[] = {
411 {"affected_rows", sizeof("affected_rows") - 1, link_affected_rows_read, NULL},
412 {"client_info", sizeof("client_info") - 1, link_client_info_read, NULL},
413 {"client_version", sizeof("client_version") - 1, link_client_version_read, NULL},
414 {"connect_errno", sizeof("connect_errno") - 1, link_connect_errno_read, NULL},
415 {"connect_error", sizeof("connect_error") - 1, link_connect_error_read, NULL},
416 {"errno", sizeof("errno") - 1, link_errno_read, NULL},
417 {"error", sizeof("error") - 1, link_error_read, NULL},
418 {"error_list", sizeof("error_list") - 1, link_error_list_read, NULL},
419 {"field_count", sizeof("field_count") - 1, link_field_count_read, NULL},
420 {"host_info", sizeof("host_info") - 1, link_host_info_read, NULL},
421 {"info", sizeof("info") - 1, link_info_read, NULL},
422 {"insert_id", sizeof("insert_id") - 1, link_insert_id_read, NULL},
423 {"server_info", sizeof("server_info") - 1, link_server_info_read, NULL},
424 {"server_version", sizeof("server_version") - 1, link_server_version_read, NULL},
425 {"sqlstate", sizeof("sqlstate") - 1, link_sqlstate_read, NULL},
426 {"protocol_version",sizeof("protocol_version") - 1, link_protocol_version_read, NULL},
427 {"thread_id", sizeof("thread_id") - 1, link_thread_id_read, NULL},
428 {"warning_count", sizeof("warning_count") - 1, link_warning_count_read, NULL},
429 {NULL, 0, NULL, NULL}
430 };
431
432
433 const mysqli_property_entry mysqli_result_property_entries[] = {
434 {"current_field",sizeof("current_field")-1, result_current_field_read, NULL},
435 {"field_count", sizeof("field_count") - 1, result_field_count_read, NULL},
436 {"lengths", sizeof("lengths") - 1, result_lengths_read, NULL},
437 {"num_rows", sizeof("num_rows") - 1, result_num_rows_read, NULL},
438 {"type", sizeof("type") - 1, result_type_read, NULL},
439 {NULL, 0, NULL, NULL}
440 };
441
442 const mysqli_property_entry mysqli_stmt_property_entries[] = {
443 {"affected_rows", sizeof("affected_rows")-1,stmt_affected_rows_read, NULL},
444 {"insert_id", sizeof("insert_id") - 1, stmt_insert_id_read, NULL},
445 {"num_rows", sizeof("num_rows") - 1, stmt_num_rows_read, NULL},
446 {"param_count", sizeof("param_count") - 1, stmt_param_count_read, NULL},
447 {"field_count", sizeof("field_count") - 1, stmt_field_count_read, NULL},
448 {"errno", sizeof("errno") - 1, stmt_errno_read, NULL},
449 {"error", sizeof("error") - 1, stmt_error_read, NULL},
450 {"error_list", sizeof("error_list") - 1, stmt_error_list_read, NULL},
451 {"sqlstate", sizeof("sqlstate") - 1, stmt_sqlstate_read, NULL},
452 {"id", sizeof("id") - 1, stmt_id_read, NULL},
453 {NULL, 0, NULL, NULL}
454 };
455