From: Andrey Hristov Date: Tue, 10 Nov 2015 12:14:39 +0000 (+0100) Subject: MNDR: X-Git-Tag: php-7.1.0alpha1~760 X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=4248240648810fedf5d421f28a4f35936104657c;p=php MNDR: - move the command factory to own file - mysqlnd_commands.c --- diff --git a/ext/mysqlnd/config.w32 b/ext/mysqlnd/config.w32 index 504321814d..00a7cd4453 100644 --- a/ext/mysqlnd/config.w32 +++ b/ext/mysqlnd/config.w32 @@ -11,6 +11,7 @@ if (PHP_MYSQLND != "no") { "mysqlnd_auth.c " + "mysqlnd_block_alloc.c " + "mysqlnd_charset.c " + + "mysqlnd_commands.c " + "mysqlnd_debug.c " + "mysqlnd_driver.c " + "mysqlnd_ext_plugin.c " + diff --git a/ext/mysqlnd/config9.m4 b/ext/mysqlnd/config9.m4 index 6118018b5c..ef85f9bcca 100644 --- a/ext/mysqlnd/config9.m4 +++ b/ext/mysqlnd/config9.m4 @@ -21,7 +21,7 @@ if test "$PHP_MYSQLND" != "no" || test "$PHP_MYSQLND_ENABLED" = "yes"; then mysqlnd_base_sources="mysqlnd.c mysqlnd_alloc.c mysqlnd_charset.c mysqlnd_wireprotocol.c \ mysqlnd_loaddata.c mysqlnd_reverse_api.c mysqlnd_vio.c mysqlnd_protocol_frame_codec.c \ mysqlnd_statistics.c mysqlnd_driver.c mysqlnd_ext_plugin.c mysqlnd_auth.c \ - mysqlnd_result.c mysqlnd_result_meta.c mysqlnd_debug.c\ + mysqlnd_result.c mysqlnd_result_meta.c mysqlnd_debug.c mysqlnd_commands.c \ mysqlnd_block_alloc.c mysqlnd_plugin.c php_mysqlnd.c" diff --git a/ext/mysqlnd/mysqlnd.c b/ext/mysqlnd/mysqlnd.c index 65b69c8507..4be40ff75d 100644 --- a/ext/mysqlnd/mysqlnd.c +++ b/ext/mysqlnd/mysqlnd.c @@ -1010,8 +1010,7 @@ MYSQLND_METHOD(mysqlnd_conn, connect)(MYSQLND * conn_handle, const MYSQLND_CSTRING database, unsigned int port, const MYSQLND_CSTRING socket_or_pipe, - unsigned int mysql_flags - ) + unsigned int mysql_flags) { const size_t this_func = STRUCT_OFFSET(MYSQLND_CLASS_METHODS_TYPE(mysqlnd_conn_data), connect); enum_func_status ret = FAIL; diff --git a/ext/mysqlnd/mysqlnd_commands.c b/ext/mysqlnd/mysqlnd_commands.c new file mode 100644 index 0000000000..184f2ae1c9 --- /dev/null +++ b/ext/mysqlnd/mysqlnd_commands.c @@ -0,0 +1,1471 @@ +/* + +----------------------------------------------------------------------+ + | PHP Version 7 | + +----------------------------------------------------------------------+ + | Copyright (c) 2006-2015 The PHP Group | + +----------------------------------------------------------------------+ + | This source file is subject to version 3.01 of the PHP license, | + | that is bundled with this package in the file LICENSE, and is | + | available through the world-wide-web at the following url: | + | http://www.php.net/license/3_01.txt | + | If you did not receive a copy of the PHP license and are unable to | + | obtain it through the world-wide-web, please send a note to | + | license@php.net so we can mail you a copy immediately. | + +----------------------------------------------------------------------+ + | Authors: Andrey Hristov | + | Ulf Wendel | + +----------------------------------------------------------------------+ +*/ + +#include "php.h" +#include "php_globals.h" +#include "mysqlnd.h" +#include "mysqlnd_priv.h" +#include "mysqlnd_wireprotocol.h" +#include "mysqlnd_statistics.h" +#include "mysqlnd_debug.h" +#include "zend_ini.h" + + + +struct st_mysqlnd_protocol_no_params_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_protocol_no_params_command_context + { + MYSQLND_CONN_DATA * conn; + } context; +}; + +/* {{{ mysqlnd_com_no_params_free_command */ +static void +mysqlnd_com_no_params_free_command(void * command) +{ + DBG_ENTER("mysqlnd_com_no_params_free_command"); + mnd_efree(command); + DBG_VOID_RETURN; +} +/* }}} */ + + +/************************** COM_SET_OPTION ******************************************/ +struct st_mysqlnd_protocol_com_set_option_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_set_option_context + { + MYSQLND_CONN_DATA * conn; + enum_mysqlnd_server_option option; + } context; +}; + + +/* {{{ mysqlnd_com_set_option_run */ +enum_func_status +mysqlnd_com_set_option_run(void *cmd) +{ + struct st_mysqlnd_protocol_com_set_option_command * command = (struct st_mysqlnd_protocol_com_set_option_command *) cmd; + zend_uchar buffer[2]; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + enum_mysqlnd_server_option option = command->context.option; + func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; + func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response send_command_handle_response = conn->payload_decoder_factory->m.send_command_handle_response; + + DBG_ENTER("mysqlnd_com_set_option_run"); + int2store(buffer, (unsigned int) option); + + ret = send_command(conn->payload_decoder_factory, COM_SET_OPTION, buffer, sizeof(buffer), FALSE, + &conn->state, + conn->error_info, + conn->upsert_status, + conn->stats, + conn->m->send_close, + conn); + if (PASS == ret) { + ret = send_command_handle_response(conn->payload_decoder_factory, PROT_EOF_PACKET, FALSE, COM_SET_OPTION, TRUE, + conn->error_info, conn->upsert_status, &conn->last_message, conn->persistent); + } + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_set_option_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_set_option_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_set_option_command * command; + DBG_ENTER("mysqlnd_com_set_option_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_set_option_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->context.option = va_arg(args, enum_mysqlnd_server_option); + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_set_option_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + + +/************************** COM_DEBUG ******************************************/ +/* {{{ mysqlnd_com_debug_run */ +static enum_func_status +mysqlnd_com_debug_run(void *cmd) +{ + struct st_mysqlnd_protocol_no_params_command * command = (struct st_mysqlnd_protocol_no_params_command *) cmd; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; + func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response send_command_handle_response = conn->payload_decoder_factory->m.send_command_handle_response; + + DBG_ENTER("mysqlnd_com_debug_run"); + + ret = send_command(conn->payload_decoder_factory, COM_DEBUG, NULL, 0, FALSE, + &conn->state, + conn->error_info, + conn->upsert_status, + conn->stats, + conn->m->send_close, + conn); + if (PASS == ret) { + ret = send_command_handle_response(conn->payload_decoder_factory, PROT_EOF_PACKET, FALSE, COM_DEBUG, TRUE, + conn->error_info, conn->upsert_status, &conn->last_message, conn->persistent); + } + + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_debug_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_debug_create_command(va_list args) +{ + struct st_mysqlnd_protocol_no_params_command * command; + DBG_ENTER("mysqlnd_com_debug_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_no_params_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->parent.free_command = mysqlnd_com_no_params_free_command; + + command->parent.run = mysqlnd_com_debug_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + + +/************************** COM_INIT_DB ******************************************/ +struct st_mysqlnd_protocol_com_init_db_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_init_db_context + { + MYSQLND_CONN_DATA * conn; + MYSQLND_CSTRING db; + } context; +}; + + +/* {{{ mysqlnd_com_init_db_run */ +static enum_func_status +mysqlnd_com_init_db_run(void *cmd) +{ + struct st_mysqlnd_protocol_com_init_db_command * command = (struct st_mysqlnd_protocol_com_init_db_command *) cmd; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + const MYSQLND_CSTRING db = command->context.db; + func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; + func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response send_command_handle_response = conn->payload_decoder_factory->m.send_command_handle_response; + + DBG_ENTER("mysqlnd_com_init_db_run"); + + ret = send_command(conn->payload_decoder_factory, COM_INIT_DB, (zend_uchar*) command->context.db.s, command->context.db.l, FALSE, + &conn->state, + conn->error_info, + conn->upsert_status, + conn->stats, + conn->m->send_close, + conn); + if (PASS == ret) { + ret = send_command_handle_response(conn->payload_decoder_factory, PROT_OK_PACKET, FALSE, COM_INIT_DB, TRUE, + conn->error_info, conn->upsert_status, &conn->last_message, conn->persistent); + } + + /* + The server sends 0 but libmysql doesn't read it and has established + a protocol of giving back -1. Thus we have to follow it :( + */ + UPSERT_STATUS_SET_AFFECTED_ROWS_TO_ERROR(conn->upsert_status); + if (ret == PASS) { + if (conn->connect_or_select_db.s) { + mnd_pefree(conn->connect_or_select_db.s, conn->persistent); + } + conn->connect_or_select_db.s = mnd_pestrndup(db.s, db.l, conn->persistent); + conn->connect_or_select_db.l = db.l; + if (!conn->connect_or_select_db.s) { + /* OOM */ + SET_OOM_ERROR(conn->error_info); + ret = FAIL; + } + } + + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_init_db_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_init_db_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_init_db_command * command; + DBG_ENTER("mysqlnd_com_init_db_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_init_db_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->context.db = va_arg(args, MYSQLND_CSTRING); + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_init_db_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + + +/************************** COM_PING ******************************************/ +/* {{{ mysqlnd_com_ping_run */ +static enum_func_status +mysqlnd_com_ping_run(void *cmd) +{ + struct st_mysqlnd_protocol_no_params_command * command = (struct st_mysqlnd_protocol_no_params_command *) cmd; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; + func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response send_command_handle_response = conn->payload_decoder_factory->m.send_command_handle_response; + + DBG_ENTER("mysqlnd_com_ping_run"); + + ret = send_command(conn->payload_decoder_factory, COM_PING, NULL, 0, TRUE, + &conn->state, + conn->error_info, + conn->upsert_status, + conn->stats, + conn->m->send_close, + conn); + if (PASS == ret) { + ret = send_command_handle_response(conn->payload_decoder_factory, PROT_OK_PACKET, TRUE, COM_PING, TRUE, + conn->error_info, conn->upsert_status, &conn->last_message, conn->persistent); + } + /* + The server sends 0 but libmysql doesn't read it and has established + a protocol of giving back -1. Thus we have to follow it :( + */ + UPSERT_STATUS_SET_AFFECTED_ROWS_TO_ERROR(conn->upsert_status); + + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_ping_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_ping_create_command(va_list args) +{ + struct st_mysqlnd_protocol_no_params_command * command; + DBG_ENTER("mysqlnd_com_ping_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_no_params_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->parent.free_command = mysqlnd_com_no_params_free_command; + + command->parent.run = mysqlnd_com_ping_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + + +/************************** COM_STATISTICS ******************************************/ +struct st_mysqlnd_protocol_com_statistics_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_statistics_context + { + MYSQLND_CONN_DATA * conn; + zend_string ** message; + } context; +}; + + +/* {{{ mysqlnd_com_statistics_run */ +static enum_func_status +mysqlnd_com_statistics_run(void *cmd) +{ + struct st_mysqlnd_protocol_com_statistics_command * command = (struct st_mysqlnd_protocol_com_statistics_command *) cmd; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + zend_string **message = command->context.message; + func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; + + DBG_ENTER("mysqlnd_com_statistics_run"); + + ret = send_command(conn->payload_decoder_factory, COM_STATISTICS, NULL, 0, FALSE, + &conn->state, + conn->error_info, + conn->upsert_status, + conn->stats, + conn->m->send_close, + conn); + + if (PASS == ret) { + MYSQLND_PACKET_STATS * stats_header = conn->payload_decoder_factory->m.get_stats_packet(conn->payload_decoder_factory, FALSE); + if (!stats_header) { + SET_OOM_ERROR(conn->error_info); + } else { + if (PASS == (ret = PACKET_READ(stats_header))) { + /* will be freed by Zend, thus don't use the mnd_ allocator */ + *message = zend_string_init(stats_header->message.s, stats_header->message.l, 0); + DBG_INF(ZSTR_VAL(*message)); + } + PACKET_FREE(stats_header); + } + } + + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_statistics_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_statistics_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_statistics_command * command; + DBG_ENTER("mysqlnd_com_statistics_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_statistics_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->context.message = va_arg(args, zend_string **); + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_statistics_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + +/************************** COM_PROCESS_KILL ******************************************/ +struct st_mysqlnd_protocol_com_process_kill_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_process_kill_context + { + MYSQLND_CONN_DATA * conn; + unsigned int process_id; + zend_bool read_response; + } context; +}; + + +/* {{{ mysqlnd_com_process_kill_run */ +enum_func_status +mysqlnd_com_process_kill_run(void *cmd) +{ + struct st_mysqlnd_protocol_com_process_kill_command * command = (struct st_mysqlnd_protocol_com_process_kill_command *) cmd; + zend_uchar buff[4]; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + zend_bool read_response = command->context.read_response; + func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; + func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response send_command_handle_response = conn->payload_decoder_factory->m.send_command_handle_response; + + DBG_ENTER("mysqlnd_com_process_kill_run"); + int4store(buff, command->context.process_id); + + ret = send_command(conn->payload_decoder_factory, COM_PROCESS_KILL, buff, 4, FALSE, + &conn->state, + conn->error_info, + conn->upsert_status, + conn->stats, + conn->m->send_close, + conn); + if (PASS == ret && read_response) { + ret = send_command_handle_response(conn->payload_decoder_factory, PROT_OK_PACKET, FALSE, COM_PROCESS_KILL, TRUE, + conn->error_info, conn->upsert_status, &conn->last_message, conn->persistent); + } + + if (read_response) { + /* + The server sends 0 but libmysql doesn't read it and has established + a protocol of giving back -1. Thus we have to follow it :( + */ + UPSERT_STATUS_SET_AFFECTED_ROWS_TO_ERROR(conn->upsert_status); + } else if (PASS == ret) { + SET_CONNECTION_STATE(&conn->state, CONN_QUIT_SENT); + conn->m->send_close(conn); + } + + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_process_kill_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_process_kill_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_process_kill_command * command; + DBG_ENTER("mysqlnd_com_process_kill_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_process_kill_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->context.process_id = va_arg(args, unsigned int); + command->context.read_response = va_arg(args, unsigned int)? TRUE:FALSE; + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_process_kill_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + +/************************** COM_REFRESH ******************************************/ +struct st_mysqlnd_protocol_com_refresh_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_refresh_context + { + MYSQLND_CONN_DATA * conn; + uint8_t options; + } context; +}; + + +/* {{{ mysqlnd_com_refresh_run */ +enum_func_status +mysqlnd_com_refresh_run(void *cmd) +{ + struct st_mysqlnd_protocol_com_refresh_command * command = (struct st_mysqlnd_protocol_com_refresh_command *) cmd; + zend_uchar bits[1]; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; + func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response send_command_handle_response = conn->payload_decoder_factory->m.send_command_handle_response; + + DBG_ENTER("mysqlnd_com_refresh_run"); + int1store(bits, command->context.options); + + ret = send_command(conn->payload_decoder_factory, COM_REFRESH, bits, 1, FALSE, + &conn->state, + conn->error_info, + conn->upsert_status, + conn->stats, + conn->m->send_close, + conn); + if (PASS == ret) { + ret = send_command_handle_response(conn->payload_decoder_factory, PROT_OK_PACKET, FALSE, COM_REFRESH, TRUE, + conn->error_info, conn->upsert_status, &conn->last_message, conn->persistent); + } + + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_refresh_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_refresh_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_refresh_command * command; + DBG_ENTER("mysqlnd_com_refresh_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_refresh_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->context.options = va_arg(args, unsigned int); + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_refresh_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + + +/************************** COM_SHUTDOWN ******************************************/ +struct st_mysqlnd_protocol_com_shutdown_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_shutdown_context + { + MYSQLND_CONN_DATA * conn; + uint8_t level; + } context; +}; + + +/* {{{ mysqlnd_com_shutdown_run */ +enum_func_status +mysqlnd_com_shutdown_run(void *cmd) +{ + struct st_mysqlnd_protocol_com_shutdown_command * command = (struct st_mysqlnd_protocol_com_shutdown_command *) cmd; + zend_uchar bits[1]; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; + func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response send_command_handle_response = conn->payload_decoder_factory->m.send_command_handle_response; + + DBG_ENTER("mysqlnd_com_shutdown_run"); + int1store(bits, command->context.level); + + ret = send_command(conn->payload_decoder_factory, COM_SHUTDOWN, bits, 1, FALSE, + &conn->state, + conn->error_info, + conn->upsert_status, + conn->stats, + conn->m->send_close, + conn); + if (PASS == ret) { + ret = send_command_handle_response(conn->payload_decoder_factory, PROT_OK_PACKET, FALSE, COM_SHUTDOWN, TRUE, + conn->error_info, conn->upsert_status, &conn->last_message, conn->persistent); + } + + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_shutdown_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_shutdown_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_shutdown_command * command; + DBG_ENTER("mysqlnd_com_shutdown_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_shutdown_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->context.level = va_arg(args, unsigned int); + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_shutdown_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + + +/************************** COM_QUIT ******************************************/ +struct st_mysqlnd_protocol_com_quit_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_quit_context + { + MYSQLND_CONN_DATA * conn; + } context; +}; + + +/* {{{ mysqlnd_com_quit_run */ +enum_func_status +mysqlnd_com_quit_run(void *cmd) +{ + struct st_mysqlnd_protocol_com_quit_command * command = (struct st_mysqlnd_protocol_com_quit_command *) cmd; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; + + DBG_ENTER("mysqlnd_com_quit_run"); + + ret = send_command(conn->payload_decoder_factory, COM_QUIT, NULL, 0, TRUE, + &conn->state, + conn->error_info, + conn->upsert_status, + conn->stats, + conn->m->send_close, + conn); + + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_quit_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_quit_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_quit_command * command; + DBG_ENTER("mysqlnd_com_quit_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_quit_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_quit_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + +/************************** COM_QUERY ******************************************/ +struct st_mysqlnd_protocol_com_query_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_query_context + { + MYSQLND_CONN_DATA * conn; + MYSQLND_CSTRING query; + } context; +}; + + +/* {{{ mysqlnd_com_query_run */ +static enum_func_status +mysqlnd_com_query_run(void *cmd) +{ + struct st_mysqlnd_protocol_com_query_command * command = (struct st_mysqlnd_protocol_com_query_command *) cmd; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; + + DBG_ENTER("mysqlnd_com_query_run"); + + ret = send_command(conn->payload_decoder_factory, COM_QUERY, (zend_uchar*) command->context.query.s, command->context.query.l, FALSE, + &conn->state, + conn->error_info, + conn->upsert_status, + conn->stats, + conn->m->send_close, + conn); + + if (PASS == ret) { + SET_CONNECTION_STATE(&conn->state, CONN_QUERY_SENT); + } + + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_query_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_query_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_query_command * command; + DBG_ENTER("mysqlnd_com_query_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_query_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->context.query = va_arg(args, MYSQLND_CSTRING); + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_query_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + +/************************** COM_CHANGE_USER ******************************************/ +struct st_mysqlnd_protocol_com_change_user_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_change_user_context + { + MYSQLND_CONN_DATA * conn; + MYSQLND_CSTRING payload; + zend_bool silent; + } context; +}; + + +/* {{{ mysqlnd_com_change_user_run */ +static enum_func_status +mysqlnd_com_change_user_run(void *cmd) +{ + struct st_mysqlnd_protocol_com_change_user_command * command = (struct st_mysqlnd_protocol_com_change_user_command *) cmd; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; + + DBG_ENTER("mysqlnd_com_change_user_run"); + + ret = send_command(conn->payload_decoder_factory, COM_CHANGE_USER, (zend_uchar*) command->context.payload.s, command->context.payload.l, command->context.silent, + &conn->state, + conn->error_info, + conn->upsert_status, + conn->stats, + conn->m->send_close, + conn); + + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_change_user_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_change_user_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_change_user_command * command; + DBG_ENTER("mysqlnd_com_change_user_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_change_user_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->context.payload = va_arg(args, MYSQLND_CSTRING); + command->context.silent = va_arg(args, unsigned int); + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_change_user_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + + +/************************** COM_REAP_RESULT ******************************************/ +struct st_mysqlnd_protocol_com_reap_result_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_reap_result_context + { + MYSQLND_CONN_DATA * conn; + } context; +}; + + +/* {{{ mysqlnd_com_reap_result_run */ +static enum_func_status +mysqlnd_com_reap_result_run(void *cmd) +{ + struct st_mysqlnd_protocol_com_reap_result_command * command = (struct st_mysqlnd_protocol_com_reap_result_command *) cmd; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + const enum_mysqlnd_connection_state state = GET_CONNECTION_STATE(&conn->state); + + DBG_ENTER("mysqlnd_com_reap_result_run"); + if (state <= CONN_READY || state == CONN_QUIT_SENT) { + php_error_docref(NULL, E_WARNING, "Connection not opened, clear or has been closed"); + DBG_ERR_FMT("Connection not opened, clear or has been closed. State=%u", state); + DBG_RETURN(ret); + } + ret = conn->m->query_read_result_set_header(conn, NULL); + + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_reap_result_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_reap_result_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_reap_result_command * command; + DBG_ENTER("mysqlnd_com_reap_result_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_reap_result_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_reap_result_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + + +/************************** COM_STMT_PREPARE ******************************************/ +struct st_mysqlnd_protocol_com_stmt_prepare_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_stmt_prepare_context + { + MYSQLND_CONN_DATA * conn; + MYSQLND_CSTRING query; + } context; +}; + + +/* {{{ mysqlnd_com_stmt_prepare_run */ +static enum_func_status +mysqlnd_com_stmt_prepare_run(void *cmd) +{ + struct st_mysqlnd_protocol_com_stmt_prepare_command * command = (struct st_mysqlnd_protocol_com_stmt_prepare_command *) cmd; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; + + DBG_ENTER("mysqlnd_com_stmt_prepare_run"); + + ret = send_command(conn->payload_decoder_factory, COM_STMT_PREPARE, (zend_uchar*) command->context.query.s, command->context.query.l, FALSE, + &conn->state, + conn->error_info, + conn->upsert_status, + conn->stats, + conn->m->send_close, + conn); + + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_stmt_prepare_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_stmt_prepare_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_stmt_prepare_command * command; + DBG_ENTER("mysqlnd_com_stmt_prepare_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_stmt_prepare_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->context.query = va_arg(args, MYSQLND_CSTRING); + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_stmt_prepare_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + + +/************************** COM_STMT_EXECUTE ******************************************/ +struct st_mysqlnd_protocol_com_stmt_execute_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_stmt_execute_context + { + MYSQLND_CONN_DATA * conn; + MYSQLND_CSTRING payload; + } context; +}; + + +/* {{{ mysqlnd_com_stmt_execute_run */ +static enum_func_status +mysqlnd_com_stmt_execute_run(void *cmd) +{ + struct st_mysqlnd_protocol_com_stmt_execute_command * command = (struct st_mysqlnd_protocol_com_stmt_execute_command *) cmd; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; + + DBG_ENTER("mysqlnd_com_stmt_execute_run"); + + ret = send_command(conn->payload_decoder_factory, COM_STMT_EXECUTE, (zend_uchar*) command->context.payload.s, command->context.payload.l, FALSE, + &conn->state, + conn->error_info, + conn->upsert_status, + conn->stats, + conn->m->send_close, + conn); + + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_stmt_execute_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_stmt_execute_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_stmt_execute_command * command; + DBG_ENTER("mysqlnd_com_stmt_execute_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_stmt_execute_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->context.payload = va_arg(args, MYSQLND_CSTRING); + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_stmt_execute_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + + +/************************** COM_STMT_FETCH ******************************************/ +struct st_mysqlnd_protocol_com_stmt_fetch_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_stmt_fetch_context + { + MYSQLND_CONN_DATA * conn; + MYSQLND_CSTRING payload; + } context; +}; + + +/* {{{ mysqlnd_com_stmt_fetch_run */ +static enum_func_status +mysqlnd_com_stmt_fetch_run(void *cmd) +{ + struct st_mysqlnd_protocol_com_stmt_fetch_command * command = (struct st_mysqlnd_protocol_com_stmt_fetch_command *) cmd; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; + + DBG_ENTER("mysqlnd_com_stmt_fetch_run"); + + ret = send_command(conn->payload_decoder_factory, COM_STMT_FETCH, (zend_uchar*) command->context.payload.s, command->context.payload.l, FALSE, + &conn->state, + conn->error_info, + conn->upsert_status, + conn->stats, + conn->m->send_close, + conn); + + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_stmt_fetch_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_stmt_fetch_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_stmt_fetch_command * command; + DBG_ENTER("mysqlnd_com_stmt_fetch_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_stmt_fetch_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->context.payload = va_arg(args, MYSQLND_CSTRING); + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_stmt_fetch_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + + +/************************** COM_STMT_RESET ******************************************/ +struct st_mysqlnd_protocol_com_stmt_reset_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_stmt_reset_context + { + MYSQLND_CONN_DATA * conn; + zend_ulong stmt_id; + } context; +}; + + +/* {{{ mysqlnd_com_stmt_reset_run */ +static enum_func_status +mysqlnd_com_stmt_reset_run(void *cmd) +{ + zend_uchar cmd_buf[MYSQLND_STMT_ID_LENGTH /* statement id */]; + struct st_mysqlnd_protocol_com_stmt_reset_command * command = (struct st_mysqlnd_protocol_com_stmt_reset_command *) cmd; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; + func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response send_command_handle_response = conn->payload_decoder_factory->m.send_command_handle_response; + + DBG_ENTER("mysqlnd_com_stmt_reset_run"); + + int4store(cmd_buf, command->context.stmt_id); + ret = send_command(conn->payload_decoder_factory, COM_STMT_RESET, cmd_buf, sizeof(cmd_buf), FALSE, + &conn->state, + conn->error_info, + conn->upsert_status, + conn->stats, + conn->m->send_close, + conn); + if (PASS == ret) { + ret = send_command_handle_response(conn->payload_decoder_factory, PROT_OK_PACKET, FALSE, COM_STMT_RESET, TRUE, + conn->error_info, conn->upsert_status, &conn->last_message, conn->persistent); + } + + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_stmt_reset_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_stmt_reset_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_stmt_reset_command * command; + DBG_ENTER("mysqlnd_com_stmt_reset_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_stmt_reset_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->context.stmt_id = va_arg(args, size_t); + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_stmt_reset_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + + +/************************** COM_STMT_SEND_LONG_DATA ******************************************/ +struct st_mysqlnd_protocol_com_stmt_send_long_data_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_stmt_send_long_data_context + { + MYSQLND_CONN_DATA * conn; + MYSQLND_CSTRING payload; + } context; +}; + + +/* {{{ mysqlnd_com_stmt_send_long_data_run */ +static enum_func_status +mysqlnd_com_stmt_send_long_data_run(void *cmd) +{ + struct st_mysqlnd_protocol_com_stmt_send_long_data_command * command = (struct st_mysqlnd_protocol_com_stmt_send_long_data_command *) cmd; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; + + DBG_ENTER("mysqlnd_com_stmt_send_long_data_run"); + + ret = send_command(conn->payload_decoder_factory, COM_STMT_SEND_LONG_DATA, (zend_uchar*) command->context.payload.s, command->context.payload.l, FALSE, + &conn->state, + conn->error_info, + conn->upsert_status, + conn->stats, + conn->m->send_close, + conn); + + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_stmt_send_long_data_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_stmt_send_long_data_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_stmt_send_long_data_command * command; + DBG_ENTER("mysqlnd_com_stmt_send_long_data_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_stmt_send_long_data_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->context.payload = va_arg(args, MYSQLND_CSTRING); + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_stmt_send_long_data_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + + +/************************** COM_STMT_CLOSE ******************************************/ +struct st_mysqlnd_protocol_com_stmt_close_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_stmt_close_context + { + MYSQLND_CONN_DATA * conn; + zend_ulong stmt_id; + } context; +}; + + +/* {{{ mysqlnd_com_stmt_close_run */ +static enum_func_status +mysqlnd_com_stmt_close_run(void *cmd) +{ + zend_uchar cmd_buf[MYSQLND_STMT_ID_LENGTH /* statement id */]; + struct st_mysqlnd_protocol_com_stmt_close_command * command = (struct st_mysqlnd_protocol_com_stmt_close_command *) cmd; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; + + DBG_ENTER("mysqlnd_com_stmt_close_run"); + + int4store(cmd_buf, command->context.stmt_id); + ret = send_command(conn->payload_decoder_factory, COM_STMT_CLOSE, cmd_buf, sizeof(cmd_buf), FALSE, + &conn->state, + conn->error_info, + conn->upsert_status, + conn->stats, + conn->m->send_close, + conn); + + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_stmt_close_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_stmt_close_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_stmt_close_command * command; + DBG_ENTER("mysqlnd_com_stmt_close_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_stmt_close_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->context.stmt_id = va_arg(args, size_t); + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_stmt_close_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + + + +/************************** COM_ENABLE_SSL ******************************************/ +struct st_mysqlnd_protocol_com_enable_ssl_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_enable_ssl_context + { + MYSQLND_CONN_DATA * conn; + size_t client_capabilities; + size_t server_capabilities; + unsigned int charset_no; + } context; +}; + + +/* {{{ mysqlnd_com_enable_ssl_run */ +static enum_func_status +mysqlnd_com_enable_ssl_run(void *cmd) +{ + struct st_mysqlnd_protocol_com_enable_ssl_command * command = (struct st_mysqlnd_protocol_com_enable_ssl_command *) cmd; + enum_func_status ret = FAIL; + MYSQLND_CONN_DATA * conn = command->context.conn; + MYSQLND_PACKET_AUTH * auth_packet; + size_t client_capabilities = command->context.client_capabilities; + size_t server_capabilities = command->context.server_capabilities; + + DBG_ENTER("mysqlnd_com_enable_ssl_run"); + DBG_INF_FMT("client_capability_flags=%lu", client_capabilities); + DBG_INF_FMT("CLIENT_LONG_PASSWORD= %d", client_capabilities & CLIENT_LONG_PASSWORD? 1:0); + DBG_INF_FMT("CLIENT_FOUND_ROWS= %d", client_capabilities & CLIENT_FOUND_ROWS? 1:0); + DBG_INF_FMT("CLIENT_LONG_FLAG= %d", client_capabilities & CLIENT_LONG_FLAG? 1:0); + DBG_INF_FMT("CLIENT_NO_SCHEMA= %d", client_capabilities & CLIENT_NO_SCHEMA? 1:0); + DBG_INF_FMT("CLIENT_COMPRESS= %d", client_capabilities & CLIENT_COMPRESS? 1:0); + DBG_INF_FMT("CLIENT_ODBC= %d", client_capabilities & CLIENT_ODBC? 1:0); + DBG_INF_FMT("CLIENT_LOCAL_FILES= %d", client_capabilities & CLIENT_LOCAL_FILES? 1:0); + DBG_INF_FMT("CLIENT_IGNORE_SPACE= %d", client_capabilities & CLIENT_IGNORE_SPACE? 1:0); + DBG_INF_FMT("CLIENT_PROTOCOL_41= %d", client_capabilities & CLIENT_PROTOCOL_41? 1:0); + DBG_INF_FMT("CLIENT_INTERACTIVE= %d", client_capabilities & CLIENT_INTERACTIVE? 1:0); + DBG_INF_FMT("CLIENT_SSL= %d", client_capabilities & CLIENT_SSL? 1:0); + DBG_INF_FMT("CLIENT_IGNORE_SIGPIPE= %d", client_capabilities & CLIENT_IGNORE_SIGPIPE? 1:0); + DBG_INF_FMT("CLIENT_TRANSACTIONS= %d", client_capabilities & CLIENT_TRANSACTIONS? 1:0); + DBG_INF_FMT("CLIENT_RESERVED= %d", client_capabilities & CLIENT_RESERVED? 1:0); + DBG_INF_FMT("CLIENT_SECURE_CONNECTION=%d", client_capabilities & CLIENT_SECURE_CONNECTION? 1:0); + DBG_INF_FMT("CLIENT_MULTI_STATEMENTS=%d", client_capabilities & CLIENT_MULTI_STATEMENTS? 1:0); + DBG_INF_FMT("CLIENT_MULTI_RESULTS= %d", client_capabilities & CLIENT_MULTI_RESULTS? 1:0); + DBG_INF_FMT("CLIENT_PS_MULTI_RESULTS=%d", client_capabilities & CLIENT_PS_MULTI_RESULTS? 1:0); + DBG_INF_FMT("CLIENT_CONNECT_ATTRS= %d", client_capabilities & CLIENT_PLUGIN_AUTH? 1:0); + DBG_INF_FMT("CLIENT_PLUGIN_AUTH_LENENC_CLIENT_DATA= %d", client_capabilities & CLIENT_PLUGIN_AUTH_LENENC_CLIENT_DATA? 1:0); + DBG_INF_FMT("CLIENT_CAN_HANDLE_EXPIRED_PASSWORDS= %d", client_capabilities & CLIENT_CAN_HANDLE_EXPIRED_PASSWORDS? 1:0); + DBG_INF_FMT("CLIENT_SESSION_TRACK= %d", client_capabilities & CLIENT_SESSION_TRACK? 1:0); + DBG_INF_FMT("CLIENT_SSL_VERIFY_SERVER_CERT= %d", client_capabilities & CLIENT_SSL_VERIFY_SERVER_CERT? 1:0); + DBG_INF_FMT("CLIENT_REMEMBER_OPTIONS= %d", client_capabilities & CLIENT_REMEMBER_OPTIONS? 1:0); + + auth_packet = conn->payload_decoder_factory->m.get_auth_packet(conn->payload_decoder_factory, FALSE); + if (!auth_packet) { + SET_OOM_ERROR(conn->error_info); + goto end; + } + auth_packet->client_flags = client_capabilities; + auth_packet->max_packet_size = MYSQLND_ASSEMBLED_PACKET_MAX_SIZE; + + auth_packet->charset_no = command->context.charset_no; + +#ifdef MYSQLND_SSL_SUPPORTED + if (client_capabilities & CLIENT_SSL) { + const zend_bool server_has_ssl = (server_capabilities & CLIENT_SSL)? TRUE:FALSE; + if (server_has_ssl == FALSE) { + goto close_conn; + } else { + enum mysqlnd_ssl_peer verify = client_capabilities & CLIENT_SSL_VERIFY_SERVER_CERT? + MYSQLND_SSL_PEER_VERIFY: + (client_capabilities & CLIENT_SSL_DONT_VERIFY_SERVER_CERT? + MYSQLND_SSL_PEER_DONT_VERIFY: + MYSQLND_SSL_PEER_DEFAULT); + DBG_INF("Switching to SSL"); + if (!PACKET_WRITE(auth_packet)) { + goto close_conn; + } + + conn->vio->data->m.set_client_option(conn->vio, MYSQL_OPT_SSL_VERIFY_SERVER_CERT, (const char *) &verify); + + if (FAIL == conn->vio->data->m.enable_ssl(conn->vio)) { + goto end; + } + } + } +#else + auth_packet->client_flags &= ~CLIENT_SSL; + if (!PACKET_WRITE(auth_packet)) { + goto close_conn; + } +#endif + ret = PASS; +end: + PACKET_FREE(auth_packet); + DBG_RETURN(ret); + +close_conn: + SET_CONNECTION_STATE(&conn->state, CONN_QUIT_SENT); + conn->m->send_close(conn); + SET_CLIENT_ERROR(conn->error_info, CR_SERVER_GONE_ERROR, UNKNOWN_SQLSTATE, mysqlnd_server_gone); + PACKET_FREE(auth_packet); + DBG_RETURN(ret); +} +/* }}} */ + + +/* {{{ mysqlnd_com_enable_ssl_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_enable_ssl_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_enable_ssl_command * command; + DBG_ENTER("mysqlnd_com_enable_ssl_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_enable_ssl_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->context.client_capabilities = va_arg(args, size_t); + command->context.server_capabilities = va_arg(args, size_t); + command->context.charset_no = va_arg(args, unsigned int); + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_enable_ssl_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + +/************************** COM_READ_HANDSHAKE ******************************************/ +struct st_mysqlnd_protocol_com_handshake_command +{ + struct st_mysqlnd_protocol_command parent; + struct st_mysqlnd_com_handshake_context + { + MYSQLND_CONN_DATA * conn; + MYSQLND_CSTRING user; + MYSQLND_CSTRING passwd; + MYSQLND_CSTRING database; + size_t client_flags; + } context; +}; + + +/* {{{ mysqlnd_com_handshake_run */ +static enum_func_status +mysqlnd_com_handshake_run(void *cmd) +{ + struct st_mysqlnd_protocol_com_handshake_command * command = (struct st_mysqlnd_protocol_com_handshake_command *) cmd; + const char * user = command->context.user.s; + + const char * passwd = command->context.passwd.s; + size_t passwd_len = command->context.passwd.l; + + const char * db = command->context.database.s; + size_t db_len = command->context.database.l; + + size_t mysql_flags = command->context.client_flags; + + MYSQLND_CONN_DATA * conn = command->context.conn; + MYSQLND_PACKET_GREET * greet_packet; + + DBG_ENTER("mysqlnd_conn_data::connect_handshake"); + DBG_INF_FMT("stream=%p", conn->vio->data->m.get_stream(conn->vio)); + DBG_INF_FMT("[user=%s] [db=%s:%d] [flags=%llu]", user, db, db_len, mysql_flags); + + greet_packet = conn->payload_decoder_factory->m.get_greet_packet(conn->payload_decoder_factory, FALSE); + if (!greet_packet) { + SET_OOM_ERROR(conn->error_info); + DBG_RETURN(FAIL); /* OOM */ + } + + if (FAIL == PACKET_READ(greet_packet)) { + DBG_ERR("Error while reading greeting packet"); + php_error_docref(NULL, E_WARNING, "Error while reading greeting packet. PID=%d", getpid()); + goto err; + } else if (greet_packet->error_no) { + DBG_ERR_FMT("errorno=%u error=%s", greet_packet->error_no, greet_packet->error); + SET_CLIENT_ERROR(conn->error_info, greet_packet->error_no, greet_packet->sqlstate, greet_packet->error); + goto err; + } else if (greet_packet->pre41) { + DBG_ERR_FMT("Connecting to 3.22, 3.23 & 4.0 is not supported. Server is %-.32s", greet_packet->server_version); + php_error_docref(NULL, E_WARNING, "Connecting to 3.22, 3.23 & 4.0 " + " is not supported. Server is %-.32s", greet_packet->server_version); + SET_CLIENT_ERROR(conn->error_info, CR_NOT_IMPLEMENTED, UNKNOWN_SQLSTATE, + "Connecting to 3.22, 3.23 & 4.0 servers is not supported"); + goto err; + } + + conn->thread_id = greet_packet->thread_id; + conn->protocol_version = greet_packet->protocol_version; + conn->server_version = mnd_pestrdup(greet_packet->server_version, conn->persistent); + + conn->greet_charset = mysqlnd_find_charset_nr(greet_packet->charset_no); + if (!conn->greet_charset) { + php_error_docref(NULL, E_WARNING, + "Server sent charset (%d) unknown to the client. Please, report to the developers", greet_packet->charset_no); + SET_CLIENT_ERROR(conn->error_info, CR_NOT_IMPLEMENTED, UNKNOWN_SQLSTATE, + "Server sent charset unknown to the client. Please, report to the developers"); + goto err; + } + + conn->server_capabilities = greet_packet->server_capabilities; + + if (FAIL == mysqlnd_connect_run_authentication(conn, user, passwd, db, db_len, (size_t) passwd_len, + greet_packet->authentication_plugin_data, greet_packet->auth_protocol, + greet_packet->charset_no, greet_packet->server_capabilities, + conn->options, mysql_flags)) + { + goto err; + } + + UPSERT_STATUS_RESET(conn->upsert_status); + UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, greet_packet->server_status); + + PACKET_FREE(greet_packet); + DBG_RETURN(PASS); +err: + conn->server_capabilities = 0; + PACKET_FREE(greet_packet); + DBG_RETURN(FAIL); +} +/* }}} */ + + +/* {{{ mysqlnd_com_handshake_create_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_com_handshake_create_command(va_list args) +{ + struct st_mysqlnd_protocol_com_handshake_command * command; + DBG_ENTER("mysqlnd_com_handshake_create_command"); + command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_handshake_command)); + if (command) { + command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); + command->context.user = *va_arg(args, const MYSQLND_CSTRING *); + command->context.passwd = *va_arg(args, const MYSQLND_CSTRING *); + command->context.database = *va_arg(args, const MYSQLND_CSTRING *); + command->context.client_flags = va_arg(args, size_t); + + command->parent.free_command = mysqlnd_com_no_params_free_command; + command->parent.run = mysqlnd_com_handshake_run; + } + + DBG_RETURN((struct st_mysqlnd_protocol_command *) command); +} +/* }}} */ + + + +/* {{{ mysqlnd_get_command */ +static struct st_mysqlnd_protocol_command * +mysqlnd_get_command(enum php_mysqlnd_server_command command, ...) +{ + struct st_mysqlnd_protocol_command * ret; + va_list args; + DBG_ENTER("mysqlnd_get_command"); + + va_start(args, command); + switch (command) { + case COM_SET_OPTION: + ret = mysqlnd_com_set_option_create_command(args); + break; + case COM_DEBUG: + ret = mysqlnd_com_debug_create_command(args); + break; + case COM_INIT_DB: + ret = mysqlnd_com_init_db_create_command(args); + break; + case COM_PING: + ret = mysqlnd_com_ping_create_command(args); + break; + case COM_STATISTICS: + ret = mysqlnd_com_statistics_create_command(args); + break; + case COM_PROCESS_KILL: + ret = mysqlnd_com_process_kill_create_command(args); + break; + case COM_REFRESH: + ret = mysqlnd_com_refresh_create_command(args); + break; + case COM_SHUTDOWN: + ret = mysqlnd_com_shutdown_create_command(args); + break; + case COM_QUIT: + ret = mysqlnd_com_quit_create_command(args); + break; + case COM_QUERY: + ret = mysqlnd_com_query_create_command(args); + break; + case COM_REAP_RESULT: + ret = mysqlnd_com_reap_result_create_command(args); + break; + case COM_CHANGE_USER: + ret = mysqlnd_com_change_user_create_command(args); + break; + case COM_STMT_PREPARE: + ret = mysqlnd_com_stmt_prepare_create_command(args); + break; + case COM_STMT_EXECUTE: + ret = mysqlnd_com_stmt_execute_create_command(args); + break; + case COM_STMT_FETCH: + ret = mysqlnd_com_stmt_fetch_create_command(args); + break; + case COM_STMT_RESET: + ret = mysqlnd_com_stmt_reset_create_command(args); + break; + case COM_STMT_SEND_LONG_DATA: + ret = mysqlnd_com_stmt_send_long_data_create_command(args); + break; + case COM_STMT_CLOSE: + ret = mysqlnd_com_stmt_close_create_command(args); + break; + case COM_ENABLE_SSL: + ret = mysqlnd_com_enable_ssl_create_command(args); + break; + case COM_HANDSHAKE: + ret = mysqlnd_com_handshake_create_command(args); + break; + default: + break; + } + va_end(args); + DBG_RETURN(ret); +} +/* }}} */ + +func_mysqlnd__command_factory mysqlnd_command_factory = mysqlnd_get_command; + +/* + * Local variables: + * tab-width: 4 + * c-basic-offset: 4 + * End: + * vim600: noet sw=4 ts=4 fdm=marker + * vim<600: noet sw=4 ts=4 + */ diff --git a/ext/mysqlnd/mysqlnd_commands.h b/ext/mysqlnd/mysqlnd_commands.h new file mode 100644 index 0000000000..d035132e75 --- /dev/null +++ b/ext/mysqlnd/mysqlnd_commands.h @@ -0,0 +1,34 @@ +/* + +----------------------------------------------------------------------+ + | PHP Version 7 | + +----------------------------------------------------------------------+ + | Copyright (c) 2006-2015 The PHP Group | + +----------------------------------------------------------------------+ + | This source file is subject to version 3.01 of the PHP license, | + | that is bundled with this package in the file LICENSE, and is | + | available through the world-wide-web at the following url: | + | http://www.php.net/license/3_01.txt | + | If you did not receive a copy of the PHP license and are unable to | + | obtain it through the world-wide-web, please send a note to | + | license@php.net so we can mail you a copy immediately. | + +----------------------------------------------------------------------+ + | Authors: Andrey Hristov | + | Ulf Wendel | + +----------------------------------------------------------------------+ +*/ + +#ifndef MYSQLND_COMMANDS_H +#define MYSQLND_COMMANDS_H + +extern func_mysqlnd__command_factory mysqlnd_command_factory; + +#endif /* MYSQLND_COMMANDS_H */ + +/* + * Local variables: + * tab-width: 4 + * c-basic-offset: 4 + * End: + * vim600: noet sw=4 ts=4 fdm=marker + * vim<600: noet sw=4 ts=4 + */ diff --git a/ext/mysqlnd/mysqlnd_ext_plugin.c b/ext/mysqlnd/mysqlnd_ext_plugin.c index 6a6627bc47..d375dafcd8 100644 --- a/ext/mysqlnd/mysqlnd_ext_plugin.c +++ b/ext/mysqlnd/mysqlnd_ext_plugin.c @@ -21,6 +21,7 @@ #include "mysqlnd_priv.h" #include "mysqlnd_result.h" #include "mysqlnd_debug.h" +#include "mysqlnd_commands.h" #include "mysqlnd_ext_plugin.h" static struct st_mysqlnd_conn_methods * mysqlnd_conn_methods; diff --git a/ext/mysqlnd/mysqlnd_priv.h b/ext/mysqlnd/mysqlnd_priv.h index af8cf830e6..e3bfee5d8c 100644 --- a/ext/mysqlnd/mysqlnd_priv.h +++ b/ext/mysqlnd/mysqlnd_priv.h @@ -214,23 +214,6 @@ mysqlnd_auth_change_user(MYSQLND_CONN_DATA * const conn, size_t * switch_to_auth_protocol_data_len ); -extern func_mysqlnd__command_factory mysqlnd_command_factory; - - -enum_func_status -send_command_handle_response( - const enum mysqlnd_packet_type ok_packet, - const zend_bool silent, - const enum php_mysqlnd_server_command command, - const zend_bool ignore_upsert_status, - - MYSQLND_ERROR_INFO * error_info, - MYSQLND_UPSERT_STATUS * upsert_status, - MYSQLND_PROTOCOL_PAYLOAD_DECODER_FACTORY * payload_decoder_factory, - MYSQLND_STRING * last_message, - zend_bool last_message_persistent - ); - enum_func_status mysqlnd_connect_run_authentication( MYSQLND_CONN_DATA * conn, diff --git a/ext/mysqlnd/mysqlnd_protocol_frame_codec.c b/ext/mysqlnd/mysqlnd_protocol_frame_codec.c index fccfd31a6b..b23b8d37c2 100644 --- a/ext/mysqlnd/mysqlnd_protocol_frame_codec.c +++ b/ext/mysqlnd/mysqlnd_protocol_frame_codec.c @@ -536,3 +536,12 @@ mysqlnd_pfc_free(MYSQLND_PFC * const pfc, MYSQLND_STATS * stats, MYSQLND_ERROR_I } /* }}} */ + +/* + * Local variables: + * tab-width: 4 + * c-basic-offset: 4 + * End: + * vim600: noet sw=4 ts=4 fdm=marker + * vim<600: noet sw=4 ts=4 + */ diff --git a/ext/mysqlnd/mysqlnd_wireprotocol.c b/ext/mysqlnd/mysqlnd_wireprotocol.c index 204c8fbe7f..dd239d5545 100644 --- a/ext/mysqlnd/mysqlnd_wireprotocol.c +++ b/ext/mysqlnd/mysqlnd_wireprotocol.c @@ -25,7 +25,6 @@ #include "mysqlnd_wireprotocol.h" #include "mysqlnd_statistics.h" #include "mysqlnd_debug.h" -#include "zend_ini.h" #define MYSQLND_SILENT 1 #define MYSQLND_DUMP_HEADER_N_BODY @@ -2981,1441 +2980,6 @@ mysqlnd_protocol_payload_decoder_factory_free(MYSQLND_PROTOCOL_PAYLOAD_DECODER_F /* }}} */ - - -struct st_mysqlnd_protocol_no_params_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_protocol_no_params_command_context - { - MYSQLND_CONN_DATA * conn; - } context; -}; - -/* {{{ mysqlnd_com_no_params_free_command */ -static void -mysqlnd_com_no_params_free_command(void * command) -{ - DBG_ENTER("mysqlnd_com_no_params_free_command"); - mnd_efree(command); - DBG_VOID_RETURN; -} -/* }}} */ - - -/************************** COM_SET_OPTION ******************************************/ -struct st_mysqlnd_protocol_com_set_option_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_set_option_context - { - MYSQLND_CONN_DATA * conn; - enum_mysqlnd_server_option option; - } context; -}; - - -/* {{{ mysqlnd_com_set_option_run */ -enum_func_status -mysqlnd_com_set_option_run(void *cmd) -{ - struct st_mysqlnd_protocol_com_set_option_command * command = (struct st_mysqlnd_protocol_com_set_option_command *) cmd; - zend_uchar buffer[2]; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - enum_mysqlnd_server_option option = command->context.option; - func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; - func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response send_command_handle_response = conn->payload_decoder_factory->m.send_command_handle_response; - - DBG_ENTER("mysqlnd_com_set_option_run"); - int2store(buffer, (unsigned int) option); - - ret = send_command(conn->payload_decoder_factory, COM_SET_OPTION, buffer, sizeof(buffer), FALSE, - &conn->state, - conn->error_info, - conn->upsert_status, - conn->stats, - conn->m->send_close, - conn); - if (PASS == ret) { - ret = send_command_handle_response(conn->payload_decoder_factory, PROT_EOF_PACKET, FALSE, COM_SET_OPTION, TRUE, - conn->error_info, conn->upsert_status, &conn->last_message, conn->persistent); - } - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_set_option_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_set_option_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_set_option_command * command; - DBG_ENTER("mysqlnd_com_set_option_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_set_option_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->context.option = va_arg(args, enum_mysqlnd_server_option); - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_set_option_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - - -/************************** COM_DEBUG ******************************************/ -/* {{{ mysqlnd_com_debug_run */ -static enum_func_status -mysqlnd_com_debug_run(void *cmd) -{ - struct st_mysqlnd_protocol_no_params_command * command = (struct st_mysqlnd_protocol_no_params_command *) cmd; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; - func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response send_command_handle_response = conn->payload_decoder_factory->m.send_command_handle_response; - - DBG_ENTER("mysqlnd_com_debug_run"); - - ret = send_command(conn->payload_decoder_factory, COM_DEBUG, NULL, 0, FALSE, - &conn->state, - conn->error_info, - conn->upsert_status, - conn->stats, - conn->m->send_close, - conn); - if (PASS == ret) { - ret = send_command_handle_response(conn->payload_decoder_factory, PROT_EOF_PACKET, FALSE, COM_DEBUG, TRUE, - conn->error_info, conn->upsert_status, &conn->last_message, conn->persistent); - } - - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_debug_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_debug_create_command(va_list args) -{ - struct st_mysqlnd_protocol_no_params_command * command; - DBG_ENTER("mysqlnd_com_debug_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_no_params_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->parent.free_command = mysqlnd_com_no_params_free_command; - - command->parent.run = mysqlnd_com_debug_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - - -/************************** COM_INIT_DB ******************************************/ -struct st_mysqlnd_protocol_com_init_db_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_init_db_context - { - MYSQLND_CONN_DATA * conn; - MYSQLND_CSTRING db; - } context; -}; - - -/* {{{ mysqlnd_com_init_db_run */ -static enum_func_status -mysqlnd_com_init_db_run(void *cmd) -{ - struct st_mysqlnd_protocol_com_init_db_command * command = (struct st_mysqlnd_protocol_com_init_db_command *) cmd; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - const MYSQLND_CSTRING db = command->context.db; - func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; - func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response send_command_handle_response = conn->payload_decoder_factory->m.send_command_handle_response; - - DBG_ENTER("mysqlnd_com_init_db_run"); - - ret = send_command(conn->payload_decoder_factory, COM_INIT_DB, (zend_uchar*) command->context.db.s, command->context.db.l, FALSE, - &conn->state, - conn->error_info, - conn->upsert_status, - conn->stats, - conn->m->send_close, - conn); - if (PASS == ret) { - ret = send_command_handle_response(conn->payload_decoder_factory, PROT_OK_PACKET, FALSE, COM_INIT_DB, TRUE, - conn->error_info, conn->upsert_status, &conn->last_message, conn->persistent); - } - - /* - The server sends 0 but libmysql doesn't read it and has established - a protocol of giving back -1. Thus we have to follow it :( - */ - UPSERT_STATUS_SET_AFFECTED_ROWS_TO_ERROR(conn->upsert_status); - if (ret == PASS) { - if (conn->connect_or_select_db.s) { - mnd_pefree(conn->connect_or_select_db.s, conn->persistent); - } - conn->connect_or_select_db.s = mnd_pestrndup(db.s, db.l, conn->persistent); - conn->connect_or_select_db.l = db.l; - if (!conn->connect_or_select_db.s) { - /* OOM */ - SET_OOM_ERROR(conn->error_info); - ret = FAIL; - } - } - - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_init_db_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_init_db_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_init_db_command * command; - DBG_ENTER("mysqlnd_com_init_db_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_init_db_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->context.db = va_arg(args, MYSQLND_CSTRING); - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_init_db_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - - -/************************** COM_PING ******************************************/ -/* {{{ mysqlnd_com_ping_run */ -static enum_func_status -mysqlnd_com_ping_run(void *cmd) -{ - struct st_mysqlnd_protocol_no_params_command * command = (struct st_mysqlnd_protocol_no_params_command *) cmd; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; - func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response send_command_handle_response = conn->payload_decoder_factory->m.send_command_handle_response; - - DBG_ENTER("mysqlnd_com_ping_run"); - - ret = send_command(conn->payload_decoder_factory, COM_PING, NULL, 0, TRUE, - &conn->state, - conn->error_info, - conn->upsert_status, - conn->stats, - conn->m->send_close, - conn); - if (PASS == ret) { - ret = send_command_handle_response(conn->payload_decoder_factory, PROT_OK_PACKET, TRUE, COM_PING, TRUE, - conn->error_info, conn->upsert_status, &conn->last_message, conn->persistent); - } - /* - The server sends 0 but libmysql doesn't read it and has established - a protocol of giving back -1. Thus we have to follow it :( - */ - UPSERT_STATUS_SET_AFFECTED_ROWS_TO_ERROR(conn->upsert_status); - - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_ping_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_ping_create_command(va_list args) -{ - struct st_mysqlnd_protocol_no_params_command * command; - DBG_ENTER("mysqlnd_com_ping_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_no_params_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->parent.free_command = mysqlnd_com_no_params_free_command; - - command->parent.run = mysqlnd_com_ping_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - - -/************************** COM_STATISTICS ******************************************/ -struct st_mysqlnd_protocol_com_statistics_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_statistics_context - { - MYSQLND_CONN_DATA * conn; - zend_string ** message; - } context; -}; - - -/* {{{ mysqlnd_com_statistics_run */ -static enum_func_status -mysqlnd_com_statistics_run(void *cmd) -{ - struct st_mysqlnd_protocol_com_statistics_command * command = (struct st_mysqlnd_protocol_com_statistics_command *) cmd; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - zend_string **message = command->context.message; - func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; - - DBG_ENTER("mysqlnd_com_statistics_run"); - - ret = send_command(conn->payload_decoder_factory, COM_STATISTICS, NULL, 0, FALSE, - &conn->state, - conn->error_info, - conn->upsert_status, - conn->stats, - conn->m->send_close, - conn); - - if (PASS == ret) { - MYSQLND_PACKET_STATS * stats_header = conn->payload_decoder_factory->m.get_stats_packet(conn->payload_decoder_factory, FALSE); - if (!stats_header) { - SET_OOM_ERROR(conn->error_info); - } else { - if (PASS == (ret = PACKET_READ(stats_header))) { - /* will be freed by Zend, thus don't use the mnd_ allocator */ - *message = zend_string_init(stats_header->message.s, stats_header->message.l, 0); - DBG_INF(ZSTR_VAL(*message)); - } - PACKET_FREE(stats_header); - } - } - - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_statistics_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_statistics_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_statistics_command * command; - DBG_ENTER("mysqlnd_com_statistics_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_statistics_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->context.message = va_arg(args, zend_string **); - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_statistics_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - -/************************** COM_PROCESS_KILL ******************************************/ -struct st_mysqlnd_protocol_com_process_kill_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_process_kill_context - { - MYSQLND_CONN_DATA * conn; - unsigned int process_id; - zend_bool read_response; - } context; -}; - - -/* {{{ mysqlnd_com_process_kill_run */ -enum_func_status -mysqlnd_com_process_kill_run(void *cmd) -{ - struct st_mysqlnd_protocol_com_process_kill_command * command = (struct st_mysqlnd_protocol_com_process_kill_command *) cmd; - zend_uchar buff[4]; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - zend_bool read_response = command->context.read_response; - func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; - func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response send_command_handle_response = conn->payload_decoder_factory->m.send_command_handle_response; - - DBG_ENTER("mysqlnd_com_process_kill_run"); - int4store(buff, command->context.process_id); - - ret = send_command(conn->payload_decoder_factory, COM_PROCESS_KILL, buff, 4, FALSE, - &conn->state, - conn->error_info, - conn->upsert_status, - conn->stats, - conn->m->send_close, - conn); - if (PASS == ret && read_response) { - ret = send_command_handle_response(conn->payload_decoder_factory, PROT_OK_PACKET, FALSE, COM_PROCESS_KILL, TRUE, - conn->error_info, conn->upsert_status, &conn->last_message, conn->persistent); - } - - if (read_response) { - /* - The server sends 0 but libmysql doesn't read it and has established - a protocol of giving back -1. Thus we have to follow it :( - */ - UPSERT_STATUS_SET_AFFECTED_ROWS_TO_ERROR(conn->upsert_status); - } else if (PASS == ret) { - SET_CONNECTION_STATE(&conn->state, CONN_QUIT_SENT); - conn->m->send_close(conn); - } - - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_process_kill_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_process_kill_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_process_kill_command * command; - DBG_ENTER("mysqlnd_com_process_kill_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_process_kill_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->context.process_id = va_arg(args, unsigned int); - command->context.read_response = va_arg(args, unsigned int)? TRUE:FALSE; - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_process_kill_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - -/************************** COM_REFRESH ******************************************/ -struct st_mysqlnd_protocol_com_refresh_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_refresh_context - { - MYSQLND_CONN_DATA * conn; - uint8_t options; - } context; -}; - - -/* {{{ mysqlnd_com_refresh_run */ -enum_func_status -mysqlnd_com_refresh_run(void *cmd) -{ - struct st_mysqlnd_protocol_com_refresh_command * command = (struct st_mysqlnd_protocol_com_refresh_command *) cmd; - zend_uchar bits[1]; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; - func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response send_command_handle_response = conn->payload_decoder_factory->m.send_command_handle_response; - - DBG_ENTER("mysqlnd_com_refresh_run"); - int1store(bits, command->context.options); - - ret = send_command(conn->payload_decoder_factory, COM_REFRESH, bits, 1, FALSE, - &conn->state, - conn->error_info, - conn->upsert_status, - conn->stats, - conn->m->send_close, - conn); - if (PASS == ret) { - ret = send_command_handle_response(conn->payload_decoder_factory, PROT_OK_PACKET, FALSE, COM_REFRESH, TRUE, - conn->error_info, conn->upsert_status, &conn->last_message, conn->persistent); - } - - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_refresh_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_refresh_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_refresh_command * command; - DBG_ENTER("mysqlnd_com_refresh_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_refresh_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->context.options = va_arg(args, unsigned int); - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_refresh_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - - -/************************** COM_SHUTDOWN ******************************************/ -struct st_mysqlnd_protocol_com_shutdown_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_shutdown_context - { - MYSQLND_CONN_DATA * conn; - uint8_t level; - } context; -}; - - -/* {{{ mysqlnd_com_shutdown_run */ -enum_func_status -mysqlnd_com_shutdown_run(void *cmd) -{ - struct st_mysqlnd_protocol_com_shutdown_command * command = (struct st_mysqlnd_protocol_com_shutdown_command *) cmd; - zend_uchar bits[1]; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; - func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response send_command_handle_response = conn->payload_decoder_factory->m.send_command_handle_response; - - DBG_ENTER("mysqlnd_com_shutdown_run"); - int1store(bits, command->context.level); - - ret = send_command(conn->payload_decoder_factory, COM_SHUTDOWN, bits, 1, FALSE, - &conn->state, - conn->error_info, - conn->upsert_status, - conn->stats, - conn->m->send_close, - conn); - if (PASS == ret) { - ret = send_command_handle_response(conn->payload_decoder_factory, PROT_OK_PACKET, FALSE, COM_SHUTDOWN, TRUE, - conn->error_info, conn->upsert_status, &conn->last_message, conn->persistent); - } - - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_shutdown_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_shutdown_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_shutdown_command * command; - DBG_ENTER("mysqlnd_com_shutdown_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_shutdown_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->context.level = va_arg(args, unsigned int); - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_shutdown_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - - -/************************** COM_QUIT ******************************************/ -struct st_mysqlnd_protocol_com_quit_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_quit_context - { - MYSQLND_CONN_DATA * conn; - } context; -}; - - -/* {{{ mysqlnd_com_quit_run */ -enum_func_status -mysqlnd_com_quit_run(void *cmd) -{ - struct st_mysqlnd_protocol_com_quit_command * command = (struct st_mysqlnd_protocol_com_quit_command *) cmd; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; - - DBG_ENTER("mysqlnd_com_quit_run"); - - ret = send_command(conn->payload_decoder_factory, COM_QUIT, NULL, 0, TRUE, - &conn->state, - conn->error_info, - conn->upsert_status, - conn->stats, - conn->m->send_close, - conn); - - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_quit_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_quit_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_quit_command * command; - DBG_ENTER("mysqlnd_com_quit_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_quit_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_quit_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - -/************************** COM_QUERY ******************************************/ -struct st_mysqlnd_protocol_com_query_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_query_context - { - MYSQLND_CONN_DATA * conn; - MYSQLND_CSTRING query; - } context; -}; - - -/* {{{ mysqlnd_com_query_run */ -static enum_func_status -mysqlnd_com_query_run(void *cmd) -{ - struct st_mysqlnd_protocol_com_query_command * command = (struct st_mysqlnd_protocol_com_query_command *) cmd; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; - - DBG_ENTER("mysqlnd_com_query_run"); - - ret = send_command(conn->payload_decoder_factory, COM_QUERY, (zend_uchar*) command->context.query.s, command->context.query.l, FALSE, - &conn->state, - conn->error_info, - conn->upsert_status, - conn->stats, - conn->m->send_close, - conn); - - if (PASS == ret) { - SET_CONNECTION_STATE(&conn->state, CONN_QUERY_SENT); - } - - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_query_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_query_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_query_command * command; - DBG_ENTER("mysqlnd_com_query_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_query_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->context.query = va_arg(args, MYSQLND_CSTRING); - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_query_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - -/************************** COM_CHANGE_USER ******************************************/ -struct st_mysqlnd_protocol_com_change_user_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_change_user_context - { - MYSQLND_CONN_DATA * conn; - MYSQLND_CSTRING payload; - zend_bool silent; - } context; -}; - - -/* {{{ mysqlnd_com_change_user_run */ -static enum_func_status -mysqlnd_com_change_user_run(void *cmd) -{ - struct st_mysqlnd_protocol_com_change_user_command * command = (struct st_mysqlnd_protocol_com_change_user_command *) cmd; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; - - DBG_ENTER("mysqlnd_com_change_user_run"); - - ret = send_command(conn->payload_decoder_factory, COM_CHANGE_USER, (zend_uchar*) command->context.payload.s, command->context.payload.l, command->context.silent, - &conn->state, - conn->error_info, - conn->upsert_status, - conn->stats, - conn->m->send_close, - conn); - - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_change_user_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_change_user_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_change_user_command * command; - DBG_ENTER("mysqlnd_com_change_user_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_change_user_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->context.payload = va_arg(args, MYSQLND_CSTRING); - command->context.silent = va_arg(args, unsigned int); - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_change_user_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - - -/************************** COM_REAP_RESULT ******************************************/ -struct st_mysqlnd_protocol_com_reap_result_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_reap_result_context - { - MYSQLND_CONN_DATA * conn; - } context; -}; - - -/* {{{ mysqlnd_com_reap_result_run */ -static enum_func_status -mysqlnd_com_reap_result_run(void *cmd) -{ - struct st_mysqlnd_protocol_com_reap_result_command * command = (struct st_mysqlnd_protocol_com_reap_result_command *) cmd; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - const enum_mysqlnd_connection_state state = GET_CONNECTION_STATE(&conn->state); - - DBG_ENTER("mysqlnd_com_reap_result_run"); - if (state <= CONN_READY || state == CONN_QUIT_SENT) { - php_error_docref(NULL, E_WARNING, "Connection not opened, clear or has been closed"); - DBG_ERR_FMT("Connection not opened, clear or has been closed. State=%u", state); - DBG_RETURN(ret); - } - ret = conn->m->query_read_result_set_header(conn, NULL); - - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_reap_result_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_reap_result_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_reap_result_command * command; - DBG_ENTER("mysqlnd_com_reap_result_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_reap_result_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_reap_result_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - - -/************************** COM_STMT_PREPARE ******************************************/ -struct st_mysqlnd_protocol_com_stmt_prepare_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_stmt_prepare_context - { - MYSQLND_CONN_DATA * conn; - MYSQLND_CSTRING query; - } context; -}; - - -/* {{{ mysqlnd_com_stmt_prepare_run */ -static enum_func_status -mysqlnd_com_stmt_prepare_run(void *cmd) -{ - struct st_mysqlnd_protocol_com_stmt_prepare_command * command = (struct st_mysqlnd_protocol_com_stmt_prepare_command *) cmd; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; - - DBG_ENTER("mysqlnd_com_stmt_prepare_run"); - - ret = send_command(conn->payload_decoder_factory, COM_STMT_PREPARE, (zend_uchar*) command->context.query.s, command->context.query.l, FALSE, - &conn->state, - conn->error_info, - conn->upsert_status, - conn->stats, - conn->m->send_close, - conn); - - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_stmt_prepare_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_stmt_prepare_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_stmt_prepare_command * command; - DBG_ENTER("mysqlnd_com_stmt_prepare_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_stmt_prepare_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->context.query = va_arg(args, MYSQLND_CSTRING); - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_stmt_prepare_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - - -/************************** COM_STMT_EXECUTE ******************************************/ -struct st_mysqlnd_protocol_com_stmt_execute_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_stmt_execute_context - { - MYSQLND_CONN_DATA * conn; - MYSQLND_CSTRING payload; - } context; -}; - - -/* {{{ mysqlnd_com_stmt_execute_run */ -static enum_func_status -mysqlnd_com_stmt_execute_run(void *cmd) -{ - struct st_mysqlnd_protocol_com_stmt_execute_command * command = (struct st_mysqlnd_protocol_com_stmt_execute_command *) cmd; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; - - DBG_ENTER("mysqlnd_com_stmt_execute_run"); - - ret = send_command(conn->payload_decoder_factory, COM_STMT_EXECUTE, (zend_uchar*) command->context.payload.s, command->context.payload.l, FALSE, - &conn->state, - conn->error_info, - conn->upsert_status, - conn->stats, - conn->m->send_close, - conn); - - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_stmt_execute_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_stmt_execute_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_stmt_execute_command * command; - DBG_ENTER("mysqlnd_com_stmt_execute_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_stmt_execute_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->context.payload = va_arg(args, MYSQLND_CSTRING); - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_stmt_execute_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - - -/************************** COM_STMT_FETCH ******************************************/ -struct st_mysqlnd_protocol_com_stmt_fetch_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_stmt_fetch_context - { - MYSQLND_CONN_DATA * conn; - MYSQLND_CSTRING payload; - } context; -}; - - -/* {{{ mysqlnd_com_stmt_fetch_run */ -static enum_func_status -mysqlnd_com_stmt_fetch_run(void *cmd) -{ - struct st_mysqlnd_protocol_com_stmt_fetch_command * command = (struct st_mysqlnd_protocol_com_stmt_fetch_command *) cmd; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; - - DBG_ENTER("mysqlnd_com_stmt_fetch_run"); - - ret = send_command(conn->payload_decoder_factory, COM_STMT_FETCH, (zend_uchar*) command->context.payload.s, command->context.payload.l, FALSE, - &conn->state, - conn->error_info, - conn->upsert_status, - conn->stats, - conn->m->send_close, - conn); - - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_stmt_fetch_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_stmt_fetch_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_stmt_fetch_command * command; - DBG_ENTER("mysqlnd_com_stmt_fetch_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_stmt_fetch_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->context.payload = va_arg(args, MYSQLND_CSTRING); - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_stmt_fetch_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - - -/************************** COM_STMT_RESET ******************************************/ -struct st_mysqlnd_protocol_com_stmt_reset_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_stmt_reset_context - { - MYSQLND_CONN_DATA * conn; - zend_ulong stmt_id; - } context; -}; - - -/* {{{ mysqlnd_com_stmt_reset_run */ -static enum_func_status -mysqlnd_com_stmt_reset_run(void *cmd) -{ - zend_uchar cmd_buf[MYSQLND_STMT_ID_LENGTH /* statement id */]; - struct st_mysqlnd_protocol_com_stmt_reset_command * command = (struct st_mysqlnd_protocol_com_stmt_reset_command *) cmd; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; - func_mysqlnd_protocol_payload_decoder_factory__send_command_handle_response send_command_handle_response = conn->payload_decoder_factory->m.send_command_handle_response; - - DBG_ENTER("mysqlnd_com_stmt_reset_run"); - - int4store(cmd_buf, command->context.stmt_id); - ret = send_command(conn->payload_decoder_factory, COM_STMT_RESET, cmd_buf, sizeof(cmd_buf), FALSE, - &conn->state, - conn->error_info, - conn->upsert_status, - conn->stats, - conn->m->send_close, - conn); - if (PASS == ret) { - ret = send_command_handle_response(conn->payload_decoder_factory, PROT_OK_PACKET, FALSE, COM_STMT_RESET, TRUE, - conn->error_info, conn->upsert_status, &conn->last_message, conn->persistent); - } - - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_stmt_reset_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_stmt_reset_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_stmt_reset_command * command; - DBG_ENTER("mysqlnd_com_stmt_reset_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_stmt_reset_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->context.stmt_id = va_arg(args, size_t); - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_stmt_reset_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - - -/************************** COM_STMT_SEND_LONG_DATA ******************************************/ -struct st_mysqlnd_protocol_com_stmt_send_long_data_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_stmt_send_long_data_context - { - MYSQLND_CONN_DATA * conn; - MYSQLND_CSTRING payload; - } context; -}; - - -/* {{{ mysqlnd_com_stmt_send_long_data_run */ -static enum_func_status -mysqlnd_com_stmt_send_long_data_run(void *cmd) -{ - struct st_mysqlnd_protocol_com_stmt_send_long_data_command * command = (struct st_mysqlnd_protocol_com_stmt_send_long_data_command *) cmd; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; - - DBG_ENTER("mysqlnd_com_stmt_send_long_data_run"); - - ret = send_command(conn->payload_decoder_factory, COM_STMT_SEND_LONG_DATA, (zend_uchar*) command->context.payload.s, command->context.payload.l, FALSE, - &conn->state, - conn->error_info, - conn->upsert_status, - conn->stats, - conn->m->send_close, - conn); - - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_stmt_send_long_data_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_stmt_send_long_data_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_stmt_send_long_data_command * command; - DBG_ENTER("mysqlnd_com_stmt_send_long_data_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_stmt_send_long_data_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->context.payload = va_arg(args, MYSQLND_CSTRING); - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_stmt_send_long_data_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - - -/************************** COM_STMT_CLOSE ******************************************/ -struct st_mysqlnd_protocol_com_stmt_close_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_stmt_close_context - { - MYSQLND_CONN_DATA * conn; - zend_ulong stmt_id; - } context; -}; - - -/* {{{ mysqlnd_com_stmt_close_run */ -static enum_func_status -mysqlnd_com_stmt_close_run(void *cmd) -{ - zend_uchar cmd_buf[MYSQLND_STMT_ID_LENGTH /* statement id */]; - struct st_mysqlnd_protocol_com_stmt_close_command * command = (struct st_mysqlnd_protocol_com_stmt_close_command *) cmd; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - func_mysqlnd_protocol_payload_decoder_factory__send_command send_command = conn->payload_decoder_factory->m.send_command; - - DBG_ENTER("mysqlnd_com_stmt_close_run"); - - int4store(cmd_buf, command->context.stmt_id); - ret = send_command(conn->payload_decoder_factory, COM_STMT_CLOSE, cmd_buf, sizeof(cmd_buf), FALSE, - &conn->state, - conn->error_info, - conn->upsert_status, - conn->stats, - conn->m->send_close, - conn); - - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_stmt_close_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_stmt_close_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_stmt_close_command * command; - DBG_ENTER("mysqlnd_com_stmt_close_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_stmt_close_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->context.stmt_id = va_arg(args, size_t); - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_stmt_close_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - - - -/************************** COM_ENABLE_SSL ******************************************/ -struct st_mysqlnd_protocol_com_enable_ssl_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_enable_ssl_context - { - MYSQLND_CONN_DATA * conn; - size_t client_capabilities; - size_t server_capabilities; - unsigned int charset_no; - } context; -}; - - -/* {{{ mysqlnd_com_enable_ssl_run */ -static enum_func_status -mysqlnd_com_enable_ssl_run(void *cmd) -{ - struct st_mysqlnd_protocol_com_enable_ssl_command * command = (struct st_mysqlnd_protocol_com_enable_ssl_command *) cmd; - enum_func_status ret = FAIL; - MYSQLND_CONN_DATA * conn = command->context.conn; - MYSQLND_PACKET_AUTH * auth_packet; - size_t client_capabilities = command->context.client_capabilities; - size_t server_capabilities = command->context.server_capabilities; - - DBG_ENTER("mysqlnd_com_enable_ssl_run"); - DBG_INF_FMT("client_capability_flags=%lu", client_capabilities); - DBG_INF_FMT("CLIENT_LONG_PASSWORD= %d", client_capabilities & CLIENT_LONG_PASSWORD? 1:0); - DBG_INF_FMT("CLIENT_FOUND_ROWS= %d", client_capabilities & CLIENT_FOUND_ROWS? 1:0); - DBG_INF_FMT("CLIENT_LONG_FLAG= %d", client_capabilities & CLIENT_LONG_FLAG? 1:0); - DBG_INF_FMT("CLIENT_NO_SCHEMA= %d", client_capabilities & CLIENT_NO_SCHEMA? 1:0); - DBG_INF_FMT("CLIENT_COMPRESS= %d", client_capabilities & CLIENT_COMPRESS? 1:0); - DBG_INF_FMT("CLIENT_ODBC= %d", client_capabilities & CLIENT_ODBC? 1:0); - DBG_INF_FMT("CLIENT_LOCAL_FILES= %d", client_capabilities & CLIENT_LOCAL_FILES? 1:0); - DBG_INF_FMT("CLIENT_IGNORE_SPACE= %d", client_capabilities & CLIENT_IGNORE_SPACE? 1:0); - DBG_INF_FMT("CLIENT_PROTOCOL_41= %d", client_capabilities & CLIENT_PROTOCOL_41? 1:0); - DBG_INF_FMT("CLIENT_INTERACTIVE= %d", client_capabilities & CLIENT_INTERACTIVE? 1:0); - DBG_INF_FMT("CLIENT_SSL= %d", client_capabilities & CLIENT_SSL? 1:0); - DBG_INF_FMT("CLIENT_IGNORE_SIGPIPE= %d", client_capabilities & CLIENT_IGNORE_SIGPIPE? 1:0); - DBG_INF_FMT("CLIENT_TRANSACTIONS= %d", client_capabilities & CLIENT_TRANSACTIONS? 1:0); - DBG_INF_FMT("CLIENT_RESERVED= %d", client_capabilities & CLIENT_RESERVED? 1:0); - DBG_INF_FMT("CLIENT_SECURE_CONNECTION=%d", client_capabilities & CLIENT_SECURE_CONNECTION? 1:0); - DBG_INF_FMT("CLIENT_MULTI_STATEMENTS=%d", client_capabilities & CLIENT_MULTI_STATEMENTS? 1:0); - DBG_INF_FMT("CLIENT_MULTI_RESULTS= %d", client_capabilities & CLIENT_MULTI_RESULTS? 1:0); - DBG_INF_FMT("CLIENT_PS_MULTI_RESULTS=%d", client_capabilities & CLIENT_PS_MULTI_RESULTS? 1:0); - DBG_INF_FMT("CLIENT_CONNECT_ATTRS= %d", client_capabilities & CLIENT_PLUGIN_AUTH? 1:0); - DBG_INF_FMT("CLIENT_PLUGIN_AUTH_LENENC_CLIENT_DATA= %d", client_capabilities & CLIENT_PLUGIN_AUTH_LENENC_CLIENT_DATA? 1:0); - DBG_INF_FMT("CLIENT_CAN_HANDLE_EXPIRED_PASSWORDS= %d", client_capabilities & CLIENT_CAN_HANDLE_EXPIRED_PASSWORDS? 1:0); - DBG_INF_FMT("CLIENT_SESSION_TRACK= %d", client_capabilities & CLIENT_SESSION_TRACK? 1:0); - DBG_INF_FMT("CLIENT_SSL_VERIFY_SERVER_CERT= %d", client_capabilities & CLIENT_SSL_VERIFY_SERVER_CERT? 1:0); - DBG_INF_FMT("CLIENT_REMEMBER_OPTIONS= %d", client_capabilities & CLIENT_REMEMBER_OPTIONS? 1:0); - - auth_packet = conn->payload_decoder_factory->m.get_auth_packet(conn->payload_decoder_factory, FALSE); - if (!auth_packet) { - SET_OOM_ERROR(conn->error_info); - goto end; - } - auth_packet->client_flags = client_capabilities; - auth_packet->max_packet_size = MYSQLND_ASSEMBLED_PACKET_MAX_SIZE; - - auth_packet->charset_no = command->context.charset_no; - -#ifdef MYSQLND_SSL_SUPPORTED - if (client_capabilities & CLIENT_SSL) { - const zend_bool server_has_ssl = (server_capabilities & CLIENT_SSL)? TRUE:FALSE; - if (server_has_ssl == FALSE) { - goto close_conn; - } else { - enum mysqlnd_ssl_peer verify = client_capabilities & CLIENT_SSL_VERIFY_SERVER_CERT? - MYSQLND_SSL_PEER_VERIFY: - (client_capabilities & CLIENT_SSL_DONT_VERIFY_SERVER_CERT? - MYSQLND_SSL_PEER_DONT_VERIFY: - MYSQLND_SSL_PEER_DEFAULT); - DBG_INF("Switching to SSL"); - if (!PACKET_WRITE(auth_packet)) { - goto close_conn; - } - - conn->vio->data->m.set_client_option(conn->vio, MYSQL_OPT_SSL_VERIFY_SERVER_CERT, (const char *) &verify); - - if (FAIL == conn->vio->data->m.enable_ssl(conn->vio)) { - goto end; - } - } - } -#else - auth_packet->client_flags &= ~CLIENT_SSL; - if (!PACKET_WRITE(auth_packet)) { - goto close_conn; - } -#endif - ret = PASS; -end: - PACKET_FREE(auth_packet); - DBG_RETURN(ret); - -close_conn: - SET_CONNECTION_STATE(&conn->state, CONN_QUIT_SENT); - conn->m->send_close(conn); - SET_CLIENT_ERROR(conn->error_info, CR_SERVER_GONE_ERROR, UNKNOWN_SQLSTATE, mysqlnd_server_gone); - PACKET_FREE(auth_packet); - DBG_RETURN(ret); -} -/* }}} */ - - -/* {{{ mysqlnd_com_enable_ssl_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_enable_ssl_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_enable_ssl_command * command; - DBG_ENTER("mysqlnd_com_enable_ssl_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_enable_ssl_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->context.client_capabilities = va_arg(args, size_t); - command->context.server_capabilities = va_arg(args, size_t); - command->context.charset_no = va_arg(args, unsigned int); - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_enable_ssl_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - -/************************** COM_READ_HANDSHAKE ******************************************/ -struct st_mysqlnd_protocol_com_handshake_command -{ - struct st_mysqlnd_protocol_command parent; - struct st_mysqlnd_com_handshake_context - { - MYSQLND_CONN_DATA * conn; - MYSQLND_CSTRING user; - MYSQLND_CSTRING passwd; - MYSQLND_CSTRING database; - size_t client_flags; - } context; -}; - - -/* {{{ mysqlnd_com_handshake_run */ -static enum_func_status -mysqlnd_com_handshake_run(void *cmd) -{ - struct st_mysqlnd_protocol_com_handshake_command * command = (struct st_mysqlnd_protocol_com_handshake_command *) cmd; - const char * user = command->context.user.s; - - const char * passwd = command->context.passwd.s; - size_t passwd_len = command->context.passwd.l; - - const char * db = command->context.database.s; - size_t db_len = command->context.database.l; - - size_t mysql_flags = command->context.client_flags; - - MYSQLND_CONN_DATA * conn = command->context.conn; - MYSQLND_PACKET_GREET * greet_packet; - - DBG_ENTER("mysqlnd_conn_data::connect_handshake"); - DBG_INF_FMT("stream=%p", conn->vio->data->m.get_stream(conn->vio)); - DBG_INF_FMT("[user=%s] [db=%s:%d] [flags=%llu]", user, db, db_len, mysql_flags); - - greet_packet = conn->payload_decoder_factory->m.get_greet_packet(conn->payload_decoder_factory, FALSE); - if (!greet_packet) { - SET_OOM_ERROR(conn->error_info); - DBG_RETURN(FAIL); /* OOM */ - } - - if (FAIL == PACKET_READ(greet_packet)) { - DBG_ERR("Error while reading greeting packet"); - php_error_docref(NULL, E_WARNING, "Error while reading greeting packet. PID=%d", getpid()); - goto err; - } else if (greet_packet->error_no) { - DBG_ERR_FMT("errorno=%u error=%s", greet_packet->error_no, greet_packet->error); - SET_CLIENT_ERROR(conn->error_info, greet_packet->error_no, greet_packet->sqlstate, greet_packet->error); - goto err; - } else if (greet_packet->pre41) { - DBG_ERR_FMT("Connecting to 3.22, 3.23 & 4.0 is not supported. Server is %-.32s", greet_packet->server_version); - php_error_docref(NULL, E_WARNING, "Connecting to 3.22, 3.23 & 4.0 " - " is not supported. Server is %-.32s", greet_packet->server_version); - SET_CLIENT_ERROR(conn->error_info, CR_NOT_IMPLEMENTED, UNKNOWN_SQLSTATE, - "Connecting to 3.22, 3.23 & 4.0 servers is not supported"); - goto err; - } - - conn->thread_id = greet_packet->thread_id; - conn->protocol_version = greet_packet->protocol_version; - conn->server_version = mnd_pestrdup(greet_packet->server_version, conn->persistent); - - conn->greet_charset = mysqlnd_find_charset_nr(greet_packet->charset_no); - if (!conn->greet_charset) { - php_error_docref(NULL, E_WARNING, - "Server sent charset (%d) unknown to the client. Please, report to the developers", greet_packet->charset_no); - SET_CLIENT_ERROR(conn->error_info, CR_NOT_IMPLEMENTED, UNKNOWN_SQLSTATE, - "Server sent charset unknown to the client. Please, report to the developers"); - goto err; - } - - conn->server_capabilities = greet_packet->server_capabilities; - - if (FAIL == mysqlnd_connect_run_authentication(conn, user, passwd, db, db_len, (size_t) passwd_len, - greet_packet->authentication_plugin_data, greet_packet->auth_protocol, - greet_packet->charset_no, greet_packet->server_capabilities, - conn->options, mysql_flags)) - { - goto err; - } - - UPSERT_STATUS_RESET(conn->upsert_status); - UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, greet_packet->server_status); - - PACKET_FREE(greet_packet); - DBG_RETURN(PASS); -err: - conn->server_capabilities = 0; - PACKET_FREE(greet_packet); - DBG_RETURN(FAIL); -} -/* }}} */ - - -/* {{{ mysqlnd_com_handshake_create_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_com_handshake_create_command(va_list args) -{ - struct st_mysqlnd_protocol_com_handshake_command * command; - DBG_ENTER("mysqlnd_com_handshake_create_command"); - command = mnd_ecalloc(1, sizeof(struct st_mysqlnd_protocol_com_handshake_command)); - if (command) { - command->context.conn = va_arg(args, MYSQLND_CONN_DATA *); - command->context.user = *va_arg(args, const MYSQLND_CSTRING *); - command->context.passwd = *va_arg(args, const MYSQLND_CSTRING *); - command->context.database = *va_arg(args, const MYSQLND_CSTRING *); - command->context.client_flags = va_arg(args, size_t); - - command->parent.free_command = mysqlnd_com_no_params_free_command; - command->parent.run = mysqlnd_com_handshake_run; - } - - DBG_RETURN((struct st_mysqlnd_protocol_command *) command); -} -/* }}} */ - - - -/* {{{ mysqlnd_get_command */ -static struct st_mysqlnd_protocol_command * -mysqlnd_get_command(enum php_mysqlnd_server_command command, ...) -{ - struct st_mysqlnd_protocol_command * ret; - va_list args; - DBG_ENTER("mysqlnd_get_command"); - - va_start(args, command); - switch (command) { - case COM_SET_OPTION: - ret = mysqlnd_com_set_option_create_command(args); - break; - case COM_DEBUG: - ret = mysqlnd_com_debug_create_command(args); - break; - case COM_INIT_DB: - ret = mysqlnd_com_init_db_create_command(args); - break; - case COM_PING: - ret = mysqlnd_com_ping_create_command(args); - break; - case COM_STATISTICS: - ret = mysqlnd_com_statistics_create_command(args); - break; - case COM_PROCESS_KILL: - ret = mysqlnd_com_process_kill_create_command(args); - break; - case COM_REFRESH: - ret = mysqlnd_com_refresh_create_command(args); - break; - case COM_SHUTDOWN: - ret = mysqlnd_com_shutdown_create_command(args); - break; - case COM_QUIT: - ret = mysqlnd_com_quit_create_command(args); - break; - case COM_QUERY: - ret = mysqlnd_com_query_create_command(args); - break; - case COM_REAP_RESULT: - ret = mysqlnd_com_reap_result_create_command(args); - break; - case COM_CHANGE_USER: - ret = mysqlnd_com_change_user_create_command(args); - break; - case COM_STMT_PREPARE: - ret = mysqlnd_com_stmt_prepare_create_command(args); - break; - case COM_STMT_EXECUTE: - ret = mysqlnd_com_stmt_execute_create_command(args); - break; - case COM_STMT_FETCH: - ret = mysqlnd_com_stmt_fetch_create_command(args); - break; - case COM_STMT_RESET: - ret = mysqlnd_com_stmt_reset_create_command(args); - break; - case COM_STMT_SEND_LONG_DATA: - ret = mysqlnd_com_stmt_send_long_data_create_command(args); - break; - case COM_STMT_CLOSE: - ret = mysqlnd_com_stmt_close_create_command(args); - break; - case COM_ENABLE_SSL: - ret = mysqlnd_com_enable_ssl_create_command(args); - break; - case COM_HANDSHAKE: - ret = mysqlnd_com_handshake_create_command(args); - break; - default: - break; - } - va_end(args); - DBG_RETURN(ret); -} -/* }}} */ - -func_mysqlnd__command_factory mysqlnd_command_factory = mysqlnd_get_command; - /* * Local variables: * tab-width: 4