This is extention of Protocol_local. More...

#include <protocol_local_v2.h>

Inheritance diagram for Protocol_local_v2:

Public Member Functions
	Protocol_local_v2 (THD thd, Statement_handle execute_statement)

	~Protocol_local_v2 () override

int	read_packet () override
	Read packet from client. More...

int	get_command (COM_DATA , enum_server_command ) override
	Reads the command from the protocol and creates a command. More...

ulong	get_client_capabilities () override
	Returns the client capabilities stored on the protocol. More...

bool	has_client_capability (unsigned long client_capability) override
	Checks if the client capabilities include the one specified as parameter. More...

void	end_partial_result_set () override

int	shutdown (bool server_shutdown=false) override
	Thread is being shut down, disconnect and free resources. More...

bool	connection_alive () const override
	Checks if the protocol's connection with the client is still alive. More...

void	start_row () override
	Called between two result set rows. More...

bool	end_row () override
	Add the current row to the result set. More...

void	abort_row () override

uint	get_rw_status () override
	Returns the read/writing status. More...

bool	get_compression () override
	Returns if the protocol is compressed or not. More...

char *	get_compression_algorithm () override
	Returns compression algorithm name. More...

uint	get_compression_level () override
	Returns compression level. More...

bool	start_result_metadata (uint num_cols, uint flags, const CHARSET_INFO *resultcs) override
	Prepares the server for metadata sending. More...

bool	end_result_metadata () override
	Signals the client that the metadata sending is done. More...

bool	send_field_metadata (Send_field field, const CHARSET_INFO charset) override
	Sends field metadata. More...

bool	flush () override
	Used for the classic protocol. More...

bool	send_parameters (List< Item_param > *, bool) override
	Sends the OUT-parameters to the client. More...

bool	store_ps_status (ulong, uint, uint, ulong) override
	Sends prepared statement's id and metadata to the client after prepare. More...

void	set_result_set_capacity (size_t capacity)
	Set the capacity in bytes allowed for caching results. More...

size_t	get_result_set_capacity ()
	Get the capacity in bytes allowed for caching results. More...

void	clear_resultset_mem_root ()
	Clear MEM_ROOT and related members. More...

Public Member Functions inherited from Protocol
virtual	~Protocol ()=default

Protocol *	pop_protocol ()
	Remove the reference to the previous protocol and return it. More...

void	push_protocol (Protocol *protocol)
	Set reference to "this" as the previous protocol on the protocol provided as argument. More...

bool	store (int from)

bool	store (uint32 from)

bool	store (longlong from)

bool	store (ulonglong from)

bool	store_tiny (longlong from)

bool	store_short (longlong from)

bool	store_long (longlong from)

bool	store_longlong (longlong from, bool unsigned_flag)

bool	store (const char from, const CHARSET_INFO fromcs)
	Send \0 end terminated string. More...

bool	store (String *str)

bool	store (const LEX_STRING &s, const CHARSET_INFO *cs)

Protected Member Functions
bool	store_null () override
	Add a NULL column to the current row. More...

bool	store_tiny (longlong from, uint32) override

bool	store_short (longlong from, uint32) override

bool	store_long (longlong from, uint32) override

bool	store_longlong (longlong from, bool unsigned_flag, uint32) override

bool	store_decimal (const my_decimal *, uint, uint) override

bool	store_string (const char from, size_t length, const CHARSET_INFO cs) override
	Convert to cs_results and store a string. More...

bool	store_datetime (const MYSQL_TIME &time, uint precision) override

bool	store_date (const MYSQL_TIME &time) override

bool	store_time (const MYSQL_TIME &time, uint precision) override

bool	store_float (float value, uint32 decimals, uint32 zerofill) override

bool	store_double (double value, uint32 decimals, uint32 zerofill) override

bool	store_field (const Field *field) override

enum enum_protocol_type	type () const override

enum enum_vio_type	connection_type () const override

bool	send_ok (uint server_status, uint statement_warn_count, ulonglong affected_rows, ulonglong last_insert_id, const char *message) override
	Called for statements that don't have a result set, at statement end. More...

