![]() |
MySQL 9.1.0
Source Code Documentation
|
Table_map_log_event which maps a table definition to a number. More...
#include <log_event.h>
Public Member Functions | |
Table_map_log_event (Table_map_log_event &&) noexcept=delete | |
Table_map_log_event & | operator= (Table_map_log_event &&) noexcept=delete |
Table_map_log_event (const Table_map_log_event &)=delete | |
Table_map_log_event & | operator= (const Table_map_log_event &)=delete |
flag_set | get_flags (flag_set flag) const |
Table_map_log_event (THD *thd_arg, TABLE *tbl, const mysql::binlog::event::Table_id &tid, bool using_trans) | |
Table_map_log_event (const char *buf, const mysql::binlog::event::Format_description_event *description_event) | |
void | claim_memory_ownership (bool claim) override |
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed. More... | |
~Table_map_log_event () override | |
const mysql::binlog::event::Table_id & | get_table_id () const |
const char * | get_table_name () const |
const char * | get_db_name () const |
size_t | get_data_size () override |
virtual int | save_field_metadata () |
Save the field metadata based on the real_type of the field. More... | |
bool | write_data_header (Basic_ostream *ostream) override |
bool | write_data_body (Basic_ostream *ostream) override |
const char * | get_db () override |
uint8 | mts_number_dbs () override |
uint8 | get_mts_dbs (Mts_db_names *arg, Rpl_filter *rpl_filter) override |
int | pack_info (Protocol *protocol) override |
Stores a string representation of this event in the Protocol. More... | |
bool | has_generated_invisible_primary_key () const |
bool | is_rbr_logging_format () const override |
Return true if the event has to be logged using RBR for DMLs. More... | |
![]() | |
Table_map_event (const char *buf, const Format_description_event *fde) | |
Table_map_event (const Table_id &tid, unsigned long colcnt, const char *dbnam, size_t dblen, const char *tblnam, size_t tbllen) | |
~Table_map_event () override | |
Table_map_event () | |
unsigned long long | get_table_id () |
std::string | get_table_name () |
std::string | get_db_name () |
![]() | |
virtual | ~Binary_log_event ()=0 |
Binary_log_event (const Binary_log_event &)=default | |
Binary_log_event (Binary_log_event &&)=default | |
Binary_log_event & | operator= (const Binary_log_event &)=default |
Binary_log_event & | operator= (Binary_log_event &&)=default |
enum Log_event_type | get_event_type () const |
Helper method. More... | |
const Log_event_header * | header () const |
Return a const pointer to the header of the log event. More... | |
Log_event_header * | header () |
Return a non-const pointer to the header of the log event. More... | |
const Log_event_footer * | footer () const |
Return a const pointer to the footer of the log event. More... | |
Log_event_footer * | footer () |
Return a non-const pointer to the footer of the log event. More... | |
Event_reader & | reader () |
Returns a reference to the event Event_reader object. More... | |
![]() | |
Log_event (mysql::binlog::event::Log_event_header *header, mysql::binlog::event::Log_event_footer *footer, enum_event_cache_type cache_type_arg, enum_event_logging_type logging_type_arg) | |
This minimal constructor is for when you are not even sure that there is a valid THD. More... | |
Log_event (THD *thd_arg, uint16 flags_arg, enum_event_cache_type cache_type_arg, enum_event_logging_type logging_type_arg, mysql::binlog::event::Log_event_header *header, mysql::binlog::event::Log_event_footer *footer) | |
int | net_send (Protocol *protocol, const char *log_name, my_off_t pos) |
Only called by SHOW BINLOG EVENTS. More... | |
void * | operator new (size_t size) |
bool | wrapper_my_b_safe_write (Basic_ostream *ostream, const uchar *buf, size_t data_length) |
Write the given buffer to the given output stream, updating the checksum if checksums are enabled. More... | |
virtual bool | write (Basic_ostream *ostream) |
time_t | get_time () |
Prints a "session_var=value" string. More... | |
virtual mysql::binlog::event::Log_event_type | get_type_code () const |
virtual bool | is_sbr_logging_format () const |
Return true if the event has to be logged using SBR for DMLs. More... | |
bool | is_valid () |
void | set_artificial_event () |
void | set_relay_log_event () |
bool | is_artificial_event () const |
bool | is_relay_log_event () const |
bool | is_ignorable_event () const |
bool | is_no_filter_event () const |
bool | is_using_trans_cache () const |
bool | is_using_stmt_cache () const |
bool | is_using_immediate_logging () const |
Log_event (mysql::binlog::event::Log_event_header *header, mysql::binlog::event::Log_event_footer *footer) | |
virtual | ~Log_event () |
void | register_temp_buf (char *buf, bool free_in_destructor=true) |
void | free_temp_buf () |
const char * | get_type_str () const |
Returns the human readable name of this event's type. More... | |
bool | is_mts_sequential_exec () const |
Is called from get_mts_execution_mode() to. More... | |
bool | contains_partition_info (bool) |
bool | is_mts_group_isolated () |
virtual bool | starts_group () const |
Events of a certain type can start or end a group of events treated transactionally wrt binlog. More... | |
virtual bool | ends_group () const |
int | apply_event (Relay_log_info *rli) |
Apply the event to the database. More... | |
int | apply_gtid_event (Relay_log_info *rli) |
Apply the GTID event in curr_group_data to the database. More... | |
int | update_pos (Relay_log_info *rli) |
Update the relay log position. More... | |
enum_skip_reason | shall_skip (Relay_log_info *rli) |
Decide if the event shall be skipped, and the reason for skipping it. More... | |
virtual int | do_apply_event_worker (Slave_worker *w) |
Private Member Functions | |
int | do_apply_event (Relay_log_info const *rli) override |
Primitive to apply an event to the database. More... | |
int | do_update_pos (Relay_log_info *rli) override |
Advance relay log coordinates. More... | |
enum_skip_reason | do_shall_skip (Relay_log_info *rli) override |
Decide if this event shall be skipped or not and the reason for skipping it. More... | |
void | init_metadata_fields () |
Capture the optional metadata fields which should be logged into table_map_log_event and serialize them into m_metadata_buf. More... | |
bool | init_signedness_field () |
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. More... | |
bool | init_column_name_field () |
bool | init_set_str_value_field () |
bool | init_enum_str_value_field () |
bool | init_geometry_type_field () |
bool | init_primary_key_field () |
bool | init_column_visibility_field () |
bool | init_vector_dimensionality_field () |
Private Attributes | |
TABLE * | m_table |
StringBuffer< 1024 > | m_metadata_buf |
ColumnViewPtr | m_column_view {nullptr} |
Wrapper around TABLE *m_table that abstracts the table field set iteration logic, since it is not mandatory that all table fields are to be replicated. More... | |
Additional Inherited Members | |
![]() | |
static void | init_show_field_list (mem_root_deque< Item * > *field_list) |
init_show_field_list() prepares the column names and types for the output of SHOW BINLOG EVENTS; it is used only by SHOW BINLOG EVENTS. More... | |
static void | operator delete (void *ptr, size_t) |
static void * | operator new (size_t, void *ptr) |
static void | operator delete (void *, void *) |
static const char * | get_type_str (mysql::binlog::event::Log_event_type type) |
Returns the human readable name of the given event type. More... | |
static const char * | get_type_str (uint type) |
Get the name of an event type, or "Unknown" if out of range. More... | |
static bool | is_mts_sequential_exec (mysql::binlog::event::Log_event_type type_code) |
static enum enum_mts_event_exec_mode | get_mts_execution_mode (bool mts_in_group, mysql::binlog::event::Log_event_type type_code, uint32 server_id, uint32 log_pos) |
![]() | |
Table_id | m_table_id |
Event post header contents. More... | |
flag_set | m_flags |
size_t | m_data_size |
std::string | m_dbnam |
event data size More... | |
unsigned long long int | m_dblen |
std::string | m_tblnam |
unsigned long long int | m_tbllen |
unsigned long | m_colcnt |
unsigned char * | m_coltype |
unsigned long | m_field_metadata_size |
The size of field metadata buffer set by calling save_field_metadata() More... | |
unsigned char * | m_field_metadata |
unsigned char * | m_null_bits |
field metadata More... | |
unsigned int | m_optional_metadata_len |
unsigned char * | m_optional_metadata |
![]() | |
char * | temp_buf |
bool | m_free_temp_buf_in_destructor |
ulong | exec_time |
uint32 | server_id |
ulong | rbr_exec_mode |
A storage to cache the global system variable's value. More... | |
enum_event_cache_type | event_cache_type |
Defines the type of the cache, if any, where the event will be stored before being flushed to disk. More... | |
enum_event_logging_type | event_logging_type |
Defines when information, i.e. More... | |
ha_checksum | crc |
Placeholder for event checksum while writing to binlog. More... | |
ulong | mts_group_idx |
Index in rli->gaq array to indicate a group that this event is purging. More... | |
mysql::binlog::event::Log_event_header * | common_header |
The Log_event_header class contains the variable present in the common header. More... | |
mysql::binlog::event::Log_event_footer * | common_footer |
The Log_event_footer class contains the variable present in the common footer. More... | |
Relay_log_info * | worker |
MTS: associating the event with either an assigned Worker or Coordinator. More... | |
ulonglong | future_event_relay_log_pos |
A copy of the main rli value stored into event to pass to MTS worker rli. More... | |
THD * | thd |
db_worker_hash_entry * | mts_assigned_partitions [MAX_DBS_IN_EVENT_MTS] |
Partition info associate with event to deliver to MTS event applier. More... | |
![]() | |
static const int | LOG_EVENT_TYPES = (ENUM_END_EVENT - 1) |
![]() | |
enum | enum_event_cache_type { EVENT_INVALID_CACHE = 0 , EVENT_STMT_CACHE , EVENT_TRANSACTIONAL_CACHE , EVENT_NO_CACHE , EVENT_CACHE_COUNT } |
enum | enum_event_logging_type { EVENT_INVALID_LOGGING = 0 , EVENT_NORMAL_LOGGING , EVENT_IMMEDIATE_LOGGING , EVENT_CACHE_LOGGING_COUNT } |
![]() | |
Binary_log_event (Log_event_type type_code) | |
This constructor is used to initialize the type_code of header object m_header. More... | |
Binary_log_event (const char **buf, const Format_description_event *fde) | |
This constructor will create a new object of Log_event_header and initialize the variable m_header, which in turn will be used to initialize Log_event's member common_header. More... | |
![]() | |
uint32 | write_header_to_memory (uchar *buf) |
Writes the common header of this event to the given memory buffer. More... | |
bool | write_header (Basic_ostream *ostream, size_t data_length) |
Writes the common-header of this event to the given output stream and updates the checksum. More... | |
bool | write_footer (Basic_ostream *ostream) |
bool | need_checksum () |
A decider of whether to trigger checksum computation or not. More... | |
enum_skip_reason | continue_group (Relay_log_info *rli) |
Helper function to ignore an event w.r.t. More... | |
Table_map_log_event which maps a table definition to a number.
anonymous enum |
|
deletenoexcept |
|
delete |
Table_map_log_event::Table_map_log_event | ( | THD * | thd_arg, |
TABLE * | tbl, | ||
const mysql::binlog::event::Table_id & | tid, | ||
bool | using_trans | ||
) |
Table_map_log_event::Table_map_log_event | ( | const char * | buf, |
const mysql::binlog::event::Format_description_event * | description_event | ||
) |
|
overridedefault |
|
overridevirtual |
Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed.
claim | True - claim ownership of the memory False - disclaim ownership of the memory |
Reimplemented from Log_event.
|
overrideprivatevirtual |
Primitive to apply an event to the database.
This is where the change to the database is made.
rli | Pointer to relay log info structure |
0 | Event applied successfully |
errno | Error code if event application failed |
Reimplemented from Log_event.
|
overrideprivatevirtual |
Decide if this event shall be skipped or not and the reason for skipping it.
The default implementation decide that the event shall be skipped if either:
rli->replicate_same_server_id
is true, orrli->slave_skip_counter
is greater than zero.Log_event::EVENT_SKIP_NOT | The event shall not be skipped and should be applied. |
Log_event::EVENT_SKIP_IGNORE | The event shall be skipped by just ignoring it, i.e., the slave skip counter shall not be changed. This happends if, for example, the originating server id of the event is the same as the server id of the slave. |
Log_event::EVENT_SKIP_COUNT | The event shall be skipped because the slave skip counter was non-zero. The caller shall decrease the counter by one. |
Reimplemented from Log_event.
|
overrideprivatevirtual |
Advance relay log coordinates.
This function is called to advance the relay log coordinates to just after the event. It is essential that both the relay log coordinate and the group log position is updated correctly, since this function is used also for skipping events.
Normally, each implementation of do_update_pos() shall:
rli | Pointer to relay log info structure |
0 | Coordinates changed successfully |
errno | Error code if advancing failed (usually just 1). Observe that handler errors are returned by the do_apply_event() function, and not by this one. |
Reimplemented from Log_event.
|
inlineoverridevirtual |
Reimplemented from Log_event.
|
inlineoverridevirtual |
Reimplemented from Log_event.
|
inline |
|
inlineoverridevirtual |
[out] | arg | pointer to a struct containing char* array pointers be filled in and the number of filled instances. |
rpl_filter | pointer to a replication filter. |
Reimplemented from Log_event.
|
inline |
|
inline |
bool Table_map_log_event::has_generated_invisible_primary_key | ( | ) | const |
|
private |
Capture and serialize character sets.
Character sets for character columns (TEXT etc) and character sets for ENUM and SET columns are stored in different metadata fields. The reason is that TEXT character sets are included even when binlog_row_metadata=MINIMAL, whereas ENUM and SET character sets are included only when binlog_row_metadata=FULL.
include_type | Predicate to determine if a given Field object is to be included in the metadata field. |
default_charset_type | Type code when storing in "default charset" format. (See comment above Table_maps_log_event in mysql/binlog/event/rows_event.h) |
column_charset_type | Type code when storing in "column charset" format. (See comment above Table_maps_log_event in mysql/binlog/event/rows_event.h) |
|
private |
|
private |
|
private |
|
private |
|
private |
Capture the optional metadata fields which should be logged into table_map_log_event and serialize them into m_metadata_buf.
|
private |
|
private |
|
private |
|
private |
|
inlineoverridevirtual |
Return true if the event has to be logged using RBR for DMLs.
Reimplemented from Log_event.
|
delete |
|
deletenoexcept |
|
overridevirtual |
Stores a string representation of this event in the Protocol.
This is used by SHOW BINLOG EVENTS.
0 | success |
nonzero | error |
Reimplemented from Log_event.
|
virtual |
Save the field metadata based on the real_type of the field.
The metadata saved depends on the type of the field. Some fields store a single byte for pack_length() while others store two bytes for field_length (max length).
0 | Ok. |
|
overridevirtual |
Reimplemented from Log_event.
|
overridevirtual |
Reimplemented from Log_event.
|
private |
Wrapper around TABLE *m_table
that abstracts the table field set iteration logic, since it is not mandatory that all table fields are to be replicated.
For details,
A smart pointer is used here as the developer might want to instantiate the view using different classes in runtime depending on the given context. As of now the column view is only used on outbound scenarios
|
private |
|
private |