A Query event is written to the binary log whenever the database is modified on the master, unless row based logging is used. More...

#include <log_event.h>

Inheritance diagram for Query_log_event:

[legend]

Public Member Functions
	Query_log_event (Query_log_event &&) noexcept=delete

Query_log_event &	operator= (Query_log_event &&) noexcept=delete

	Query_log_event (const Query_log_event &)=delete

Query_log_event &	operator= (const Query_log_event &)=delete

void	set_skip_temp_tables_handling_by_worker ()

bool	is_skip_temp_tables_handling_by_worker ()

	Query_log_event (THD thd_arg, const char query_arg, size_t query_length, bool using_trans, bool immediate, bool suppress_use, int error, bool ignore_command=false)
	Creates a Query Log Event. More...

const char *	get_db () override

uint8	get_mts_dbs (Mts_db_names arg, Rpl_filter rpl_filter) override

void	attach_temp_tables_worker (THD , const Relay_log_info )
	Associating slave Worker thread to a subset of temporary tables. More...

void	detach_temp_tables_worker (THD , const Relay_log_info )
	Dissociating slave Worker thread from its thd->temporary_tables to possibly update the involved entries of db-to-worker hash with new values of temporary_tables. More...

uchar	mts_number_dbs () override

int	pack_info (Protocol *protocol) override
	This (which is used only for SHOW BINLOG EVENTS) could be updated to print SET @session_var=. More...

	Query_log_event ()
	The simplest constructor that could possibly work. More...

	Query_log_event (const char buf, const mysql::binlog::event::Format_description_event description_event, mysql::binlog::event::Log_event_type event_type)
	This is used by the SQL slave thread to prepare the event before execution. More...

	~Query_log_event () override

void	claim_memory_ownership (bool claim) override
	Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed. More...

bool	write (Basic_ostream *ostream) override
	Query_log_event::write(). More...

virtual bool	write_post_header_for_derived (Basic_ostream *)

virtual ulong	get_post_header_size_for_derived ()

enum_skip_reason	do_shall_skip (Relay_log_info *rli) override
	Decide if this event shall be skipped or not and the reason for skipping it. More...

int	do_apply_event (Relay_log_info const *rli) override
	Primitive to apply an event to the database. More...

int	do_update_pos (Relay_log_info *rli) override
	Advance relay log coordinates. More...

int	do_apply_event (Relay_log_info const rli, const char query_arg, size_t q_len_arg)

bool	is_trans_keyword () const

bool	is_sbr_logging_format () const override
	When a query log event contains a non-transaction control statement, we assume that it is changing database content (DML) and was logged using binlog_format=statement. More...

bool	starts_group () const override
	Notice, DDL queries are logged without BEGIN/COMMIT parentheses and identification of such single-query group occurs within logics of `get_slave_worker()`. More...

bool	ends_group () const override

bool	is_query_prefix_match (const char *pattern, uint p_len)

Public Member Functions inherited from mysql::binlog::event::Query_event
	Query_event (const char query_arg, const char catalog_arg, const char *db_arg, uint32_t query_length, unsigned long thread_id_arg, unsigned long long sql_mode_arg, unsigned long auto_increment_increment_arg, unsigned long auto_increment_offset_arg, unsigned int number, unsigned long long table_map_for_update_arg, int errcode)
	The constructor will be used while creating a Query_event, to be written to the binary log. More...

	Query_event (const char buf, const Format_description_event fde, Log_event_type event_type)
	The constructor receives a buffer and instantiates a Query_event filled in with the data from the buffer. More...

	Query_event (Log_event_type type_arg=QUERY_EVENT)
	The simplest constructor that could possibly work. More...

	~Query_event () override=default

Public Member Functions inherited from mysql::binlog::event::Binary_log_event
virtual	~Binary_log_event ()=0

	Binary_log_event (const Binary_log_event &)=default

	Binary_log_event (Binary_log_event &&)=default

Binary_log_event &	operator= (const Binary_log_event &)=default

Binary_log_event &	operator= (Binary_log_event &&)=default

enum Log_event_type	get_event_type () const
	Helper method. More...

const Log_event_header *	header () const
	Return a const pointer to the header of the log event. More...

Log_event_header *	header ()
	Return a non-const pointer to the header of the log event. More...

const Log_event_footer *	footer () const
	Return a const pointer to the footer of the log event. More...