bool	send_eof (uint server_status, uint statement_warn_count) override
	Send eof message to the client. More...

bool	send_error (uint sql_errno, const char err_msg, const char sqlstate) override
	Called at the end of a result set. More...

uint	get_current_column_number ()

Private Member Functions
bool	store_string (const char str, size_t length, const CHARSET_INFO src_cs, const CHARSET_INFO *dst_cs)
	Store a string value in a result set column, optionally having converted it to character_set_results. More...

bool	store_longlong (longlong value)

bool	store_floating_type (double value)

bool	store_temporal (const MYSQL_TIME &time)

void	add_row_to_result_set ()

template<typename T , typename V >
bool	allocate_type (V *value)

Private Attributes
Statement_handle *	m_execute_statement

MEM_ROOT	m_result_set_mem_root

Result_set *	m_result_set = nullptr

List< Row< value_t > > *	m_data_rows

Row< Column_metadata > *	m_fields

value_t *	m_current_row

value_t *	m_current_column

Column_metadata *	m_metadata_row

Column_metadata *	m_current_metadata_column

bool	m_send_metadata

size_t	m_column_count

THD *	m_thd

uint	m_current_row_index = 0

Result_set_capacity	m_result_set_capacity

Additional Inherited Members
Public Types inherited from Protocol
enum	enum_protocol_type { PROTOCOL_TEXT = 0 , PROTOCOL_BINARY = 1 , PROTOCOL_LOCAL = 2 , PROTOCOL_ERROR = 3 , PROTOCOL_PLUGIN = 4 }
	Enum used by type() to specify the protocol type. More...

enum	{ SEND_NUM_ROWS = 1 , SEND_DEFAULTS = 2 , SEND_EOF = 4 }
	Flags available to alter the way the messages are sent to the client. More...

using	Type = BaseProtocol::Type

Static Public Member Functions inherited from Protocol
static Type	get_default ()

static Type	get_by_name (const std::string &name)
	Returns type of the protocol by its name. More...

static std::string	to_string (const Type &type)

static uint16_t	get_default_port (Type type)
	Returns default port for the selected protocol. More...

Detailed Description

This is extention of Protocol_local.

We support reading field metadata and field data attributes.

Constructor & Destructor Documentation

◆ Protocol_local_v2()

Protocol_local_v2::Protocol_local_v2	(	THD *	thd,
		Statement_handle *	execute_statement
	)

◆ ~Protocol_local_v2()

Protocol_local_v2::~Protocol_local_v2 ( )

inlineoverride

Member Function Documentation

◆ abort_row()

void Protocol_local_v2::abort_row ( )

inlineoverridevirtual

Implements Protocol.

◆ add_row_to_result_set()

void Protocol_local_v2::add_row_to_result_set ( )

private

◆ allocate_type()

template<typename T , typename V >

bool Protocol_local_v2::allocate_type ( V * value )

private

◆ clear_resultset_mem_root()

void Protocol_local_v2::clear_resultset_mem_root ( )

Clear MEM_ROOT and related members.

◆ connection_alive()

bool Protocol_local_v2::connection_alive ( ) const

overridevirtual

Checks if the protocol's connection with the client is still alive.

It should always return true unless the protocol closed the connection.

Return values

true	if the connection is still alive
false	otherwise

Implements Protocol.

◆ connection_type()

enum enum_vio_type Protocol_local_v2::connection_type ( ) const

inlineoverrideprotectedvirtual

Implements Protocol.

◆ end_partial_result_set()

void Protocol_local_v2::end_partial_result_set ( )

overridevirtual

Implements Protocol.

◆ end_result_metadata()

bool Protocol_local_v2::end_result_metadata ( )

overridevirtual

Signals the client that the metadata sending is done.

Clears the server after sending the metadata.

Return values

false	Ok
true	An error occurred

Implements Protocol.

◆ end_row()

bool Protocol_local_v2::end_row ( )

overridevirtual

Add the current row to the result set.

Implements Protocol.

◆ flush()

bool Protocol_local_v2::flush ( )

inlineoverridevirtual

Used for the classic protocol.

Makes the protocol send the messages/data to the client.

