1 /*
2 +----------------------------------------------------------------------+
3 | Copyright (c) The PHP Group |
4 +----------------------------------------------------------------------+
5 | This source file is subject to version 3.01 of the PHP license, |
6 | that is bundled with this package in the file LICENSE, and is |
7 | available through the world-wide-web at the following url: |
8 | https://www.php.net/license/3_01.txt |
9 | If you did not receive a copy of the PHP license and are unable to |
10 | obtain it through the world-wide-web, please send a note to |
11 | license@php.net so we can mail you a copy immediately. |
12 +----------------------------------------------------------------------+
13 | Authors: Andrey Hristov <andrey@php.net> |
14 | Ulf Wendel <uw@php.net> |
15 +----------------------------------------------------------------------+
16 */
17
18 #ifndef MYSQLND_STRUCTS_H
19 #define MYSQLND_STRUCTS_H
20
21 #include "zend_smart_str_public.h"
22
23 #define MYSQLND_TYPEDEFED_METHODS
24
25 #define MYSQLND_CLASS_METHOD_TABLE_NAME(class) mysqlnd_##class##_methods
26 #define MYSQLND_CLASS_METHODS_TYPE(class) struct st_##class##_methods
27 #define MYSQLND_CLASS_METHOD_TABLE_NAME_FORWARD(class) MYSQLND_CLASS_METHODS_TYPE(class) MYSQLND_CLASS_METHOD_TABLE_NAME(class)
28
29 #define MYSQLND_CLASS_METHODS_START(class) MYSQLND_CLASS_METHOD_TABLE_NAME_FORWARD(class) = {
30 #define MYSQLND_CLASS_METHODS_END }
31
32 #define MYSQLND_CLASS_METHODS_INSTANCE_NAME(class) mysqlnd_##class##_methods_ptr
33 #define MYSQLND_CLASS_METHODS_INSTANCE_DECLARE(class) extern const MYSQLND_CLASS_METHODS_TYPE(class) * MYSQLND_CLASS_METHODS_INSTANCE_NAME(class)
34 #define MYSQLND_CLASS_METHODS_INSTANCE_DEFINE(class) const MYSQLND_CLASS_METHODS_TYPE(class) * MYSQLND_CLASS_METHODS_INSTANCE_NAME(class) = & MYSQLND_CLASS_METHOD_TABLE_NAME(class)
35
36 typedef struct st_mysqlnd_string
37 {
38 char *s;
39 size_t l;
40 } MYSQLND_STRING;
41
42 typedef struct st_mysqlnd_const_string
43 {
44 const char *s;
45 size_t l;
46 } MYSQLND_CSTRING;
47
48
49 typedef struct st_mysqlnd_memory_pool MYSQLND_MEMORY_POOL;
50
51 struct st_mysqlnd_memory_pool
52 {
53 zend_arena *arena;
54 void *checkpoint;
55
56 void* (*get_chunk)(MYSQLND_MEMORY_POOL * pool, size_t size);
57 };
58
59
60 typedef struct st_mysqlnd_row_buffer MYSQLND_ROW_BUFFER;
61
62 struct st_mysqlnd_row_buffer
63 {
64 void *ptr;
65 size_t size;
66 };
67
68
69 typedef struct st_mysqlnd_cmd_buffer
70 {
71 zend_uchar *buffer;
72 size_t length;
73 } MYSQLND_CMD_BUFFER;
74
75
76 typedef struct st_mysqlnd_field
77 {
78 zend_string *sname; /* Name of column */
79 bool is_numeric;
80 zend_ulong num_key;
81 const char *name; /* Name of column in C string */
82 const char *org_name; /* Original column name, if an alias */
83 const char *table; /* Table of column if column was a field */
84 const char *org_table; /* Org table name, if table was an alias */
85 const char *db; /* Database for table */
86 const char *catalog; /* Catalog for table */
87 char *def; /* Default value */
88 zend_ulong length; /* Width of column (create length) */
89 unsigned int name_length;
90 unsigned int org_name_length;
91 unsigned int table_length;
92 unsigned int org_table_length;
93 unsigned int db_length;
94 unsigned int catalog_length;
95 unsigned int def_length;
96 unsigned int flags; /* Diverse flags */
97 unsigned int decimals; /* Number of decimals in field */
98 unsigned int charsetnr; /* Character set */
99 enum mysqlnd_field_types type; /* Type of field. See mysql_com.h for types */
100 char *root;
101 size_t root_len;
102 } MYSQLND_FIELD;
103
104
105 typedef struct st_mysqlnd_upsert_status MYSQLND_UPSERT_STATUS;
106 typedef void (*func_mysqlnd_upsert_status__reset)(MYSQLND_UPSERT_STATUS * const upsert_status);
107 typedef void (*func_mysqlnd_upsert_status__set_affected_rows_to_error)(MYSQLND_UPSERT_STATUS * const upsert_status);
108
MYSQLND_CLASS_METHODS_TYPE(mysqlnd_upsert_status)109 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_upsert_status)
110 {
111 func_mysqlnd_upsert_status__reset reset;
112 func_mysqlnd_upsert_status__set_affected_rows_to_error set_affected_rows_to_error;
113 };
114
115 struct st_mysqlnd_upsert_status
116 {
117 unsigned int warning_count;
118 unsigned int server_status;
119 uint64_t affected_rows;
120 uint64_t last_insert_id;
121
122 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_upsert_status) *m;
123 };
124
125 #define SET_EMPTY_ERROR(info) (info)->m->reset((info))
126 #define SET_CLIENT_ERROR(info, err_no, sqlstate, error) (err_no)? (info)->m->set_client_error((info), (err_no), (sqlstate), (error)) : (info)->m->reset((info))
127 #define SET_OOM_ERROR(info) SET_CLIENT_ERROR((info), CR_OUT_OF_MEMORY, UNKNOWN_SQLSTATE, mysqlnd_out_of_memory)
128 #define COPY_CLIENT_ERROR(dest, source) SET_CLIENT_ERROR((dest), (source).error_no, (source).sqlstate, (source).error)
129
130
131 typedef struct st_mysqlnd_error_info MYSQLND_ERROR_INFO;
132 typedef void (*func_mysqlnd_error_info__reset)(MYSQLND_ERROR_INFO * const info);
133 typedef void (*func_mysqlnd_error_info__set_client_error)(MYSQLND_ERROR_INFO * const info, const unsigned int err_no, const char * const sqlstate, const char * const error);
134
135
MYSQLND_CLASS_METHODS_TYPE(mysqlnd_error_info)136 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_error_info)
137 {
138 func_mysqlnd_error_info__reset reset;
139 func_mysqlnd_error_info__set_client_error set_client_error;
140 };
141
142 struct st_mysqlnd_error_info
143 {
144 char error[MYSQLND_ERRMSG_SIZE+1];
145 char sqlstate[MYSQLND_SQLSTATE_LENGTH + 1];
146 unsigned int error_no;
147 zend_llist error_list;
148
149 bool persistent;
150 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_error_info) *m;
151 };
152
153
154 typedef struct st_mysqlnd_error_list_element
155 {
156 char * error;
157 char sqlstate[MYSQLND_SQLSTATE_LENGTH + 1];
158 unsigned int error_no;
159 } MYSQLND_ERROR_LIST_ELEMENT;
160
161
162 typedef struct st_mysqlnd_infile_info
163 {
164 php_stream *fd;
165 int error_no;
166 char error_msg[MYSQLND_ERRMSG_SIZE + 1];
167 const char *filename;
168 } MYSQLND_INFILE_INFO;
169
170
171 typedef int (*func_mysqlnd_local_infile__init)(void ** ptr, const char * const filename);
172 typedef int (*func_mysqlnd_local_infile__read)(void * ptr, zend_uchar * buf, unsigned int buf_len);
173 typedef int (*func_mysqlnd_local_infile__error)(void * ptr, char * error_msg, unsigned int error_msg_len);
174 typedef void (*func_mysqlnd_local_infile__end)(void * ptr);
175
176
177 /* character set information */
178 typedef struct st_mysqlnd_charset
179 {
180 unsigned int nr;
181 const char *name;
182 const char *collation;
183 unsigned int char_minlen;
184 unsigned int char_maxlen;
185 const char *comment;
186 short mb_charlen;
187 short mb_valid;
188 unsigned int lowest_mb_byte;
189 } MYSQLND_CHARSET;
190
191
192 /* local infile handler */
193 typedef struct st_mysqlnd_infile
194 {
195 func_mysqlnd_local_infile__init local_infile_init;
196 func_mysqlnd_local_infile__read local_infile_read;
197 func_mysqlnd_local_infile__error local_infile_error;
198 func_mysqlnd_local_infile__end local_infile_end;
199 } MYSQLND_INFILE;
200
201
202 typedef struct st_mysqlnd_session_options
203 {
204 unsigned int flags;
205
206 /* init commands - we need to send them to server directly after connect */
207 unsigned int num_commands;
208 char **init_commands;
209
210 /* configuration file information */
211 char *cfg_file;
212 char *cfg_section;
213
214 char *auth_protocol;
215 /*
216 We need to keep these because otherwise st_mysqlnd_conn will be changed.
217 The ABI will be broken and the methods structure will be somewhere else
218 in the memory which can crash external code. Feel free to reuse these.
219 */
220 HashTable * connect_attr;
221 char * unused1;
222 char * unused2;
223 char * unused3;
224
225 enum_mysqlnd_session_protocol_type protocol;
226
227 char *charset_name;
228 /* maximum allowed packet size for communication */
229 unsigned int max_allowed_packet;
230
231 bool int_and_float_native;
232
233 char *local_infile_directory;
234 } MYSQLND_SESSION_OPTIONS;
235
236
237 typedef struct st_mysqlnd_vio_options
238 {
239 /* timeouts */
240 unsigned int timeout_connect;
241 unsigned int timeout_read;
242 unsigned int timeout_write;
243
244 size_t net_read_buffer_size;
245
246 /* SSL information */
247 char *ssl_key;
248 char *ssl_cert;
249 char *ssl_ca;
250 char *ssl_capath;
251 char *ssl_cipher;
252 char *ssl_passphrase;
253 enum mysqlnd_ssl_peer {
254 MYSQLND_SSL_PEER_DEFAULT = 0,
255 MYSQLND_SSL_PEER_VERIFY = 1,
256 MYSQLND_SSL_PEER_DONT_VERIFY = 2,
257
258 #define MYSQLND_SSL_PEER_DEFAULT_ACTION MYSQLND_SSL_PEER_VERIFY
259 } ssl_verify_peer;
260 } MYSQLND_VIO_OPTIONS;
261
262
263
264 typedef struct st_mysqlnd_connection MYSQLND;
265 typedef struct st_mysqlnd_connection_data MYSQLND_CONN_DATA;
266 typedef struct st_mysqlnd_protocol_frame_codec MYSQLND_PFC;
267 typedef struct st_mysqlnd_protocol_frame_codec_data MYSQLND_PFC_DATA;
268 typedef struct st_mysqlnd_vio MYSQLND_VIO;
269 typedef struct st_mysqlnd_vio_data MYSQLND_VIO_DATA;
270 typedef struct st_mysqlnd_protocol_payload_decoder_factory MYSQLND_PROTOCOL_PAYLOAD_DECODER_FACTORY;
271 typedef struct st_mysqlnd_res MYSQLND_RES;
272 typedef char** MYSQLND_ROW_C; /* return data as array of strings */
273 typedef struct st_mysqlnd_stmt_data MYSQLND_STMT_DATA;
274 typedef struct st_mysqlnd_stmt MYSQLND_STMT;
275 typedef unsigned int MYSQLND_FIELD_OFFSET;
276
277 typedef struct st_mysqlnd_param_bind MYSQLND_PARAM_BIND;
278
279 typedef struct st_mysqlnd_result_bind MYSQLND_RESULT_BIND;
280
281 typedef struct st_mysqlnd_result_metadata MYSQLND_RES_METADATA;
282 typedef struct st_mysqlnd_buffered_result MYSQLND_RES_BUFFERED;
283 typedef struct st_mysqlnd_unbuffered_result MYSQLND_RES_UNBUFFERED;
284
285 typedef struct st_mysqlnd_debug MYSQLND_DEBUG;
286
287
288 typedef MYSQLND_RES* (*mysqlnd_stmt_use_or_store_func)(MYSQLND_STMT * const);
289 typedef enum_func_status (*mysqlnd_fetch_row_func)(MYSQLND_RES *result,
290 zval **row,
291 const unsigned int flags,
292 bool * fetched_anything
293 );
294
295
296 typedef struct st_mysqlnd_stats MYSQLND_STATS;
297
298 struct st_mysqlnd_stats
299 {
300 uint64_t *values;
301 size_t count;
302 #ifdef ZTS
303 MUTEX_T LOCK_access;
304 #endif
305 };
306
307
308 typedef enum_func_status (*func_mysqlnd_execute_com_set_option)(MYSQLND_CONN_DATA * const conn, const enum_mysqlnd_server_option option);
309 typedef enum_func_status (*func_mysqlnd_execute_com_debug)(MYSQLND_CONN_DATA * const conn);
310 typedef enum_func_status (*func_mysqlnd_execute_com_init_db)(MYSQLND_CONN_DATA * const conn, const MYSQLND_CSTRING db);
311 typedef enum_func_status (*func_mysqlnd_execute_com_ping)(MYSQLND_CONN_DATA * const conn);
312 typedef enum_func_status (*func_mysqlnd_execute_com_statistics)(MYSQLND_CONN_DATA * const conn, zend_string ** message);
313 typedef enum_func_status (*func_mysqlnd_execute_com_process_kill)(MYSQLND_CONN_DATA * const conn, const unsigned int process_id, const bool read_response);
314 typedef enum_func_status (*func_mysqlnd_execute_com_refresh)(MYSQLND_CONN_DATA * const conn, const uint8_t options);
315 typedef enum_func_status (*func_mysqlnd_execute_com_quit)(MYSQLND_CONN_DATA * const conn);
316 typedef enum_func_status (*func_mysqlnd_execute_com_query)(MYSQLND_CONN_DATA * const conn, MYSQLND_CSTRING query);
317 typedef enum_func_status (*func_mysqlnd_execute_com_change_user)(MYSQLND_CONN_DATA * const conn, const MYSQLND_CSTRING payload, const bool silent);
318 typedef enum_func_status (*func_mysqlnd_execute_com_reap_result)(MYSQLND_CONN_DATA * const conn);
319 typedef enum_func_status (*func_mysqlnd_execute_com_stmt_prepare)(MYSQLND_CONN_DATA * const conn, const MYSQLND_CSTRING query);
320 typedef enum_func_status (*func_mysqlnd_execute_com_stmt_execute)(MYSQLND_CONN_DATA * conn, const MYSQLND_CSTRING payload);
321 typedef enum_func_status (*func_mysqlnd_execute_com_stmt_fetch)(MYSQLND_CONN_DATA * const conn, const MYSQLND_CSTRING payload);
322 typedef enum_func_status (*func_mysqlnd_execute_com_stmt_reset)(MYSQLND_CONN_DATA * const conn, const zend_ulong stmt_id);
323 typedef enum_func_status (*func_mysqlnd_execute_com_stmt_send_long_data)(MYSQLND_CONN_DATA * const conn, const MYSQLND_CSTRING payload);
324 typedef enum_func_status (*func_mysqlnd_execute_com_stmt_close)(MYSQLND_CONN_DATA * const conn, const zend_ulong stmt_id);
325 typedef enum_func_status (*func_mysqlnd_execute_com_enable_ssl)(MYSQLND_CONN_DATA * const conn, const size_t client_capabilities, const size_t server_capabilities, const unsigned int charset_no);
326 typedef enum_func_status (*func_mysqlnd_execute_com_handshake)(MYSQLND_CONN_DATA * const conn, const MYSQLND_CSTRING username, const MYSQLND_CSTRING password, const MYSQLND_CSTRING database, const size_t client_flags);
327
328
MYSQLND_CLASS_METHODS_TYPE(mysqlnd_command)329 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_command)
330 {
331 func_mysqlnd_execute_com_set_option set_option;
332 func_mysqlnd_execute_com_debug debug;
333 func_mysqlnd_execute_com_init_db init_db;
334 func_mysqlnd_execute_com_ping ping;
335 func_mysqlnd_execute_com_statistics statistics;
336 func_mysqlnd_execute_com_process_kill process_kill;
337 func_mysqlnd_execute_com_refresh refresh;
338 func_mysqlnd_execute_com_quit quit;
339 func_mysqlnd_execute_com_query query;
340 func_mysqlnd_execute_com_change_user change_user;
341 func_mysqlnd_execute_com_reap_result reap_result;
342 func_mysqlnd_execute_com_stmt_prepare stmt_prepare;
343 func_mysqlnd_execute_com_stmt_execute stmt_execute;
344 func_mysqlnd_execute_com_stmt_fetch stmt_fetch;
345 func_mysqlnd_execute_com_stmt_reset stmt_reset;
346 func_mysqlnd_execute_com_stmt_send_long_data stmt_send_long_data;
347 func_mysqlnd_execute_com_stmt_close stmt_close;
348 func_mysqlnd_execute_com_enable_ssl enable_ssl;
349 func_mysqlnd_execute_com_handshake handshake;
350 };
351
352
353
354 typedef void (*func_mysqlnd_vio__init)(MYSQLND_VIO * const vio, MYSQLND_STATS * const stats, MYSQLND_ERROR_INFO * const error_info);
355 typedef void (*func_mysqlnd_vio__dtor)(MYSQLND_VIO * const vio, MYSQLND_STATS * const conn_stats, MYSQLND_ERROR_INFO * const error_info);
356
357 typedef enum_func_status (*func_mysqlnd_vio__connect)(MYSQLND_VIO * const vio, const MYSQLND_CSTRING scheme, const bool persistent, MYSQLND_STATS * const conn_stats, MYSQLND_ERROR_INFO * const error_info);
358
359 typedef void (*func_mysqlnd_vio__close_stream)(MYSQLND_VIO * const vio, MYSQLND_STATS * const conn_stats, MYSQLND_ERROR_INFO * const error_info);
360 typedef php_stream * (*func_mysqlnd_vio__open_stream)(MYSQLND_VIO * const vio, const MYSQLND_CSTRING scheme, const bool persistent, MYSQLND_STATS * const conn_stats, MYSQLND_ERROR_INFO * const error_info);
361 typedef php_stream * (*func_mysqlnd_vio__get_stream)(const MYSQLND_VIO * const vio);
362 typedef enum_func_status (*func_mysqlnd_vio__set_stream)(MYSQLND_VIO * const vio, php_stream * vio_stream);
363 typedef bool (*func_mysqlnd_vio__has_valid_stream)(const MYSQLND_VIO * const vio);
364 typedef func_mysqlnd_vio__open_stream (*func_mysqlnd_vio__get_open_stream)(MYSQLND_VIO * const vio, const MYSQLND_CSTRING scheme, MYSQLND_ERROR_INFO * const error_info);
365
366 typedef enum_func_status (*func_mysqlnd_vio__set_client_option)(MYSQLND_VIO * const vio, enum_mysqlnd_client_option option, const char * const value);
367 typedef void (*func_mysqlnd_vio__post_connect_set_opt)(MYSQLND_VIO * const vio, const MYSQLND_CSTRING scheme, MYSQLND_STATS * const conn_stats, MYSQLND_ERROR_INFO * const error_info);
368
369 typedef enum_func_status (*func_mysqlnd_vio__enable_ssl)(MYSQLND_VIO * const vio);
370 typedef enum_func_status (*func_mysqlnd_vio__disable_ssl)(MYSQLND_VIO * const vio);
371 typedef enum_func_status (*func_mysqlnd_vio__network_read)(MYSQLND_VIO * const vio, zend_uchar * const buffer, const size_t count, MYSQLND_STATS * const stats, MYSQLND_ERROR_INFO * const error_info);
372 typedef ssize_t (*func_mysqlnd_vio__network_write)(MYSQLND_VIO * const vio, const zend_uchar * const buf, const size_t count, MYSQLND_STATS * const stats, MYSQLND_ERROR_INFO * const error_info);
373
374 typedef size_t (*func_mysqlnd_vio__consume_uneaten_data)(MYSQLND_VIO * const vio, enum php_mysqlnd_server_command cmd);
375
376 typedef void (*func_mysqlnd_vio__free_contents)(MYSQLND_VIO * vio);
377
378
MYSQLND_CLASS_METHODS_TYPE(mysqlnd_vio)379 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_vio)
380 {
381 func_mysqlnd_vio__init init;
382 func_mysqlnd_vio__dtor dtor;
383 func_mysqlnd_vio__connect connect;
384
385 func_mysqlnd_vio__close_stream close_stream;
386 func_mysqlnd_vio__open_stream open_pipe;
387 func_mysqlnd_vio__open_stream open_tcp_or_unix;
388
389 func_mysqlnd_vio__get_stream get_stream;
390 func_mysqlnd_vio__set_stream set_stream;
391 func_mysqlnd_vio__has_valid_stream has_valid_stream;
392 func_mysqlnd_vio__get_open_stream get_open_stream;
393
394 func_mysqlnd_vio__set_client_option set_client_option;
395 func_mysqlnd_vio__post_connect_set_opt post_connect_set_opt;
396
397 func_mysqlnd_vio__enable_ssl enable_ssl;
398 func_mysqlnd_vio__disable_ssl disable_ssl;
399
400 func_mysqlnd_vio__network_read network_read;
401 func_mysqlnd_vio__network_write network_write;
402
403 func_mysqlnd_vio__consume_uneaten_data consume_uneaten_data;
404
405 func_mysqlnd_vio__free_contents free_contents;
406 };
407
408
409 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_object_factory);
410
411 typedef MYSQLND * (*func_mysqlnd_object_factory__get_connection)(MYSQLND_CLASS_METHODS_TYPE(mysqlnd_object_factory) * factory, const bool persistent);
412 typedef MYSQLND * (*func_mysqlnd_object_factory__clone_connection_object)(MYSQLND * conn);
413 typedef MYSQLND_STMT * (*func_mysqlnd_object_factory__get_prepared_statement)(MYSQLND_CONN_DATA * conn);
414 typedef MYSQLND_PFC * (*func_mysqlnd_object_factory__get_pfc)(const bool persistent, MYSQLND_STATS * stats, MYSQLND_ERROR_INFO * error_info);
415 typedef MYSQLND_VIO * (*func_mysqlnd_object_factory__get_vio)(const bool persistent, MYSQLND_STATS * stats, MYSQLND_ERROR_INFO * error_info);
416 typedef MYSQLND_PROTOCOL_PAYLOAD_DECODER_FACTORY * (*func_mysqlnd_object_factory__get_protocol_payload_decoder_factory)(MYSQLND_CONN_DATA * conn, const bool persistent);
417
418
MYSQLND_CLASS_METHODS_TYPE(mysqlnd_object_factory)419 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_object_factory)
420 {
421 func_mysqlnd_object_factory__get_connection get_connection;
422 func_mysqlnd_object_factory__clone_connection_object clone_connection_object;
423 func_mysqlnd_object_factory__get_prepared_statement get_prepared_statement;
424 func_mysqlnd_object_factory__get_pfc get_protocol_frame_codec;
425 func_mysqlnd_object_factory__get_vio get_vio;
426 func_mysqlnd_object_factory__get_protocol_payload_decoder_factory get_protocol_payload_decoder_factory;
427 };
428
429
430 typedef enum_func_status (*func_mysqlnd_conn_data__connect)(MYSQLND_CONN_DATA * conn, MYSQLND_CSTRING hostname, MYSQLND_CSTRING username, MYSQLND_CSTRING password, MYSQLND_CSTRING database, unsigned int port, MYSQLND_CSTRING socket_or_pipe, unsigned int mysql_flags);
431 typedef zend_ulong (*func_mysqlnd_conn_data__escape_string)(MYSQLND_CONN_DATA * const conn, char *newstr, const char *escapestr, size_t escapestr_len);
432 typedef enum_func_status (*func_mysqlnd_conn_data__set_charset)(MYSQLND_CONN_DATA * const conn, const char * const charset);
433 typedef enum_func_status (*func_mysqlnd_conn_data__query)(MYSQLND_CONN_DATA * conn, const char * const query, const size_t query_len);
434 typedef enum_func_status (*func_mysqlnd_conn_data__send_query)(MYSQLND_CONN_DATA * conn, const char * const query, const size_t query_len, zval *read_cb, zval *err_cb);
435 typedef enum_func_status (*func_mysqlnd_conn_data__reap_query)(MYSQLND_CONN_DATA * conn);
436 typedef MYSQLND_RES * (*func_mysqlnd_conn_data__use_result)(MYSQLND_CONN_DATA * const conn);
437 typedef MYSQLND_RES * (*func_mysqlnd_conn_data__store_result)(MYSQLND_CONN_DATA * const conn);
438 typedef enum_func_status (*func_mysqlnd_conn_data__next_result)(MYSQLND_CONN_DATA * const conn);
439 typedef bool (*func_mysqlnd_conn_data__more_results)(const MYSQLND_CONN_DATA * const conn);
440
441 typedef MYSQLND_STMT * (*func_mysqlnd_conn_data__stmt_init)(MYSQLND_CONN_DATA * const conn);
442
443 typedef enum_func_status (*func_mysqlnd_conn_data__shutdown_server)(MYSQLND_CONN_DATA * const conn, uint8_t level);
444 typedef enum_func_status (*func_mysqlnd_conn_data__refresh_server)(MYSQLND_CONN_DATA * const conn, uint8_t options);
445
446 typedef enum_func_status (*func_mysqlnd_conn_data__ping)(MYSQLND_CONN_DATA * const conn);
447 typedef enum_func_status (*func_mysqlnd_conn_data__kill_connection)(MYSQLND_CONN_DATA * conn, unsigned int pid);
448 typedef enum_func_status (*func_mysqlnd_conn_data__select_db)(MYSQLND_CONN_DATA * const conn, const char * const db, const size_t db_len);
449 typedef enum_func_status (*func_mysqlnd_conn_data__server_dump_debug_information)(MYSQLND_CONN_DATA * const conn);
450 typedef enum_func_status (*func_mysqlnd_conn_data__change_user)(MYSQLND_CONN_DATA * const conn, const char * user, const char * passwd, const char * db, bool silent, size_t passwd_len);
451
452 typedef unsigned int (*func_mysqlnd_conn_data__get_error_no)(const MYSQLND_CONN_DATA * const conn);
453 typedef const char * (*func_mysqlnd_conn_data__get_error_str)(const MYSQLND_CONN_DATA * const conn);
454 typedef const char * (*func_mysqlnd_conn_data__get_sqlstate)(const MYSQLND_CONN_DATA * const conn);
455 typedef uint64_t (*func_mysqlnd_conn_data__get_thread_id)(const MYSQLND_CONN_DATA * const conn);
456 typedef void (*func_mysqlnd_conn_data__get_statistics)(const MYSQLND_CONN_DATA * const conn, zval *return_value ZEND_FILE_LINE_DC);
457
458 typedef zend_ulong (*func_mysqlnd_conn_data__get_server_version)(const MYSQLND_CONN_DATA * const conn);
459 typedef const char * (*func_mysqlnd_conn_data__get_server_information)(const MYSQLND_CONN_DATA * const conn);
460 typedef enum_func_status (*func_mysqlnd_conn_data__get_server_statistics)(MYSQLND_CONN_DATA * conn, zend_string **message);
461 typedef const char * (*func_mysqlnd_conn_data__get_host_information)(const MYSQLND_CONN_DATA * const conn);
462 typedef unsigned int (*func_mysqlnd_conn_data__get_protocol_information)(const MYSQLND_CONN_DATA * const conn);
463 typedef const char * (*func_mysqlnd_conn_data__get_last_message)(const MYSQLND_CONN_DATA * const conn);
464 typedef const char * (*func_mysqlnd_conn_data__charset_name)(const MYSQLND_CONN_DATA * const conn);
465 typedef MYSQLND_RES * (*func_mysqlnd_conn_data__list_method)(MYSQLND_CONN_DATA * conn, const char * const query, const char * const achtung_wild, const char * const par1);
466
467 typedef uint64_t (*func_mysqlnd_conn_data__get_last_insert_id)(const MYSQLND_CONN_DATA * const conn);
468 typedef uint64_t (*func_mysqlnd_conn_data__get_affected_rows)(const MYSQLND_CONN_DATA * const conn);
469 typedef unsigned int (*func_mysqlnd_conn_data__get_warning_count)(const MYSQLND_CONN_DATA * const conn);
470
471 typedef unsigned int (*func_mysqlnd_conn_data__get_field_count)(const MYSQLND_CONN_DATA * const conn);
472
473 typedef unsigned int (*func_mysqlnd_conn_data__get_server_status)(const MYSQLND_CONN_DATA * const conn);
474 typedef enum_func_status (*func_mysqlnd_conn_data__set_server_option)(MYSQLND_CONN_DATA * const conn, enum_mysqlnd_server_option option);
475 typedef enum_func_status (*func_mysqlnd_conn_data__set_client_option)(MYSQLND_CONN_DATA * const conn, enum_mysqlnd_client_option option, const char * const value);
476 typedef void (*func_mysqlnd_conn_data__free_contents)(MYSQLND_CONN_DATA * conn);/* private */
477 typedef void (*func_mysqlnd_conn_data__free_options)(MYSQLND_CONN_DATA * conn); /* private */
478 typedef void (*func_mysqlnd_conn_data__dtor)(MYSQLND_CONN_DATA * conn); /* private */
479
480 typedef enum_func_status (*func_mysqlnd_conn_data__query_read_result_set_header)(MYSQLND_CONN_DATA * conn, MYSQLND_STMT * stmt);
481
482 typedef MYSQLND_CONN_DATA * (*func_mysqlnd_conn_data__get_reference)(MYSQLND_CONN_DATA * const conn);
483 typedef enum_func_status (*func_mysqlnd_conn_data__free_reference)(MYSQLND_CONN_DATA * const conn);
484
485 typedef enum_func_status (*func_mysqlnd_conn_data__send_command_do_request)(MYSQLND_CONN_DATA * const conn, const enum php_mysqlnd_server_command command, const zend_uchar * const arg, const size_t arg_len, const bool silent, const bool ignore_upsert_status);
486 typedef enum_func_status (*func_mysqlnd_conn_data__send_command_handle_response)(MYSQLND_CONN_DATA * const conn, const enum mysqlnd_packet_type ok_packet, const bool silent, const enum php_mysqlnd_server_command command, const bool ignore_upsert_status);
487
488 typedef void (*func_mysqlnd_conn_data__restart_psession)(MYSQLND_CONN_DATA * conn);
489 typedef void (*func_mysqlnd_conn_data__end_psession)(MYSQLND_CONN_DATA * conn);
490 typedef enum_func_status (*func_mysqlnd_conn_data__send_close)(MYSQLND_CONN_DATA * conn);
491
492 typedef enum_func_status (*func_mysqlnd_conn_data__ssl_set)(MYSQLND_CONN_DATA * const conn, const char * key, const char * const cert, const char * const ca, const char * const capath, const char * const cipher);
493
494 typedef MYSQLND_RES * (*func_mysqlnd_conn_data__result_init)(unsigned int field_count);
495
496 typedef enum_func_status (*func_mysqlnd_conn_data__set_autocommit)(MYSQLND_CONN_DATA * conn, unsigned int mode);
497 typedef enum_func_status (*func_mysqlnd_conn_data__tx_commit)(MYSQLND_CONN_DATA * conn);
498 typedef enum_func_status (*func_mysqlnd_conn_data__tx_rollback)(MYSQLND_CONN_DATA * conn);
499 typedef enum_func_status (*func_mysqlnd_conn_data__tx_begin)(MYSQLND_CONN_DATA * conn, const unsigned int mode, const char * const name);
500 typedef enum_func_status (*func_mysqlnd_conn_data__tx_commit_or_rollback)(MYSQLND_CONN_DATA * conn, const bool commit, const unsigned int flags, const char * const name);
501 typedef void (*func_mysqlnd_conn_data__tx_cor_options_to_string)(const MYSQLND_CONN_DATA * const conn, smart_str * tmp_str, const unsigned int mode);
502 typedef enum_func_status (*func_mysqlnd_conn_data__tx_savepoint)(MYSQLND_CONN_DATA * conn, const char * const name);
503 typedef enum_func_status (*func_mysqlnd_conn_data__tx_savepoint_release)(MYSQLND_CONN_DATA * conn, const char * const name);
504
505 typedef enum_func_status (*func_mysqlnd_conn_data__execute_init_commands)(MYSQLND_CONN_DATA * conn);
506 typedef unsigned int (*func_mysqlnd_conn_data__get_updated_connect_flags)(MYSQLND_CONN_DATA * conn, unsigned int mysql_flags);
507 typedef enum_func_status (*func_mysqlnd_conn_data__connect_handshake)(MYSQLND_CONN_DATA * conn, const MYSQLND_CSTRING * const scheme, const MYSQLND_CSTRING * const username, const MYSQLND_CSTRING * const password, const MYSQLND_CSTRING * const database, const unsigned int mysql_flags);
508 typedef struct st_mysqlnd_authentication_plugin * (*func_mysqlnd_conn_data__fetch_auth_plugin_by_name)(const char * const requested_protocol);
509
510 typedef enum_func_status (*func_mysqlnd_conn_data__set_client_option_2d)(MYSQLND_CONN_DATA * const conn, const enum_mysqlnd_client_option option, const char * const key, const char * const value);
511
512
513 typedef size_t (*func_mysqlnd_conn_data__negotiate_client_api_capabilities)(MYSQLND_CONN_DATA * const conn, const size_t flags);
514 typedef size_t (*func_mysqlnd_conn_data__get_client_api_capabilities)(const MYSQLND_CONN_DATA * const conn);
515
516 typedef MYSQLND_STRING (*func_mysqlnd_conn_data__get_scheme)(MYSQLND_CONN_DATA * conn, MYSQLND_CSTRING hostname, MYSQLND_CSTRING *socket_or_pipe, unsigned int port, bool * unix_socket, bool * named_pipe);
517
518
519
MYSQLND_CLASS_METHODS_TYPE(mysqlnd_conn_data)520 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_conn_data)
521 {
522 func_mysqlnd_conn_data__connect connect;
523 func_mysqlnd_conn_data__escape_string escape_string;
524 func_mysqlnd_conn_data__set_charset set_charset;
525 func_mysqlnd_conn_data__query query;
526 func_mysqlnd_conn_data__send_query send_query;
527 func_mysqlnd_conn_data__reap_query reap_query;
528 func_mysqlnd_conn_data__use_result use_result;
529 func_mysqlnd_conn_data__store_result store_result;
530 func_mysqlnd_conn_data__next_result next_result;
531 func_mysqlnd_conn_data__more_results more_results;
532
533 func_mysqlnd_conn_data__stmt_init stmt_init;
534
535 func_mysqlnd_conn_data__refresh_server refresh_server;
536
537 func_mysqlnd_conn_data__ping ping;
538 func_mysqlnd_conn_data__kill_connection kill_connection;
539 func_mysqlnd_conn_data__select_db select_db;
540 func_mysqlnd_conn_data__server_dump_debug_information server_dump_debug_information;
541 func_mysqlnd_conn_data__change_user change_user;
542
543 func_mysqlnd_conn_data__get_error_no get_error_no;
544 func_mysqlnd_conn_data__get_error_str get_error_str;
545 func_mysqlnd_conn_data__get_sqlstate get_sqlstate;
546 func_mysqlnd_conn_data__get_thread_id get_thread_id;
547 func_mysqlnd_conn_data__get_statistics get_statistics;
548
549 func_mysqlnd_conn_data__get_server_version get_server_version;
550 func_mysqlnd_conn_data__get_server_information get_server_information;
551 func_mysqlnd_conn_data__get_server_statistics get_server_statistics;
552 func_mysqlnd_conn_data__get_host_information get_host_information;
553 func_mysqlnd_conn_data__get_protocol_information get_protocol_information;
554 func_mysqlnd_conn_data__get_last_message get_last_message;
555 func_mysqlnd_conn_data__charset_name charset_name;
556 func_mysqlnd_conn_data__list_method list_method;
557
558 func_mysqlnd_conn_data__get_last_insert_id get_last_insert_id;
559 func_mysqlnd_conn_data__get_affected_rows get_affected_rows;
560 func_mysqlnd_conn_data__get_warning_count get_warning_count;
561
562 func_mysqlnd_conn_data__get_field_count get_field_count;
563
564 func_mysqlnd_conn_data__get_server_status get_server_status;
565
566 func_mysqlnd_conn_data__set_server_option set_server_option;
567 func_mysqlnd_conn_data__set_client_option set_client_option;
568 func_mysqlnd_conn_data__free_contents free_contents;
569 func_mysqlnd_conn_data__free_options free_options;
570 func_mysqlnd_conn_data__dtor dtor;
571
572 func_mysqlnd_conn_data__query_read_result_set_header query_read_result_set_header;
573
574 func_mysqlnd_conn_data__get_reference get_reference;
575 func_mysqlnd_conn_data__free_reference free_reference;
576
577 func_mysqlnd_conn_data__restart_psession restart_psession;
578 func_mysqlnd_conn_data__end_psession end_psession;
579 func_mysqlnd_conn_data__send_close send_close;
580
581 func_mysqlnd_conn_data__ssl_set ssl_set;
582
583 func_mysqlnd_conn_data__result_init result_init;
584 func_mysqlnd_conn_data__set_autocommit set_autocommit;
585 func_mysqlnd_conn_data__tx_commit tx_commit;
586 func_mysqlnd_conn_data__tx_rollback tx_rollback;
587 func_mysqlnd_conn_data__tx_begin tx_begin;
588 func_mysqlnd_conn_data__tx_commit_or_rollback tx_commit_or_rollback;
589 func_mysqlnd_conn_data__tx_cor_options_to_string tx_cor_options_to_string;
590 func_mysqlnd_conn_data__tx_savepoint tx_savepoint;
591 func_mysqlnd_conn_data__tx_savepoint_release tx_savepoint_release;
592
593 func_mysqlnd_conn_data__execute_init_commands execute_init_commands;
594 func_mysqlnd_conn_data__get_updated_connect_flags get_updated_connect_flags;
595 func_mysqlnd_conn_data__connect_handshake connect_handshake;
596 func_mysqlnd_conn_data__fetch_auth_plugin_by_name fetch_auth_plugin_by_name;
597
598 func_mysqlnd_conn_data__set_client_option_2d set_client_option_2d;
599
600 func_mysqlnd_conn_data__negotiate_client_api_capabilities negotiate_client_api_capabilities;
601 func_mysqlnd_conn_data__get_client_api_capabilities get_client_api_capabilities;
602
603 func_mysqlnd_conn_data__get_scheme get_scheme;
604 };
605
606
607 typedef enum_func_status (*func_mysqlnd_data__connect)(MYSQLND * conn, const MYSQLND_CSTRING hostname, const MYSQLND_CSTRING username, const MYSQLND_CSTRING password, const MYSQLND_CSTRING database, unsigned int port, const MYSQLND_CSTRING socket_or_pipe, unsigned int mysql_flags);
608 typedef MYSQLND * (*func_mysqlnd_conn__clone_object)(MYSQLND * const conn);
609 typedef void (*func_mysqlnd_conn__dtor)(MYSQLND * conn);
610 typedef enum_func_status (*func_mysqlnd_conn__close)(MYSQLND * conn, const enum_connection_close_type close_type);
611
MYSQLND_CLASS_METHODS_TYPE(mysqlnd_conn)612 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_conn)
613 {
614 func_mysqlnd_data__connect connect;
615 func_mysqlnd_conn__clone_object clone_object;
616 func_mysqlnd_conn__dtor dtor;
617 func_mysqlnd_conn__close close;
618 };
619
620
621 /* for decoding - binary or text protocol */
622 typedef enum_func_status (*func_mysqlnd_res__row_decoder)(MYSQLND_ROW_BUFFER * row_buffer, zval * fields,
623 const unsigned int field_count, const MYSQLND_FIELD * const fields_metadata,
624 const bool as_int_or_float, MYSQLND_STATS * const stats);
625
626
627 typedef MYSQLND_RES * (*func_mysqlnd_res__use_result)(MYSQLND_RES * const result, MYSQLND_STMT_DATA *stmt);
628 typedef MYSQLND_RES * (*func_mysqlnd_res__store_result)(MYSQLND_RES * result, MYSQLND_CONN_DATA * const conn, MYSQLND_STMT_DATA *stmt);
629 typedef void (*func_mysqlnd_res__fetch_into)(MYSQLND_RES *result, const unsigned int flags, zval *return_value ZEND_FILE_LINE_DC);
630 typedef MYSQLND_ROW_C (*func_mysqlnd_res__fetch_row_c)(MYSQLND_RES *result);
631 typedef uint64_t (*func_mysqlnd_res__num_rows)(const MYSQLND_RES * const result);
632 typedef unsigned int (*func_mysqlnd_res__num_fields)(const MYSQLND_RES * const result);
633 typedef void (*func_mysqlnd_res__skip_result)(MYSQLND_RES * const result);
634 typedef enum_func_status (*func_mysqlnd_res__seek_data)(MYSQLND_RES * const result, const uint64_t row);
635 typedef MYSQLND_FIELD_OFFSET (*func_mysqlnd_res__seek_field)(MYSQLND_RES * const result, const MYSQLND_FIELD_OFFSET field_offset);
636 typedef MYSQLND_FIELD_OFFSET (*func_mysqlnd_res__field_tell)(const MYSQLND_RES * const result);
637 typedef const MYSQLND_FIELD *(*func_mysqlnd_res__fetch_field)(MYSQLND_RES * const result);
638 typedef const MYSQLND_FIELD *(*func_mysqlnd_res__fetch_field_direct)(MYSQLND_RES * const result, const MYSQLND_FIELD_OFFSET fieldnr);
639 typedef const MYSQLND_FIELD *(*func_mysqlnd_res__fetch_fields)(MYSQLND_RES * const result);
640
641 typedef enum_func_status (*func_mysqlnd_res__read_result_metadata)(MYSQLND_RES * result, MYSQLND_CONN_DATA * conn);
642 typedef const size_t * (*func_mysqlnd_res__fetch_lengths)(const MYSQLND_RES * const result);
643 typedef enum_func_status (*func_mysqlnd_res__store_result_fetch_data)(MYSQLND_CONN_DATA * const conn, MYSQLND_RES * result, MYSQLND_RES_METADATA * meta, MYSQLND_ROW_BUFFER ** row_buffers, bool binary_protocol);
644
645 typedef void (*func_mysqlnd_res__free_result_buffers)(MYSQLND_RES * result); /* private */
646 typedef enum_func_status (*func_mysqlnd_res__free_result)(MYSQLND_RES * result, const bool implicit);
647 typedef void (*func_mysqlnd_res__free_result_contents)(MYSQLND_RES *result);
648 typedef void (*func_mysqlnd_res__free_buffered_data)(MYSQLND_RES *result);
649
650
651 typedef MYSQLND_RES_METADATA * (*func_mysqlnd_res__result_meta_init)(MYSQLND_RES *result, unsigned int field_count);
652
MYSQLND_CLASS_METHODS_TYPE(mysqlnd_res)653 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_res)
654 {
655 mysqlnd_fetch_row_func fetch_row;
656
657 func_mysqlnd_res__use_result use_result;
658 func_mysqlnd_res__store_result store_result;
659 func_mysqlnd_res__fetch_into fetch_into;
660 func_mysqlnd_res__fetch_row_c fetch_row_c;
661 func_mysqlnd_res__num_rows num_rows;
662 func_mysqlnd_res__num_fields num_fields;
663 func_mysqlnd_res__skip_result skip_result;
664 func_mysqlnd_res__seek_data seek_data;
665 func_mysqlnd_res__seek_field seek_field;
666 func_mysqlnd_res__field_tell field_tell;
667 func_mysqlnd_res__fetch_field fetch_field;
668 func_mysqlnd_res__fetch_field_direct fetch_field_direct;
669 func_mysqlnd_res__fetch_fields fetch_fields;
670 func_mysqlnd_res__read_result_metadata read_result_metadata;
671 func_mysqlnd_res__fetch_lengths fetch_lengths;
672 func_mysqlnd_res__store_result_fetch_data store_result_fetch_data;
673 func_mysqlnd_res__free_result_buffers free_result_buffers;
674 func_mysqlnd_res__free_result free_result;
675 func_mysqlnd_res__free_result_contents free_result_contents;
676
677 func_mysqlnd_res__result_meta_init result_meta_init;
678
679 void * unused1;
680 void * unused2;
681 void * unused3;
682 void * unused4;
683 void * unused5;
684 };
685
686
687 typedef uint64_t (*func_mysqlnd_result_unbuffered__num_rows)(const MYSQLND_RES_UNBUFFERED * const result);
688 typedef const size_t * (*func_mysqlnd_result_unbuffered__fetch_lengths)(const MYSQLND_RES_UNBUFFERED * const result);
689 typedef void (*func_mysqlnd_result_unbuffered__free_result)(MYSQLND_RES_UNBUFFERED * const result, MYSQLND_STATS * const global_stats);
690
MYSQLND_CLASS_METHODS_TYPE(mysqlnd_result_unbuffered)691 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_result_unbuffered)
692 {
693 mysqlnd_fetch_row_func fetch_row;
694 func_mysqlnd_res__row_decoder row_decoder;
695 func_mysqlnd_result_unbuffered__num_rows num_rows;
696 func_mysqlnd_result_unbuffered__fetch_lengths fetch_lengths;
697 func_mysqlnd_result_unbuffered__free_result free_result;
698 };
699
700 typedef uint64_t (*func_mysqlnd_result_buffered__num_rows)(const MYSQLND_RES_BUFFERED * const result);
701 typedef const size_t * (*func_mysqlnd_result_buffered__fetch_lengths)(const MYSQLND_RES_BUFFERED * const result);
702 typedef enum_func_status (*func_mysqlnd_result_buffered__data_seek)(MYSQLND_RES_BUFFERED * const result, const uint64_t row);
703 typedef void (*func_mysqlnd_result_buffered__free_result)(MYSQLND_RES_BUFFERED * const result);
704
MYSQLND_CLASS_METHODS_TYPE(mysqlnd_result_buffered)705 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_result_buffered)
706 {
707 mysqlnd_fetch_row_func fetch_row;
708 func_mysqlnd_res__row_decoder row_decoder;
709 func_mysqlnd_result_buffered__num_rows num_rows;
710 func_mysqlnd_result_buffered__fetch_lengths fetch_lengths;
711 func_mysqlnd_result_buffered__data_seek data_seek;
712 func_mysqlnd_result_buffered__free_result free_result;
713 };
714
715
716 typedef const MYSQLND_FIELD * (*func_mysqlnd_res_meta__fetch_field)(MYSQLND_RES_METADATA * const meta);
717 typedef const MYSQLND_FIELD * (*func_mysqlnd_res_meta__fetch_field_direct)(const MYSQLND_RES_METADATA * const meta, const MYSQLND_FIELD_OFFSET fieldnr);
718 typedef const MYSQLND_FIELD * (*func_mysqlnd_res_meta__fetch_fields)(MYSQLND_RES_METADATA * const meta);
719 typedef MYSQLND_FIELD_OFFSET (*func_mysqlnd_res_meta__field_tell)(const MYSQLND_RES_METADATA * const meta);
720 typedef MYSQLND_FIELD_OFFSET (*func_mysqlnd_res_meta__field_seek)(MYSQLND_RES_METADATA * const meta, const MYSQLND_FIELD_OFFSET field_offset);
721 typedef enum_func_status (*func_mysqlnd_res_meta__read_metadata)(MYSQLND_RES_METADATA * const meta, MYSQLND_CONN_DATA * conn, MYSQLND_RES * result);
722 typedef MYSQLND_RES_METADATA * (*func_mysqlnd_res_meta__clone_metadata)(MYSQLND_RES *result, const MYSQLND_RES_METADATA * const meta);
723 typedef void (*func_mysqlnd_res_meta__free_metadata)(MYSQLND_RES_METADATA * meta);
724
MYSQLND_CLASS_METHODS_TYPE(mysqlnd_res_meta)725 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_res_meta)
726 {
727 func_mysqlnd_res_meta__fetch_field fetch_field;
728 func_mysqlnd_res_meta__fetch_field_direct fetch_field_direct;
729 func_mysqlnd_res_meta__fetch_fields fetch_fields;
730 func_mysqlnd_res_meta__field_tell field_tell;
731 func_mysqlnd_res_meta__field_seek field_seek;
732 func_mysqlnd_res_meta__read_metadata read_metadata;
733 func_mysqlnd_res_meta__clone_metadata clone_metadata;
734 func_mysqlnd_res_meta__free_metadata free_metadata;
735 };
736
737
738 typedef enum_func_status (*func_mysqlnd_stmt__prepare)(MYSQLND_STMT * const stmt, const char * const query, const size_t query_len);
739 typedef enum_func_status (*func_mysqlnd_stmt__send_execute)(MYSQLND_STMT * const s, const enum_mysqlnd_send_execute_type type, zval * read_cb, zval * err_cb);
740 typedef enum_func_status (*func_mysqlnd_stmt__execute)(MYSQLND_STMT * const stmt);
741 typedef MYSQLND_RES * (*func_mysqlnd_stmt__use_result)(MYSQLND_STMT * const stmt);
742 typedef MYSQLND_RES * (*func_mysqlnd_stmt__store_result)(MYSQLND_STMT * const stmt);
743 typedef MYSQLND_RES * (*func_mysqlnd_stmt__get_result)(MYSQLND_STMT * const stmt);
744 typedef bool (*func_mysqlnd_stmt__more_results)(const MYSQLND_STMT * const stmt);
745 typedef enum_func_status (*func_mysqlnd_stmt__next_result)(MYSQLND_STMT * const stmt);
746 typedef enum_func_status (*func_mysqlnd_stmt__free_result)(MYSQLND_STMT * const stmt);
747 typedef enum_func_status (*func_mysqlnd_stmt__seek_data)(const MYSQLND_STMT * const stmt, uint64_t row);
748 typedef enum_func_status (*func_mysqlnd_stmt__reset)(MYSQLND_STMT * const stmt);
749 typedef enum_func_status (*func_mysqlnd_stmt__close_on_server)(MYSQLND_STMT * const stmt, bool implicit); /* private */
750 typedef enum_func_status (*func_mysqlnd_stmt__dtor)(MYSQLND_STMT * const stmt, bool implicit); /* use this for mysqlnd_stmt_close */
751 typedef enum_func_status (*func_mysqlnd_stmt__fetch)(MYSQLND_STMT * const stmt, bool * const fetched_anything);
752 typedef enum_func_status (*func_mysqlnd_stmt__bind_parameters)(MYSQLND_STMT * const stmt, MYSQLND_PARAM_BIND * const param_bind);
753 typedef enum_func_status (*func_mysqlnd_stmt__bind_one_parameter)(MYSQLND_STMT * const stmt, unsigned int param_no, zval * const zv, zend_uchar type);
754 typedef enum_func_status (*func_mysqlnd_stmt__refresh_bind_param)(MYSQLND_STMT * const stmt);
755 typedef enum_func_status (*func_mysqlnd_stmt__bind_result)(MYSQLND_STMT * const stmt, MYSQLND_RESULT_BIND * const result_bind);
756 typedef enum_func_status (*func_mysqlnd_stmt__bind_one_result)(MYSQLND_STMT * const stmt, unsigned int param_no);
757 typedef enum_func_status (*func_mysqlnd_stmt__send_long_data)(MYSQLND_STMT * const stmt, unsigned int param_num, const char * const data, zend_ulong length);
758 typedef MYSQLND_RES * (*func_mysqlnd_stmt__get_parameter_metadata)(MYSQLND_STMT * const stmt);
759 typedef MYSQLND_RES * (*func_mysqlnd_stmt__get_result_metadata)(MYSQLND_STMT * const stmt);
760 typedef uint64_t (*func_mysqlnd_stmt__get_last_insert_id)(const MYSQLND_STMT * const stmt);
761 typedef uint64_t (*func_mysqlnd_stmt__get_affected_rows)(const MYSQLND_STMT * const stmt);
762 typedef uint64_t (*func_mysqlnd_stmt__get_num_rows)(const MYSQLND_STMT * const stmt);
763 typedef unsigned int (*func_mysqlnd_stmt__get_param_count)(const MYSQLND_STMT * const stmt);
764 typedef unsigned int (*func_mysqlnd_stmt__get_field_count)(const MYSQLND_STMT * const stmt);
765 typedef unsigned int (*func_mysqlnd_stmt__get_warning_count)(const MYSQLND_STMT * const stmt);
766 typedef unsigned int (*func_mysqlnd_stmt__get_error_no)(const MYSQLND_STMT * const stmt);
767 typedef const char * (*func_mysqlnd_stmt__get_error_str)(const MYSQLND_STMT * const stmt);
768 typedef const char * (*func_mysqlnd_stmt__get_sqlstate)(const MYSQLND_STMT * const stmt);
769 typedef enum_func_status (*func_mysqlnd_stmt__get_attribute)(const MYSQLND_STMT * const stmt, enum mysqlnd_stmt_attr attr_type, void * const value);
770 typedef enum_func_status (*func_mysqlnd_stmt__set_attribute)(MYSQLND_STMT * const stmt, enum mysqlnd_stmt_attr attr_type, const void * const value);
771 typedef MYSQLND_PARAM_BIND *(*func_mysqlnd_stmt__alloc_param_bind)(MYSQLND_STMT * const stmt);
772 typedef MYSQLND_RESULT_BIND*(*func_mysqlnd_stmt__alloc_result_bind)(MYSQLND_STMT * const stmt);
773 typedef void (*func_mysqlnd_stmt__free_parameter_bind)(MYSQLND_STMT * const stmt, MYSQLND_PARAM_BIND *);
774 typedef void (*func_mysqlnd_stmt__free_result_bind)(MYSQLND_STMT * const stmt, MYSQLND_RESULT_BIND *);
775 typedef unsigned int (*func_mysqlnd_stmt__server_status)(const MYSQLND_STMT * const stmt);
776 typedef enum_func_status (*func_mysqlnd_stmt__generate_execute_request)(MYSQLND_STMT * const s, zend_uchar ** request, size_t *request_len, bool * free_buffer);
777 typedef enum_func_status (*func_mysqlnd_stmt__parse_execute_response)(MYSQLND_STMT * const s, enum_mysqlnd_parse_exec_response_type type);
778 typedef void (*func_mysqlnd_stmt__free_stmt_content)(MYSQLND_STMT * const s);
779 typedef enum_func_status (*func_mysqlnd_stmt__flush)(MYSQLND_STMT * const stmt);
780 typedef void (*func_mysqlnd_stmt__free_stmt_result)(MYSQLND_STMT * const s);
781
MYSQLND_CLASS_METHODS_TYPE(mysqlnd_stmt)782 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_stmt)
783 {
784 func_mysqlnd_stmt__prepare prepare;
785 func_mysqlnd_stmt__send_execute send_execute;
786 func_mysqlnd_stmt__execute execute;
787 func_mysqlnd_stmt__use_result use_result;
788 func_mysqlnd_stmt__store_result store_result;
789 func_mysqlnd_stmt__get_result get_result;
790 func_mysqlnd_stmt__more_results more_results;
791 func_mysqlnd_stmt__next_result next_result;
792 func_mysqlnd_stmt__free_result free_result;
793 func_mysqlnd_stmt__seek_data seek_data;
794 func_mysqlnd_stmt__reset reset;
795 func_mysqlnd_stmt__close_on_server close_on_server;
796 func_mysqlnd_stmt__dtor dtor;
797 func_mysqlnd_stmt__fetch fetch;
798
799 func_mysqlnd_stmt__bind_parameters bind_parameters;
800 func_mysqlnd_stmt__bind_one_parameter bind_one_parameter;
801 func_mysqlnd_stmt__refresh_bind_param refresh_bind_param;
802 func_mysqlnd_stmt__bind_result bind_result;
803 func_mysqlnd_stmt__bind_one_result bind_one_result;
804 func_mysqlnd_stmt__send_long_data send_long_data;
805 func_mysqlnd_stmt__get_result_metadata get_result_metadata;
806
807 func_mysqlnd_stmt__get_last_insert_id get_last_insert_id;
808 func_mysqlnd_stmt__get_affected_rows get_affected_rows;
809 func_mysqlnd_stmt__get_num_rows get_num_rows;
810
811 func_mysqlnd_stmt__get_param_count get_param_count;
812 func_mysqlnd_stmt__get_field_count get_field_count;
813 func_mysqlnd_stmt__get_warning_count get_warning_count;
814
815 func_mysqlnd_stmt__get_error_no get_error_no;
816 func_mysqlnd_stmt__get_error_str get_error_str;
817 func_mysqlnd_stmt__get_sqlstate get_sqlstate;
818
819 func_mysqlnd_stmt__get_attribute get_attribute;
820 func_mysqlnd_stmt__set_attribute set_attribute;
821
822 func_mysqlnd_stmt__alloc_param_bind alloc_parameter_bind;
823 func_mysqlnd_stmt__alloc_result_bind alloc_result_bind;
824
825 func_mysqlnd_stmt__free_parameter_bind free_parameter_bind;
826 func_mysqlnd_stmt__free_result_bind free_result_bind;
827
828 func_mysqlnd_stmt__server_status get_server_status;
829
830 func_mysqlnd_stmt__generate_execute_request generate_execute_request;
831 func_mysqlnd_stmt__parse_execute_response parse_execute_response;
832
833 func_mysqlnd_stmt__free_stmt_content free_stmt_content;
834
835 func_mysqlnd_stmt__flush flush;
836
837 func_mysqlnd_stmt__free_stmt_result free_stmt_result;
838 };
839
840
841 struct st_mysqlnd_vio_data
842 {
843 php_stream *stream;
844 bool ssl;
845 MYSQLND_VIO_OPTIONS options;
846 #ifdef MYSQLND_DO_WIRE_CHECK_BEFORE_COMMAND
847 zend_uchar last_command;
848 #else
849 zend_uchar unused_pad1;
850 #endif
851
852 bool persistent;
853
854 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_vio) m;
855 };
856
857
858 struct st_mysqlnd_vio
859 {
860 struct st_mysqlnd_vio_data * data;
861
862 bool persistent;
863 };
864
865
866
867 typedef struct st_mysqlnd_connection_state MYSQLND_CONNECTION_STATE;
868 typedef enum mysqlnd_connection_state (*func_mysqlnd_connection_state__get)(const MYSQLND_CONNECTION_STATE * const state_struct);
869 typedef void (*func_mysqlnd_connection_state__set)(MYSQLND_CONNECTION_STATE * const state_struct, const enum mysqlnd_connection_state state);
870
871
MYSQLND_CLASS_METHODS_TYPE(mysqlnd_connection_state)872 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_connection_state)
873 {
874 func_mysqlnd_connection_state__get get;
875 func_mysqlnd_connection_state__set set;
876 };
877
878 struct st_mysqlnd_connection_state
879 {
880 enum mysqlnd_connection_state state;
881
882 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_connection_state) *m;
883 };
884
885 struct st_mysqlnd_connection_data
886 {
887 /* Operation related */
888 MYSQLND_PFC * protocol_frame_codec;
889 MYSQLND_VIO * vio;
890 MYSQLND_PROTOCOL_PAYLOAD_DECODER_FACTORY * payload_decoder_factory;
891
892 /* Information related */
893 MYSQLND_STRING hostname;
894 MYSQLND_STRING unix_socket;
895 MYSQLND_STRING username;
896 MYSQLND_STRING password;
897 MYSQLND_STRING scheme;
898 uint64_t thread_id;
899 char *server_version;
900 char *host_info;
901 MYSQLND_STRING authentication_plugin_data;
902 const MYSQLND_CHARSET *charset;
903 const MYSQLND_CHARSET *greet_charset;
904 MYSQLND_STRING connect_or_select_db;
905 MYSQLND_INFILE infile;
906 unsigned int protocol_version;
907 unsigned int port;
908 zend_ulong server_capabilities;
909
910 /* For UPSERT queries */
911 MYSQLND_UPSERT_STATUS * upsert_status;
912 MYSQLND_UPSERT_STATUS upsert_status_impl;
913 MYSQLND_STRING last_message;
914
915 /* If error packet, we use these */
916 MYSQLND_ERROR_INFO * error_info;
917 MYSQLND_ERROR_INFO error_info_impl;
918
919 MYSQLND_CONNECTION_STATE state;
920 enum_mysqlnd_query_type last_query_type;
921 /* Temporary storage between query and (use|store)_result() call */
922 MYSQLND_RES *current_result;
923
924 /*
925 How many result sets reference this connection.
926 It won't be freed until this number reaches 0.
927 The last one, please close the door! :-)
928 The result set objects can determine by inspecting
929 'quit_sent' whether the connection is still valid.
930 */
931 unsigned int refcount;
932
933 /* Temporal storage for mysql_query */
934 unsigned int field_count;
935
936 /* options */
937 MYSQLND_SESSION_OPTIONS * options;
938 MYSQLND_SESSION_OPTIONS options_impl;
939
940 /* stats */
941 MYSQLND_STATS * stats;
942
943 size_t client_api_capabilities;
944
945 zval async_read_cb;
946 zval async_err_cb;
947 bool in_async_read_cb;
948 bool in_async_err_cb;
949
950 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_object_factory) object_factory;
951 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_command) * command;
952 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_conn_data) * m;
953
954 /* persistent connection */
955 bool persistent;
956 };
957
958
959 struct st_mysqlnd_connection
960 {
961 MYSQLND_CONN_DATA * data;
962 bool persistent;
963 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_conn) * m;
964 };
965
966
967
968 struct st_mysqlnd_packet_greet;
969 struct st_mysqlnd_packet_auth;
970 struct st_mysqlnd_packet_auth_response;
971 struct st_mysqlnd_packet_change_auth_response;
972 struct st_mysqlnd_packet_ok;
973 struct st_mysqlnd_packet_command;
974 struct st_mysqlnd_packet_eof;
975 struct st_mysqlnd_packet_rset_header;
976 struct st_mysqlnd_packet_res_field;
977 struct st_mysqlnd_packet_row;
978 struct st_mysqlnd_packet_stats;
979 struct st_mysqlnd_packet_prepare_response;
980 struct st_mysqlnd_packet_chg_user_resp;
981 struct st_mysqlnd_packet_auth_pam;
982 struct st_mysqlnd_packet_sha256_pk_request;
983 struct st_mysqlnd_packet_sha256_pk_request_response;
984 struct st_mysqlnd_packet_cached_sha2_result;
985
986 typedef void (*func_mysqlnd_protocol_payload_decoder_factory__init_greet_packet)(struct st_mysqlnd_packet_greet *packet);
987 typedef void (*func_mysqlnd_protocol_payload_decoder_factory__init_auth_packet)(struct st_mysqlnd_packet_auth *packet);
988 typedef void (*func_mysqlnd_protocol_payload_decoder_factory__init_auth_response_packet)(struct st_mysqlnd_packet_auth_response *packet);
989 typedef void (*func_mysqlnd_protocol_payload_decoder_factory__init_change_auth_response_packet)(struct st_mysqlnd_packet_change_auth_response *packet);
990 typedef void (*func_mysqlnd_protocol_payload_decoder_factory__init_ok_packet)(struct st_mysqlnd_packet_ok *packet);
991 typedef void (*func_mysqlnd_protocol_payload_decoder_factory__init_command_packet)(struct st_mysqlnd_packet_command *packet);
992 typedef void (*func_mysqlnd_protocol_payload_decoder_factory__init_eof_packet)(struct st_mysqlnd_packet_eof *packet);
993 typedef void (*func_mysqlnd_protocol_payload_decoder_factory__init_rset_header_packet)(struct st_mysqlnd_packet_rset_header *packet);
994 typedef void (*func_mysqlnd_protocol_payload_decoder_factory__init_result_field_packet)(struct st_mysqlnd_packet_res_field *packet);
995 typedef void (*func_mysqlnd_protocol_payload_decoder_factory__init_row_packet)(struct st_mysqlnd_packet_row *packet);
996 typedef void (*func_mysqlnd_protocol_payload_decoder_factory__init_stats_packet)(struct st_mysqlnd_packet_stats *packet);
997 typedef void (*func_mysqlnd_protocol_payload_decoder_factory__init_prepare_response_packet)(struct st_mysqlnd_packet_prepare_response *packet);
998 typedef void (*func_mysqlnd_protocol_payload_decoder_factory__init_change_user_response_packet)(struct st_mysqlnd_packet_chg_user_resp *packet);
999 typedef void (*func_mysqlnd_protocol_payload_decoder_factory__init_sha256_pk_request_packet)(struct st_mysqlnd_packet_sha256_pk_request *packet);
1000 typedef void (*func_mysqlnd_protocol_payload_decoder_factory__init_sha256_pk_request_response_packet)(struct st_mysqlnd_packet_sha256_pk_request_response *packet);
1001 typedef void (*func_mysqlnd_protocol_payload_decoder_factory__init_cached_sha2_result_packet)(struct st_mysqlnd_packet_cached_sha2_result *packet);
1002
1003 typedef enum_func_status (*func_mysqlnd_protocol_payload_decoder_factory__send_command)(
1004 MYSQLND_PROTOCOL_PAYLOAD_DECODER_FACTORY * payload_decoder_factory,
1005 const enum php_mysqlnd_server_command command,
1006 const zend_uchar * const arg, const size_t arg_len,
1007 const bool silent,
1008
1009 MYSQLND_CONNECTION_STATE * connection_state,
1010 MYSQLND_ERROR_INFO * error_info,
1011 MYSQLND_UPSERT_STATUS * upsert_status,
1012 MYSQLND_STATS * stats,
1013 func_mysqlnd_conn_data__send_close send_close,
1014 void * send_close_ctx);
1015
1016 typedef enum_func_status (*func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_OK)(
1017 MYSQLND_PROTOCOL_PAYLOAD_DECODER_FACTORY * const payload_decoder_factory,
1018 MYSQLND_ERROR_INFO * const error_info,
1019 MYSQLND_UPSERT_STATUS * const upsert_status,
1020 const bool ignore_upsert_status, /* actually used only by LOAD DATA. COM_QUERY and COM_EXECUTE handle the responses themselves */
1021 MYSQLND_STRING * const last_message);
1022
1023 typedef enum_func_status (*func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_EOF)(
1024 MYSQLND_PROTOCOL_PAYLOAD_DECODER_FACTORY * const payload_decoder_factory,
1025 MYSQLND_ERROR_INFO * const error_info,
1026 MYSQLND_UPSERT_STATUS * const upsert_status);
1027
1028 typedef enum_func_status (*func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response)(
1029 MYSQLND_PROTOCOL_PAYLOAD_DECODER_FACTORY * payload_decoder_factory,
1030 const enum mysqlnd_packet_type ok_packet,
1031 const bool silent,
1032 const enum php_mysqlnd_server_command command,
1033 const bool ignore_upsert_status, /* actually used only by LOAD DATA. COM_QUERY and COM_EXECUTE handle the responses themselves */
1034
1035 MYSQLND_ERROR_INFO * error_info,
1036 MYSQLND_UPSERT_STATUS * upsert_status,
1037 MYSQLND_STRING * last_message);
1038
1039
MYSQLND_CLASS_METHODS_TYPE(mysqlnd_protocol_payload_decoder_factory)1040 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_protocol_payload_decoder_factory)
1041 {
1042 func_mysqlnd_protocol_payload_decoder_factory__init_greet_packet init_greet_packet;
1043 func_mysqlnd_protocol_payload_decoder_factory__init_auth_packet init_auth_packet;
1044 func_mysqlnd_protocol_payload_decoder_factory__init_auth_response_packet init_auth_response_packet;
1045 func_mysqlnd_protocol_payload_decoder_factory__init_change_auth_response_packet init_change_auth_response_packet;
1046 func_mysqlnd_protocol_payload_decoder_factory__init_ok_packet init_ok_packet;
1047 func_mysqlnd_protocol_payload_decoder_factory__init_command_packet init_command_packet;
1048 func_mysqlnd_protocol_payload_decoder_factory__init_eof_packet init_eof_packet;
1049 func_mysqlnd_protocol_payload_decoder_factory__init_rset_header_packet init_rset_header_packet;
1050 func_mysqlnd_protocol_payload_decoder_factory__init_result_field_packet init_result_field_packet;
1051 func_mysqlnd_protocol_payload_decoder_factory__init_row_packet init_row_packet;
1052 func_mysqlnd_protocol_payload_decoder_factory__init_stats_packet init_stats_packet;
1053 func_mysqlnd_protocol_payload_decoder_factory__init_prepare_response_packet init_prepare_response_packet;
1054 func_mysqlnd_protocol_payload_decoder_factory__init_change_user_response_packet init_change_user_response_packet;
1055 func_mysqlnd_protocol_payload_decoder_factory__init_sha256_pk_request_packet init_sha256_pk_request_packet;
1056 func_mysqlnd_protocol_payload_decoder_factory__init_sha256_pk_request_response_packet init_sha256_pk_request_response_packet;
1057 func_mysqlnd_protocol_payload_decoder_factory__init_cached_sha2_result_packet init_cached_sha2_result_packet;
1058
1059 func_mysqlnd_protocol_payload_decoder_factory__send_command send_command;
1060 func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response send_command_handle_response;
1061 func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_OK send_command_handle_OK;
1062 func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_EOF send_command_handle_EOF;
1063 };
1064
1065 struct st_mysqlnd_protocol_payload_decoder_factory
1066 {
1067 MYSQLND_CONN_DATA * conn;
1068 bool persistent;
1069 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_protocol_payload_decoder_factory) m;
1070 };
1071
1072
1073 typedef struct st_mysqlnd_read_buffer {
1074 zend_uchar * data;
1075 size_t offset;
1076 size_t size;
1077 size_t len;
1078 bool (*is_empty)(const struct st_mysqlnd_read_buffer *);
1079 void (*read)(struct st_mysqlnd_read_buffer *, size_t count, zend_uchar * dest);
1080 size_t (*bytes_left)(const struct st_mysqlnd_read_buffer *);
1081 void (*free_buffer)(struct st_mysqlnd_read_buffer **);
1082 } MYSQLND_READ_BUFFER;
1083
1084
1085
1086 typedef void (*func_mysqlnd_pfc__init)(MYSQLND_PFC * const pfc, MYSQLND_STATS * const stats, MYSQLND_ERROR_INFO * const error_info);
1087 typedef void (*func_mysqlnd_pfc__dtor)(MYSQLND_PFC * const pfc, MYSQLND_STATS * const conn_stats, MYSQLND_ERROR_INFO * const error_info);
1088 typedef void (*func_mysqlnd_pfc__reset)(MYSQLND_PFC * const pfc, MYSQLND_STATS * const conn_stats, MYSQLND_ERROR_INFO * const error_info);
1089 typedef enum_func_status (*func_mysqlnd_pfc__set_client_option)(MYSQLND_PFC * const pfc, enum_mysqlnd_client_option option, const char * const value);
1090 typedef enum_func_status (*func_mysqlnd_pfc__decode)(zend_uchar * uncompressed_data, const size_t uncompressed_data_len, const zend_uchar * const compressed_data, const size_t compressed_data_len);
1091 typedef enum_func_status (*func_mysqlnd_pfc__encode)(zend_uchar * compress_buffer, size_t * compress_buffer_len, const zend_uchar * const uncompressed_data, const size_t uncompressed_data_len);
1092 typedef size_t (*func_mysqlnd_pfc__send)(MYSQLND_PFC * const pfc, MYSQLND_VIO * const vio, zend_uchar * const buffer, const size_t count, MYSQLND_STATS * const conn_stats, MYSQLND_ERROR_INFO * const error_info);
1093 typedef enum_func_status (*func_mysqlnd_pfc__receive)(MYSQLND_PFC * const pfc, MYSQLND_VIO * const vio, zend_uchar * const buffer, const size_t count, MYSQLND_STATS * const conn_stats, MYSQLND_ERROR_INFO * const error_info);
1094 typedef enum_func_status (*func_mysqlnd_pfc__read_compressed_packet_from_stream_and_fill_read_buffer)(MYSQLND_PFC * pfc, MYSQLND_VIO * const vio, size_t net_payload_size, MYSQLND_STATS * conn_stats, MYSQLND_ERROR_INFO * error_info);
1095 typedef void (*func_mysqlnd_pfc__free_contents)(MYSQLND_PFC * pfc);
1096
MYSQLND_CLASS_METHODS_TYPE(mysqlnd_protocol_packet_frame_codec)1097 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_protocol_packet_frame_codec)
1098 {
1099 func_mysqlnd_pfc__init init;
1100 func_mysqlnd_pfc__dtor dtor;
1101 func_mysqlnd_pfc__reset reset;
1102 func_mysqlnd_pfc__set_client_option set_client_option;
1103
1104 func_mysqlnd_pfc__decode decode;
1105 func_mysqlnd_pfc__encode encode;
1106
1107 func_mysqlnd_pfc__send send;
1108 func_mysqlnd_pfc__receive receive;
1109
1110 func_mysqlnd_pfc__read_compressed_packet_from_stream_and_fill_read_buffer read_compressed_packet_from_stream_and_fill_read_buffer;
1111
1112 func_mysqlnd_pfc__free_contents free_contents;
1113 };
1114
1115
1116 struct st_mysqlnd_protocol_frame_codec_data
1117 {
1118 php_stream *stream;
1119 bool compressed;
1120 bool ssl;
1121 uint64_t flags;
1122 char * sha256_server_public_key;
1123
1124 #ifdef MYSQLND_COMPRESSION_ENABLED
1125 MYSQLND_READ_BUFFER * uncompressed_data;
1126 #else
1127 void * unused_pad1;
1128 #endif
1129
1130 /* sequence for simple checking of correct packets */
1131 zend_uchar packet_no;
1132 zend_uchar compressed_envelope_packet_no;
1133
1134 bool persistent;
1135
1136 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_protocol_packet_frame_codec) m;
1137 };
1138
1139
1140 struct st_mysqlnd_protocol_frame_codec
1141 {
1142 MYSQLND_CMD_BUFFER cmd_buffer;
1143
1144 struct st_mysqlnd_protocol_frame_codec_data * data;
1145
1146 bool persistent;
1147 };
1148
1149
1150 struct st_mysqlnd_result_metadata
1151 {
1152 MYSQLND_FIELD *fields;
1153
1154 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_res_meta) * m;
1155
1156 unsigned int current_field;
1157 unsigned int field_count;
1158 };
1159
1160
1161 struct st_mysqlnd_buffered_result
1162 {
1163 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_result_buffered) m;
1164
1165 MYSQLND_ROW_BUFFER *row_buffers;
1166 uint64_t row_count;
1167
1168 /* Column lengths of current row - both buffered and unbuffered. For buffered results it duplicates the data found in **data */
1169 size_t *lengths;
1170
1171 MYSQLND_MEMORY_POOL *result_set_memory_pool;
1172
1173 unsigned int references;
1174
1175 MYSQLND_ERROR_INFO error_info;
1176
1177 unsigned int field_count;
1178 MYSQLND_STMT_DATA *stmt;
1179
1180 uint64_t current_row;
1181
1182 void * unused1;
1183 void * unused2;
1184 void * unused3;
1185 };
1186
1187
1188 struct st_mysqlnd_unbuffered_result
1189 {
1190 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_result_unbuffered) m;
1191 uint64_t row_count;
1192
1193 /* For unbuffered (both normal and PS) */
1194 MYSQLND_ROW_BUFFER last_row_buffer;
1195
1196 /*
1197 Column lengths of current row - both buffered and unbuffered.
1198 For buffered results it duplicates the data found in **data
1199 */
1200 size_t *lengths;
1201
1202 MYSQLND_MEMORY_POOL *result_set_memory_pool;
1203
1204 struct st_mysqlnd_packet_row *row_packet;
1205
1206 unsigned int field_count;
1207
1208 bool eof_reached;
1209
1210 MYSQLND_STMT_DATA *stmt;
1211 };
1212
1213
1214 struct st_mysqlnd_res
1215 {
1216 MYSQLND_CONN_DATA *conn;
1217 enum_mysqlnd_res_type type;
1218 unsigned int field_count;
1219
1220 zval *row_data;
1221 bool free_row_data;
1222
1223 /* For metadata functions */
1224 MYSQLND_RES_METADATA *meta;
1225
1226 /* To be used with store_result() - both normal and PS */
1227 MYSQLND_RES_BUFFERED *stored_data;
1228 MYSQLND_RES_UNBUFFERED *unbuf;
1229
1230 MYSQLND_MEMORY_POOL *memory_pool;
1231
1232 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_res) m;
1233 };
1234
1235
1236 struct st_mysqlnd_param_bind
1237 {
1238 zval zv;
1239 zend_uchar type;
1240 enum_param_bind_flags flags;
1241 };
1242
1243 struct st_mysqlnd_result_bind
1244 {
1245 zval zv;
1246 bool bound;
1247 };
1248
1249
1250 struct st_mysqlnd_stmt_data
1251 {
1252 MYSQLND_CONN_DATA *conn;
1253 zend_ulong stmt_id;
1254 zend_ulong flags;/* cursor is set here */
1255 enum_mysqlnd_stmt_state state;
1256 MYSQLND_RES *result;
1257 unsigned int field_count;
1258 unsigned int param_count;
1259 unsigned char send_types_to_server;
1260 MYSQLND_PARAM_BIND *param_bind;
1261 MYSQLND_RESULT_BIND *result_bind;
1262
1263 MYSQLND_UPSERT_STATUS * upsert_status;
1264 MYSQLND_UPSERT_STATUS upsert_status_impl;
1265
1266 MYSQLND_ERROR_INFO * error_info;
1267 MYSQLND_ERROR_INFO error_info_impl;
1268
1269 bool update_max_length;
1270 zend_ulong prefetch_rows;
1271
1272 bool cursor_exists;
1273 mysqlnd_stmt_use_or_store_func default_rset_handler;
1274
1275 zval execute_read_cb;
1276 zval execute_err_cb;
1277 bool in_execute_read_cb;
1278 bool in_execute_err_cb;
1279
1280 MYSQLND_CMD_BUFFER execute_cmd_buffer;
1281 unsigned int execute_count;/* count how many times the stmt was executed */
1282 };
1283
1284
1285 struct st_mysqlnd_stmt
1286 {
1287 MYSQLND_STMT_DATA * data;
1288 MYSQLND_CLASS_METHODS_TYPE(mysqlnd_stmt) * m;
1289 };
1290
1291
1292 struct st_mysqlnd_plugin_header
1293 {
1294 unsigned int plugin_api_version;
1295 const char * plugin_name;
1296 zend_ulong plugin_version;
1297 const char * plugin_string_version;
1298 const char * plugin_license;
1299 const char * plugin_author;
1300 struct
1301 {
1302 MYSQLND_STATS * values;
1303 const MYSQLND_STRING * names;
1304 } plugin_stats;
1305
1306 struct
1307 {
1308 enum_func_status (*plugin_shutdown)(void * plugin);
1309 } m;
1310 };
1311
1312
1313 struct st_mysqlnd_plugin_core
1314 {
1315 struct st_mysqlnd_plugin_header plugin_header;
1316 };
1317
1318
1319 struct st_mysqlnd_typeii_plugin_example
1320 {
1321 struct st_mysqlnd_plugin_header plugin_header;
1322 void * methods;
1323 unsigned int counter;
1324 };
1325
1326 struct st_mysqlnd_authentication_plugin;
1327
1328 typedef zend_uchar * (*func_auth_plugin__get_auth_data)(struct st_mysqlnd_authentication_plugin * self,
1329 size_t * auth_data_len,
1330 MYSQLND_CONN_DATA * conn, const char * const user, const char * const passwd,
1331 const size_t passwd_len, zend_uchar * auth_plugin_data, size_t auth_plugin_data_len,
1332 const MYSQLND_SESSION_OPTIONS * const session_options,
1333 const MYSQLND_PFC_DATA * const pfc_data, const zend_ulong mysql_flags
1334 );
1335
1336 typedef enum_func_status (*func_auth_plugin__handle_server_response)(struct st_mysqlnd_authentication_plugin * self,
1337 MYSQLND_CONN_DATA * conn,
1338 const zend_uchar * auth_plugin_data, size_t auth_plugin_data_len,
1339 const char * const passwd,
1340 const size_t passwd_len,
1341 char **new_auth_protocol, size_t *new_auth_protocol_len,
1342 zend_uchar **new_auth_protocol_data, size_t *new_auth_protocol_data_len
1343 );
1344
1345 struct st_mysqlnd_authentication_plugin
1346 {
1347 struct st_mysqlnd_plugin_header plugin_header;
1348 struct {
1349 func_auth_plugin__get_auth_data get_auth_data;
1350 func_auth_plugin__handle_server_response handle_server_response;
1351 } methods;
1352 };
1353
1354 #endif /* MYSQLND_STRUCTS_H */
1355