Log_event_footer *	footer ()
	Return a non-const pointer to the footer of the log event. More...

Event_reader &	reader ()
	Returns a reference to the event Event_reader object. More...

Public Member Functions inherited from Log_event
	Log_event (mysql::binlog::event::Log_event_header header, mysql::binlog::event::Log_event_footer footer, enum_event_cache_type cache_type_arg, enum_event_logging_type logging_type_arg)
	This minimal constructor is for when you are not even sure that there is a valid THD. More...

	Log_event (THD thd_arg, uint16 flags_arg, enum_event_cache_type cache_type_arg, enum_event_logging_type logging_type_arg, mysql::binlog::event::Log_event_header header, mysql::binlog::event::Log_event_footer *footer)

int	net_send (Protocol protocol, const char log_name, my_off_t pos)
	Only called by SHOW BINLOG EVENTS. More...

void *	operator new (size_t size)

bool	wrapper_my_b_safe_write (Basic_ostream ostream, const uchar buf, size_t data_length)
	Write the given buffer to the given output stream, updating the checksum if checksums are enabled. More...

time_t	get_time ()
	Prints a "session_var=value" string. More...

virtual bool	write_data_header (Basic_ostream *)

virtual bool	write_data_body (Basic_ostream *)

virtual mysql::binlog::event::Log_event_type	get_type_code () const

virtual bool	is_rbr_logging_format () const
	Return true if the event has to be logged using RBR for DMLs. More...

bool	is_valid ()

void	set_artificial_event ()

void	set_relay_log_event ()

bool	is_artificial_event () const

bool	is_relay_log_event () const

bool	is_ignorable_event () const

bool	is_no_filter_event () const

bool	is_using_trans_cache () const

bool	is_using_stmt_cache () const

bool	is_using_immediate_logging () const

	Log_event (mysql::binlog::event::Log_event_header header, mysql::binlog::event::Log_event_footer footer)

virtual	~Log_event ()

void	register_temp_buf (char *buf, bool free_in_destructor=true)

void	free_temp_buf ()

virtual size_t	get_data_size ()

const char *	get_type_str () const
	Returns the human readable name of this event's type. More...

bool	is_mts_sequential_exec () const
	Is called from get_mts_execution_mode() to. More...

bool	contains_partition_info (bool)

bool	is_mts_group_isolated ()

int	apply_event (Relay_log_info *rli)
	Apply the event to the database. More...

int	apply_gtid_event (Relay_log_info *rli)
	Apply the GTID event in curr_group_data to the database. More...

int	update_pos (Relay_log_info *rli)
	Update the relay log position. More...

enum_skip_reason	shall_skip (Relay_log_info *rli)
	Decide if the event shall be skipped, and the reason for skipping it. More...

virtual int	do_apply_event_worker (Slave_worker *w)