Return values

false	The flush was successful.
true	An error occurred.

Implements Protocol.

◆ get_client_capabilities()

ulong Protocol_local_v2::get_client_capabilities ( )

overridevirtual

Returns the client capabilities stored on the protocol.

The available capabilities are defined in mysql_com.h

Implements Protocol.

◆ get_command()

int Protocol_local_v2::get_command	(	COM_DATA *	com_data,
		enum_server_command *	cmd
	)

inlineoverridevirtual

Reads the command from the protocol and creates a command.

Parameters

com_data	out parameter
cmd	out parameter

Returns: -1 fatal protocol error 0 ok 1 non-fatal protocol or parsing error

Implements Protocol.

◆ get_compression()

bool Protocol_local_v2::get_compression ( )

overridevirtual

Returns if the protocol is compressed or not.

Return values

false	Not compressed
true	Compressed

Implements Protocol.

◆ get_compression_algorithm()

char * Protocol_local_v2::get_compression_algorithm ( )

overridevirtual

Returns compression algorithm name.

Return values

string	compression method name
NULL	if no compression is enabled

Implements Protocol.

◆ get_compression_level()

uint Protocol_local_v2::get_compression_level ( )

overridevirtual

Returns compression level.

Returns: compression level

Implements Protocol.

◆ get_current_column_number()

uint Protocol_local_v2::get_current_column_number ( )

inlineprotected

◆ get_result_set_capacity()

size_t Protocol_local_v2::get_result_set_capacity ( )

inline

Get the capacity in bytes allowed for caching results.

◆ get_rw_status()

uint Protocol_local_v2::get_rw_status ( )

overridevirtual

Returns the read/writing status.

Return values

1	Read
2	Write
0	Other(Idle, Killed)

Implements Protocol.

◆ has_client_capability()

bool Protocol_local_v2::has_client_capability ( unsigned long client_capability )

overridevirtual

Checks if the client capabilities include the one specified as parameter.

Return values

true	if it includes the specified capability
false	otherwise

Implements Protocol.

◆ read_packet()

int Protocol_local_v2::read_packet ( )

overridevirtual

Read packet from client.

Return values

-1	fatal error
0	ok
1	non-fatal error

Implements Protocol.

◆ send_eof()

bool Protocol_local_v2::send_eof	(	uint	server_status,
		uint	statement_warn_count
	)

overrideprotectedvirtual

Send eof message to the client.

Parameters

server_status	The server status
statement_warn_count	Total number of warnings

Return values

false	The message was successfully sent
true	An error occurred and the messages wasn't sent properly

Implements Protocol.

◆ send_error()

bool Protocol_local_v2::send_error	(	uint	sql_errno,
		const char *	err_msg,
		const char *	sqlstate
	)

overrideprotectedvirtual

Called at the end of a result set.

Append a complete result set to the list.

Don't send anything to the client, but instead finish building of the result set at hand. Called to send an error to the client at the end of a statement.

Implements Protocol.

◆ send_field_metadata()

bool Protocol_local_v2::send_field_metadata	(	Send_field *	field,
		const CHARSET_INFO *	charset
	)

overridevirtual

Sends field metadata.

Parameters

field	Field metadata to be send to the client
charset	Field's charset: in case it is different than the one used by the connection it will be used to convert the value to the connection's charset

Return values

false	The metadata was successfully sent
true	An error occurred

Implements Protocol.

◆ send_ok()

bool Protocol_local_v2::send_ok	(	uint	server_status,
		uint	statement_warn_count,
		ulonglong	affected_rows,
		ulonglong	last_insert_id,
		const char *	message
	)

overrideprotectedvirtual

Called for statements that don't have a result set, at statement end.

Implements Protocol.

◆ send_parameters()

bool Protocol_local_v2::send_parameters	(	List< Item_param > *	parameters,
		bool	is_sql_prepare
	)

inlineoverridevirtual

Sends the OUT-parameters to the client.

Parameters

parameters	List of PS/SP parameters (both input and output).
is_sql_prepare	Used for the legacy protocol. If we're dealing with sql prepare then text protocol will be used.

