105#include <sys/types.h>
108#ifdef HAVE_PSI_STAGE_INTERFACE
120#if defined(MYSQL_SERVER)
128#if defined(MYSQL_SERVER)
131#define PREFIX_SQL_LOAD "SQL_LOAD-"
143#define TEMP_FILE_MAX_LEN UUID_LENGTH + 38
155#define ASSERT_OR_RETURN_ERROR(COND, ERRNO) \
157 if (!(COND)) return ERRNO; \
160#define ASSERT_OR_RETURN_ERROR(COND, ERRNO) assert(COND)
163#define LOG_EVENT_OFFSET 4
165#define NUM_LOAD_DELIM_STRS 5
188#define MAX_LOG_EVENT_HEADER \
190 (LOG_EVENT_HEADER_LEN + \
191 mysql::binlog::event::Binary_log_event::QUERY_HEADER_LEN +
193 mysql::binlog::event::Binary_log_event:: \
194 EXECUTE_LOAD_QUERY_EXTRA_HEADER_LEN) +
196 MAX_SIZE_LOG_EVENT_STATUS + \
202#define SL_MASTER_PORT_OFFSET 8
203#define SL_MASTER_POS_OFFSET 0
204#define SL_MASTER_HOST_OFFSET 10
209#define I_TYPE_OFFSET 0
210#define I_VAL_OFFSET 1
213#define BINLOG_MAGIC "\xfe\x62\x69\x6e"
214#define BINLOG_MAGIC_SIZE 4
245#define LOG_EVENT_THREAD_SPECIFIC_F 0x4
260#define LOG_EVENT_SUPPRESS_USE_F 0x8
277#define LOG_EVENT_ARTIFICIAL_F 0x20
285#define LOG_EVENT_RELAY_LOG_F 0x40
296#define LOG_EVENT_IGNORABLE_F 0x80
305#define LOG_EVENT_NO_FILTER_F 0x100
316#define LOG_EVENT_MTS_ISOLATE_F 0x200
341#define OPTIONS_WRITTEN_TO_BIN_LOG \
342 (OPTION_AUTO_IS_NULL | OPTION_NO_FOREIGN_KEY_CHECKS | \
343 OPTION_RELAXED_UNIQUE_CHECKS | OPTION_NOT_AUTOCOMMIT)
346#define EXPECTED_OPTIONS \
347 ((1ULL << 14) | (1ULL << 26) | (1ULL << 27) | (1ULL << 19))
349#if OPTIONS_WRITTEN_TO_BIN_LOG != EXPECTED_OPTIONS
350#error OPTIONS_WRITTEN_TO_BIN_LOG must NOT change their values!
352#undef EXPECTED_OPTIONS
386enum enum_base64_output_mode {
387 BASE64_OUTPUT_NEVER = 0,
388 BASE64_OUTPUT_AUTO = 1,
389 BASE64_OUTPUT_UNSPEC = 2,
390 BASE64_OUTPUT_DECODE_ROWS = 3,
392 BASE64_OUTPUT_MODE_COUNT
407struct PRINT_EVENT_INFO {
417 bool sql_mode_inited;
419 ulong auto_increment_increment, auto_increment_offset;
423 uint lc_time_names_number;
424 uint charset_database_number;
425 uint default_collation_for_utf8mb4_number;
426 uint8_t sql_require_primary_key;
428 bool thread_id_printed;
429 uint8_t default_table_encryption;
433 ~PRINT_EVENT_INFO() {
448 enum_base64_output_mode base64_output_mode;
458 bool printed_fd_event;
460 uint8 common_header_len;
477 bool have_unflushed_events;
487 bool skipped_event_in_transaction;
489 bool print_table_metadata;
497 bool require_row_format;
502 uint32_t immediate_server_version;
754 virtual const char *
get_db();
757 virtual void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const = 0;
761 void print_base64(
IO_CACHE *
file, PRINT_EVENT_INFO *print_event_info,
765 void *
operator new(
size_t size);
767 static void operator delete(
void *ptr, size_t) {
my_free(ptr); }
770 static void *
operator new(size_t,
void *ptr) {
return ptr; }
771 static void operator delete(
void *,
void *) {}
897#if defined(MYSQL_SERVER)
1101 virtual bool ends_group()
const {
return false; }
1142 DBUG_PRINT(
"info", (
"skip reason=%d=%s", ret,
1342 bool using_trans,
bool immediate,
bool suppress_use,
1343 int error,
bool ignore_command =
false);
1344 const char *
get_db()
override {
return db; }
1368 const char *db_filtered =
1387 PRINT_EVENT_INFO *print_event_info)
const;
1388 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
1389 static bool rewrite_db_in_buffer(
1390 char **
buf, ulong *event_len,
1419#if defined(MYSQL_SERVER)
1485 const char **query_arg);
1488 return !strncmp(
query, pattern, p_len);
1555 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
1571#if defined(MYSQL_SERVER)
1622 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
1643#if defined(MYSQL_SERVER)
1695 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
1713#if defined(MYSQL_SERVER)
1762 bool ends_group()
const override {
return true; }
1763#if defined(MYSQL_SERVER)
1788 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
1803#if defined(MYSQL_SERVER)
1855 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
1857#if defined(MYSQL_SERVER)
1896 char *val_arg, ulong val_len_arg,
Item_result type_arg,
1897 uint charset_number_arg,
uchar flags_arg,
1901 val_len_arg, type_arg,
1902 charset_number_arg, flags_arg),
1910 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
1941#if defined(MYSQL_SERVER)
1969 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
1989#if defined(MYSQL_SERVER)
2042 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
2061#if defined(MYSQL_SERVER)
2105 uint block_len_arg,
bool using_trans);
2109 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
2125 const char *
get_db()
override {
return db; }
2131#if defined(MYSQL_SERVER)
2178 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
2179 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info,
bool enable_local);
2194 const char *
get_db()
override {
return db; }
2200#if defined(MYSQL_SERVER)
2256 uint block_len_arg,
bool using_trans);
2268#if defined(MYSQL_SERVER)
2315 THD *
thd,
const char *query_arg, ulong query_length,
2316 uint fn_pos_start_arg, uint fn_pos_end_arg,
2318 bool using_trans,
bool immediate,
bool suppress_use,
int errcode);
2321 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
2324 const char *local_fname)
const;
2341#if defined(MYSQL_SERVER)
2346#if defined MYSQL_SERVER
2350 const char *table_name_arg,
bool is_concurrent_arg,
2380 Unknown_log_event(Unknown_log_event &&)
noexcept =
delete;
2381 Unknown_log_event &
operator=(Unknown_log_event &&)
noexcept =
delete;
2382 Unknown_log_event(
const Unknown_log_event &) =
delete;
2383 Unknown_log_event &
operator=(
const Unknown_log_event &) =
delete;
2401 ~Unknown_log_event()
override =
default;
2402 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
2408char *
str_to_hex(
char *to,
const char *from,
size_t len);
2498 static bool rewrite_db_in_buffer(
2499 char **
buf, ulong *event_len,
2543#if defined(MYSQL_SERVER)
2548 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
2560 const Optional_metadata_fields &fields)
const;
2571 const Optional_metadata_fields &fields)
const;
2579#if defined(MYSQL_SERVER)
2639 class Charset_iterator;
2640 class Default_charset_iterator;
2641 class Column_charset_iterator;
2645#ifdef HAVE_PSI_STAGE_INTERFACE
2697 if (estimated == 0) {
2698 assert(cursor >
begin);
2700 estimated = (
end -
begin) / avg_row_change_size;
2767#ifdef HAVE_PSI_STAGE_INTERFACE
2813#if defined(MYSQL_SERVER)
2818 void print_verbose(
IO_CACHE *
file, PRINT_EVENT_INFO *print_event_info);
2820 PRINT_EVENT_INFO *print_event_info,
2822 const uchar *prefix,
2841#if defined(MYSQL_SERVER)
2872 MY_BITMAP const *cols,
bool is_transactional,
2874 const unsigned char *extra_row_ndb_info);
2877 const char *row_data,
2881 void print_helper(
FILE *, PRINT_EVENT_INFO *)
const;
2942#if defined(MYSQL_SERVER)
2963 return key_cmp2((*m_key_info)->key_part, k1, (*m_key_info)->key_length,
2964 k2, (*m_key_info)->key_length) < 0;
2971 std::set<uchar *, Key_compare>::iterator
m_itr;
3000 bool is_after_image,
bool only_seek =
false);
3061#if defined(MYSQL_SERVER)
3198 const uchar *curr_bi_start
3318#if defined(MYSQL_SERVER)
3321 bool is_transactional,
3322 const unsigned char *extra_row_ndb_info);
3327#if defined(MYSQL_SERVER)
3329 bool is_transactional,
3330 const uchar *before_record
3332 const uchar *after_record);
3349 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
3352#if defined(MYSQL_SERVER)
3411 bool is_transactional,
3412 const unsigned char *extra_row_ndb_info);
3416 bool is_transactional,
3417 const unsigned char *extra_row_ndb_info);
3430 bool is_transactional,
3432 const uchar *after_record);
3447 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
3450#if defined(MYSQL_SERVER)
3456 const uchar *curr_bi_start)
override;
3468 const THD *thd_arg);
3529 bool is_transactional,
3530 const unsigned char *extra_row_ndb_info);
3537 bool is_transactional,
3538 const uchar *before_record,
3554 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
3557#if defined(MYSQL_SERVER)
3605 std::string_view msg)
3610 DBUG_PRINT(
"enter", (
"incident: %d", incident_arg));
3639 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
3642#if defined(MYSQL_SERVER)
3653 bool ends_group()
const override {
return true; }
3716 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
3802 bool flush_stream) {
3804 (flush_stream ? (fflush(
file) || ferror(
file)) : 0) ||
3865 uint64_t payload_size,
3866 uint16_t compression_type,
3867 uint64_t uncompressed_size)
3874 uint64_t payload_size)
3876 thd_arg, payload, payload_size,
3893 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
3899#if defined(MYSQL_SERVER)
3954 int64 sequence_number_arg,
bool may_have_sbr_stmts_arg,
3955 ulonglong original_commit_timestamp_arg,
3956 ulonglong immediate_commit_timestamp_arg,
3957 uint32_t original_server_version_arg,
3958 uint32_t immediate_server_version_arg);
3965 int64 last_committed_arg,
int64 sequence_number_arg,
3966 bool may_have_sbr_stmts_arg,
3967 ulonglong original_commit_timestamp_arg,
3968 ulonglong immediate_commit_timestamp_arg,
3970 uint32_t original_server_version_arg,
3971 uint32_t immediate_server_version_arg);
3991 { size_calculated += 2; });
3992 return size_calculated;
4061 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
4064#if defined(MYSQL_SERVER)
4153 bool is_checksum_enabled =
false,
4154 int event_counter = 0);
4159 bool is_checksum_enabled =
false,
4160 int event_counter = 0);
4217 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
4230 (
"skip writing Previous_gtids_log_event because of"
4231 "debug option 'skip_writing_previous_gtids_log_event'"));
4242 (
"writing partial Previous_gtids_log_event because of"
4243 "debug option 'write_partial_previous_gtids_log_event'"));
4275#if defined(MYSQL_SERVER)
4361 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
4364#if defined(MYSQL_SERVER)
4461 std::map<std::string, std::string> *
map);
4490 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
4493#if defined(MYSQL_SERVER)
4514 size_t *event_size);
4565 return evt !=
nullptr &&
4599template <
class EVENT>
4601 return ev->write(ostream);
4609 const char *identifier,
size_t length);
4614 const char *identifier,
4635template <
typename T>
4645std::pair<bool, mysql::binlog::event::Log_event_basic_info>
4657std::pair<bool, mysql::binlog::event::Log_event_basic_info>
Kerberos Client Authentication nullptr
Definition: auth_kerberos_client_plugin.cc:251
int64 query_id_t
Definition: binlog.h:72
Contains the classes representing events occurring in the replication stream.
#define LOG_EVENT_HEADER_LEN
Definition: binlog_event.h:443
This event is created to contain the file data.
Definition: log_event.h:2092
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:7009
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:7036
virtual int get_create_or_append() const
Definition: log_event.cc:7059
bool is_sbr_logging_format() const override
Return true if the event has to be logged using SBR for DMLs.
Definition: log_event.h:2126
size_t get_data_size() override
Definition: log_event.h:2117
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:7046
~Append_block_log_event() override=default
const char * get_db() override
Definition: log_event.h:2123
Append_block_log_event(Append_block_log_event &&) noexcept=delete
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:7089
The abstract class for basic output streams which provides write operation.
Definition: basic_ostream.h:37
Event for the first block of file to be loaded, its only difference from Append_block event is that t...
Definition: log_event.h:2242
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.
Definition: log_event.cc:7310
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:7300
~Begin_load_query_log_event() override=default
Begin_load_query_log_event(THD *thd)
Begin_load_query_log_event(Begin_load_query_log_event &&) noexcept=delete
int get_create_or_append() const override
Definition: log_event.cc:7306
Delete_file_log_event is created when the LOAD_DATA query fails on the master for some reason,...
Definition: log_event.h:2164
Delete_file_log_event(const Delete_file_log_event &)=delete
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:7250
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:7228
size_t get_data_size() override
Definition: log_event.h:2187
~Delete_file_log_event() override=default
bool is_sbr_logging_format() const override
Return true if the event has to be logged using SBR for DMLs.
Definition: log_event.h:2195
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:7205
const char * get_db() override
Definition: log_event.h:2192
Delete_file_log_event(Delete_file_log_event &&) noexcept=delete
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:7238
Log row deletions.
Definition: log_event.h:3518
bool read_write_bitmaps_cmp(const TABLE *table) const override
Compares the table's read/write_set with the columns included in this event's before-image and/or aft...
Definition: log_event.h:3539
static bool binlog_row_logging_function(THD *thd, TABLE *table, bool is_transactional, const uchar *before_record, const uchar *after_record)
Definition: log_event.cc:12392
int do_after_row_operations(const Relay_log_info *const, int) override
Definition: log_event.cc:12445
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:12412
Delete_rows_log_event(THD *, TABLE *, const mysql::binlog::event::Table_id &, bool is_transactional, const unsigned char *extra_row_ndb_info)
Definition: log_event.cc:12381
mysql::binlog::event::Log_event_type get_general_type_code() override
Definition: log_event.h:3547
int do_exec_row(const Relay_log_info *const) override
Definition: log_event.cc:12452
@ TYPE_CODE
Definition: log_event.h:3522
int do_before_row_operations(const Relay_log_info *const) override
Definition: log_event.cc:12419
Event responsible for LOAD DATA execution, it similar to Query_log_event but before executing the que...
Definition: log_event.h:2309
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:7464
bool is_sbr_logging_format() const override
When a query log event contains a non-transaction control statement, we assume that it is changing da...
Definition: log_event.h:2334
bool write_post_header_for_derived(Basic_ostream *ostream) override
Definition: log_event.cc:7374
int pack_info(Protocol *protocol) override
This (which is used only for SHOW BINLOG EVENTS) could be updated to print SET @session_var=.
Definition: log_event.cc:7433
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:7368
ulong get_post_header_size_for_derived() override
Definition: log_event.cc:7364
Execute_load_query_log_event(THD *thd, const char *query_arg, ulong query_length, uint fn_pos_start_arg, uint fn_pos_end_arg, mysql::binlog::event::enum_load_dup_handling dup_handling_arg, bool using_trans, bool immediate, bool suppress_use, int errcode)
Definition: log_event.cc:7323
~Execute_load_query_log_event() override=default
This is a subclass if Gtid_event and Log_event.
Definition: log_event.h:3939
void set_trx_length_by_cache_size_tagged(ulonglong cache_size, bool is_checksum_enabled=false, int event_counter=0)
Set the transaction length information based on binlog cache size.
Definition: log_event.cc:13490
rpl_gno get_gno() const override
Return the GNO for this GTID.
Definition: log_event.h:4108
rpl_sidno get_sidno(bool need_lock)
Return the SIDNO relative to the global tsid_map for this GTID.
Definition: log_event.cc:13521
~Gtid_log_event() override=default
bool write_data_header(Basic_ostream *ostream) override
Writes the post-header to the given output stream.
Definition: log_event.cc:13204
Gtid_log_event(Gtid_log_event &&) noexcept=delete
size_t get_event_length()
Definition: log_event.h:4004
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:13471
enum_gtid_type get_type() const
Return the gtid type for this Gtid_log_event: this can be either ANONYMOUS_GTID, AUTOMATIC_GTID,...
Definition: log_event.h:4072
uint32 write_body_to_memory(uchar *buff)
Writes the body to the given memory buffer.
Definition: log_event.cc:13241
Gtid_log_event(const Gtid_log_event &)=delete
uint32 write_tagged_event_body_to_memory(uchar *buffer)
Writes the body to the given memory buffer.
Definition: log_event.cc:13214
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:13315
uint32 write_post_header_to_memory(uchar *buffer)
Writes the post-header to the given memory buffer.
Definition: log_event.cc:13149
static const size_t SET_STRING_PREFIX_LENGTH
Length of SET_STRING_PREFIX.
Definition: log_event.h:4115
Tsid tsid
TSID for this GTID.
Definition: log_event.h:4128
const Tsid & get_tsid() const
Return the TSID for this GTID.
Definition: log_event.h:4078
bool write_data_body(Basic_ostream *ostream) override
Definition: log_event.cc:13306
void set_trx_length_by_cache_size(ulonglong cache_size, bool is_checksum_enabled=false, int event_counter=0)
Set the transaction length information based on binlog cache size.
Definition: log_event.cc:13500
static const size_t MAX_SET_STRING_LENGTH
The maximal length of the entire "SET ..." query.
Definition: log_event.h:4117
void update_parent_gtid_info()
Updates parent tsid and gtid info structure.
Definition: log_event.cc:12974
static const char * SET_STRING_PREFIX
string holding the text "SET @@GLOBAL.GTID_NEXT = '"
Definition: log_event.h:4111
void clear_gtid_and_spec()
Clears tsid and spec.
Definition: log_event.cc:12980
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:13064
Gtid_specification spec
Internal representation of the GTID.
Definition: log_event.h:4126
int pack_info(Protocol *) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:13045
size_t get_data_size() override
Definition: log_event.h:3985
size_t to_string(char *buf) const
Used internally by both print() and pack_info().
Definition: log_event.cc:13053
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.
Definition: log_event.cc:13485
Represents a set of GTIDs.
Definition: rpl_gtid.h:1556
Definition: rpl_utility.h:109
Definition: log_event.h:3825
Heartbeat_log_event_v2(const char *buf, const mysql::binlog::event::Format_description_event *description_event)
Definition: log_event.cc:14387
Definition: log_event.h:3817
Heartbeat_log_event(const char *buf, const mysql::binlog::event::Format_description_event *description_event)
Definition: log_event.cc:14380
Base class for ignorable log events is Ignorable_event.
Definition: log_event.h:3684
int pack_info(Protocol *) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:12789
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:12782
size_t get_data_size() override
Definition: log_event.h:3717
Ignorable_log_event(Ignorable_log_event &&) noexcept=delete
~Ignorable_log_event() override
Ignorable_log_event(const Ignorable_log_event &)=delete
Class representing an incident, an occurrence out of the ordinary, that happened on the master.
Definition: log_event.h:3593
Incident_log_event(const Incident_log_event &)=delete
bool write_data_header(Basic_ostream *ostream) override
Definition: log_event.cc:12734
size_t get_data_size() override
Definition: log_event.h:3646
bool write_data_body(Basic_ostream *ostream) override
Definition: log_event.cc:12760
~Incident_log_event() override
Definition: log_event.cc:12648
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:12694
int pack_info(Protocol *) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:12667
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:12661
const char * description() const
Definition: log_event.cc:12652
bool ends_group() const override
Definition: log_event.h:3651
Incident_log_event(Incident_log_event &&) noexcept=delete
The class derives from the class Intvar_event in Binlog API, defined in the header binlog_event....
Definition: log_event.h:1601
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:5820
~Intvar_log_event() override=default
Intvar_log_event(Intvar_log_event &&) noexcept=delete
size_t get_data_size() override
Definition: log_event.h:1630
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.
Definition: log_event.cc:5899
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:5830
Intvar_log_event(const Intvar_log_event &)=delete
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:5795
bool is_sbr_logging_format() const override
Return true if the event has to be logged using SBR for DMLs.
Definition: log_event.h:1638
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:5874
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:5894
Base class that is used to represent any kind of expression in a relational query.
Definition: item.h:936
Definition: sql_list.h:467
Definition: log_event.h:2345
bool has_replace
Definition: log_event.h:2365
const size_t BUF_SIZE
Definition: log_event.h:2354
const char * table_name
Definition: log_event.h:2361
const char * fname
Definition: log_event.h:2362
const sql_exchange * sql_ex
Definition: log_event.h:2359
THD * thd
Definition: log_event.h:2358
bool has_ignore
Definition: log_event.h:2366
String str
Definition: log_event.h:2355
const char * db
Definition: log_event.h:2360
bool is_concurrent
Definition: log_event.h:2364
const String * generate(size_t *fn_start, size_t *fn_end)
Definition: log_event.cc:7573
Load_query_generator(THD *thd_arg, const sql_exchange *ex, const char *db_arg, const char *table_name_arg, bool is_concurrent_arg, bool replace, bool ignore)
Definition: log_event.cc:7556
This is the abstract base class for binary log events.
Definition: log_event.h:538
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.
Definition: log_event.cc:1254
ulong mts_group_idx
Index in rli->gaq array to indicate a group that this event is purging.
Definition: log_event.h:693
bool is_mts_sequential_exec()
Is called from get_mts_execution_mode() to.
Definition: log_event.h:909
bool is_using_stmt_cache() const
Definition: log_event.h:839
enum_skip_reason continue_group(Relay_log_info *rli)
Helper function to ignore an event w.r.t.
Definition: log_event.cc:2442
bool is_no_filter_event() const
Definition: log_event.h:833
int apply_event(Relay_log_info *rli)
Apply the event to the database.
Definition: log_event.cc:3043
virtual int do_apply_event(Relay_log_info const *rli)
Primitive to apply an event to the database.
Definition: log_event.h:1162
virtual const char * get_db()
Definition: log_event.cc:1057
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.
Definition: log_event.h:676
int net_send(Protocol *protocol, const char *log_name, my_off_t pos)
Only called by SHOW BINLOG EVENTS.
Definition: log_event.cc:1062
uint32 write_header_to_memory(uchar *buf)
Writes the common header of this event to the given memory buffer.
Definition: log_event.cc:1215
virtual mysql::binlog::event::Log_event_type get_type_code() const
Definition: log_event.h:797
virtual bool starts_group() const
Events of a certain type can start or end a group of events treated transactionally wrt binlog.
Definition: log_event.h:1094
uint32 server_id
Definition: log_event.h:664
enum_mts_event_exec_mode
Definition: log_event.h:929
@ EVENT_EXEC_PARALLEL
Definition: log_event.h:933
@ EVENT_EXEC_SYNC
Definition: log_event.h:941
@ EVENT_EXEC_CAN_NOT
Definition: log_event.h:945
@ EVENT_EXEC_ASYNC
Definition: log_event.h:937
enum_skip_reason shall_skip(Relay_log_info *rli)
Decide if the event shall be skipped, and the reason for skipping it.
Definition: log_event.h:1137
bool is_valid()
Definition: log_event.cc:1307
virtual uint8 get_mts_dbs(Mts_db_names *arg, Rpl_filter *rpl_filter)
The method fills in pointers to event's database name c-strings to a supplied array.
Definition: log_event.h:1056
ha_checksum crc
Placeholder for event checksum while writing to binlog.
Definition: log_event.h:686
virtual size_t get_data_size()
Definition: log_event.h:879
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.
Definition: log_event.cc:1193
enum_event_cache_type
Definition: log_event.h:567
@ EVENT_CACHE_COUNT
Definition: log_event.h:589
@ EVENT_INVALID_CACHE
Definition: log_event.h:568
@ EVENT_NO_CACHE
Definition: log_event.h:585
@ EVENT_STMT_CACHE
Definition: log_event.h:574
@ EVENT_TRANSACTIONAL_CACHE
Definition: log_event.h:580
enum_skip_reason
Enumeration of what kinds of skipping (and non-skipping) that can occur when the slave executes an ev...
Definition: log_event.h:547
@ EVENT_SKIP_IGNORE
Skip event by ignoring it.
Definition: log_event.h:558
@ EVENT_SKIP_COUNT
Skip event and decrease skip counter.
Definition: log_event.h:563
@ EVENT_SKIP_NOT
Don't skip event.
Definition: log_event.h:551
bool m_free_temp_buf_in_destructor
Definition: log_event.h:655
bool contains_partition_info(bool)
Definition: log_event.cc:2462
bool is_relay_log_event() const
Definition: log_event.h:827
bool is_ignorable_event() const
Definition: log_event.h:830
ulonglong future_event_relay_log_pos
A copy of the main rli value stored into event to pass to MTS worker rli.
Definition: log_event.h:716
int update_pos(Relay_log_info *rli)
Update the relay log position.
Definition: log_event.h:1129
virtual int do_apply_event_worker(Slave_worker *w)
Definition: log_event.cc:981
void set_artificial_event()
Definition: log_event.h:815
const char * get_type_str() const
Returns the human readable name of this event's type.
Definition: log_event.cc:897
time_t get_time()
Prints a "session_var=value" string.
Definition: log_event.cc:874
bool write_footer(Basic_ostream *ostream)
Definition: log_event.cc:1202
Relay_log_info * worker
MTS: associating the event with either an assigned Worker or Coordinator.
Definition: log_event.h:711
bool is_using_trans_cache() const
Definition: log_event.h:836
enum enum_mts_event_exec_mode get_mts_execution_mode(bool mts_in_group)
MTS Coordinator finds out a way how to execute the current event.
Definition: log_event.h:963
virtual enum_skip_reason do_shall_skip(Relay_log_info *rli)
Decide if this event shall be skipped or not and the reason for skipping it.
Definition: log_event.cc:1003
db_worker_hash_entry * mts_assigned_partitions[MAX_DBS_IN_EVENT_MTS]
Partition info associate with event to deliver to MTS event applier.
Definition: log_event.h:723
virtual bool write(Basic_ostream *ostream)
Definition: log_event.h:785
ulong rbr_exec_mode
A storage to cache the global system variable's value.
Definition: log_event.h:670
mysql::binlog::event::Log_event_header * common_header
The Log_event_header class contains the variable present in the common header.
Definition: log_event.h:699
virtual void set_mts_isolate_group()
Definition: log_event.h:1035
THD * thd
Definition: log_event.h:719
int apply_gtid_event(Relay_log_info *rli)
Apply the GTID event in curr_group_data to the database.
Definition: log_event.cc:2999
mysql::binlog::event::Log_event_footer * common_footer
The Log_event_footer class contains the variable present in the common footer.
Definition: log_event.h:705
virtual bool write_data_body(Basic_ostream *)
Definition: log_event.h:794
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.
Definition: log_event.cc:933
void register_temp_buf(char *buf, bool free_in_destructor=true)
Definition: log_event.h:865
virtual uint8 mts_number_dbs()
Definition: log_event.h:1073
void free_temp_buf()
Definition: log_event.h:869
bool is_mts_group_isolated()
Definition: log_event.h:1080
ulong exec_time
Definition: log_event.h:658
virtual bool is_rbr_logging_format() const
Return true if the event has to be logged using RBR for DMLs.
Definition: log_event.h:808
virtual ~Log_event()
Definition: log_event.h:864
enum_event_logging_type event_logging_type
Defines when information, i.e.
Definition: log_event.h:682
enum_event_logging_type
Definition: log_event.h:592
@ EVENT_NORMAL_LOGGING
Definition: log_event.h:598
@ EVENT_IMMEDIATE_LOGGING
Definition: log_event.h:603
@ EVENT_INVALID_LOGGING
Definition: log_event.h:593
@ EVENT_CACHE_LOGGING_COUNT
Definition: log_event.h:607
char * temp_buf
Definition: log_event.h:648
virtual bool is_sbr_logging_format() const
Return true if the event has to be logged using SBR for DMLs.
Definition: log_event.h:804
virtual int pack_info(Protocol *protocol)
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:1052
bool is_using_immediate_logging() const
Definition: log_event.h:842
void set_relay_log_event()
Definition: log_event.h:823
virtual bool write_data_header(Basic_ostream *)
Definition: log_event.h:793
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 i...
Definition: log_event.cc:1085
bool is_artificial_event() const
Definition: log_event.h:824
virtual int do_update_pos(Relay_log_info *rli)
Advance relay log coordinates.
Definition: log_event.cc:995
virtual bool ends_group() const
Definition: log_event.h:1099
bool need_checksum()
A decider of whether to trigger checksum computation or not.
Definition: log_event.cc:1114
virtual void claim_memory_ownership(bool claim)
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.h:862
Slave_worker * get_slave_worker(Relay_log_info *rli)
The method maps the event to a Worker and return a pointer to it.
Definition: log_event.cc:2590
This is the subclass of Previous_gtids_event and Log_event It is used to record the gtid_executed in ...
Definition: log_event.h:4187
bool write_data_body(Basic_ostream *ostream) override
Definition: log_event.cc:13623
Previous_gtids_log_event(Previous_gtids_log_event &&) noexcept=delete
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:13630
char * get_str(size_t *length, const Gtid_set::String_format *string_format) const
Return the formatted string, or NULL on error.
Definition: log_event.cc:13604
int pack_info(Protocol *) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:13567
int do_apply_event(Relay_log_info const *) override
Primitive to apply an event to the database.
Definition: log_event.h:4279
int add_to_set(Gtid_set *gtid_set) const
Add all GTIDs from this event to the given Gtid_set.
Definition: log_event.cc:13593
size_t get_data_size() override
Definition: log_event.h:4210
enum_skip_reason do_shall_skip(Relay_log_info *) override
Decide if this event shall be skipped or not and the reason for skipping it.
Definition: log_event.h:4274
bool write(Basic_ostream *ostream) override
Definition: log_event.h:4218
~Previous_gtids_log_event() override=default
const uchar * get_buf()
Return the encoded buffer, or NULL on error.
Definition: log_event.h:4255
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:13541
Definition: protocol.h:33
A Query event is written to the binary log whenever the database is modified on the master,...
Definition: log_event.h:1285
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:5096
bool need_sql_require_primary_key
Whether or not the statement represented by this event requires Q_SQL_REQUIRE_PRIMARY_KEY to be logge...
Definition: log_event.h:1491
bool is_sbr_logging_format() const override
When a query log event contains a non-transaction control statement, we assume that it is changing da...
Definition: log_event.h:1461
Query_log_event(const Query_log_event &)=delete
bool is_trans_keyword() const
Definition: log_event.h:1429
mysql::binlog::event::Log_event_header::Byte * data_buf
Definition: log_event.h:1287
bool m_skip_temp_tables_handling_by_worker
Instructs the applier to skip temporary tables handling.
Definition: log_event.h:1329
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...
Definition: log_event.cc:5146
Query_log_event()
The simplest constructor that could possibly work.
Definition: log_event.cc:3630
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.
Definition: log_event.cc:5110
virtual ulong get_post_header_size_for_derived()
Definition: log_event.h:1413
bool starts_group() const override
Notice, DDL queries are logged without BEGIN/COMMIT parentheses and identification of such single-que...
Definition: log_event.h:1469
uchar mts_number_dbs() override
Definition: log_event.h:1380
my_thread_id slave_proxy_id
Definition: log_event.h:1302
void set_skip_temp_tables_handling_by_worker()
Definition: log_event.h:1331
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:5199
bool has_ddl_committed
The flag indicates whether the DDL query has been (already) committed or not.
Definition: log_event.h:1322
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:4376
~Query_log_event() override
Definition: log_event.h:1398
void attach_temp_tables_worker(THD *, const Relay_log_info *)
Associating slave Worker thread to a subset of temporary tables.
Definition: log_event.cc:4353
bool write(Basic_ostream *ostream) override
Query_log_event::write().
Definition: log_event.cc:3337
bool rollback_injected_by_coord
True if this is a ROLLBACK event injected by the mts coordinator to finish a group corresponding to a...
Definition: log_event.h:1310
bool is_query_prefix_match(const char *pattern, uint p_len)
Definition: log_event.h:1485
uint8 get_mts_dbs(Mts_db_names *arg, Rpl_filter *rpl_filter) override
Definition: log_event.h:1355
bool needs_default_table_encryption
Whether or not the statement represented by this event requires Q_DEFAULT_TABLE_ENCRYPTION to be logg...
Definition: log_event.h:1495
const char * get_db() override
Definition: log_event.h:1342
int pack_info(Protocol *protocol) override
This (which is used only for SHOW BINLOG EVENTS) could be updated to print SET @session_var=.
Definition: log_event.cc:3286
bool ends_group() const override
Definition: log_event.h:1474
bool is_skip_temp_tables_handling_by_worker()
Definition: log_event.h:1335
virtual bool write_post_header_for_derived(Basic_ostream *)
Definition: log_event.h:1406
void detach_temp_tables_worker(THD *, const Relay_log_info *)
Dissociating slave Worker thread from its thd->temporary_tables to possibly update the involved entri...
Definition: log_event.cc:4367
Logs random seed used by the next RAND(), and by PASSWORD() in 4.1.0.
Definition: log_event.h:1674
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:5940
bool is_sbr_logging_format() const override
Return true if the event has to be logged using SBR for DMLs.
Definition: log_event.h:1708
~Rand_log_event() override=default
size_t get_data_size() override
Definition: log_event.h:1703
Rand_log_event(const Rand_log_event &)=delete
Rand_log_event(Rand_log_event &&) noexcept=delete
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.
Definition: log_event.cc:5985
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:5966
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:5916
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:5980
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:5934
Definition: rpl_rli.h:203
This will be deprecated when we move to using sequence ids.
Definition: log_event.h:2027
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:5628
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:5516
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.
Definition: log_event.cc:5771
~Rotate_log_event() override=default
Rotate_log_event(Rotate_log_event &&) noexcept=delete
Rotate_log_event(const Rotate_log_event &)=delete
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:5589
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:5599
size_t get_data_size() override
Definition: log_event.h:2047
Definition: log_event.h:2647
bool is_enabled()
If instrumentation is enabled this member function SHALL return true.
Definition: log_event.h:2674
Rows_applier_psi_stage & operator=(const Rows_applier_psi_stage &rhs)
void inc_n_rows_applied(ulonglong delta)
Updates the counter of processed rows.
Definition: log_event.h:2720
ulonglong m_n_rows_applied
Counter that is unconditionally incremented on each row that is processed.
Definition: log_event.h:2662
ulonglong get_n_rows_applied()
Gets the value of the counter of rows that have been processed.
Definition: log_event.h:2726
Rows_applier_psi_stage()
Definition: log_event.h:2665
void update_work_estimated_and_completed(const uchar *cursor, const uchar *begin, const uchar *end)
This member function shall update the progress and reestimate the remaining work needed.
Definition: log_event.h:2687
void set_progress(PSI_stage_progress *progress)
Definition: log_event.h:2667
void end_work()
Resets this object.
Definition: log_event.h:2711
PSI_stage_progress * m_progress
A cached pointer to this stage PSI_stage_progress.
Definition: log_event.h:2655
Definition: log_event.h:2946
KEY ** m_key_info
Definition: log_event.h:2966
Key_compare(KEY **ki=nullptr)
Definition: log_event.h:2959
bool operator()(uchar *k1, uchar *k2) const
Definition: log_event.h:2960
Common base class for all row-containing log events.
Definition: log_event.h:2764
MY_BITMAP write_set_backup
This bitmap is used as a backup for the write set while we calculate the values for any hidden genera...
Definition: log_event.h:3269
uint32 m_bitbuf[128/(sizeof(uint32) *8)]
Definition: log_event.h:2927
uchar * m_rows_end
Definition: log_event.h:2936
int close_record_scan()
Does the cleanup.
Definition: log_event.cc:8833
virtual mysql::binlog::event::Log_event_type get_general_type_code()=0
int handle_idempotent_and_ignored_errors(Relay_log_info const *rli, int *err)
Private member function called while handling idempotent errors.
Definition: log_event.cc:8778
bool write_data_header(Basic_ostream *ostream) override
Definition: log_event.cc:10362
virtual int do_before_row_operations(const Relay_log_info *const log)=0
uchar * m_rows_buf
Definition: log_event.h:2934
uint m_rows_lookup_algorithm
The algorithm to use while searching for rows using the before image.
Definition: log_event.h:2908
TABLE * m_table
Definition: log_event.h:2887
ColumnViewPtr m_column_view
Wrapper around TABLE *m_table that abstracts the table field set iteration logic, since it is not man...
Definition: log_event.h:3069
bool is_rbr_logging_format() const override
Return true if the event has to be logged using RBR for DMLs.
Definition: log_event.h:3056
int do_hash_row(Relay_log_info const *rli)
Populates the m_hash when using HASH_SCAN.
Definition: log_event.cc:9215
Hash_slave_rows m_hash
Hash table that will hold the entries for while using HASH_SCAN algorithm to search and update/delete...
Definition: log_event.h:2902
uchar * m_distinct_key_spare_buf
A spare buffer which will be used when saving the distinct keys for doing an index scan with HASH_SCA...
Definition: log_event.h:2974
int do_hash_scan_and_update(Relay_log_info const *rli)
Implementation of the hash_scan and update algorithm.
Definition: log_event.cc:9458
int add_row_data(uchar *data, size_t length)
Definition: log_event.h:2825
void decide_row_lookup_algorithm_and_key() SUPPRESS_UBSAN_CLANG10
Definition: log_event.cc:8387
uint m_key_index
Definition: log_event.h:2944
int do_apply_row(Relay_log_info const *rli)
Commodity wrapper around do_exec_row(), that deals with resetting the thd reference in the table.
Definition: log_event.cc:8808
int row_operations_scan_and_key_setup()
Definition: log_event.cc:8484
MY_BITMAP const * get_cols_ai() const
Definition: log_event.h:2834
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.
Definition: log_event.cc:10224
Rows_log_event(const Rows_log_event &)=delete
MY_BITMAP m_local_cols_ai
Bitmap denoting columns available in the after-image as they appear in the table setup.
Definition: log_event.h:2924
uchar * m_key
Definition: log_event.h:2943
int do_index_scan_and_update(Relay_log_info const *rli)
Implementation of the index scan and update algorithm.
Definition: log_event.cc:8984
int do_scan_and_update(Relay_log_info const *rli)
This member function scans the table and applies the changes that had been previously hashed.
Definition: log_event.cc:9283
virtual int do_add_row_data(uchar *data, size_t length)
Definition: log_event.cc:8120
@ RLE_NO_FLAGS
Definition: log_event.h:2800
Rows_applier_psi_stage m_psi_progress
Definition: log_event.h:2767
static bool is_trx_retryable_upon_engine_error(int error)
Helper function to check whether the storage engine error allows for the transaction to be retried or...
Definition: log_event.cc:8575
size_t get_data_size() override
Definition: log_event.cc:8087
const char * get_db() override
Definition: log_event.h:2858
uint16 flag_set
Definition: log_event.h:2777
row_lookup_mode
Definition: log_event.h:2779
@ ROW_LOOKUP_INDEX_SCAN
Definition: log_event.h:2782
@ ROW_LOOKUP_UNDEFINED
Definition: log_event.h:2780
@ ROW_LOOKUP_NOT_NEEDED
Definition: log_event.h:2781
@ ROW_LOOKUP_TABLE_SCAN
Definition: log_event.h:2783
@ ROW_LOOKUP_HASH_SCAN
Definition: log_event.h:2784
virtual bool read_write_bitmaps_cmp(const TABLE *table) const =0
Compares the table's read/write_set with the columns included in this event's before-image and/or aft...
virtual int skip_after_image_for_update_event(const Relay_log_info *rli, const uchar *curr_bi_start)
Seek past the after-image of an update event, in case a row was processed without reading the after-i...
Definition: log_event.h:3194
bool is_auto_inc_in_extra_columns(const Relay_log_info *const rli)
Helper function to check whether there is an auto increment column on the table where the event is to...
Definition: log_event.cc:8557
uchar * m_rows_cur
Definition: log_event.h:2935
const mysql::binlog::event::Table_id & get_table_id() const
Definition: log_event.h:2835
uint m_row_count
Definition: log_event.h:2861
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:9562
int next_record_scan(bool first_read)
Fetches next row.
Definition: log_event.cc:8846
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:10468
int do_table_scan_and_update(Relay_log_info const *rli)
Implementation of the legacy table_scan and update algorithm.
Definition: log_event.cc:9479
MY_BITMAP m_local_cols
Bitmap denoting columns available in the image as they appear in the table setup.
Definition: log_event.h:2896
int open_record_scan()
Initializes scanning of rows.
Definition: log_event.cc:8908
void clear_flags(flag_set flags_arg)
Definition: log_event.h:2805
virtual int do_exec_row(const Relay_log_info *const rli)=0
std::set< uchar *, Key_compare >::iterator m_itr
Definition: log_event.h:2969
enum_error
Enumeration of the errors that can be returned.
Definition: log_event.h:2790
@ ERR_TABLE_LIMIT_EXCEEDED
No more room for tables.
Definition: log_event.h:2793
@ ERR_BAD_TABLE_DEF
Table definition does not match.
Definition: log_event.h:2795
@ ERR_OPEN_FAILURE
Failure to open table.
Definition: log_event.h:2791
@ ERR_RBR_TO_SBR
daisy-chanining RBR to SBR not allowed
Definition: log_event.h:2796
@ ERR_OUT_OF_MEM
Out of memory.
Definition: log_event.h:2794
@ ERR_OK
No error.
Definition: log_event.h:2792
int row_operations_scan_and_key_teardown(int error)
Definition: log_event.cc:8527
int update_generated_columns(MY_BITMAP const &fields_to_update)
Updates the generated columns of the TABLE object referenced by m_table, that have an active bit in t...
Definition: log_event.cc:8064
virtual int do_after_row_operations(const Relay_log_info *const log, int error)=0
MY_BITMAP const * get_cols() const
Definition: log_event.h:2833
std::set< uchar *, Key_compare > m_distinct_keys
Definition: log_event.h:2968
void do_post_row_operations(Relay_log_info const *rli, int err)
Private member function called after updating/deleting a row.
Definition: log_event.cc:8690
Rows_log_event(Rows_log_event &&) noexcept=delete
const uchar * m_curr_row
Definition: log_event.h:2941
MY_BITMAP m_cols_ai
Bitmap for columns available in the after image, if present.
Definition: log_event.h:2917
int add_key_to_distinct_keyset()
Populates the m_distinct_keys with unique keys to be modified during HASH_SCAN over keys.
Definition: log_event.cc:8964
KEY * m_key_info
Definition: log_event.h:2945
int unpack_current_row(const Relay_log_info *const rli, MY_BITMAP const *cols, bool is_after_image, bool only_seek=false)
Unpack the current row image from the event into m_table->record[0].
Definition: log_event.cc:7971
int do_update_pos(Relay_log_info *rli) override
The method either increments the relay log position or commits the current statement and increments t...
Definition: log_event.cc:10330
~Rows_log_event() override
Definition: log_event.cc:7951
void set_flags(flag_set flags_arg)
Definition: log_event.h:2804
friend class Old_rows_log_event
Definition: log_event.h:3261
const uchar * m_curr_row_end
Definition: log_event.h:2942
bool write_data_body(Basic_ostream *ostream) override
Definition: log_event.cc:10435
uint32 m_bitbuf_ai[128/(sizeof(uint32) *8)]
Definition: log_event.h:2928
MY_BITMAP m_cols
Definition: log_event.h:2889
It is used to record the original query for the rows events in RBR.
Definition: log_event.h:3756
size_t get_data_size() override
Definition: log_event.h:3792
~Rows_query_log_event() override
Definition: log_event.h:3785
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:12878
bool write_data_body(Basic_ostream *ostream) override
Definition: log_event.cc:12868
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:12819
int pack_info(Protocol *) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:12826
Rows_query_log_event(THD *thd_arg, const char *query, size_t query_len)
Definition: log_event.h:3759
Rpl_filter.
Definition: rpl_filter.h:214
const char * get_rewrite_db(const char *db, size_t *new_len)
Definition: rpl_filter.cc:1176
bool is_rewrite_empty()
Definition: rpl_filter.cc:571
Mix-in to handle the message logging and reporting for relay log info and master log info structures.
Definition: rpl_reporting.h:54
Definition: rpl_rli_pdb.h:498
Definition: log_event.h:1951
mysql::binlog::event::Log_event_type get_type_code() const override
Definition: log_event.h:1980
Stop_log_event()
Definition: log_event.h:1960
~Stop_log_event() override=default
Stop_log_event(const Stop_log_event &)=delete
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:6930
enum_skip_reason do_shall_skip(Relay_log_info *) override
Decide if this event shall be skipped or not and the reason for skipping it.
Definition: log_event.h:1989
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:6950
String class wrapper with a preallocated buffer of size buff_sz.
Definition: sql_string.h:681
Using this class is fraught with peril, and you need to be very careful when doing so.
Definition: sql_string.h:167
For each client connection we create a separate thread with THD serving as a thread/connection descri...
Definition: sql_lexer_thd.h:36
Table_map_log_event which maps a table definition to a number.
Definition: log_event.h:2429
@ TM_GENERATED_INVISIBLE_PK_F
Table has generated invisible primary key.
Definition: log_event.h:2472
@ TM_BIT_LEN_EXACT_F
Definition: log_event.h:2465
@ TM_NO_FLAGS
Definition: log_event.h:2464
@ TM_REFERRED_FK_DB_F
Definition: log_event.h:2466
Table_map_log_event(Table_map_log_event &&) noexcept=delete
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.
Definition: log_event.cc:10986
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:10859
@ TYPE_CODE
Definition: log_event.h:2438
Table_map_log_event(const Table_map_log_event &)=delete
uint8 mts_number_dbs() override
Definition: log_event.h:2512
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:10995
const char * get_db_name() const
Definition: log_event.h:2504
virtual int save_field_metadata()
Save the field metadata based on the real_type of the field.
Definition: log_event.cc:10556
bool init_set_str_value_field()
Definition: log_event.cc:11302
flag_set get_flags(flag_set flag) const
Definition: log_event.h:2475
~Table_map_log_event() override
bool init_geometry_type_field()
Definition: log_event.cc:11350
bool init_charset_field(std::function< bool(const Field *)> include_type, Optional_metadata_field_type default_charset_type, Optional_metadata_field_type column_charset_type)
Capture and serialize character sets.
Definition: log_event.cc:11196
bool init_primary_key_field()
Definition: log_event.cc:11367
enum_flag
Definition: log_event.h:2452
@ ENUM_FLAG_COUNT
Nothing here right now, but the flags support is there in preparation for changes that are coming.
Definition: log_event.h:2459
bool is_rbr_logging_format() const override
Return true if the event has to be logged using RBR for DMLs.
Definition: log_event.h:2574
const mysql::binlog::event::Table_id & get_table_id() const
Definition: log_event.h:2500
bool init_column_visibility_field()
Definition: log_event.cc:11415
const char * get_table_name() const
Definition: log_event.h:2503
uint8 get_mts_dbs(Mts_db_names *arg, Rpl_filter *rpl_filter) override
Definition: log_event.h:2524
bool write_data_header(Basic_ostream *ostream) override
Definition: log_event.cc:11000
bool write_data_body(Basic_ostream *ostream) override
Definition: log_event.cc:11014
bool init_enum_str_value_field()
Definition: log_event.cc:11329
bool init_column_name_field()
Definition: log_event.cc:11290
ColumnViewPtr m_column_view
Wrapper around TABLE *m_table that abstracts the table field set iteration logic, since it is not man...
Definition: log_event.h:2598
const char * get_db() override
Definition: log_event.h:2511
size_t get_data_size() override
Definition: log_event.h:2506
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:11447
TABLE * m_table
Definition: log_event.h:2584
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:10740
void init_metadata_fields()
Capture the optional metadata fields which should be logged into table_map_log_event and serialize th...
Definition: log_event.cc:11142
enum_error
Enumeration of the errors that can be returned.
Definition: log_event.h:2443
@ ERR_OK
No error.
Definition: log_event.h:2445
@ ERR_TABLE_LIMIT_EXCEEDED
No more room for tables.
Definition: log_event.h:2446
@ ERR_OPEN_FAILURE
Failure to open table.
Definition: log_event.h:2444
@ ERR_OUT_OF_MEM
Out of memory.
Definition: log_event.h:2447
@ ERR_BAD_TABLE_DEF
Table definition does not match.
Definition: log_event.h:2448
@ ERR_RBR_TO_SBR
daisy-chanining RBR to SBR not allowed
Definition: log_event.h:2449
bool has_generated_invisible_primary_key() const
Definition: log_event.cc:10736
StringBuffer< 1024 > m_metadata_buf
Definition: log_event.h:2587
bool init_signedness_field()
Definition: log_event.cc:11165
This is the subclass of Transaction_context_event and Log_event This class encodes the transaction_co...
Definition: log_event.h:4309
static int get_data_set_size(std::list< const char * > *set)
Definition: log_event.cc:13865
void add_write_set(const char *hash)
Add a hash which identifies a inserted/updated/deleted row on the ongoing transaction.
Definition: log_event.cc:13877
my_thread_id get_thread_id() const
Return the id of the committing thread.
Definition: log_event.h:4413
Transaction_context_log_event(const char *server_uuid_arg, bool using_trans, my_thread_id thread_id_arg, bool is_gtid_specified)
Definition: log_event.cc:13639
void add_read_set(const char *hash)
Add a hash which identifies a read row on the ongoing transaction.
Definition: log_event.cc:13882
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:13757
Gtid_set * get_snapshot_version()
Return the transaction snapshot timestamp.
Definition: log_event.h:4403
size_t get_data_size() override
Definition: log_event.cc:13764
int do_apply_event(Relay_log_info const *) override
Primitive to apply an event to the database.
Definition: log_event.h:4363
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:13732
bool read_snapshot_version()
Read snapshot version from encoded buffers.
Definition: log_event.cc:13845
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:13724
Gtid_set * snapshot_version
A gtid_set which is used to store the transaction set used for conflict detection.
Definition: log_event.h:4315
size_t get_event_length()
Definition: log_event.cc:13776
Tsid_map * tsid_map
The Tsid_map to use for creating the Gtid_set.
Definition: log_event.h:4312
std::list< const char * > * get_read_set()
Return a pointer to read-set list.
Definition: log_event.h:4390
size_t get_snapshot_version_size()
Definition: log_event.cc:13859
bool write_data_header(Basic_ostream *ostream) override
Definition: log_event.cc:13781
bool is_gtid_specified() const
Return true if transaction has GTID fully specified, false otherwise.
Definition: log_event.h:4420
~Transaction_context_log_event() override
Definition: log_event.cc:13707
bool write_data_set(Basic_ostream *ostream, std::list< const char * > *set)
Definition: log_event.cc:13825
std::list< const char * > * get_write_set()
Return a pointer to write-set list.
Definition: log_event.h:4378
bool write_data_body(Basic_ostream *ostream) override
Definition: log_event.cc:13797
size_t to_string(char *buf, ulong len) const
Definition: log_event.cc:13718
const char * get_server_uuid()
Return the server uuid.
Definition: log_event.h:4408
bool write_snapshot_version(Basic_ostream *ostream)
Definition: log_event.cc:13809
Definition: log_event.h:3850
Mts_db_names & get_mts_db_names()
Definition: log_event.h:3859
Mts_db_names m_mts_db_names
Definition: log_event.h:3853
void reset()
Definition: log_event.h:3858
virtual ~Applier_context()
Definition: log_event.h:3857
Applier_context()=default
Definition: log_event.h:3846
size_t get_event_length()
Definition: log_event.h:3894
void set_mts_dbs(Mts_db_names &arg)
Definition: log_event.cc:14130
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:14109
uint8 get_mts_dbs(Mts_db_names *arg, Rpl_filter *rpl_filter) override
The method fills in pointers to event's database name c-strings to a supplied array.
Definition: log_event.cc:14115
bool apply_payload_event(Relay_log_info const *rli, const uchar *event_buf)
Definition: log_event.cc:14201
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.
Definition: log_event.cc:14287
bool ends_group() const override
Definition: log_event.cc:14334
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:14292
~Transaction_payload_log_event() override=default
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:14324
size_t get_data_size() override
Definition: log_event.cc:14101
Transaction_payload_log_event(THD *thd_arg, const char *payload, uint64_t payload_size, uint16_t compression_type, uint64_t uncompressed_size)
Definition: log_event.h:3862
Applier_context m_applier_ctx
Definition: log_event.h:3899
uint8 mts_number_dbs() override
Definition: log_event.cc:14146
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:14150
Represents a bidirectional map between TSID and SIDNO.
Definition: rpl_gtid.h:749
rpl_sidno add_tsid(const Tsid &tsid)
Add the given TSID to this map if it does not already exist.
Definition: rpl_gtid_tsid_map.cc:61
Log row updates with a before image.
Definition: log_event.h:3398
int do_exec_row(const Relay_log_info *const) override
Definition: log_event.cc:12590
static mysql::binlog::event::Log_event_type get_update_rows_event_type(const THD *thd_arg)
Auxiliary function used in the (THD*, ...) constructor to determine the type code based on configurat...
Definition: log_event.cc:12477
static bool binlog_row_logging_function(THD *thd, TABLE *table, bool is_transactional, const uchar *before_record, const uchar *after_record)
Definition: log_event.cc:12505
bool read_write_bitmaps_cmp(const TABLE *table) const override
Compares the table's read/write_set with the columns included in this event's before-image and/or aft...
Definition: log_event.h:3431
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:12550
int do_after_row_operations(const Relay_log_info *const, int) override
Definition: log_event.cc:12583
@ TYPE_CODE
Definition: log_event.h:3402
Update_rows_log_event(THD *, TABLE *, const mysql::binlog::event::Table_id &table_id, MY_BITMAP const *cols_bi, MY_BITMAP const *cols_ai, bool is_transactional, const unsigned char *extra_row_ndb_info)
int do_before_row_operations(const Relay_log_info *const) override
Definition: log_event.cc:12557
mysql::binlog::event::Log_event_type get_general_type_code() override
Definition: log_event.h:3440
~Update_rows_log_event() override
Definition: log_event.cc:12528
int skip_after_image_for_update_event(const Relay_log_info *rli, const uchar *curr_bi_start) override
Seek past the after-image of an update event, in case a row was processed without reading the after-i...
Definition: log_event.cc:9157
void init(MY_BITMAP const *cols)
Definition: log_event.cc:12512
Every time a query uses the value of a user variable, a User_var_log_event is written before the Quer...
Definition: log_event.h:1882
~User_var_log_event() override=default
bool is_sbr_logging_format() const override
Return true if the event has to be logged using SBR for DMLs.
Definition: log_event.h:1936
bool is_deferred()
Definition: log_event.h:1925
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:6878
query_id_t query_id
Definition: log_event.h:1892
void set_deferred(query_id_t qid)
Definition: log_event.h:1930
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:6499
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:6768
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:6897
User_var_log_event(const User_var_log_event &)=delete
User_var_log_event(User_var_log_event &&) noexcept=delete
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.
Definition: log_event.cc:6883
bool deferred
Definition: log_event.h:1891
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:6597
This is the subclass of View_change_log_event and Log_event This class created the view_change_log_ev...
Definition: log_event.h:4449
std::map< std::string, std::string > * get_certification_info()
Returns the certification info.
Definition: log_event.h:4517
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:14022
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:13949
bool write_data_body(Basic_ostream *ostream) override
Definition: log_event.cc:14039
void set_seq_number(rpl_gno number)
Set the certification sequence number.
Definition: log_event.h:4526
char * get_view_id()
Returns the view id.
Definition: log_event.h:4499
size_t get_size_data_map(std::map< std::string, std::string > *map)
Definition: log_event.cc:13930
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:13955
size_t get_data_size() override
Definition: log_event.cc:13921
bool write_data_header(Basic_ostream *ostream) override
Definition: log_event.cc:14028
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:13981
rpl_gno get_seq_number()
Returns the certification sequence number.
Definition: log_event.h:4531
bool write_data_map(Basic_ostream *ostream, std::map< std::string, std::string > *map)
Definition: log_event.cc:14047
void set_certification_info(std::map< std::string, std::string > *info, size_t *event_size)
Sets the certification info in the event.
Definition: log_event.cc:14083
View_change_log_event(const View_change_log_event &)=delete
size_t to_string(char *buf, ulong len) const
Definition: log_event.cc:13944
Log row insertions and updates.
Definition: log_event.h:3309
int do_before_row_operations(const Relay_log_info *const) override
Definition: log_event.cc:11920
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:12367
mysql::binlog::event::Log_event_type get_general_type_code() override
Definition: log_event.h:3342
Write_rows_log_event(THD *, TABLE *, const mysql::binlog::event::Table_id &table_id, bool is_transactional, const unsigned char *extra_row_ndb_info)
Definition: log_event.cc:11890
bool read_write_bitmaps_cmp(const TABLE *table) const override
Compares the table's read/write_set with the columns included in this event's before-image and/or aft...
Definition: log_event.h:3331
int do_exec_row(const Relay_log_info *const) override
Definition: log_event.cc:12344
int write_row(const Relay_log_info *const, const bool)
Write the current row into event's table.
Definition: log_event.cc:12109
@ TYPE_CODE
Definition: log_event.h:3313
int do_after_row_operations(const Relay_log_info *const, int) override
Definition: log_event.cc:12028
static bool binlog_row_logging_function(THD *thd, TABLE *table, bool is_transactional, const uchar *before_record, const uchar *after_record)
Definition: log_event.cc:11900
Similar to Xid_log_event except that.
Definition: log_event.h:1821
static const int xid_bufs_size
Definition: log_event.h:1824
bool do_commit(THD *thd) override
Differs from Xid_log_event::do_commit in that it carries out XA prepare (not the commit).
Definition: log_event.cc:6455
XA_prepare_log_event(THD *thd_arg, XID *xid_arg, bool one_phase_arg=false)
Definition: log_event.h:1828
size_t get_data_size() override
Definition: log_event.h:1844
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:6393
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:6421
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:6379
mysql::binlog::event::Log_event_type get_type_code() const override
Definition: log_event.h:1841
Definition: log_event.h:1747
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.
Definition: log_event.cc:6365
bool ends_group() const override
Definition: log_event.h:1760
Xid_apply_log_event(THD *thd_arg, mysql::binlog::event::Log_event_header *header_arg, mysql::binlog::event::Log_event_footer *footer_arg)
Definition: log_event.h:1750
virtual bool do_commit(THD *thd_arg)=0
int do_apply_event_worker(Slave_worker *rli) override
Worker commits Xid transaction and in case of its transactional info table marks the current group as...
Definition: log_event.cc:6120
~Xid_apply_log_event() override=default
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:6193
This is the subclass of Xid_event defined in libbinlogevent, An XID event is generated for a commit o...
Definition: log_event.h:1770
~Xid_log_event() override=default
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:6046
Xid_log_event(const Xid_log_event &)=delete
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:6023
size_t get_data_size() override
Definition: log_event.h:1796
bool do_commit(THD *thd_arg) override
The methods combines few commit actions to make it usable as in the single- so multi- threaded case.
Definition: log_event.cc:6079
void claim_memory_ownership(bool claim) override
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
Definition: log_event.cc:6040
Xid_log_event(Xid_log_event &&) noexcept=delete
A (partial) implementation of std::deque allocating its blocks on a MEM_ROOT.
Definition: mem_root_deque.h:111
This event is created to contain the file data.
Definition: load_data_events.h:274
const char * db
'db' is filled when the event is created in mysql_load() (the event needs to have a 'db' member to be...
Definition: load_data_events.h:311
unsigned int block_len
Definition: load_data_events.h:298
Event for the first block of file to be loaded, its only difference from Append_block event is that t...
Definition: load_data_events.h:358
@ APPEND_BLOCK_HEADER_LEN
Definition: binlog_event.h:882
@ IGNORABLE_HEADER_LEN
Definition: binlog_event.h:896
@ FORMAT_DESCRIPTION_HEADER_LEN
Definition: binlog_event.h:886
@ INCIDENT_HEADER_LEN
Definition: binlog_event.h:894
@ DELETE_FILE_HEADER_LEN
Definition: binlog_event.h:883
@ ROTATE_HEADER_LEN
Definition: binlog_event.h:880
const Log_event_header * header() const
Return a const pointer to the header of the log event.
Definition: binlog_event.h:959
Binary_log_event & operator=(const Binary_log_event &)=default
const Log_event_footer * footer() const
Return a const pointer to the footer of the log event.
Definition: binlog_event.h:967
DELETE_FILE_EVENT occurs when the LOAD DATA failed on the master.
Definition: load_data_events.h:202
const char * db
Definition: load_data_events.h:215
Log row deletions.
Definition: rows_event.h:1134
Event responsible for LOAD DATA execution, it similar to Query_event but before executing the query i...
Definition: load_data_events.h:119
GTID stands for Global Transaction IDentifier It is composed of two parts:
Definition: control_events.h:1016
int get_server_version_length() const
We only store the immediate_server_version if both server versions are the same.
Definition: control_events.h:1236
int get_commit_timestamp_length() const
Definition: control_events.h:1226
int get_commit_group_ticket_length() const
Returns the length of the packed commit_group_ticket field.
Definition: control_events.cpp:620
bool is_tagged() const
Checks whether this Gtid log event contains a tag.
Definition: control_events.cpp:650
unsigned long long get_trx_length() const
Definition: control_events.h:1315
static const int POST_HEADER_LENGTH
Total length of post header.
Definition: control_events.h:1254
Replication event to ensure to replica that source is alive.
Definition: control_events.h:1669
Replication event to ensure to replica that source is alive.
Definition: control_events.h:1743
Base class for ignorable log events.
Definition: control_events.h:674
Class representing an incident, an occurrence out of the ordinary, that happened on the master.
Definition: control_events.h:440
char * message
Definition: control_events.h:491
Incident_event(enum_incident incident_arg)
This will create an Incident_event with an empty message and set the type_code as INCIDENT_EVENT in t...
Definition: control_events.h:461
size_t message_length
Definition: control_events.h:492
enum_incident
Enumeration of the incidents that can occur for the server.
Definition: control_events.h:445
@ INCIDENT_NONE
No incident.
Definition: control_events.h:447
@ INCIDENT_COUNT
Shall be last event of the enumeration.
Definition: control_events.h:451
An Intvar_event will be created just before a Query_event, if the query uses one of the variables LAS...
Definition: statement_events.h:921
Intvar_event(const char *buf, const Format_description_event *fde)
Constructor receives a packet from the MySQL master or the binary log and decodes it to create an Int...
Definition: statement_events.cpp:483
Definition: control_events.h:1380
size_t buf_size
Definition: control_events.h:1408
const unsigned char * buf
Definition: control_events.h:1409
A Query_event is created for each query that modifies the database, unless the query is logged row-ba...
Definition: statement_events.h:451
const char * db
Definition: statement_events.h:535
const char * query
Definition: statement_events.h:534
unsigned char mts_accessed_dbs
Definition: statement_events.h:640
char mts_accessed_db_names[MAX_DBS_IN_EVENT_MTS][NAME_LEN]
Definition: statement_events.h:641
size_t q_len
Definition: statement_events.h:587
Logs random seed used by the next RAND(), and by PASSWORD() in 4.1.0.
Definition: statement_events.h:1033
Rand_event(unsigned long long seed1_arg, unsigned long long seed2_arg)
Definition: statement_events.h:1043
When a binary log file exceeds a size limit, a ROTATE_EVENT is written at the end of the file that po...
Definition: control_events.h:116
unsigned int flags
Definition: control_events.h:120
size_t ident_len
Definition: control_events.h:119
Common base class for all row-containing binary log events.
Definition: rows_event.h:880
Table_id m_table_id
Actual event type.
Definition: rows_event.h:952
enum_flag get_flags() const
Definition: rows_event.h:1032
uint16_t m_flags
Definition: rows_event.h:953
Rows query event type, which is a subclass of the Ignorable_event, to record the original query for t...
Definition: rows_event.h:1170
char * m_rows_query
Definition: rows_event.h:1198
A stop event is written to the log files under these circumstances:
Definition: control_events.h:379
Stop_event()
It is the minimal constructor, and all it will do is set the type_code as STOP_EVENT in the header ob...
Definition: control_events.h:385
Each table share has a table id, it is mainly used for row based replication.
Definition: table_id.h:42
In row-based mode, every row operation event is preceded by a Table_map_event which maps a table defi...
Definition: rows_event.h:525
unsigned char * m_coltype
Definition: rows_event.h:684
std::string m_tblnam
Definition: rows_event.h:681
uint16_t flag_set
Definition: rows_event.h:534
unsigned char * m_null_bits
field metadata
Definition: rows_event.h:691
Optional_metadata_field_type
DEFAULT_CHARSET and COLUMN_CHARSET don't appear together, and ENUM_AND_SET_DEFAULT_CHARSET and ENUM_A...
Definition: rows_event.h:548
unsigned long m_colcnt
Definition: rows_event.h:683
unsigned char * m_field_metadata
Definition: rows_event.h:690
unsigned long m_field_metadata_size
The size of field metadata buffer set by calling save_field_metadata()
Definition: rows_event.h:689
size_t m_data_size
Definition: rows_event.h:676
std::string m_dbnam
event data size
Definition: rows_event.h:679
flag_set m_flags
Definition: rows_event.h:674
Table_id m_table_id
Event post header contents.
Definition: rows_event.h:673
This class is used to combine the information of the ongoing transaction including the write set and ...
Definition: control_events.h:1468
bool gtid_specified
Definition: control_events.h:1504
uint32_t thread_id
Definition: control_events.h:1503
std::list< const char * > read_set
Definition: control_events.h:1508
const char * server_uuid
Definition: control_events.h:1502
std::list< const char * > write_set
Definition: control_events.h:1507
Event that encloses all the events of a transaction.
Definition: control_events.h:735
Transaction_payload_event(const Transaction_payload_event &)=delete
An unknown event should never occur.
Definition: binlog_event.h:997
Log row updates with a before image.
Definition: rows_event.h:1115
Written every time a statement uses a user variable; precedes other events for the statement.
Definition: statement_events.h:804
const char * name
Definition: statement_events.h:853
User_var_event(const char *name_arg, unsigned int name_len_arg, char *val_arg, unsigned long val_len_arg, Value_type type_arg, unsigned int charset_number_arg, unsigned char flags_arg)
This constructor will initialize the instance variables and the type_code, it will be used only by th...
Definition: statement_events.h:820
This class is used to add view change markers in the binary log when a member of the group enters or ...
Definition: control_events.h:1568
long long int seq_number
Definition: control_events.h:1622
std::map< std::string, std::string > certification_info
Definition: control_events.h:1624
char view_id[ENCODED_VIEW_ID_MAX_LEN]
Definition: control_events.h:1620
Log row insertions.
Definition: rows_event.h:1097
An XA_prepare event is generated for a XA prepared transaction.
Definition: control_events.h:588
XA_prepare_event(void *xid_arg, bool oph_arg)
The minimal constructor of XA_prepare_event, it initializes the instance variable xid and set the typ...
Definition: control_events.h:617
void * xid
Definition: control_events.h:608
An XID event is generated for a commit of a transaction that modifies one or more tables of an XA-cap...
Definition: control_events.h:523
Xid_event(uint64_t xid_arg)
The minimal constructor of Xid_event, it initializes the instance variable xid and set the type_code ...
Definition: control_events.h:530
uint64_t xid
Definition: control_events.h:540
Represents Transaction Source Identifier which is composed of source UUID and transaction tag.
Definition: tsid.h:47
static std::size_t get_size(const T &arg)
Definition: serializer_impl.hpp:70
Definition: partition_info.h:209
Used to hold information about file and file structure in exchange via non-DB file (....
Definition: sql_exchange.h:79
A table definition from the master.
Definition: rpl_utility.h:248
Maps table id's (integers) to table pointers.
Definition: rpl_tblmap.h:51
static char buf[MAX_BUF]
Definition: conf_to_src.cc:73
Contains the classes representing events operating in the replication stream properties.
#define U
Definition: ctype-tis620.cc:74
uint64_t sql_mode_t
Definition: dd_event.h:39
#define MAX_DBS_IN_EVENT_MTS
The maximum number of updated databases that a status of Query-log-event can carry.
Definition: binlog_event.h:117
#define MAX_TIME_ZONE_NAME_LENGTH
Maximum length of time zone name that we support (Time zone name is char(64) in db).
Definition: binlog_event.h:130
#define OVER_MAX_DBS_IN_EVENT_MTS
When the actual number of databases exceeds MAX_DBS_IN_EVENT_MTS the value of OVER_MAX_DBS_IN_EVENT_M...
Definition: binlog_event.h:124
void close_cached_file(IO_CACHE *cache)
Definition: mf_cache.cc:87
bool my_b_inited(const IO_CACHE *info)
Definition: my_sys.h:495
#define MY_WME
Definition: my_sys.h:128
int my_b_copy_to_file(IO_CACHE *cache, FILE *file)
Definition: mf_iocache2.cc:72
bool reinit_io_cache(IO_CACHE *info, enum cache_type type, my_off_t seek_offset, bool use_async_io, bool clear_cache)
Definition: mf_iocache.cc:328
@ WRITE_CACHE
Definition: my_sys.h:290
std::pair< bool, mysql::binlog::event::Log_event_basic_info > extract_log_event_basic_info(Log_event *log_event)
Extract basic info about an event: type, query, is it ignorable.
Definition: log_event.cc:14447
size_t my_strmov_quoted_identifier(THD *thd, char *buffer, const char *identifier, size_t length)
Definition: log_event.cc:14407
bool is_atomic_ddl_event(Log_event const *evt)
The function checks the argument event properties to deduce whether it represents an atomic DDL.
Definition: log_event.h:4562
char * str_to_hex(char *to, const char *from, size_t len)
Transforms a string into "" or its expression in 0x... form.
Definition: log_event.cc:800
bool binary_event_serialize(EVENT *ev, Basic_ostream *ostream)
Serialize an binary event to the given output stream.
Definition: log_event.h:4598
bool net_field_length_checked(const uchar **packet, size_t *max_length, T *out)
Read an integer in net_field_length format, guarding against read out of bounds and advancing the pos...
Definition: log_event.cc:760
TYPELIB binlog_checksum_typelib
Definition: log_event.cc:220
bool is_atomic_ddl(THD *thd, bool using_trans)
The function lists all DDL instances that are supported for crash-recovery (WL9175).
Definition: log_event.cc:3703
int ignored_error_code(int err_code)
Ignore error code specified on command line.
Definition: log_event.cc:606
MYSQL_PLUGIN_IMPORT char server_version[SERVER_VERSION_LENGTH]
Definition: log_event.h:125
std::unique_ptr< cs::util::ReplicatedColumnsView > ColumnViewPtr
Definition: log_event.h:121
bool is_any_gtid_event(const Log_event *evt)
Definition: log_event.h:4534
size_t my_strmov_quoted_identifier_helper(int q, char *buffer, const char *identifier, size_t length)
Definition: log_event.cc:14420
bool is_session_control_event(Log_event *evt)
Check if the given event is a session control event, one of User_var_event, Intvar_event or Rand_even...
Definition: log_event.h:4548
PSI_memory_key key_memory_Rows_query_log_event_rows_query
Definition: log_event.cc:195
const int64 SEQ_MAX_TIMESTAMP
Maximum value of binlog logical timestamp.
Definition: log_event.h:355
MYSQL_PLUGIN_IMPORT ulong server_id
Definition: log_event.h:118
static bool copy_event_cache_to_file_and_reinit(IO_CACHE *cache, FILE *file, bool flush_stream)
Definition: log_event.h:3798
PSI_memory_key key_memory_Incident_log_event_message
Definition: log_event.cc:194
bool slave_execute_deferred_events(THD *thd)
The function is called by slave applier in case there are active table filtering rules to force gathe...
Definition: log_event.cc:6005
int append_query_string(const THD *thd, const CHARSET_INFO *csinfo, String const *from, String *to)
Append a version of the 'from' string suitable for use in a query to the 'to' string.
Definition: log_event.cc:818
int get_rpl_part_id(partition_info *part_info)
This method is used to extract the partition_id from a partitioned table.
Definition: log_event.cc:7726
unsigned int PSI_memory_key
Instrumented memory key.
Definition: psi_memory_bits.h:49
#define mysql_stage_set_work_completed(P1, P2)
Definition: mysql_stage.h:115
#define mysql_stage_get_work_estimated(P1)
Definition: mysql_stage.h:143
#define mysql_stage_set_work_estimated(P1, P2)
Definition: mysql_stage.h:140
static int flag
Definition: hp_test1.cc:40
int key_cmp2(KEY_PART_INFO *key_part, const uchar *key1, uint key1_length, const uchar *key2, uint key2_length)
Compare two given keys.
Definition: key.cc:505
#define free(A)
Definition: lexyy.cc:915
LOAD DATA INFILE is not written to the binary log like other statements.
static int native_strncasecmp(const char *s1, const char *s2, size_t n)
Definition: m_string.h:216
static bool bitmap_cmp(const MY_BITMAP *map1, const MY_BITMAP *map2)
Quite unlike other C comparison functions ending with 'cmp', e.g.
Definition: my_bitmap.h:108
Abstraction functions over zlib/intrinsics.
std::uint32_t ha_checksum
Definition: my_checksum.h:106
Header for compiler-dependent features.
#define SUPPRESS_UBSAN_CLANG10
Definition: my_compiler.h:129
#define DBUG_EXECUTE_IF(keyword, a1)
Definition: my_dbug.h:171
#define DBUG_PRINT(keyword, arglist)
Definition: my_dbug.h:181
#define DBUG_EVALUATE_IF(keyword, a1, a2)
Definition: my_dbug.h:179
#define DBUG_TRACE
Definition: my_dbug.h:146
Some integer typedefs for easier portability.
unsigned long long int ulonglong
Definition: my_inttypes.h:56
uint8_t uint8
Definition: my_inttypes.h:63
ulonglong my_off_t
Definition: my_inttypes.h:72
unsigned char uchar
Definition: my_inttypes.h:52
int64_t int64
Definition: my_inttypes.h:68
#define MYF(v)
Definition: my_inttypes.h:97
uint16_t uint16
Definition: my_inttypes.h:65
uint32_t uint32
Definition: my_inttypes.h:67
#define FN_REFLEN
Definition: my_io.h:83
void * my_malloc(PSI_memory_key key, size_t size, int flags)
Allocates size bytes of memory.
Definition: my_memory.cc:57
void my_free(void *ptr)
Frees the memory pointed by the ptr.
Definition: my_memory.cc:81
Defines various enable/disable and HAVE_ macros related to the performance schema instrumentation sys...
Functions related to handling of plugins and other dynamically loaded libraries.
#define MYSQL_PLUGIN_IMPORT
Definition: my_sharedlib.h:71
Common header for many mysys elements.
static my_thread_id thread_id
Definition: my_thr_init.cc:63
uint32 my_thread_id
Definition: my_thread_local.h:34
static char * query
Definition: myisam_ftdump.cc:47
Common definition between mysql server & client.
unsigned int net_length_size(unsigned long long num)
#define SERVER_VERSION_LENGTH
Definition: mysql_com.h:74
Instrumentation helpers for stages.
static void print_header(MYSQL_RES *result)
Definition: mysqladmin.cc:1280
static uint verbose
Definition: mysqlcheck.cc:66
static bool replace
Definition: mysqlimport.cc:70
static bool ignore
Definition: mysqlimport.cc:70
static const char * sql_mode
Definition: mysqlslap.cc:199
const char * delimiter
Definition: mysqlslap.cc:160
static PFS_engine_table_share_proxy table
Definition: pfs.cc:61
Definition: buf0block_hint.cc:30
const std::string charset("charset")
const std::string FILE("FILE")
bool length(const dd::Spatial_reference_system *srs, const Geometry *g1, double *length, bool *null) noexcept
Computes the length of linestrings and multilinestrings.
Definition: length.cc:76
bool is_valid(const dd::Spatial_reference_system *srs, const Geometry *g, const char *func_name, bool *is_valid) noexcept
Decides if a geometry is valid.
Definition: is_valid.cc:95
static Value err()
Create a Value object that represents an error condition.
Definition: json_binary.cc:927
void print(trx_t *trx, dict_index_t *index, std::ostream &out, ref_t ref, bool fatal)
Print information about the given LOB.
Definition: lob0impl.cc:1331
The namespace contains classes representing events that can occur in a replication stream.
Definition: binlog_event.cpp:36
Log_event_type
Enumeration type for the different types of log events.
Definition: binlog_event.h:286
@ INCIDENT_EVENT
Something out of the ordinary happened on the master.
Definition: binlog_event.h:330
@ FORMAT_DESCRIPTION_EVENT
Definition: binlog_event.h:312
@ EXECUTE_LOAD_QUERY_EVENT
Definition: binlog_event.h:315
@ ROWS_QUERY_LOG_EVENT
Definition: binlog_event.h:345
@ WRITE_ROWS_EVENT
Version 2 of the Row events.
Definition: binlog_event.h:348
@ DELETE_ROWS_EVENT
Definition: binlog_event.h:350
@ XA_PREPARE_LOG_EVENT
Definition: binlog_event.h:362
@ QUERY_EVENT
Definition: binlog_event.h:300
@ UNKNOWN_EVENT
Every time you add a type, you have to.
Definition: binlog_event.h:294
@ PREVIOUS_GTIDS_LOG_EVENT
Definition: binlog_event.h:355
@ UPDATE_ROWS_EVENT
Definition: binlog_event.h:349
@ RAND_EVENT
Definition: binlog_event.h:310
@ TABLE_MAP_EVENT
Definition: binlog_event.h:317
@ STOP_EVENT
Definition: binlog_event.h:301
@ INTVAR_EVENT
Definition: binlog_event.h:303
@ USER_VAR_EVENT
Definition: binlog_event.h:311
@ ROTATE_EVENT
Definition: binlog_event.h:302
@ SLAVE_EVENT
Definition: binlog_event.h:305
const uint64_t INVALID_XID
The following constant represents the maximum of MYSQL_XID domain.
Definition: statement_events.h:49
enum_load_dup_handling
Elements of this enum describe how LOAD DATA handles duplicates.
Definition: load_data_events.h:64
constexpr auto tsid_max_length
Maximum TSID text length (without null character)
Definition: tsid.h:41
HARNESS_EXPORT std::string string_format(const char *format,...)
Definition: utilities.cc:64
Definition: instrumented_condition_variable.h:32
const char * begin(const char *const c)
Definition: base64.h:44
size_t size(const char *const c)
Definition: base64.h:46
mutable_buffer buffer(void *p, size_t n) noexcept
Definition: buffer.h:418
Cursor end()
A past-the-end Cursor.
Definition: rules_table_service.cc:192
const char * db_name
Definition: rules_table_service.cc:55
std::set< Key, Compare, ut::allocator< Key > > set
Specialization of set which uses ut_allocator.
Definition: ut0new.h:2883
std::map< Key, Value, Compare, ut::allocator< std::pair< const Key, Value > > > map
Specialization of map which uses ut_allocator.
Definition: ut0new.h:2893
Performance schema instrumentation interface.
required string type
Definition: replication_group_member_actions.proto:34
required string event
Definition: replication_group_member_actions.proto:32
Contains the classes representing events which are used for row based replication.
mysql::gtid::gno_t rpl_gno
GNO, the second (numeric) component of a GTID, is an alias of mysql::gtid::gno_t.
Definition: rpl_gtid.h:112
const int MAX_GNO_TEXT_LENGTH
The length of MAX_GNO when printed in decimal.
Definition: rpl_gtid.h:286
enum_gtid_type
Enumeration of different types of values for Gtid_specification, i.e, the different internal states t...
Definition: rpl_gtid.h:3868
cs::index::rpl_sidno rpl_sidno
Type of SIDNO (source ID number, first component of GTID)
Definition: rpl_gtid.h:108
mysql::gtid::Tsid Tsid
Definition: rpl_gtid_state.cc:56
enum_row_image_type
Definition: rpl_record.h:40
ulonglong my_xid
Definition: handler.h:1235
File containing constants that can be used throughout the server.
Our own string classes, used pervasively throughout the executor.
Contains the classes representing statement events occurring in the replication stream.
#define STRING_WITH_LEN(X)
Definition: string_with_len.h:29
char * strmake(char *dst, const char *src, size_t length)
Definition: strmake.cc:42
Definition: m_ctype.h:423
This struct represents a specification of a GTID for a statement to be executed: either "AUTOMATIC",...
Definition: rpl_gtid.h:3985
enum_gtid_type type
The type of this GTID.
Definition: rpl_gtid.h:3998
Gtid gtid
The GTID: { SIDNO, GNO } if type == GTID; { 0, 0 } if type == AUTOMATIC or ANONYMOUS.
Definition: rpl_gtid.h:4004
rpl_gno gno
GNO of this Gtid.
Definition: rpl_gtid.h:1106
const char * str
Definition: mysql_lex_string.h:41
Definition: my_bitmap.h:43
Definition: log_event.h:507
const char * name[MAX_DBS_IN_EVENT_MTS]
Definition: log_event.h:508
int num
Definition: log_event.h:509
void reset_and_dispose()
Definition: log_event.h:513
Interface for an instrumented stage progress.
Definition: psi_stage_bits.h:63
LEX_CSTRING db
Definition: table.h:779
TABLE_SHARE * s
Definition: table.h:1407
Legends running throughout the module:
Definition: rpl_rli_pdb.h:74
static bool is_any_gtid_event(const Log_event_type &type)
Helps to identify any GTID event - returns true for GTID_LOG_EVENT, GTID_TAGGED_LOG_EVENT and ANONYMO...
Definition: binlog_event.h:399
struct xid_t is binary compatible with the XID structure as in the X/Open CAE Specification,...
Definition: xa.h:83
Include file for Sun RPC to compile out of the box.
Item_result
Type of the user defined function return slot and arguments.
Definition: udf_registration_types.h:39
synode_no q[FIFO_SIZE]
Definition: xcom_base.cc:4086
static uint64_t cache_size
Definition: xcom_cache.cc:362