104#include <sys/types.h>
107#ifdef HAVE_PSI_STAGE_INTERFACE
119#if defined(MYSQL_SERVER)
127#if defined(MYSQL_SERVER)
130#define PREFIX_SQL_LOAD "SQL_LOAD-"
142#define TEMP_FILE_MAX_LEN UUID_LENGTH + 38
154#define ASSERT_OR_RETURN_ERROR(COND, ERRNO) \
156 if (!(COND)) return ERRNO; \
159#define ASSERT_OR_RETURN_ERROR(COND, ERRNO) assert(COND)
162#define LOG_EVENT_OFFSET 4
164#define NUM_LOAD_DELIM_STRS 5
187#define MAX_LOG_EVENT_HEADER \
189 (LOG_EVENT_HEADER_LEN + \
190 mysql::binlog::event::Binary_log_event::QUERY_HEADER_LEN +
192 mysql::binlog::event::Binary_log_event:: \
193 EXECUTE_LOAD_QUERY_EXTRA_HEADER_LEN) +
195 MAX_SIZE_LOG_EVENT_STATUS + \
201#define SL_MASTER_PORT_OFFSET 8
202#define SL_MASTER_POS_OFFSET 0
203#define SL_MASTER_HOST_OFFSET 10
208#define I_TYPE_OFFSET 0
209#define I_VAL_OFFSET 1
212#define BINLOG_MAGIC "\xfe\x62\x69\x6e"
213#define BINLOG_MAGIC_SIZE 4
244#define LOG_EVENT_THREAD_SPECIFIC_F 0x4
259#define LOG_EVENT_SUPPRESS_USE_F 0x8
276#define LOG_EVENT_ARTIFICIAL_F 0x20
284#define LOG_EVENT_RELAY_LOG_F 0x40
295#define LOG_EVENT_IGNORABLE_F 0x80
304#define LOG_EVENT_NO_FILTER_F 0x100
315#define LOG_EVENT_MTS_ISOLATE_F 0x200
340#define OPTIONS_WRITTEN_TO_BIN_LOG \
341 (OPTION_AUTO_IS_NULL | OPTION_NO_FOREIGN_KEY_CHECKS | \
342 OPTION_RELAXED_UNIQUE_CHECKS | OPTION_NOT_AUTOCOMMIT)
345#define EXPECTED_OPTIONS \
346 ((1ULL << 14) | (1ULL << 26) | (1ULL << 27) | (1ULL << 19))
348#if OPTIONS_WRITTEN_TO_BIN_LOG != EXPECTED_OPTIONS
349#error OPTIONS_WRITTEN_TO_BIN_LOG must NOT change their values!
351#undef EXPECTED_OPTIONS
385enum enum_base64_output_mode {
386 BASE64_OUTPUT_NEVER = 0,
387 BASE64_OUTPUT_AUTO = 1,
388 BASE64_OUTPUT_UNSPEC = 2,
389 BASE64_OUTPUT_DECODE_ROWS = 3,
391 BASE64_OUTPUT_MODE_COUNT
406struct PRINT_EVENT_INFO {
416 bool sql_mode_inited;
418 ulong auto_increment_increment, auto_increment_offset;
422 uint lc_time_names_number;
423 uint charset_database_number;
424 uint default_collation_for_utf8mb4_number;
425 uint8_t sql_require_primary_key;
427 bool thread_id_printed;
428 uint8_t default_table_encryption;
432 ~PRINT_EVENT_INFO() {
447 enum_base64_output_mode base64_output_mode;
457 bool printed_fd_event;
459 uint8 common_header_len;
476 bool have_unflushed_events;
486 bool skipped_event_in_transaction;
488 bool print_table_metadata;
496 bool require_row_format;
501 uint32_t immediate_server_version;
753 virtual const char *
get_db();
756 virtual void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const = 0;
760 void print_base64(
IO_CACHE *
file, PRINT_EVENT_INFO *print_event_info,
764 void *
operator new(
size_t size);
766 static void operator delete(
void *ptr, size_t) {
my_free(ptr); }
769 static void *
operator new(size_t,
void *ptr) {
return ptr; }
770 static void operator delete(
void *,
void *) {}
896#if defined(MYSQL_SERVER)
1100 virtual bool ends_group()
const {
return false; }
1141 DBUG_PRINT(
"info", (
"skip reason=%d=%s", ret,
1341 bool using_trans,
bool immediate,
bool suppress_use,
1342 int error,
bool ignore_command =
false);
1343 const char *
get_db()
override {
return db; }
1367 const char *db_filtered =
1386 PRINT_EVENT_INFO *print_event_info)
const;
1387 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
1388 static bool rewrite_db_in_buffer(
1389 char **
buf, ulong *event_len,
1418#if defined(MYSQL_SERVER)
1484 const char **query_arg);
1487 return !strncmp(
query, pattern, p_len);
1554 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
1570#if defined(MYSQL_SERVER)
1621 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
1642#if defined(MYSQL_SERVER)
1694 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
1712#if defined(MYSQL_SERVER)
1761 bool ends_group()
const override {
return true; }
1762#if defined(MYSQL_SERVER)
1787 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
1802#if defined(MYSQL_SERVER)
1854 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
1856#if defined(MYSQL_SERVER)
1895 char *val_arg, ulong val_len_arg,
Item_result type_arg,
1896 uint charset_number_arg,
uchar flags_arg,
1900 val_len_arg, type_arg,
1901 charset_number_arg, flags_arg),
1909 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
1940#if defined(MYSQL_SERVER)
1968 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
1988#if defined(MYSQL_SERVER)
2041 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
2060#if defined(MYSQL_SERVER)
2104 uint block_len_arg,
bool using_trans);
2108 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
2124 const char *
get_db()
override {
return db; }
2130#if defined(MYSQL_SERVER)
2177 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
2178 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info,
bool enable_local);
2193 const char *
get_db()
override {
return db; }
2199#if defined(MYSQL_SERVER)
2255 uint block_len_arg,
bool using_trans);
2267#if defined(MYSQL_SERVER)
2314 THD *
thd,
const char *query_arg, ulong query_length,
2315 uint fn_pos_start_arg, uint fn_pos_end_arg,
2317 bool using_trans,
bool immediate,
bool suppress_use,
int errcode);
2320 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
2323 const char *local_fname)
const;
2340#if defined(MYSQL_SERVER)
2345#if defined MYSQL_SERVER
2349 const char *table_name_arg,
bool is_concurrent_arg,
2379 Unknown_log_event(Unknown_log_event &&)
noexcept =
delete;
2380 Unknown_log_event &
operator=(Unknown_log_event &&)
noexcept =
delete;
2381 Unknown_log_event(
const Unknown_log_event &) =
delete;
2382 Unknown_log_event &
operator=(
const Unknown_log_event &) =
delete;
2400 ~Unknown_log_event()
override =
default;
2401 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
2407char *
str_to_hex(
char *to,
const char *from,
size_t len);
2497 static bool rewrite_db_in_buffer(
2498 char **
buf, ulong *event_len,
2542#if defined(MYSQL_SERVER)
2547 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
2559 const Optional_metadata_fields &fields)
const;
2570 const Optional_metadata_fields &fields)
const;
2578#if defined(MYSQL_SERVER)
2638 class Charset_iterator;
2639 class Default_charset_iterator;
2640 class Column_charset_iterator;
2644#ifdef HAVE_PSI_STAGE_INTERFACE
2696 if (estimated == 0) {
2697 assert(cursor >
begin);
2699 estimated = (
end -
begin) / avg_row_change_size;
2766#ifdef HAVE_PSI_STAGE_INTERFACE
2812#if defined(MYSQL_SERVER)
2817 void print_verbose(
IO_CACHE *
file, PRINT_EVENT_INFO *print_event_info);
2819 PRINT_EVENT_INFO *print_event_info,
2821 const uchar *prefix,
2840#if defined(MYSQL_SERVER)
2871 MY_BITMAP const *cols,
bool is_transactional,
2873 const unsigned char *extra_row_ndb_info);
2876 const char *row_data,
2880 void print_helper(
FILE *, PRINT_EVENT_INFO *)
const;
2941#if defined(MYSQL_SERVER)
2962 return key_cmp2((*m_key_info)->key_part, k1, (*m_key_info)->key_length,
2963 k2, (*m_key_info)->key_length) < 0;
2970 std::set<uchar *, Key_compare>::iterator
m_itr;
2999 bool is_after_image,
bool only_seek =
false);
3060#if defined(MYSQL_SERVER)
3197 const uchar *curr_bi_start
3317#if defined(MYSQL_SERVER)
3320 bool is_transactional,
3321 const unsigned char *extra_row_ndb_info);
3326#if defined(MYSQL_SERVER)
3328 bool is_transactional,
3329 const uchar *before_record
3331 const uchar *after_record);
3348 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
3351#if defined(MYSQL_SERVER)
3410 bool is_transactional,
3411 const unsigned char *extra_row_ndb_info);
3415 bool is_transactional,
3416 const unsigned char *extra_row_ndb_info);
3429 bool is_transactional,
3431 const uchar *after_record);
3446 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
3449#if defined(MYSQL_SERVER)
3455 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)
3609 DBUG_PRINT(
"enter", (
"incident: %d", incident_arg));
3622 DBUG_PRINT(
"enter", (
"incident: %d", incident_arg));
3651 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
3654#if defined(MYSQL_SERVER)
3665 bool ends_group()
const override {
return true; }
3728 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
3814 bool flush_stream) {
3816 (flush_stream ? (fflush(
file) || ferror(
file)) : 0) ||
3877 uint64_t payload_size,
3878 uint16_t compression_type,
3879 uint64_t uncompressed_size)
3886 uint64_t payload_size)
3888 thd_arg, payload, payload_size,
3905 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
3911#if defined(MYSQL_SERVER)
3966 int64 sequence_number_arg,
bool may_have_sbr_stmts_arg,
3967 ulonglong original_commit_timestamp_arg,
3968 ulonglong immediate_commit_timestamp_arg,
3969 uint32_t original_server_version_arg,
3970 uint32_t immediate_server_version_arg);
3977 int64 last_committed_arg,
int64 sequence_number_arg,
3978 bool may_have_sbr_stmts_arg,
3979 ulonglong original_commit_timestamp_arg,
3980 ulonglong immediate_commit_timestamp_arg,
3982 uint32_t original_server_version_arg,
3983 uint32_t immediate_server_version_arg);
4003 { size_calculated += 2; });
4004 return size_calculated;
4073 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
4076#if defined(MYSQL_SERVER)
4165 bool is_checksum_enabled =
false,
4166 int event_counter = 0);
4171 bool is_checksum_enabled =
false,
4172 int event_counter = 0);
4229 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
4242 (
"skip writing Previous_gtids_log_event because of"
4243 "debug option 'skip_writing_previous_gtids_log_event'"));
4254 (
"writing partial Previous_gtids_log_event because of"
4255 "debug option 'write_partial_previous_gtids_log_event'"));
4287#if defined(MYSQL_SERVER)
4373 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
4376#if defined(MYSQL_SERVER)
4473 std::map<std::string, std::string> *
map);
4502 void print(
FILE *
file, PRINT_EVENT_INFO *print_event_info)
const override;
4505#if defined(MYSQL_SERVER)
4526 size_t *event_size);
4577 return evt !=
nullptr &&
4611template <
class EVENT>
4613 return ev->write(ostream);
4621 const char *identifier,
size_t length);
4626 const char *identifier,
4647template <
typename T>
4657std::pair<bool, mysql::binlog::event::Log_event_basic_info>
4669std::pair<bool, mysql::binlog::event::Log_event_basic_info>
Kerberos Client Authentication nullptr
Definition: auth_kerberos_client_plugin.cc:250
int64 query_id_t
Definition: binlog.h:71
Contains the classes representing events occurring in the replication stream.
#define LOG_EVENT_HEADER_LEN
Definition: binlog_event.h:441
This event is created to contain the file data.
Definition: log_event.h:2091
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:6999
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:7026
virtual int get_create_or_append() const
Definition: log_event.cc:7049
bool is_sbr_logging_format() const override
Return true if the event has to be logged using SBR for DMLs.
Definition: log_event.h:2125
size_t get_data_size() override
Definition: log_event.h:2116
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:7036
~Append_block_log_event() override=default
const char * get_db() override
Definition: log_event.h:2122
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:7079
The abstract class for basic output streams which provides write operation.
Definition: basic_ostream.h:36
Event for the first block of file to be loaded, its only difference from Append_block event is that t...
Definition: log_event.h:2241
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:7300
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:7290
~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:7296
Delete_file_log_event is created when the LOAD_DATA query fails on the master for some reason,...
Definition: log_event.h:2163
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:7240
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:7218
size_t get_data_size() override
Definition: log_event.h:2186
~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:2194
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:7195
const char * get_db() override
Definition: log_event.h:2191
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:7228
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:12382
int do_after_row_operations(const Relay_log_info *const, int) override
Definition: log_event.cc:12435
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:12402
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:12371
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:12442
@ TYPE_CODE
Definition: log_event.h:3522
int do_before_row_operations(const Relay_log_info *const) override
Definition: log_event.cc:12409
Event responsible for LOAD DATA execution, it similar to Query_log_event but before executing the que...
Definition: log_event.h:2308
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:7454
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:2333
bool write_post_header_for_derived(Basic_ostream *ostream) override
Definition: log_event.cc:7364
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:7423
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:7358
ulong get_post_header_size_for_derived() override
Definition: log_event.cc:7354
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:7313
~Execute_load_query_log_event() override=default
This is a subclass if Gtid_event and Log_event.
Definition: log_event.h:3951
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:13480
rpl_gno get_gno() const override
Return the GNO for this GTID.
Definition: log_event.h:4120
rpl_sidno get_sidno(bool need_lock)
Return the SIDNO relative to the global tsid_map for this GTID.
Definition: log_event.cc:13511
~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:13194
Gtid_log_event(Gtid_log_event &&) noexcept=delete
size_t get_event_length()
Definition: log_event.h:4016
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:13461
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:4084
uint32 write_body_to_memory(uchar *buff)
Writes the body to the given memory buffer.
Definition: log_event.cc:13231
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:13204
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:13305
uint32 write_post_header_to_memory(uchar *buffer)
Writes the post-header to the given memory buffer.
Definition: log_event.cc:13139
static const size_t SET_STRING_PREFIX_LENGTH
Length of SET_STRING_PREFIX.
Definition: log_event.h:4127
Tsid tsid
TSID for this GTID.
Definition: log_event.h:4140
const Tsid & get_tsid() const
Return the TSID for this GTID.
Definition: log_event.h:4090
bool write_data_body(Basic_ostream *ostream) override
Definition: log_event.cc:13296
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:13490
static const size_t MAX_SET_STRING_LENGTH
The maximal length of the entire "SET ..." query.
Definition: log_event.h:4129
void update_parent_gtid_info()
Updates parent tsid and gtid info structure.
Definition: log_event.cc:12964
static const char * SET_STRING_PREFIX
string holding the text "SET @@GLOBAL.GTID_NEXT = '"
Definition: log_event.h:4123
void clear_gtid_and_spec()
Clears tsid and spec.
Definition: log_event.cc:12970
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:13054
Gtid_specification spec
Internal representation of the GTID.
Definition: log_event.h:4138
int pack_info(Protocol *) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:13035
size_t get_data_size() override
Definition: log_event.h:3997
size_t to_string(char *buf) const
Used internally by both print() and pack_info().
Definition: log_event.cc:13043
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:13475
Represents a set of GTIDs.
Definition: rpl_gtid.h:1555
Definition: rpl_utility.h:108
Definition: log_event.h:3837
Heartbeat_log_event_v2(const char *buf, const mysql::binlog::event::Format_description_event *description_event)
Definition: log_event.cc:14377
Definition: log_event.h:3829
Heartbeat_log_event(const char *buf, const mysql::binlog::event::Format_description_event *description_event)
Definition: log_event.cc:14370
Base class for ignorable log events is Ignorable_event.
Definition: log_event.h:3696
int pack_info(Protocol *) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:12779
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:12772
size_t get_data_size() override
Definition: log_event.h:3729
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:12724
size_t get_data_size() override
Definition: log_event.h:3658
bool write_data_body(Basic_ostream *ostream) override
Definition: log_event.cc:12750
~Incident_log_event() override
Definition: log_event.cc:12638
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:12684
int pack_info(Protocol *) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:12657
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:12651
const char * description() const
Definition: log_event.cc:12642
bool ends_group() const override
Definition: log_event.h:3663
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:1600
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:5810
~Intvar_log_event() override=default
Intvar_log_event(Intvar_log_event &&) noexcept=delete
size_t get_data_size() override
Definition: log_event.h:1629
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:5889
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:5820
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:5785
bool is_sbr_logging_format() const override
Return true if the event has to be logged using SBR for DMLs.
Definition: log_event.h:1637
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:5864
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:5884
Base class that is used to represent any kind of expression in a relational query.
Definition: item.h:933
Definition: sql_list.h:434
Definition: log_event.h:2344
bool has_replace
Definition: log_event.h:2364
const size_t BUF_SIZE
Definition: log_event.h:2353
const char * table_name
Definition: log_event.h:2360
const char * fname
Definition: log_event.h:2361
const sql_exchange * sql_ex
Definition: log_event.h:2358
THD * thd
Definition: log_event.h:2357
bool has_ignore
Definition: log_event.h:2365
String str
Definition: log_event.h:2354
const char * db
Definition: log_event.h:2359
bool is_concurrent
Definition: log_event.h:2363
const String * generate(size_t *fn_start, size_t *fn_end)
Definition: log_event.cc:7563
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:7546
This is the abstract base class for binary log events.
Definition: log_event.h:537
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:1253
ulong mts_group_idx
Index in rli->gaq array to indicate a group that this event is purging.
Definition: log_event.h:692
bool is_mts_sequential_exec()
Is called from get_mts_execution_mode() to.
Definition: log_event.h:908
bool is_using_stmt_cache() const
Definition: log_event.h:838
enum_skip_reason continue_group(Relay_log_info *rli)
Helper function to ignore an event w.r.t.
Definition: log_event.cc:2444
bool is_no_filter_event() const
Definition: log_event.h:832
int apply_event(Relay_log_info *rli)
Apply the event to the database.
Definition: log_event.cc:3040
virtual int do_apply_event(Relay_log_info const *rli)
Primitive to apply an event to the database.
Definition: log_event.h:1161
virtual const char * get_db()
Definition: log_event.cc:1056
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:675
int net_send(Protocol *protocol, const char *log_name, my_off_t pos)
Only called by SHOW BINLOG EVENTS.
Definition: log_event.cc:1061
uint32 write_header_to_memory(uchar *buf)
Writes the common header of this event to the given memory buffer.
Definition: log_event.cc:1214
virtual mysql::binlog::event::Log_event_type get_type_code() const
Definition: log_event.h:796
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:1093
uint32 server_id
Definition: log_event.h:663
enum_mts_event_exec_mode
Definition: log_event.h:928
@ EVENT_EXEC_PARALLEL
Definition: log_event.h:932
@ EVENT_EXEC_SYNC
Definition: log_event.h:940
@ EVENT_EXEC_CAN_NOT
Definition: log_event.h:944
@ EVENT_EXEC_ASYNC
Definition: log_event.h:936
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:1136
bool is_valid()
Definition: log_event.cc:1306
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:1055
ha_checksum crc
Placeholder for event checksum while writing to binlog.
Definition: log_event.h:685
virtual size_t get_data_size()
Definition: log_event.h:878
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:1192
enum_event_cache_type
Definition: log_event.h:566
@ EVENT_CACHE_COUNT
Definition: log_event.h:588
@ EVENT_INVALID_CACHE
Definition: log_event.h:567
@ EVENT_NO_CACHE
Definition: log_event.h:584
@ EVENT_STMT_CACHE
Definition: log_event.h:573
@ EVENT_TRANSACTIONAL_CACHE
Definition: log_event.h:579
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:546
@ EVENT_SKIP_IGNORE
Skip event by ignoring it.
Definition: log_event.h:557
@ EVENT_SKIP_COUNT
Skip event and decrease skip counter.
Definition: log_event.h:562
@ EVENT_SKIP_NOT
Don't skip event.
Definition: log_event.h:550
bool m_free_temp_buf_in_destructor
Definition: log_event.h:654
bool contains_partition_info(bool)
Definition: log_event.cc:2464
bool is_relay_log_event() const
Definition: log_event.h:826
bool is_ignorable_event() const
Definition: log_event.h:829
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:715
int update_pos(Relay_log_info *rli)
Update the relay log position.
Definition: log_event.h:1128
virtual int do_apply_event_worker(Slave_worker *w)
Definition: log_event.cc:980
void set_artificial_event()
Definition: log_event.h:814
const char * get_type_str() const
Returns the human readable name of this event's type.
Definition: log_event.cc:896
time_t get_time()
Prints a "session_var=value" string.
Definition: log_event.cc:873
bool write_footer(Basic_ostream *ostream)
Definition: log_event.cc:1201
Relay_log_info * worker
MTS: associating the event with either an assigned Worker or Coordinator.
Definition: log_event.h:710
bool is_using_trans_cache() const
Definition: log_event.h:835
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:962
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:1002
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:722
virtual bool write(Basic_ostream *ostream)
Definition: log_event.h:784
ulong rbr_exec_mode
A storage to cache the global system variable's value.
Definition: log_event.h:669
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:698
virtual void set_mts_isolate_group()
Definition: log_event.h:1034
THD * thd
Definition: log_event.h:718
int apply_gtid_event(Relay_log_info *rli)
Apply the GTID event in curr_group_data to the database.
Definition: log_event.cc:2996
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:704
virtual bool write_data_body(Basic_ostream *)
Definition: log_event.h:793
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:932
void register_temp_buf(char *buf, bool free_in_destructor=true)
Definition: log_event.h:864
virtual uint8 mts_number_dbs()
Definition: log_event.h:1072
void free_temp_buf()
Definition: log_event.h:868
bool is_mts_group_isolated()
Definition: log_event.h:1079
ulong exec_time
Definition: log_event.h:657
virtual bool is_rbr_logging_format() const
Return true if the event has to be logged using RBR for DMLs.
Definition: log_event.h:807
virtual ~Log_event()
Definition: log_event.h:863
enum_event_logging_type event_logging_type
Defines when information, i.e.
Definition: log_event.h:681
enum_event_logging_type
Definition: log_event.h:591
@ EVENT_NORMAL_LOGGING
Definition: log_event.h:597
@ EVENT_IMMEDIATE_LOGGING
Definition: log_event.h:602
@ EVENT_INVALID_LOGGING
Definition: log_event.h:592
@ EVENT_CACHE_LOGGING_COUNT
Definition: log_event.h:606
char * temp_buf
Definition: log_event.h:647
virtual bool is_sbr_logging_format() const
Return true if the event has to be logged using SBR for DMLs.
Definition: log_event.h:803
virtual int pack_info(Protocol *protocol)
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:1051
bool is_using_immediate_logging() const
Definition: log_event.h:841
void set_relay_log_event()
Definition: log_event.h:822
virtual bool write_data_header(Basic_ostream *)
Definition: log_event.h:792
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:1084
bool is_artificial_event() const
Definition: log_event.h:823
virtual int do_update_pos(Relay_log_info *rli)
Advance relay log coordinates.
Definition: log_event.cc:994
virtual bool ends_group() const
Definition: log_event.h:1098
bool need_checksum()
A decider of whether to trigger checksum computation or not.
Definition: log_event.cc:1113
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:861
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:2592
This is the subclass of Previous_gtids_event and Log_event It is used to record the gtid_executed in ...
Definition: log_event.h:4199
bool write_data_body(Basic_ostream *ostream) override
Definition: log_event.cc:13613
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:13620
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:13594
int pack_info(Protocol *) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:13557
int do_apply_event(Relay_log_info const *) override
Primitive to apply an event to the database.
Definition: log_event.h:4291
int add_to_set(Gtid_set *gtid_set) const
Add all GTIDs from this event to the given Gtid_set.
Definition: log_event.cc:13583
size_t get_data_size() override
Definition: log_event.h:4222
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:4286
bool write(Basic_ostream *ostream) override
Definition: log_event.h:4230
~Previous_gtids_log_event() override=default
const uchar * get_buf()
Return the encoded buffer, or NULL on error.
Definition: log_event.h:4267
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:13531
Definition: protocol.h:32
A Query event is written to the binary log whenever the database is modified on the master,...
Definition: log_event.h:1284
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:5093
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:1490
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:1460
Query_log_event(const Query_log_event &)=delete
bool is_trans_keyword() const
Definition: log_event.h:1428
mysql::binlog::event::Log_event_header::Byte * data_buf
Definition: log_event.h:1286
bool m_skip_temp_tables_handling_by_worker
Instructs the applier to skip temporary tables handling.
Definition: log_event.h:1328
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:5143
Query_log_event()
The simplest constructor that could possibly work.
Definition: log_event.cc:3627
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:5107
virtual ulong get_post_header_size_for_derived()
Definition: log_event.h:1412
bool starts_group() const override
Notice, DDL queries are logged without BEGIN/COMMIT parentheses and identification of such single-que...
Definition: log_event.h:1468
uchar mts_number_dbs() override
Definition: log_event.h:1379
my_thread_id slave_proxy_id
Definition: log_event.h:1301
void set_skip_temp_tables_handling_by_worker()
Definition: log_event.h:1330
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:5196
bool has_ddl_committed
The flag indicates whether the DDL query has been (already) committed or not.
Definition: log_event.h:1321
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:4373
~Query_log_event() override
Definition: log_event.h:1397
void attach_temp_tables_worker(THD *, const Relay_log_info *)
Associating slave Worker thread to a subset of temporary tables.
Definition: log_event.cc:4350
bool write(Basic_ostream *ostream) override
Query_log_event::write().
Definition: log_event.cc:3334
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:1309
bool is_query_prefix_match(const char *pattern, uint p_len)
Definition: log_event.h:1484
uint8 get_mts_dbs(Mts_db_names *arg, Rpl_filter *rpl_filter) override
Definition: log_event.h:1354
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:1494
const char * get_db() override
Definition: log_event.h:1341
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:3283
bool ends_group() const override
Definition: log_event.h:1473
bool is_skip_temp_tables_handling_by_worker()
Definition: log_event.h:1334
virtual bool write_post_header_for_derived(Basic_ostream *)
Definition: log_event.h:1405
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:4364
Logs random seed used by the next RAND(), and by PASSWORD() in 4.1.0.
Definition: log_event.h:1673
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:5930
bool is_sbr_logging_format() const override
Return true if the event has to be logged using SBR for DMLs.
Definition: log_event.h:1707
~Rand_log_event() override=default
size_t get_data_size() override
Definition: log_event.h:1702
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:5975
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:5956
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:5906
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:5970
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:5924
Definition: rpl_rli.h:202
This will be deprecated when we move to using sequence ids.
Definition: log_event.h:2026
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:5618
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:5506
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:5761
~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:5579
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:5589
size_t get_data_size() override
Definition: log_event.h:2046
Definition: log_event.h:2646
bool is_enabled()
If instrumentation is enabled this member function SHALL return true.
Definition: log_event.h:2673
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:2719
ulonglong m_n_rows_applied
Counter that is unconditionally incremented on each row that is processed.
Definition: log_event.h:2661
ulonglong get_n_rows_applied()
Gets the value of the counter of rows that have been processed.
Definition: log_event.h:2725
Rows_applier_psi_stage()
Definition: log_event.h:2664
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:2686
void set_progress(PSI_stage_progress *progress)
Definition: log_event.h:2666
void end_work()
Resets this object.
Definition: log_event.h:2710
PSI_stage_progress * m_progress
A cached pointer to this stage PSI_stage_progress.
Definition: log_event.h:2654
Definition: log_event.h:2945
KEY ** m_key_info
Definition: log_event.h:2965
Key_compare(KEY **ki=nullptr)
Definition: log_event.h:2958
bool operator()(uchar *k1, uchar *k2) const
Definition: log_event.h:2959
Common base class for all row-containing log events.
Definition: log_event.h:2763
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:3268
uint32 m_bitbuf[128/(sizeof(uint32) *8)]
Definition: log_event.h:2926
uchar * m_rows_end
Definition: log_event.h:2935
int close_record_scan()
Does the cleanup.
Definition: log_event.cc:8824
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:8769
bool write_data_header(Basic_ostream *ostream) override
Definition: log_event.cc:10352
virtual int do_before_row_operations(const Relay_log_info *const log)=0
uchar * m_rows_buf
Definition: log_event.h:2933
uint m_rows_lookup_algorithm
The algorithm to use while searching for rows using the before image.
Definition: log_event.h:2907
@ RLE_NO_FLAGS
Definition: log_event.h:2799
TABLE * m_table
Definition: log_event.h:2886
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:3068
bool is_rbr_logging_format() const override
Return true if the event has to be logged using RBR for DMLs.
Definition: log_event.h:3055
int do_hash_row(Relay_log_info const *rli)
Populates the m_hash when using HASH_SCAN.
Definition: log_event.cc:9206
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:2901
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:2973
int do_hash_scan_and_update(Relay_log_info const *rli)
Implementation of the hash_scan and update algorithm.
Definition: log_event.cc:9449
int add_row_data(uchar *data, size_t length)
Definition: log_event.h:2824
void decide_row_lookup_algorithm_and_key() SUPPRESS_UBSAN_CLANG10
Definition: log_event.cc:8378
uint m_key_index
Definition: log_event.h:2943
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:8799
int row_operations_scan_and_key_setup()
Definition: log_event.cc:8475
MY_BITMAP const * get_cols_ai() const
Definition: log_event.h:2833
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:10214
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:2923
uchar * m_key
Definition: log_event.h:2942
int do_index_scan_and_update(Relay_log_info const *rli)
Implementation of the index scan and update algorithm.
Definition: log_event.cc:8975
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:9274
virtual int do_add_row_data(uchar *data, size_t length)
Definition: log_event.cc:8111
Rows_applier_psi_stage m_psi_progress
Definition: log_event.h:2766
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:8566
size_t get_data_size() override
Definition: log_event.cc:8071
const char * get_db() override
Definition: log_event.h:2857
uint16 flag_set
Definition: log_event.h:2776
row_lookup_mode
Definition: log_event.h:2778
@ ROW_LOOKUP_INDEX_SCAN
Definition: log_event.h:2781
@ ROW_LOOKUP_UNDEFINED
Definition: log_event.h:2779
@ ROW_LOOKUP_NOT_NEEDED
Definition: log_event.h:2780
@ ROW_LOOKUP_TABLE_SCAN
Definition: log_event.h:2782
@ ROW_LOOKUP_HASH_SCAN
Definition: log_event.h:2783
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:3193
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:8548
uchar * m_rows_cur
Definition: log_event.h:2934
const mysql::binlog::event::Table_id & get_table_id() const
Definition: log_event.h:2834
uint m_row_count
Definition: log_event.h:2860
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:9553
int next_record_scan(bool first_read)
Fetches next row.
Definition: log_event.cc:8837
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:10458
int do_table_scan_and_update(Relay_log_info const *rli)
Implementation of the legacy table_scan and update algorithm.
Definition: log_event.cc:9470
MY_BITMAP m_local_cols
Bitmap denoting columns available in the image as they appear in the table setup.
Definition: log_event.h:2895
int open_record_scan()
Initializes scanning of rows.
Definition: log_event.cc:8899
void clear_flags(flag_set flags_arg)
Definition: log_event.h:2804
virtual int do_exec_row(const Relay_log_info *const rli)=0
std::set< uchar *, Key_compare >::iterator m_itr
Definition: log_event.h:2968
enum_error
Enumeration of the errors that can be returned.
Definition: log_event.h:2789
@ ERR_TABLE_LIMIT_EXCEEDED
No more room for tables.
Definition: log_event.h:2792
@ ERR_BAD_TABLE_DEF
Table definition does not match.
Definition: log_event.h:2794
@ ERR_OPEN_FAILURE
Failure to open table.
Definition: log_event.h:2790
@ ERR_RBR_TO_SBR
daisy-chanining RBR to SBR not allowed
Definition: log_event.h:2795
@ ERR_OUT_OF_MEM
Out of memory.
Definition: log_event.h:2793
@ ERR_OK
No error.
Definition: log_event.h:2791
int row_operations_scan_and_key_teardown(int error)
Definition: log_event.cc:8518
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:8048
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:2832
std::set< uchar *, Key_compare > m_distinct_keys
Definition: log_event.h:2967
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:8681
Rows_log_event(Rows_log_event &&) noexcept=delete
const uchar * m_curr_row
Definition: log_event.h:2940
MY_BITMAP m_cols_ai
Bitmap for columns available in the after image, if present.
Definition: log_event.h:2916
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:8955
KEY * m_key_info
Definition: log_event.h:2944
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:7962
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:10320
~Rows_log_event() override
Definition: log_event.cc:7942
void set_flags(flag_set flags_arg)
Definition: log_event.h:2803
friend class Old_rows_log_event
Definition: log_event.h:3260
const uchar * m_curr_row_end
Definition: log_event.h:2941
bool write_data_body(Basic_ostream *ostream) override
Definition: log_event.cc:10425
uint32 m_bitbuf_ai[128/(sizeof(uint32) *8)]
Definition: log_event.h:2927
MY_BITMAP m_cols
Definition: log_event.h:2888
It is used to record the original query for the rows events in RBR.
Definition: log_event.h:3768
size_t get_data_size() override
Definition: log_event.h:3804
~Rows_query_log_event() override
Definition: log_event.h:3797
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:12868
bool write_data_body(Basic_ostream *ostream) override
Definition: log_event.cc:12858
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:12809
int pack_info(Protocol *) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:12816
Rows_query_log_event(THD *thd_arg, const char *query, size_t query_len)
Definition: log_event.h:3771
Rpl_filter.
Definition: rpl_filter.h:213
const char * get_rewrite_db(const char *db, size_t *new_len)
Definition: rpl_filter.cc:1174
bool is_rewrite_empty()
Definition: rpl_filter.cc:569
Mix-in to handle the message logging and reporting for relay log info and master log info structures.
Definition: rpl_reporting.h:53
Definition: rpl_rli_pdb.h:497
Definition: log_event.h:1950
mysql::binlog::event::Log_event_type get_type_code() const override
Definition: log_event.h:1979
Stop_log_event()
Definition: log_event.h:1959
~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:6920
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:1988
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:6940
String class wrapper with a preallocated buffer of size buff_sz.
Definition: sql_string.h:658
Using this class is fraught with peril, and you need to be very careful when doing so.
Definition: sql_string.h:166
For each client connection we create a separate thread with THD serving as a thread/connection descri...
Definition: sql_lexer_thd.h:35
Table_map_log_event which maps a table definition to a number.
Definition: log_event.h:2428
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:10976
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:10849
Table_map_log_event(const Table_map_log_event &)=delete
uint8 mts_number_dbs() override
Definition: log_event.h:2511
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:10985
const char * get_db_name() const
Definition: log_event.h:2503
virtual int save_field_metadata()
Save the field metadata based on the real_type of the field.
Definition: log_event.cc:10546
bool init_set_str_value_field()
Definition: log_event.cc:11292
flag_set get_flags(flag_set flag) const
Definition: log_event.h:2474
~Table_map_log_event() override
bool init_geometry_type_field()
Definition: log_event.cc:11340
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:11186
bool init_primary_key_field()
Definition: log_event.cc:11357
enum_flag
Definition: log_event.h:2451
@ ENUM_FLAG_COUNT
Nothing here right now, but the flags support is there in preparation for changes that are coming.
Definition: log_event.h:2458
bool is_rbr_logging_format() const override
Return true if the event has to be logged using RBR for DMLs.
Definition: log_event.h:2573
const mysql::binlog::event::Table_id & get_table_id() const
Definition: log_event.h:2499
bool init_column_visibility_field()
Definition: log_event.cc:11405
const char * get_table_name() const
Definition: log_event.h:2502
uint8 get_mts_dbs(Mts_db_names *arg, Rpl_filter *rpl_filter) override
Definition: log_event.h:2523
bool write_data_header(Basic_ostream *ostream) override
Definition: log_event.cc:10990
@ TM_GENERATED_INVISIBLE_PK_F
Table has generated invisible primary key.
Definition: log_event.h:2471
@ TM_BIT_LEN_EXACT_F
Definition: log_event.h:2464
@ TM_NO_FLAGS
Definition: log_event.h:2463
@ TM_REFERRED_FK_DB_F
Definition: log_event.h:2465
bool write_data_body(Basic_ostream *ostream) override
Definition: log_event.cc:11004
bool init_enum_str_value_field()
Definition: log_event.cc:11319
bool init_column_name_field()
Definition: log_event.cc:11280
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:2597
const char * get_db() override
Definition: log_event.h:2510
size_t get_data_size() override
Definition: log_event.h:2505
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:11437
TABLE * m_table
Definition: log_event.h:2583
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:10730
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:11132
@ TYPE_CODE
Definition: log_event.h:2437
enum_error
Enumeration of the errors that can be returned.
Definition: log_event.h:2442
@ ERR_OK
No error.
Definition: log_event.h:2444
@ ERR_TABLE_LIMIT_EXCEEDED
No more room for tables.
Definition: log_event.h:2445
@ ERR_OPEN_FAILURE
Failure to open table.
Definition: log_event.h:2443
@ ERR_OUT_OF_MEM
Out of memory.
Definition: log_event.h:2446
@ ERR_BAD_TABLE_DEF
Table definition does not match.
Definition: log_event.h:2447
@ ERR_RBR_TO_SBR
daisy-chanining RBR to SBR not allowed
Definition: log_event.h:2448
bool has_generated_invisible_primary_key() const
Definition: log_event.cc:10726
StringBuffer< 1024 > m_metadata_buf
Definition: log_event.h:2586
bool init_signedness_field()
Definition: log_event.cc:11155
This is the subclass of Transaction_context_event and Log_event This class encodes the transaction_co...
Definition: log_event.h:4321
static int get_data_set_size(std::list< const char * > *set)
Definition: log_event.cc:13855
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:13867
my_thread_id get_thread_id() const
Return the id of the committing thread.
Definition: log_event.h:4425
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:13629
void add_read_set(const char *hash)
Add a hash which identifies a read row on the ongoing transaction.
Definition: log_event.cc:13872
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:13747
Gtid_set * get_snapshot_version()
Return the transaction snapshot timestamp.
Definition: log_event.h:4415
size_t get_data_size() override
Definition: log_event.cc:13754
int do_apply_event(Relay_log_info const *) override
Primitive to apply an event to the database.
Definition: log_event.h:4375
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:13722
bool read_snapshot_version()
Read snapshot version from encoded buffers.
Definition: log_event.cc:13835
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:13714
Gtid_set * snapshot_version
A gtid_set which is used to store the transaction set used for conflict detection.
Definition: log_event.h:4327
size_t get_event_length()
Definition: log_event.cc:13766
Tsid_map * tsid_map
The Tsid_map to use for creating the Gtid_set.
Definition: log_event.h:4324
std::list< const char * > * get_read_set()
Return a pointer to read-set list.
Definition: log_event.h:4402
size_t get_snapshot_version_size()
Definition: log_event.cc:13849
bool write_data_header(Basic_ostream *ostream) override
Definition: log_event.cc:13771
bool is_gtid_specified() const
Return true if transaction has GTID fully specified, false otherwise.
Definition: log_event.h:4432
~Transaction_context_log_event() override
Definition: log_event.cc:13697
bool write_data_set(Basic_ostream *ostream, std::list< const char * > *set)
Definition: log_event.cc:13815
std::list< const char * > * get_write_set()
Return a pointer to write-set list.
Definition: log_event.h:4390
bool write_data_body(Basic_ostream *ostream) override
Definition: log_event.cc:13787
size_t to_string(char *buf, ulong len) const
Definition: log_event.cc:13708
const char * get_server_uuid()
Return the server uuid.
Definition: log_event.h:4420
bool write_snapshot_version(Basic_ostream *ostream)
Definition: log_event.cc:13799
Definition: log_event.h:3862
Mts_db_names & get_mts_db_names()
Definition: log_event.h:3871
Mts_db_names m_mts_db_names
Definition: log_event.h:3865
void reset()
Definition: log_event.h:3870
virtual ~Applier_context()
Definition: log_event.h:3869
Applier_context()=default
Definition: log_event.h:3858
size_t get_event_length()
Definition: log_event.h:3906
void set_mts_dbs(Mts_db_names &arg)
Definition: log_event.cc:14120
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:14099
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:14105
bool apply_payload_event(Relay_log_info const *rli, const uchar *event_buf)
Definition: log_event.cc:14191
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:14277
bool ends_group() const override
Definition: log_event.cc:14324
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:14282
~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:14314
size_t get_data_size() override
Definition: log_event.cc:14091
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:3874
Applier_context m_applier_ctx
Definition: log_event.h:3911
uint8 mts_number_dbs() override
Definition: log_event.cc:14136
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:14140
Represents a bidirectional map between TSID and SIDNO.
Definition: rpl_gtid.h:748
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:60
Log row updates with a before image.
Definition: log_event.h:3397
int do_exec_row(const Relay_log_info *const) override
Definition: log_event.cc:12580
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:12467
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:12495
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:3430
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:12540
int do_after_row_operations(const Relay_log_info *const, int) override
Definition: log_event.cc:12573
@ TYPE_CODE
Definition: log_event.h:3401
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:12547
mysql::binlog::event::Log_event_type get_general_type_code() override
Definition: log_event.h:3439
~Update_rows_log_event() override
Definition: log_event.cc:12518
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:9148
void init(MY_BITMAP const *cols)
Definition: log_event.cc:12502
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:1881
~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:1935
bool is_deferred()
Definition: log_event.h:1924
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:6868
query_id_t query_id
Definition: log_event.h:1891
void set_deferred(query_id_t qid)
Definition: log_event.h:1929
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:6489
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:6758
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:6887
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:6873
bool deferred
Definition: log_event.h:1890
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:6587
This is the subclass of View_change_log_event and Log_event This class created the view_change_log_ev...
Definition: log_event.h:4461
std::map< std::string, std::string > * get_certification_info()
Returns the certification info.
Definition: log_event.h:4529
int do_update_pos(Relay_log_info *rli) override
Advance relay log coordinates.
Definition: log_event.cc:14012
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:13939
bool write_data_body(Basic_ostream *ostream) override
Definition: log_event.cc:14029
void set_seq_number(rpl_gno number)
Set the certification sequence number.
Definition: log_event.h:4538
char * get_view_id()
Returns the view id.
Definition: log_event.h:4511
size_t get_size_data_map(std::map< std::string, std::string > *map)
Definition: log_event.cc:13920
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:13945
size_t get_data_size() override
Definition: log_event.cc:13911
bool write_data_header(Basic_ostream *ostream) override
Definition: log_event.cc:14018
int do_apply_event(Relay_log_info const *rli) override
Primitive to apply an event to the database.
Definition: log_event.cc:13971
rpl_gno get_seq_number()
Returns the certification sequence number.
Definition: log_event.h:4543
bool write_data_map(Basic_ostream *ostream, std::map< std::string, std::string > *map)
Definition: log_event.cc:14037
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:14073
View_change_log_event(const View_change_log_event &)=delete
size_t to_string(char *buf, ulong len) const
Definition: log_event.cc:13934
Log row insertions and updates.
Definition: log_event.h:3308
int do_before_row_operations(const Relay_log_info *const) override
Definition: log_event.cc:11910
@ TYPE_CODE
Definition: log_event.h:3312
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:12357
mysql::binlog::event::Log_event_type get_general_type_code() override
Definition: log_event.h:3341
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:11880
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:3330
int do_exec_row(const Relay_log_info *const) override
Definition: log_event.cc:12334
int write_row(const Relay_log_info *const, const bool)
Write the current row into event's table.
Definition: log_event.cc:12099
int do_after_row_operations(const Relay_log_info *const, int) override
Definition: log_event.cc:12018
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:11890
Similar to Xid_log_event except that.
Definition: log_event.h:1820
static const int xid_bufs_size
Definition: log_event.h:1823
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:6445
XA_prepare_log_event(THD *thd_arg, XID *xid_arg, bool one_phase_arg=false)
Definition: log_event.h:1827
size_t get_data_size() override
Definition: log_event.h:1843
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:6383
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:6411
int pack_info(Protocol *protocol) override
Stores a string representation of this event in the Protocol.
Definition: log_event.cc:6369
mysql::binlog::event::Log_event_type get_type_code() const override
Definition: log_event.h:1840
Definition: log_event.h:1746
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:6355
bool ends_group() const override
Definition: log_event.h:1759
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:1749
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:6110
~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:6183
This is the subclass of Xid_event defined in libbinlogevent, An XID event is generated for a commit o...
Definition: log_event.h:1769
~Xid_log_event() override=default
bool write(Basic_ostream *ostream) override
Definition: log_event.cc:6036
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:6013
size_t get_data_size() override
Definition: log_event.h:1795
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:6069
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:6030
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:110
This event is created to contain the file data.
Definition: load_data_events.h:273
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:310
unsigned int block_len
Definition: load_data_events.h:297
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:357
@ APPEND_BLOCK_HEADER_LEN
Definition: binlog_event.h:880
@ IGNORABLE_HEADER_LEN
Definition: binlog_event.h:894
@ FORMAT_DESCRIPTION_HEADER_LEN
Definition: binlog_event.h:884
@ INCIDENT_HEADER_LEN
Definition: binlog_event.h:892
@ DELETE_FILE_HEADER_LEN
Definition: binlog_event.h:881
@ ROTATE_HEADER_LEN
Definition: binlog_event.h:878
const Log_event_header * header() const
Return a const pointer to the header of the log event.
Definition: binlog_event.h:957
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:965
DELETE_FILE_EVENT occurs when the LOAD DATA failed on the master.
Definition: load_data_events.h:201
const char * db
Definition: load_data_events.h:214
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:118
GTID stands for Global Transaction IDentifier It is composed of two parts:
Definition: control_events.h:1015
int get_server_version_length() const
We only store the immediate_server_version if both server versions are the same.
Definition: control_events.h:1235
int get_commit_timestamp_length() const
Definition: control_events.h:1225
int get_commit_group_ticket_length() const
Returns the length of the packed commit_group_ticket field.
Definition: control_events.cpp:618
bool is_tagged() const
Checks whether this Gtid log event contains a tag.
Definition: control_events.cpp:648
unsigned long long get_trx_length() const
Definition: control_events.h:1314
static const int POST_HEADER_LENGTH
Total length of post header.
Definition: control_events.h:1253
Replication event to ensure to replica that source is alive.
Definition: control_events.h:1668
Replication event to ensure to replica that source is alive.
Definition: control_events.h:1742
Base class for ignorable log events.
Definition: control_events.h:673
Class representing an incident, an occurrence out of the ordinary, that happened on the master.
Definition: control_events.h:439
char * message
Definition: control_events.h:490
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:460
size_t message_length
Definition: control_events.h:491
enum_incident
Enumeration of the incidents that can occur for the server.
Definition: control_events.h:444
@ INCIDENT_NONE
No incident.
Definition: control_events.h:446
@ INCIDENT_COUNT
Shall be last event of the enumeration.
Definition: control_events.h:450
An Intvar_event will be created just before a Query_event, if the query uses one of the variables LAS...
Definition: statement_events.h:920
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:482
Definition: control_events.h:1379
size_t buf_size
Definition: control_events.h:1407
const unsigned char * buf
Definition: control_events.h:1408
A Query_event is created for each query that modifies the database, unless the query is logged row-ba...
Definition: statement_events.h:450
const char * db
Definition: statement_events.h:534
const char * query
Definition: statement_events.h:533
unsigned char mts_accessed_dbs
Definition: statement_events.h:639
char mts_accessed_db_names[MAX_DBS_IN_EVENT_MTS][NAME_LEN]
Definition: statement_events.h:640
size_t q_len
Definition: statement_events.h:586
Logs random seed used by the next RAND(), and by PASSWORD() in 4.1.0.
Definition: statement_events.h:1032
Rand_event(unsigned long long seed1_arg, unsigned long long seed2_arg)
Definition: statement_events.h:1042
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:115
unsigned int flags
Definition: control_events.h:119
size_t ident_len
Definition: control_events.h:118
Common base class for all row-containing binary log events.
Definition: rows_event.h:879
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:378
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:384
Each table share has a table id, it is mainly used for row based replication.
Definition: table_id.h:41
In row-based mode, every row operation event is preceded by a Table_map_event which maps a table defi...
Definition: rows_event.h:524
unsigned char * m_coltype
Definition: rows_event.h:683
std::string m_tblnam
Definition: rows_event.h:680
uint16_t flag_set
Definition: rows_event.h:533
unsigned char * m_null_bits
field metadata
Definition: rows_event.h:690
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:547
unsigned long m_colcnt
Definition: rows_event.h:682
unsigned char * m_field_metadata
Definition: rows_event.h:689
unsigned long m_field_metadata_size
The size of field metadata buffer set by calling save_field_metadata()
Definition: rows_event.h:688
size_t m_data_size
Definition: rows_event.h:675
std::string m_dbnam
event data size
Definition: rows_event.h:678
flag_set m_flags
Definition: rows_event.h:673
Table_id m_table_id
Event post header contents.
Definition: rows_event.h:672
This class is used to combine the information of the ongoing transaction including the write set and ...
Definition: control_events.h:1467
bool gtid_specified
Definition: control_events.h:1503
uint32_t thread_id
Definition: control_events.h:1502
std::list< const char * > read_set
Definition: control_events.h:1507
const char * server_uuid
Definition: control_events.h:1501
std::list< const char * > write_set
Definition: control_events.h:1506
Event that encloses all the events of a transaction.
Definition: control_events.h:734
Transaction_payload_event(const Transaction_payload_event &)=delete
An unknown event should never occur.
Definition: binlog_event.h:995
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:803
const char * name
Definition: statement_events.h:852
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:819
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:1567
long long int seq_number
Definition: control_events.h:1621
std::map< std::string, std::string > certification_info
Definition: control_events.h:1623
char view_id[ENCODED_VIEW_ID_MAX_LEN]
Definition: control_events.h:1619
Log row insertions.
Definition: rows_event.h:1097
An XA_prepare event is generated for a XA prepared transaction.
Definition: control_events.h:587
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:616
void * xid
Definition: control_events.h:607
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:522
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:529
uint64_t xid
Definition: control_events.h:539
Represents Transaction Source Identifier which is composed of source UUID and transaction tag.
Definition: tsid.h:46
static std::size_t get_size(const T &arg)
Definition: serializer_impl.hpp:69
Definition: partition_info.h:208
Used to hold information about file and file structure in exchange via non-DB file (....
Definition: sql_exchange.h:78
A table definition from the master.
Definition: rpl_utility.h:247
Maps table id's (integers) to table pointers.
Definition: rpl_tblmap.h:50
static char buf[MAX_BUF]
Definition: conf_to_src.cc:72
Contains the classes representing events operating in the replication stream properties.
#define U
Definition: ctype-tis620.cc:73
uint64_t sql_mode_t
Definition: dd_event.h:38
#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:116
#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:129
#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:123
void close_cached_file(IO_CACHE *cache)
Definition: mf_cache.cc:86
bool my_b_inited(const IO_CACHE *info)
Definition: my_sys.h:494
#define MY_WME
Definition: my_sys.h:127
int my_b_copy_to_file(IO_CACHE *cache, FILE *file)
Definition: mf_iocache2.cc:71
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:327
@ WRITE_CACHE
Definition: my_sys.h:289
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:14437
size_t my_strmov_quoted_identifier(THD *thd, char *buffer, const char *identifier, size_t length)
Definition: log_event.cc:14397
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:4574
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:799
bool binary_event_serialize(EVENT *ev, Basic_ostream *ostream)
Serialize an binary event to the given output stream.
Definition: log_event.h:4610
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:759
TYPELIB binlog_checksum_typelib
Definition: log_event.cc:219
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:3700
int ignored_error_code(int err_code)
Ignore error code specified on command line.
Definition: log_event.cc:605
MYSQL_PLUGIN_IMPORT char server_version[SERVER_VERSION_LENGTH]
Definition: log_event.h:124
std::unique_ptr< cs::util::ReplicatedColumnsView > ColumnViewPtr
Definition: log_event.h:120
bool is_any_gtid_event(const Log_event *evt)
Definition: log_event.h:4546
size_t my_strmov_quoted_identifier_helper(int q, char *buffer, const char *identifier, size_t length)
Definition: log_event.cc:14410
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:4560
PSI_memory_key key_memory_Rows_query_log_event_rows_query
Definition: log_event.cc:194
const int64 SEQ_MAX_TIMESTAMP
Maximum value of binlog logical timestamp.
Definition: log_event.h:354
MYSQL_PLUGIN_IMPORT ulong server_id
Definition: log_event.h:117
static bool copy_event_cache_to_file_and_reinit(IO_CACHE *cache, FILE *file, bool flush_stream)
Definition: log_event.h:3810
PSI_memory_key key_memory_Incident_log_event_message
Definition: log_event.cc:193
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:5995
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:817
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:7716
unsigned int PSI_memory_key
Instrumented memory key.
Definition: psi_memory_bits.h:48
#define mysql_stage_set_work_completed(P1, P2)
Definition: mysql_stage.h:114
#define mysql_stage_get_work_estimated(P1)
Definition: mysql_stage.h:142
#define mysql_stage_set_work_estimated(P1, P2)
Definition: mysql_stage.h:139
static int flag
Definition: hp_test1.cc:39
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:504
#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:215
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:107
Abstraction functions over zlib/intrinsics.
std::uint32_t ha_checksum
Definition: my_checksum.h:105
Header for compiler-dependent features.
#define SUPPRESS_UBSAN_CLANG10
Definition: my_compiler.h:128
#define DBUG_EXECUTE_IF(keyword, a1)
Definition: my_dbug.h:170
#define DBUG_PRINT(keyword, arglist)
Definition: my_dbug.h:180
#define DBUG_EVALUATE_IF(keyword, a1, a2)
Definition: my_dbug.h:178
#define DBUG_TRACE
Definition: my_dbug.h:145
Some integer typedefs for easier portability.
unsigned long long int ulonglong
Definition: my_inttypes.h:55
uint8_t uint8
Definition: my_inttypes.h:62
ulonglong my_off_t
Definition: my_inttypes.h:71
unsigned char uchar
Definition: my_inttypes.h:51
int64_t int64
Definition: my_inttypes.h:67
#define MYF(v)
Definition: my_inttypes.h:96
uint16_t uint16
Definition: my_inttypes.h:64
uint32_t uint32
Definition: my_inttypes.h:66
#define FN_REFLEN
Definition: my_io.h:82
void * my_malloc(PSI_memory_key key, size_t size, int flags)
Allocates size bytes of memory.
Definition: my_memory.cc:56
void my_free(void *ptr)
Frees the memory pointed by the ptr.
Definition: my_memory.cc:80
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:70
Common header for many mysys elements.
static my_thread_id thread_id
Definition: my_thr_init.cc:62
uint32 my_thread_id
Definition: my_thread_local.h:33
static char * query
Definition: myisam_ftdump.cc:46
Common definition between mysql server & client.
unsigned int net_length_size(unsigned long long num)
#define SERVER_VERSION_LENGTH
Definition: mysql_com.h:73
Instrumentation helpers for stages.
static void print_header(MYSQL_RES *result)
Definition: mysqladmin.cc:1283
static uint verbose
Definition: mysqlcheck.cc:65
static bool replace
Definition: mysqlimport.cc:69
static bool ignore
Definition: mysqlimport.cc:69
static const char * sql_mode
Definition: mysqlslap.cc:198
const char * delimiter
Definition: mysqlslap.cc:159
void * begin(THD *thd, const TABLE *table, size_t data_size, size_t memory, size_t num_threads) noexcept
Definition: bulk_data_service.cc:1533
static PFS_engine_table_share_proxy table
Definition: pfs.cc:60
Definition: buf0block_hint.cc:29
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:75
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:94
static Value err()
Create a Value object that represents an error condition.
Definition: json_binary.cc:926
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:1330
The namespace contains classes representing events that can occur in a replication stream.
Definition: binlog_event.cpp:35
Log_event_type
Enumeration type for the different types of log events.
Definition: binlog_event.h:285
@ INCIDENT_EVENT
Something out of the ordinary happened on the master.
Definition: binlog_event.h:328
@ FORMAT_DESCRIPTION_EVENT
Definition: binlog_event.h:311
@ EXECUTE_LOAD_QUERY_EVENT
Definition: binlog_event.h:314
@ ROWS_QUERY_LOG_EVENT
Definition: binlog_event.h:343
@ WRITE_ROWS_EVENT
Version 2 of the Row events.
Definition: binlog_event.h:346
@ DELETE_ROWS_EVENT
Definition: binlog_event.h:348
@ XA_PREPARE_LOG_EVENT
Definition: binlog_event.h:360
@ QUERY_EVENT
Definition: binlog_event.h:299
@ UNKNOWN_EVENT
Every time you add a type, you have to.
Definition: binlog_event.h:293
@ PREVIOUS_GTIDS_LOG_EVENT
Definition: binlog_event.h:353
@ UPDATE_ROWS_EVENT
Definition: binlog_event.h:347
@ RAND_EVENT
Definition: binlog_event.h:309
@ TABLE_MAP_EVENT
Definition: binlog_event.h:316
@ STOP_EVENT
Definition: binlog_event.h:300
@ INTVAR_EVENT
Definition: binlog_event.h:302
@ USER_VAR_EVENT
Definition: binlog_event.h:310
@ ROTATE_EVENT
Definition: binlog_event.h:301
@ SLAVE_EVENT
Definition: binlog_event.h:304
const uint64_t INVALID_XID
The following constant represents the maximum of MYSQL_XID domain.
Definition: statement_events.h:48
enum_load_dup_handling
Elements of this enum describe how LOAD DATA handles duplicates.
Definition: load_data_events.h:63
constexpr auto tsid_max_length
Maximum TSID text length (without null character)
Definition: tsid.h:40
HARNESS_EXPORT std::string string_format(const char *format,...)
Definition: utilities.cc:63
Definition: instrumented_condition_variable.h:31
mutable_buffer buffer(void *p, size_t n) noexcept
Definition: buffer.h:417
Cursor end()
A past-the-end Cursor.
Definition: rules_table_service.cc:191
const char * db_name
Definition: rules_table_service.cc:54
std::set< Key, Compare, ut::allocator< Key > > set
Specialization of set which uses ut_allocator.
Definition: ut0new.h:2881
std::map< Key, Value, Compare, ut::allocator< std::pair< const Key, Value > > > map
Specialization of map which uses ut_allocator.
Definition: ut0new.h:2891
Performance schema instrumentation interface.
required string type
Definition: replication_group_member_actions.proto:33
required string event
Definition: replication_group_member_actions.proto:31
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:111
const int MAX_GNO_TEXT_LENGTH
The length of MAX_GNO when printed in decimal.
Definition: rpl_gtid.h:285
enum_gtid_type
Enumeration of different types of values for Gtid_specification, i.e, the different internal states t...
Definition: rpl_gtid.h:3854
cs::index::rpl_sidno rpl_sidno
Type of SIDNO (source ID number, first component of GTID)
Definition: rpl_gtid.h:107
mysql::gtid::Tsid Tsid
Definition: rpl_gtid_state.cc:55
enum_row_image_type
Definition: rpl_record.h:39
ulonglong my_xid
Definition: handler.h:1234
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:28
char * strmake(char *dst, const char *src, size_t length)
Definition: strmake.cc:41
Definition: m_ctype.h:422
This struct represents a specification of a GTID for a statement to be executed: either "AUTOMATIC",...
Definition: rpl_gtid.h:3971
enum_gtid_type type
The type of this GTID.
Definition: rpl_gtid.h:3984
Gtid gtid
The GTID: { SIDNO, GNO } if type == GTID; { 0, 0 } if type == AUTOMATIC or ANONYMOUS.
Definition: rpl_gtid.h:3990
rpl_gno gno
GNO of this Gtid.
Definition: rpl_gtid.h:1105
Definition: mysql_lex_string.h:39
const char * str
Definition: mysql_lex_string.h:40
size_t length
Definition: mysql_lex_string.h:41
Definition: my_bitmap.h:42
Definition: log_event.h:506
const char * name[MAX_DBS_IN_EVENT_MTS]
Definition: log_event.h:507
int num
Definition: log_event.h:508
void reset_and_dispose()
Definition: log_event.h:512
Interface for an instrumented stage progress.
Definition: psi_stage_bits.h:62
LEX_CSTRING db
Definition: table.h:776
TABLE_SHARE * s
Definition: table.h:1404
Legends running throughout the module:
Definition: rpl_rli_pdb.h:73
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:397
struct xid_t is binary compatible with the XID structure as in the X/Open CAE Specification,...
Definition: xa.h:82
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:38
synode_no q[FIFO_SIZE]
Definition: xcom_base.cc:4085
static uint64_t cache_size
Definition: xcom_cache.cc:361