Returns: Error status.

Return values

false	Success.
true	Error.

Implements Protocol.

◆ set_result_set_capacity()

void Protocol_local_v2::set_result_set_capacity ( size_t capacity )

inline

Set the capacity in bytes allowed for caching results.

Parameters

capacity capacity of the result set

◆ shutdown()

int Protocol_local_v2::shutdown ( bool server_shutdown = false )

overridevirtual

Thread is being shut down, disconnect and free resources.

Parameters

server_shutdown If false then this is normal thread shutdown. If true then the server is shutting down.

Implements Protocol.

◆ start_result_metadata()

bool Protocol_local_v2::start_result_metadata	(	uint	num_cols,
		uint	flags,
		const CHARSET_INFO *	resultcs
	)

overridevirtual

Prepares the server for metadata sending.

Notifies the client that the metadata sending will start.

Parameters

num_cols	Number of columns that will be sent
flags	Flags to alter the metadata sending Can be any of the following: SEND_NUM_ROWS, SEND_DEFAULTS, SEND_EOF
resultcs	Charset to convert to

Return values

false	Ok
true	An error occurred

Implements Protocol.

◆ start_row()

void Protocol_local_v2::start_row ( )

overridevirtual

Called between two result set rows.

Prepare structures to fill result set rows. Unfortunately, we can't return an error here. If memory allocation fails, we'll have to return an error later. And so is done in methods such as

See also: store_column().

Implements Protocol.

◆ store_date()

bool Protocol_local_v2::store_date ( const MYSQL_TIME & time )

overrideprotectedvirtual

Implements Protocol.

◆ store_datetime()

bool Protocol_local_v2::store_datetime	(	const MYSQL_TIME &	time,
		uint	precision
	)

overrideprotectedvirtual

Implements Protocol.

◆ store_decimal()

bool Protocol_local_v2::store_decimal	(	const my_decimal *	value,
		uint	prec,
		uint	dec
	)

overrideprotectedvirtual

Implements Protocol.

◆ store_double()

bool Protocol_local_v2::store_double	(	double	value,
		uint32	decimals,
		uint32	zerofill
	)

overrideprotectedvirtual

Implements Protocol.

◆ store_field()

bool Protocol_local_v2::store_field ( const Field * field )

overrideprotectedvirtual

Implements Protocol.

◆ store_float()

bool Protocol_local_v2::store_float	(	float	value,
		uint32	decimals,
		uint32	zerofill
	)

overrideprotectedvirtual

Implements Protocol.

◆ store_floating_type()

bool Protocol_local_v2::store_floating_type ( double value )

private

◆ store_long()

bool Protocol_local_v2::store_long	(	longlong	from,
		uint32
	)

overrideprotectedvirtual

Implements Protocol.

◆ store_longlong() [1/2]

bool Protocol_local_v2::store_longlong	(	longlong	from,
		bool	unsigned_flag,
		uint32
	)

overrideprotectedvirtual

Implements Protocol.

◆ store_longlong() [2/2]

bool Protocol_local_v2::store_longlong ( longlong value )

private

◆ store_null()

bool Protocol_local_v2::store_null ( )

overrideprotectedvirtual

Add a NULL column to the current row.

Implements Protocol.

◆ store_ps_status()

bool Protocol_local_v2::store_ps_status	(	ulong	stmt_id,
		uint	column_count,
		uint	param_count,
		ulong	cond_count
	)

inlineoverridevirtual

Sends prepared statement's id and metadata to the client after prepare.

Parameters

stmt_id	Statement id.
column_count	Number of columns.
param_count	Number of parameters.
cond_count	Number of conditions raised by the current statement.

Returns: Error status.

Return values

false	The send was successful.
true	An error occurred.

Implements Protocol.

◆ store_short()

bool Protocol_local_v2::store_short	(	longlong	from,
		uint32
	)

overrideprotectedvirtual

Implements Protocol.

◆ store_string() [1/2]

bool Protocol_local_v2::store_string	(	const char *	from,
		size_t	length,
		const CHARSET_INFO *	cs
	)

overrideprotectedvirtual

Convert to cs_results and store a string.