Static Public Member Functions
static size_t	get_query (const char buf, size_t length, const mysql::binlog::event::Format_description_event fd_event, const char **query_arg)
	Return the query string pointer (and its size) from a Query log event using only the event buffer (we don't instantiate a Query_log_event object for this). More...

Static Public Member Functions inherited from Log_event
static void	init_show_field_list (mem_root_deque< Item * > *field_list)
	init_show_field_list() prepares the column names and types for the output of SHOW BINLOG EVENTS; it is used only by SHOW BINLOG EVENTS. More...

static void	operator delete (void *ptr, size_t)

static void *	operator new (size_t, void *ptr)

static void	operator delete (void , void )

static const char *	get_type_str (mysql::binlog::event::Log_event_type type)
	Returns the human readable name of the given event type. More...

static const char *	get_type_str (uint type)
	Get the name of an event type, or "Unknown" if out of range. More...

static bool	is_mts_sequential_exec (mysql::binlog::event::Log_event_type type_code)

static enum enum_mts_event_exec_mode	get_mts_execution_mode (bool mts_in_group, mysql::binlog::event::Log_event_type type_code, uint32 server_id, uint32 log_pos)

Public Attributes
my_thread_id	slave_proxy_id

bool	rollback_injected_by_coord = false
	True if this is a ROLLBACK event injected by the mts coordinator to finish a group corresponding to a partial transaction in the relay log. More...

bool	has_ddl_committed
	The flag indicates whether the DDL query has been (already) committed or not. More...

bool	m_skip_temp_tables_handling_by_worker {false}
	Instructs the applier to skip temporary tables handling. More...

bool	need_sql_require_primary_key {false}
	Whether or not the statement represented by this event requires `Q_SQL_REQUIRE_PRIMARY_KEY` to be logged along aside. More...

bool	needs_default_table_encryption {false}
	Whether or not the statement represented by this event requires `Q_DEFAULT_TABLE_ENCRYPTION` to be logged along aside. More...

Public Attributes inherited from mysql::binlog::event::Query_event
const char *	query

const char *	db

const char *	catalog

const char *	time_zone_str

uint32_t	thread_id

uint32_t	query_exec_time

size_t	db_len

uint16_t	error_code

uint16_t	status_vars_len

size_t	q_len

bool	flags2_inited

bool	sql_mode_inited

bool	charset_inited

uint32_t	flags2

uint64_t	sql_mode

uint16_t	auto_increment_increment

uint16_t	auto_increment_offset

char	charset [6]

size_t	time_zone_len

size_t	catalog_len

uint16_t	lc_time_names_number

uint16_t	charset_database_number

uint64_t	table_map_for_update

enum mysql::binlog::event::Query_event::enum_ternary	explicit_defaults_ts

unsigned char	mts_accessed_dbs

char	mts_accessed_db_names [MAX_DBS_IN_EVENT_MTS][NAME_LEN]

uint64_t	ddl_xid

uint16_t	default_collation_for_utf8mb4_number

uint8_t	sql_require_primary_key

uint8_t	default_table_encryption

Public Attributes inherited from Log_event
char *	temp_buf

bool	m_free_temp_buf_in_destructor

ulong	exec_time

uint32	server_id

ulong	rbr_exec_mode
	A storage to cache the global system variable's value. More...

enum_event_cache_type	event_cache_type
	Defines the type of the cache, if any, where the event will be stored before being flushed to disk. More...

enum_event_logging_type	event_logging_type
	Defines when information, i.e. More...

ha_checksum	crc
	Placeholder for event checksum while writing to binlog. More...

ulong	mts_group_idx
	Index in `rli->gaq` array to indicate a group that this event is purging. More...

mysql::binlog::event::Log_event_header *	common_header
	The Log_event_header class contains the variable present in the common header. More...

mysql::binlog::event::Log_event_footer *	common_footer
	The Log_event_footer class contains the variable present in the common footer. More...

Relay_log_info *	worker
	MTS: associating the event with either an assigned Worker or Coordinator. More...

ulonglong	future_event_relay_log_pos
	A copy of the main rli value stored into event to pass to MTS worker rli. More...

THD *	thd

db_worker_hash_entry *	mts_assigned_partitions [MAX_DBS_IN_EVENT_MTS]
	Partition info associate with event to deliver to MTS event applier. More...

Protected Attributes
mysql::binlog::event::Log_event_header::Byte *	data_buf

Protected Attributes inherited from mysql::binlog::event::Query_event
const char *	user

size_t	user_len

const char *	host

size_t	host_len

unsigned long	data_len

Additional Inherited Members
Public Types inherited from mysql::binlog::event::Query_event
enum	Query_event_post_header_offset { Q_THREAD_ID_OFFSET = 0 , Q_EXEC_TIME_OFFSET = 4 , Q_DB_LEN_OFFSET = 8 , Q_ERR_CODE_OFFSET = 9 , Q_STATUS_VARS_LEN_OFFSET = 11 , Q_DATA_OFFSET = QUERY_HEADER_LEN }
	query event post-header More...

enum	Query_event_status_vars { Q_FLAGS2_CODE = 0 , Q_SQL_MODE_CODE , Q_CATALOG_CODE , Q_AUTO_INCREMENT , Q_CHARSET_CODE , Q_TIME_ZONE_CODE , Q_CATALOG_NZ_CODE , Q_LC_TIME_NAMES_CODE , Q_CHARSET_DATABASE_CODE , Q_TABLE_MAP_FOR_UPDATE_CODE , Q_MASTER_DATA_WRITTEN_CODE , Q_INVOKER , Q_UPDATED_DB_NAMES , Q_MICROSECONDS , Q_COMMIT_TS , Q_COMMIT_TS2 , Q_EXPLICIT_DEFAULTS_FOR_TIMESTAMP , Q_DDL_LOGGED_WITH_XID , Q_DEFAULT_COLLATION_FOR_UTF8MB4 , Q_SQL_REQUIRE_PRIMARY_KEY , Q_DEFAULT_TABLE_ENCRYPTION }

enum	enum_ternary { TERNARY_UNSET , TERNARY_OFF , TERNARY_ON }

Public Types inherited from mysql::binlog::event::Binary_log_event
enum	enum_post_header_length { QUERY_HEADER_MINIMAL_LEN = (4 + 4 + 1 + 2) , QUERY_HEADER_LEN = (QUERY_HEADER_MINIMAL_LEN + 2) , STOP_HEADER_LEN = 0 , START_V3_HEADER_LEN = (2 + ST_SERVER_VER_LEN + 4) , ROTATE_HEADER_LEN = 8 , INTVAR_HEADER_LEN = 0 , APPEND_BLOCK_HEADER_LEN = 4 , DELETE_FILE_HEADER_LEN = 4 , RAND_HEADER_LEN = 0 , USER_VAR_HEADER_LEN = 0 , FORMAT_DESCRIPTION_HEADER_LEN = (START_V3_HEADER_LEN + 1 + LOG_EVENT_TYPES) , XID_HEADER_LEN = 0 , BEGIN_LOAD_QUERY_HEADER_LEN = APPEND_BLOCK_HEADER_LEN , ROWS_HEADER_LEN_V1 = 8 , TABLE_MAP_HEADER_LEN = 8 , EXECUTE_LOAD_QUERY_EXTRA_HEADER_LEN = (4 + 4 + 4 + 1) , EXECUTE_LOAD_QUERY_HEADER_LEN , INCIDENT_HEADER_LEN = 2 , HEARTBEAT_HEADER_LEN = 0 , IGNORABLE_HEADER_LEN = 0 , ROWS_HEADER_LEN_V2 = 10 , TRANSACTION_CONTEXT_HEADER_LEN = 18 , VIEW_CHANGE_HEADER_LEN = 52 , XA_PREPARE_HEADER_LEN = 0 , TRANSACTION_PAYLOAD_HEADER_LEN = 0 }
	The lengths for the fixed data part of each event. More...

Public Types inherited from Log_event
enum	enum_skip_reason { EVENT_SKIP_NOT , EVENT_SKIP_IGNORE , EVENT_SKIP_COUNT }
	Enumeration of what kinds of skipping (and non-skipping) that can occur when the slave executes an event. More...

enum	enum_mts_event_exec_mode { EVENT_EXEC_PARALLEL , EVENT_EXEC_ASYNC , EVENT_EXEC_SYNC , EVENT_EXEC_CAN_NOT }

Static Public Attributes inherited from mysql::binlog::event::Binary_log_event
static const int	LOG_EVENT_TYPES = (ENUM_END_EVENT - 1)

Protected Types inherited from Log_event
enum	enum_event_cache_type { EVENT_INVALID_CACHE = 0 , EVENT_STMT_CACHE , EVENT_TRANSACTIONAL_CACHE , EVENT_NO_CACHE , EVENT_CACHE_COUNT }

enum	enum_event_logging_type { EVENT_INVALID_LOGGING = 0 , EVENT_NORMAL_LOGGING , EVENT_IMMEDIATE_LOGGING , EVENT_CACHE_LOGGING_COUNT }

Protected Member Functions inherited from mysql::binlog::event::Query_event
int	fill_data_buf (unsigned char *dest, unsigned long len)
	Layout for the data buffer is as follows. More...

Protected Member Functions inherited from mysql::binlog::event::Binary_log_event
	Binary_log_event (Log_event_type type_code)
	This constructor is used to initialize the type_code of header object m_header. More...

	Binary_log_event (const char *buf, const Format_description_event fde)
	This constructor will create a new object of Log_event_header and initialize the variable m_header, which in turn will be used to initialize Log_event's member common_header. More...

Protected Member Functions inherited from Log_event
uint32	write_header_to_memory (uchar *buf)
	Writes the common header of this event to the given memory buffer. More...

bool	write_header (Basic_ostream *ostream, size_t data_length)
	Writes the common-header of this event to the given output stream and updates the checksum. More...

bool	write_footer (Basic_ostream *ostream)

bool	need_checksum ()
	A decider of whether to trigger checksum computation or not. More...

enum_skip_reason	continue_group (Relay_log_info *rli)
	Helper function to ignore an event w.r.t. More...

Detailed Description

A Query event is written to the binary log whenever the database is modified on the master, unless row based logging is used.

Query_log_event is created for logging, and is called after an update to the database is done. It is used when the server acts as the master.

Virtual inheritance is required here to handle the diamond problem in the class Execute_load_query_log_event. The diamond structure is explained in Excecute_load_query_log_event

Constructor & Destructor Documentation

◆ Query_log_event() [1/5]

Query_log_event::Query_log_event ( Query_log_event && )

deletenoexcept

◆ Query_log_event() [2/5]

Query_log_event::Query_log_event ( const Query_log_event & )

delete

◆ Query_log_event() [3/5]

Query_log_event::Query_log_event	(	THD *	thd_arg,
		const char *	query_arg,
		size_t	query_length,
		bool	using_trans,
		bool	immediate,
		bool	suppress_use,
		int	errcode,
		bool	ignore_cmd_internals = `false`
	)

Creates a Query Log Event.

Parameters

thd_arg	Thread handle
query_arg	Array of char representing the query
query_length	Size of the 'query_arg' array
using_trans	Indicates that there are transactional changes.
immediate	After being written to the binary log, the event must be flushed immediately. This indirectly implies the stmt-cache.
suppress_use	Suppress the generation of 'USE' statements
errcode	The error code of the query
ignore_cmd_internals	Ignore user's statement, i.e. lex information, while deciding which cache must be used.

◆ Query_log_event() [4/5]

Query_log_event::Query_log_event ( )

The simplest constructor that could possibly work.

This is used for creating static objects that have a special meaning and are invisible to the log.

◆ Query_log_event() [5/5]

Query_log_event::Query_log_event	(	const char *	buf,
		const mysql::binlog::event::Format_description_event *	description_event,
		mysql::binlog::event::Log_event_type	event_type
	)

This is used by the SQL slave thread to prepare the event before execution.

◆ ~Query_log_event()

Query_log_event::~Query_log_event ( )

inlineoverride

Member Function Documentation

◆ attach_temp_tables_worker()

void Query_log_event::attach_temp_tables_worker	(	THD *	thd_arg,
		const Relay_log_info *	rli
	)

Associating slave Worker thread to a subset of temporary tables.

Parameters

thd_arg	THD instance pointer
rli	Relay_log_info of the worker

◆ claim_memory_ownership()

void Query_log_event::claim_memory_ownership ( bool claim )

overridevirtual

Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.

Parameters

claim True - claim ownership of the memory False - disclaim ownership of the memory

Reimplemented from Log_event.

Reimplemented in Execute_load_query_log_event.

◆ detach_temp_tables_worker()

void Query_log_event::detach_temp_tables_worker	(	THD *	thd_arg,
		const Relay_log_info *	rli
	)

Dissociating slave Worker thread from its thd->temporary_tables to possibly update the involved entries of db-to-worker hash with new values of temporary_tables.

Parameters

thd_arg	THD instance pointer
rli	relay log info of the worker thread

◆ do_apply_event() [1/2]

int Query_log_event::do_apply_event ( Relay_log_info const * rli )

overridevirtual

Primitive to apply an event to the database.

This is where the change to the database is made.

Note: The primitive is protected instead of private, since there is a hierarchy of actions to be performed in some cases.

See also: Format_description_log_event::do_apply_event()

Parameters

rli	Pointer to relay log info structure

Return values

0	Event applied successfully
errno	Error code if event application failed

Reimplemented from Log_event.

Reimplemented in Execute_load_query_log_event.

◆ do_apply_event() [2/2]

int Query_log_event::do_apply_event	(	Relay_log_info const *	rli,
		const char *	query_arg,
		size_t	q_len_arg
	)

if ((uint32) affected_in_event != (uint32) affected_on_slave)
{
sql_print_error("Replica: did not get the expected number of affected "
"rows running query from source - expected %d, got %d (this numbers "
"should have matched modulo 4294967296).", 0, ...);
thd->query_error = 1;
}

We may also want an option to tell the slave to ignore "affected" mismatch. This mismatch could be implemented with a new ER_ code, and to ignore it you would use –replica-skip-errors...

The following failure injection works in cooperation with tests setting @global.debug= 'd,stop_replica_middle_group'. The sql thread receives the killed status and will proceed to shutdown trying to finish incomplete events group.

◆ do_shall_skip()

Log_event::enum_skip_reason Query_log_event::do_shall_skip ( Relay_log_info * rli )

overridevirtual

Decide if this event shall be skipped or not and the reason for skipping it.

The default implementation decide that the event shall be skipped if either:

the server id of the event is the same as the server id of the server and rli->replicate_same_server_id is true, or
if rli->slave_skip_counter is greater than zero.

See also: do_apply_event; do_update_pos

Return values

Log_event::EVENT_SKIP_NOT	The event shall not be skipped and should be applied.
Log_event::EVENT_SKIP_IGNORE	The event shall be skipped by just ignoring it, i.e., the slave skip counter shall not be changed. This happends if, for example, the originating server id of the event is the same as the server id of the slave.
Log_event::EVENT_SKIP_COUNT	The event shall be skipped because the slave skip counter was non-zero. The caller shall decrease the counter by one.

Reimplemented from Log_event.

◆ do_update_pos()

int Query_log_event::do_update_pos ( Relay_log_info * rli )

overridevirtual

Advance relay log coordinates.

This function is called to advance the relay log coordinates to just after the event. It is essential that both the relay log coordinate and the group log position is updated correctly, since this function is used also for skipping events.

Normally, each implementation of do_update_pos() shall:

Update the event position to refer to the position just after the event.
Update the group log position to refer to the position just after the event if the event is last in a group

Parameters

rli	Pointer to relay log info structure

Return values

0	Coordinates changed successfully
errno	Error code if advancing failed (usually just 1). Observe that handler errors are returned by the do_apply_event() function, and not by this one.

Reimplemented from Log_event.

◆ ends_group()

bool Query_log_event::ends_group ( ) const

inlineoverridevirtual

Returns: true if the event ends a group (transaction) false otherwise

Reimplemented from Log_event.

◆ get_db()

const char * Query_log_event::get_db ( )

inlineoverridevirtual

Reimplemented from Log_event.

◆ get_mts_dbs()

uint8 Query_log_event::get_mts_dbs	(	Mts_db_names *	arg,
		Rpl_filter *	rpl_filter
	)

inlineoverridevirtual

Parameters

[out]	arg	pointer to a struct containing char* array pointers be filled in and the number of filled instances. In case the number exceeds MAX_DBS_IN_EVENT_MTS, the overfill is indicated with assigning the number to OVER_MAX_DBS_IN_EVENT_MTS.
	rpl_filter	pointer to a replication filter.

Returns: number of databases in the array or OVER_MAX_DBS_IN_EVENT_MTS.

Reimplemented from Log_event.

◆ get_post_header_size_for_derived()

virtual ulong Query_log_event::get_post_header_size_for_derived ( )

inlinevirtual

Reimplemented in Execute_load_query_log_event.

◆ get_query()

size_t Query_log_event::get_query	(	const char *	buf,
		size_t	length,
		const mysql::binlog::event::Format_description_event *	fd_event,
		const char **	query_arg
	)

static

Return the query string pointer (and its size) from a Query log event using only the event buffer (we don't instantiate a Query_log_event object for this).

Parameters

	buf	Pointer to the event buffer.
	length	The size of the event buffer.
	fd_event	The description event of the master which logged the event.
[out]	query_arg	The pointer to receive the query pointer.

Returns: The size of the query.

◆ is_query_prefix_match()

bool Query_log_event::is_query_prefix_match	(	const char *	pattern,
		uint	p_len
	)

inline

◆ is_sbr_logging_format()

bool Query_log_event::is_sbr_logging_format ( ) const

inlineoverridevirtual

When a query log event contains a non-transaction control statement, we assume that it is changing database content (DML) and was logged using binlog_format=statement.

Returns: True the event represents a statement that was logged using SBR that can change database content. False for transaction control statements.

Reimplemented from Log_event.

Reimplemented in Execute_load_query_log_event.

◆ is_skip_temp_tables_handling_by_worker()

bool Query_log_event::is_skip_temp_tables_handling_by_worker ( )

inline

◆ is_trans_keyword()

bool Query_log_event::is_trans_keyword ( ) const

inline

◆ mts_number_dbs()

uchar Query_log_event::mts_number_dbs ( )

inlineoverridevirtual

Reimplemented from Log_event.

◆ operator=() [1/2]

Query_log_event & Query_log_event::operator= ( const Query_log_event & )

delete

◆ operator=() [2/2]

Query_log_event & Query_log_event::operator= ( Query_log_event && )

deletenoexcept

◆ pack_info()

int Query_log_event::pack_info ( Protocol * protocol )

overridevirtual

This (which is used only for SHOW BINLOG EVENTS) could be updated to print SET @session_var=.

But this is not urgent, as SHOW BINLOG EVENTS is only an information, it does not produce suitable queries to replay (for example it does not print LOAD DATA INFILE).

Reimplemented from Log_event.

Reimplemented in Execute_load_query_log_event.

◆ set_skip_temp_tables_handling_by_worker()

void Query_log_event::set_skip_temp_tables_handling_by_worker ( )

inline

◆ starts_group()

bool Query_log_event::starts_group ( ) const

inlineoverridevirtual

Notice, DDL queries are logged without BEGIN/COMMIT parentheses and identification of such single-query group occurs within logics of get_slave_worker().

Reimplemented from Log_event.

◆ write()

bool Query_log_event::write ( Basic_ostream * ostream )

overridevirtual

Query_log_event::write().

Note: In this event we have to modify the header to have the correct EVENT_LEN_OFFSET as we don't yet know how many status variables we will print!

Reimplemented from Log_event.

◆ write_post_header_for_derived()

virtual bool Query_log_event::write_post_header_for_derived ( Basic_ostream * )

inlinevirtual

Reimplemented in Execute_load_query_log_event.

Member Data Documentation

◆ data_buf

mysql::binlog::event::Log_event_header::Byte* Query_log_event::data_buf

protected

◆ has_ddl_committed

bool Query_log_event::has_ddl_committed

The flag indicates whether the DDL query has been (already) committed or not.

It's initialized as OFF at the event instantiation, flips ON when the DDL transaction has been committed with all its possible extra statement due to replication or GTID.

The flag status is also checked in few places to catch uncommitted transactions which can normally happen due to filtering out. In such a case the commit is deferred to Log_event::do_update_pos().

◆ m_skip_temp_tables_handling_by_worker

bool Query_log_event::m_skip_temp_tables_handling_by_worker {false}

Instructs the applier to skip temporary tables handling.

◆ need_sql_require_primary_key

bool Query_log_event::need_sql_require_primary_key {false}

Whether or not the statement represented by this event requires Q_SQL_REQUIRE_PRIMARY_KEY to be logged along aside.

◆ needs_default_table_encryption

bool Query_log_event::needs_default_table_encryption {false}

Whether or not the statement represented by this event requires Q_DEFAULT_TABLE_ENCRYPTION to be logged along aside.

◆ rollback_injected_by_coord

bool Query_log_event::rollback_injected_by_coord = false

True if this is a ROLLBACK event injected by the mts coordinator to finish a group corresponding to a partial transaction in the relay log.

False otherwise and by default, as it must be explicitly set to true by the coordinator.

◆ slave_proxy_id

my_thread_id Query_log_event::slave_proxy_id

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

sql/log_event.h
sql/log_event.cc

Public Member Functions

Static Public Member Functions

Public Attributes

Protected Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ Query_log_event() [1/5]

◆ Query_log_event() [2/5]

◆ Query_log_event() [3/5]

◆ Query_log_event() [4/5]

◆ Query_log_event() [5/5]

◆ ~Query_log_event()

Member Function Documentation

◆ attach_temp_tables_worker()

◆ claim_memory_ownership()

◆ detach_temp_tables_worker()

◆ do_apply_event() [1/2]

◆ do_apply_event() [2/2]

◆ do_shall_skip()

◆ do_update_pos()

◆ ends_group()

◆ get_db()

◆ get_mts_dbs()

◆ get_post_header_size_for_derived()

◆ get_query()

◆ is_query_prefix_match()

◆ is_sbr_logging_format()

◆ is_skip_temp_tables_handling_by_worker()

◆ is_trans_keyword()

◆ mts_number_dbs()

◆ operator=() [1/2]

◆ operator=() [2/2]

◆ pack_info()

◆ set_skip_temp_tables_handling_by_worker()

◆ starts_group()

◆ write()

◆ write_post_header_for_derived()

Member Data Documentation

◆ data_buf

◆ has_ddl_committed

◆ m_skip_temp_tables_handling_by_worker

◆ need_sql_require_primary_key

◆ needs_default_table_encryption

◆ rollback_injected_by_coord

◆ slave_proxy_id