Implements Protocol.

◆ store_string() [2/2]

bool Protocol_local_v2::store_string	(	const char *	str,
		size_t	length,
		const CHARSET_INFO *	src_cs,
		const CHARSET_INFO *	dst_cs
	)

private

Store a string value in a result set column, optionally having converted it to character_set_results.

◆ store_temporal()

bool Protocol_local_v2::store_temporal ( const MYSQL_TIME & time )

private

◆ store_time()

bool Protocol_local_v2::store_time	(	const MYSQL_TIME &	time,
		uint	precision
	)

overrideprotectedvirtual

Implements Protocol.

◆ store_tiny()

bool Protocol_local_v2::store_tiny	(	longlong	from,
		uint32
	)

overrideprotectedvirtual

Implements Protocol.

◆ type()

enum enum_protocol_type Protocol_local_v2::type ( ) const

inlineoverrideprotectedvirtual

Implements Protocol.

Member Data Documentation

◆ m_column_count

size_t Protocol_local_v2::m_column_count

private

◆ m_current_column

value_t* Protocol_local_v2::m_current_column

private

◆ m_current_metadata_column

Column_metadata* Protocol_local_v2::m_current_metadata_column

private

◆ m_current_row

value_t* Protocol_local_v2::m_current_row

private

◆ m_current_row_index

uint Protocol_local_v2::m_current_row_index = 0

private

◆ m_data_rows

List<Row<value_t> >* Protocol_local_v2::m_data_rows

private

◆ m_execute_statement

Statement_handle* Protocol_local_v2::m_execute_statement

private

◆ m_fields

Row<Column_metadata>* Protocol_local_v2::m_fields

private

◆ m_metadata_row

Column_metadata* Protocol_local_v2::m_metadata_row

private

◆ m_result_set

Result_set* Protocol_local_v2::m_result_set = nullptr

private

◆ m_result_set_capacity

Result_set_capacity Protocol_local_v2::m_result_set_capacity

private

◆ m_result_set_mem_root

MEM_ROOT Protocol_local_v2::m_result_set_mem_root

private

◆ m_send_metadata

bool Protocol_local_v2::m_send_metadata

private

◆ m_thd

THD* Protocol_local_v2::m_thd

private

The documentation for this class was generated from the following files:

sql/statement/protocol_local_v2.h
sql/statement/protocol_local_v2.cc

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ Protocol_local_v2()

◆ ~Protocol_local_v2()

Member Function Documentation

◆ abort_row()

◆ add_row_to_result_set()

◆ allocate_type()

◆ clear_resultset_mem_root()

◆ connection_alive()

◆ connection_type()

◆ end_partial_result_set()

◆ end_result_metadata()

◆ end_row()

◆ flush()

◆ get_client_capabilities()

◆ get_command()

◆ get_compression()

◆ get_compression_algorithm()

◆ get_compression_level()

◆ get_current_column_number()

◆ get_result_set_capacity()

◆ get_rw_status()

◆ has_client_capability()

◆ read_packet()

◆ send_eof()

◆ send_error()

◆ send_field_metadata()

◆ send_ok()

◆ send_parameters()

◆ set_result_set_capacity()

◆ shutdown()

◆ start_result_metadata()

◆ start_row()

◆ store_date()

◆ store_datetime()

◆ store_decimal()

◆ store_double()

◆ store_field()

◆ store_float()

◆ store_floating_type()

◆ store_long()

◆ store_longlong() [1/2]

◆ store_longlong() [2/2]

◆ store_null()

◆ store_ps_status()

◆ store_short()

◆ store_string() [1/2]

◆ store_string() [2/2]

◆ store_temporal()

◆ store_time()

◆ store_tiny()

◆ type()

Member Data Documentation

◆ m_column_count

◆ m_current_column

◆ m_current_metadata_column

◆ m_current_row

◆ m_current_row_index

◆ m_data_rows

◆ m_execute_statement

◆ m_fields

◆ m_metadata_row

◆ m_result_set

◆ m_result_set_capacity

◆ m_result_set_mem_root

◆ m_send_metadata

◆ m_thd