 |
MySQL 9.4.0
Source Code Documentation
|
Common base class for all row-containing log events. More...
#include <log_event.h>
Classes | |
| class | Key_compare |
Public Member Functions | |
| Rows_log_event (Rows_log_event &&) noexcept=delete | |
| Rows_log_event & | operator= (Rows_log_event &&) noexcept=delete |
| Rows_log_event (const Rows_log_event &)=delete | |
| Rows_log_event & | operator= (const Rows_log_event &)=delete |
| ~Rows_log_event () override | |
| void | set_flags (flag_set flags_arg) |
| void | clear_flags (flag_set flags_arg) |
| flag_set | get_flags (flag_set flags_arg) const |
| virtual mysql::binlog::event::Log_event_type | get_general_type_code ()=0 |
| int | pack_info (Protocol *protocol) override |
| Stores a string representation of this event in the Protocol. More... | |
| int | add_row_data (uchar *data, size_t length) |
| size_t | get_data_size () override |
| MY_BITMAP const * | get_cols () const |
| MY_BITMAP const * | get_cols_ai () const |
| const mysql::binlog::event::Table_id & | get_table_id () const |
| 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 after-image. More... | |
| bool | write_data_header (Basic_ostream *ostream) override |
| bool | write_data_body (Basic_ostream *ostream) override |
| const char * | get_db () override |
 Public Member Functions inherited from mysql::binlog::event::Rows_event | |
| Rows_event (Log_event_type type_arg) | |
| Constructs an event directly. More... | |
| Rows_event (const char *buf, const Format_description_event *fde) | |
| The constructor is responsible for decoding the event contained in the buffer. More... | |
| ~Rows_event () override | |
| unsigned long long | get_table_id () const |
| enum_flag | get_flags () const |
| uint32_t | get_null_bits_len () const |
| unsigned long | get_width () const |
| std::string | get_enum_flag_string () const |
| Gets the flags listed as strings. More... | |
| Public Member Functions inherited from mysql::binlog::event::Binary_log_event | |
| virtual | ~Binary_log_event ()=0 |
| Binary_log_event (const Binary_log_event &)=default | |
| Binary_log_event (Binary_log_event &&)=default | |
| Binary_log_event & | operator= (const Binary_log_event &)=default |
| Binary_log_event & | operator= (Binary_log_event &&)=default |
| enum Log_event_type | get_event_type () const |
| Helper method. More... | |
| const Log_event_header * | header () const |
| Return a const pointer to the header of the log event. More... | |
| Log_event_header * | header () |
| Return a non-const pointer to the header of the log event. More... | |
| const Log_event_footer * | footer () const |
| Return a const pointer to the footer of the log event. More... | |
| Log_event_footer * | footer () |
| Return a non-const pointer to the footer of the log event. More... | |
| Event_reader & | reader () |
| Returns a reference to the event Event_reader object. More... | |
| Public Member Functions inherited from Log_event | |
| Log_event (mysql::binlog::event::Log_event_header *header, mysql::binlog::event::Log_event_footer *footer, enum_event_cache_type cache_type_arg, enum_event_logging_type logging_type_arg) | |
| This minimal constructor is for when you are not even sure that there is a valid THD. More... | |
| Log_event (THD *thd_arg, uint16 flags_arg, enum_event_cache_type cache_type_arg, enum_event_logging_type logging_type_arg, mysql::binlog::event::Log_event_header *header, mysql::binlog::event::Log_event_footer *footer) | |
| int | net_send (Protocol *protocol, const char *log_name, my_off_t pos) |
| Only called by SHOW BINLOG EVENTS. More... | |
| void * | operator new (size_t size) |
| bool | wrapper_my_b_safe_write (Basic_ostream *ostream, const uchar *buf, size_t data_length) |
| Write the given buffer to the given output stream, updating the checksum if checksums are enabled. More... | |
| 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 void | claim_memory_ownership (bool claim) |
| Allow thread to CLAIM or DISCLAIM the ownership of this object depends on the parameter value passed. More... | |
| 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... | |
| 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. More... | |
| bool | contains_partition_info (bool) |
| virtual uint8 | mts_number_dbs () |
| 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) |
Public Attributes | |
| uint | m_row_count |
| Public Attributes inherited from mysql::binlog::event::Rows_event | |
| Extra_row_info | m_extra_row_info |
| Public Attributes inherited from Log_event | |
| char * | temp_buf |
| bool | m_free_temp_buf_in_destructor |
| ulong | exec_time |
| uint32 | server_id |
| ulong | rbr_exec_mode |
| A storage to cache the global system variable's value. More... | |
| enum_event_cache_type | event_cache_type |
| Defines the type of the cache, if any, where the event will be stored before being flushed to disk. More... | |
| enum_event_logging_type | event_logging_type |
| Defines when information, i.e. More... | |
| ha_checksum | crc |
| Placeholder for event checksum while writing to binlog. More... | |
| ulong | mts_group_idx |
Index in rli->gaq array to indicate a group that this event is purging. More... | |
| mysql::binlog::event::Log_event_header * | common_header |
| The Log_event_header class contains the variable present in the common header. More... | |
| mysql::binlog::event::Log_event_footer * | common_footer |
| The Log_event_footer class contains the variable present in the common footer. More... | |
| Relay_log_info * | worker |
| MTS: associating the event with either an assigned Worker or Coordinator. More... | |
| ulonglong | future_event_relay_log_pos |
| A copy of the main rli value stored into event to pass to MTS worker rli. More... | |
| THD * | thd |
| db_worker_hash_entry * | mts_assigned_partitions [MAX_DBS_IN_EVENT_MTS] |
| Partition info associate with event to deliver to MTS event applier. More... | |
Protected Member Functions | |
| Rows_log_event (THD *, TABLE *, const mysql::binlog::event::Table_id &table_id, MY_BITMAP const *cols, bool is_transactional, mysql::binlog::event::Log_event_type event_type, const unsigned char *extra_row_ndb_info) | |
| Rows_log_event (const char *row_data, const mysql::binlog::event::Format_description_event *description_event) | |
| virtual int | do_add_row_data (uchar *data, size_t length) |
| 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]. More... | |
| 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 the parameter bitset fields_to_update. More... | |
| void | decide_row_lookup_algorithm_and_key () |
| int | row_operations_scan_and_key_setup () |
| int | row_operations_scan_and_key_teardown (int error) |
| 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 be applied. More... | |
| bool | is_rbr_logging_format () const override |
| Return true if the event has to be logged using RBR for DMLs. More... | |
| Protected Member Functions inherited from mysql::binlog::event::Binary_log_event | |
| Binary_log_event (Log_event_type type_code) | |
| This constructor is used to initialize the type_code of header object m_header. More... | |
| Binary_log_event (const char **buf, const Format_description_event *fde) | |
| This constructor will create a new object of Log_event_header and initialize the variable m_header, which in turn will be used to initialize Log_event's member common_header. More... | |
| Protected Member Functions inherited from Log_event | |
| uint32 | write_header_to_memory (uchar *buf) |
| Writes the common header of this event to the given memory buffer. More... | |
| bool | write_header (Basic_ostream *ostream, size_t data_length) |
| Writes the common-header of this event to the given output stream and updates the checksum. More... | |
| bool | write_footer (Basic_ostream *ostream) |
| bool | need_checksum () |
| A decider of whether to trigger checksum computation or not. More... | |
| enum_skip_reason | continue_group (Relay_log_info *rli) |
| Helper function to ignore an event w.r.t. More... | |
Static Protected Member Functions | |
| 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 not. More... | |
Protected Attributes | |
| Rows_applier_psi_stage | m_psi_progress |
| TABLE * | m_table |
| MY_BITMAP | m_cols |
| MY_BITMAP | m_local_cols |
| Bitmap denoting columns available in the image as they appear in the table setup. More... | |
| Hash_slave_rows | m_hash |
| Hash table that will hold the entries for while using HASH_SCAN algorithm to search and update/delete rows. More... | |
| uint | m_rows_lookup_algorithm |
| The algorithm to use while searching for rows using the before image. More... | |
| MY_BITMAP | m_cols_ai |
| Bitmap for columns available in the after image, if present. More... | |
| MY_BITMAP | m_local_cols_ai |
| Bitmap denoting columns available in the after-image as they appear in the table setup. More... | |
| uint32 | m_bitbuf [128/(sizeof(uint32) *8)] |
| uint32 | m_bitbuf_ai [128/(sizeof(uint32) *8)] |
| uchar * | m_rows_buf |
| uchar * | m_rows_cur |
| uchar * | m_rows_end |
| const uchar * | m_curr_row |
| const uchar * | m_curr_row_end |
| uchar * | m_key |
| uint | m_key_index |
| KEY * | m_key_info |
| std::set< uchar *, Key_compare > | m_distinct_keys |
| std::set< uchar *, Key_compare >::iterator | m_itr |
| 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_SCAN search algorithm. More... | |
| Protected Attributes inherited from mysql::binlog::event::Rows_event | |
| Log_event_type | m_type |
| Table_id | m_table_id |
| Actual event type. More... | |
| uint16_t | m_flags |
| unsigned long | m_width |
| Flags for row-level events. More... | |
| uint32_t | n_bits_len |
| The width of the columns bitmap. More... | |
| uint16_t | var_header_len |
| value determined by (m_width + 7) / 8 More... | |
| std::vector< uint8_t > | columns_before_image |
| std::vector< uint8_t > | columns_after_image |
| std::vector< uint8_t > | row |
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 |
| The method either increments the relay log position or commits the current statement and increments the master group position if the event is STMT_END_F flagged and the statement corresponds to the autocommit query (i.e replicated without wrapping in BEGIN/COMMIT) 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... | |
| virtual int | do_before_row_operations (const Relay_log_info *const log)=0 |
| virtual int | do_after_row_operations (const Relay_log_info *const log, int error)=0 |
| virtual int | do_exec_row (const Relay_log_info *const rli)=0 |
| int | handle_idempotent_and_ignored_errors (Relay_log_info const *rli, int *err) |
| Private member function called while handling idempotent errors. More... | |
| void | do_post_row_operations (Relay_log_info const *rli, int err) |
| Private member function called after updating/deleting a row. More... | |
| 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. More... | |
| int | do_index_scan_and_update (Relay_log_info const *rli) |
| Implementation of the index scan and update algorithm. More... | |
| int | do_hash_scan_and_update (Relay_log_info const *rli) |
| Implementation of the hash_scan and update algorithm. More... | |
| int | do_table_scan_and_update (Relay_log_info const *rli) |
| Implementation of the legacy table_scan and update algorithm. More... | |
| 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-image. More... | |
| int | open_record_scan () |
| Initializes scanning of rows. More... | |
| int | close_record_scan () |
| Does the cleanup. More... | |
| int | next_record_scan (bool first_read) |
| Fetches next row. More... | |
| int | add_key_to_distinct_keyset () |
| Populates the m_distinct_keys with unique keys to be modified during HASH_SCAN over keys. More... | |
| int | do_hash_row (Relay_log_info const *rli) |
| Populates the m_hash when using HASH_SCAN. More... | |
| 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. More... | |
Private Attributes | |
| 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... | |
| MY_BITMAP | write_set_backup |
| This bitmap is used as a backup for the write set while we calculate the values for any hidden generated columns (functional indexes). More... | |
Friends | |
| class | Old_rows_log_event |
Additional Inherited Members | |
| Static Public Member Functions inherited from mysql::binlog::event::Rows_event | |
| static std::string | get_flag_string (enum_flag flag) |
| Gets a string describing the flags. More... | |
| Static Public Member Functions inherited from Log_event | |
| static void | init_show_field_list (mem_root_deque< Item * > *field_list) |
| init_show_field_list() prepares the column names and types for the output of SHOW BINLOG EVENTS; it is used only by SHOW BINLOG EVENTS. More... | |
| static void | operator delete (void *ptr, size_t) |
| static void * | operator new (size_t, void *ptr) |
| static void | operator delete (void *, void *) |
| static const char * | get_type_str (mysql::binlog::event::Log_event_type type) |
| Returns the human readable name of the given event type. More... | |
| static const char * | get_type_str (uint type) |
| Get the name of an event type, or "Unknown" if out of range. More... | |
| static bool | is_mts_sequential_exec (mysql::binlog::event::Log_event_type type_code) |
| static enum enum_mts_event_exec_mode | get_mts_execution_mode (bool mts_in_group, mysql::binlog::event::Log_event_type type_code, uint32 server_id, uint32 log_pos) |
| Static Public Attributes inherited from mysql::binlog::event::Binary_log_event | |
| static const int | LOG_EVENT_TYPES = (ENUM_END_EVENT - 1) |
| Protected Types inherited from Log_event | |
| enum | enum_event_cache_type { EVENT_INVALID_CACHE = 0 , EVENT_STMT_CACHE , EVENT_TRANSACTIONAL_CACHE , EVENT_NO_CACHE , EVENT_CACHE_COUNT } |
| enum | enum_event_logging_type { EVENT_INVALID_LOGGING = 0 , EVENT_NORMAL_LOGGING , EVENT_IMMEDIATE_LOGGING , EVENT_CACHE_LOGGING_COUNT } |
Common base class for all row-containing log events.
RESPONSIBILITIES
Encode the common parts of all events containing rows, which are:
Virtual inheritance is required here to handle the diamond problem in the class Write_rows_log_event, Update_rows_log_event and Delete_rows_log_event. The diamond structure is explained in Write_rows_log_event, Update_rows_log_event, Delete_rows_log_event
| typedef uint16 Rows_log_event::flag_set |
|
deletenoexcept |
|
delete |
|
override |
|
protected |
|
protected |
|
private |
Populates the m_distinct_keys with unique keys to be modified during HASH_SCAN over keys.
| 0 | success |
|
inline |
|
inline |
|
private |
Does the cleanup.
|
protected |
|
protectedvirtual |
|
privatepure virtual |
Implemented in Write_rows_log_event, Update_rows_log_event, and Delete_rows_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 |
When using RBR and MyISAM MERGE tables the base tables that make up the MERGE table can be appended to the list of tables to lock.
Thus, we just check compatibility for those that tables that have a correspondent table map event (ie, those that are actually going to be accessed while applying the event). That's why the loop stops at rli->tables_to_lock_count .
NOTE: The base tables are added here are removed when close_thread_tables is called.
Skip update rows events that don't have data for this slave's table.
If there are no columns marked in the read_set for this table, that means that we cannot lookup any row using the available BI in the binary log. Thence, we immediately raise an error: HA_ERR_END_OF_FILE.
Reimplemented from Log_event.
|
private |
Commodity wrapper around do_exec_row(), that deals with resetting the thd reference in the table.
|
privatepure virtual |
Implemented in Write_rows_log_event, Update_rows_log_event, and Delete_rows_log_event.
|
privatepure virtual |
Implemented in Write_rows_log_event, Update_rows_log_event, and Delete_rows_log_event.
|
private |
Populates the m_hash when using HASH_SCAN.
Thence, it:
| rli | The reference to the relay log info object. |
|
private |
Implementation of the hash_scan and update algorithm.
It collects rows positions in a hashtable until the last row is unpacked. Then it scans the table to update and when a record in the table matches the one in the hashtable, the update/delete is performed.
|
private |
Implementation of the index scan and update algorithm.
It uses PK, UK or regular Key to search for the record to update. When found it updates it.
|
private |
Private member function called after updating/deleting a row.
It performs some assertions and more importantly, it updates m_curr_row so that the next row is processed during the row execution main loop (Rows_log_event::do_apply_event()).
| rli | Pointer to relay log info structure. |
| err | the current error code. |
|
private |
This member function scans the table and applies the changes that had been previously hashed.
As such, m_hash MUST be filled by do_hash_row before calling this member function.
| rli | The reference to the relay log info object. |
The do..while loop takes care of the scenario of same row being updated more than once within a single Update_rows_log_event by performing the hash lookup for the updated_row(by taking the AI stored in table->record[0] after the ha_update_row()) when table has no primary key.
This can happen when update is called from a stored function. Ex: CREATE FUNCTION f1 () RETURNS INT BEGIN UPDATE t1 SET a = 2 WHERE a = 1; UPDATE t1 SET a = 3 WHERE a = 2; RETURN 0; END
If there are collisions we need to be sure that this is indeed the record we want. Loop through all records for the given key and explicitly compare them against the record we got from the storage engine.
We found the entry we needed, just apply the changes.
At this point, both table->record[0] and table->record[1] have the SE row that matched the one in the hash table.
Thence if this is a DELETE we wouldn't need to mess around with positions anymore, but since this can be an update, we need to provide positions so that AI is unpacked correctly to table->record[0] in UPDATE implementation of do_exec_row().
if the rbr_exec_mode is set to Idempotent, we cannot expect the hash to be empty. In such cases we count the number of idempotent errors and check if it is equal to or greater than the number of rows left in the hash.
Reset the last positions, because the positions are lost while handling entries in the hash.
|
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.
|
private |
Implementation of the legacy table_scan and update algorithm.
For each unpacked row it scans the storage engine table for a match. When a match is found, the update/delete operations are performed.
unpack the before image
save a copy so that we can compare against it later
|
overrideprivatevirtual |
The method either increments the relay log position or commits the current statement and increments the master group position if the event is STMT_END_F flagged and the statement corresponds to the autocommit query (i.e replicated without wrapping in BEGIN/COMMIT)
| 0 | Success |
| non-zero | Error in the statement commit |
Reimplemented from Log_event.
|
inline |
|
inline |
|
overridevirtual |
Reimplemented from Log_event.
|
inlineoverridevirtual |
Reimplemented from Log_event.
|
pure virtual |
Implemented in Write_rows_log_event, Update_rows_log_event, and Delete_rows_log_event.
|
inline |
|
private |
Private member function called while handling idempotent errors.
| rli | Pointer to relay log info structure. | |
| [in,out] | err | the error to handle. If it is listed as idempotent/ignored related error, then it is cleared. |
|
protected |
Helper function to check whether there is an auto increment column on the table where the event is to be applied.
GIPKs when not present in the source table are also considered a auto inc column in a extra column.
| rli | the relay log object associated to the replicated table |
|
inlineoverrideprotectedvirtual |
Return true if the event has to be logged using RBR for DMLs.
Reimplemented from Log_event.
|
staticprotected |
Helper function to check whether the storage engine error allows for the transaction to be retried or not.
| error | Storage engine error |
| true | if the error is retryable. |
| false | if the error is non-retryable. |
|
private |
Fetches next row.
If it is a HASH_SCAN over an index, it populates table->record[0] with the next row corresponding to the index. If the indexes are in non-contigous ranges it fetches record corresponding to the key value in the next range.
| first_read | signifying if this is the first time we are reading a row over an index. |
|
private |
Initializes scanning of rows.
Opens an index and initializes an iterator over a list of distinct keys (m_distinct_keys) if it is a HASH_SCAN over an index or the table if its a HASH_SCAN over the table.
|
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.
|
pure virtual |
Compares the table's read/write_set with the columns included in this event's before-image and/or after-image.
Each subclass (Write/Update/Delete) implements this function by comparing on the image(s) pertinent to the subclass.
| [in] | table | The table to compare this events bitmaps against. |
| true | if sets match |
| false | otherwise (following bitmap_cmp return logic). |
Implemented in Write_rows_log_event, Update_rows_log_event, and Delete_rows_log_event.
|
protected |
|
protected |
|
inline |
|
inlineprivatevirtual |
Seek past the after-image of an update event, in case a row was processed without reading the after-image.
An update event may process a row without reading the after-image, e.g. in case of ignored or idempotent errors. To ensure that the read position for the next row is correct, we need to seek past the after-image.
| rli | The applier context |
| curr_bi_start | The read position of the beginning of the before-image. (The function compares this with m_curr_row to know if the after-image has been read or not.) |
| 0 | Success |
| ER_* | Error code returned by unpack_current_row |
Reimplemented in Update_rows_log_event.
|
protected |
Unpack the current row image from the event into m_table->record[0].
| rli | The applier context. |
| cols | The bitmap of columns included in the update. |
| is_after_image | Should be true if this is an after-image, false if it is a before-image. |
| only_seek | unpack_row() |
| 0 | Success |
| ER_* | On error, it is guaranteed that the error has been reported through my_error, and the corresponding ER_* code is returned. Currently the error codes are: EE_OUTOFMEMORY, ER_REPLICA_CORRUPT_EVENT, or various JSON errors when applying JSON diffs (ER_COULD_NOT_APPLY_JSON_DIFF, ER_INVALID_JSON_BINARY_DATA, and maybe others). |
|
protected |
Updates the generated columns of the TABLE object referenced by m_table, that have an active bit in the parameter bitset fields_to_update.
| fields_to_update | A bitset where the bit at the index of generated columns to update must be set to 1 |
|
overridevirtual |
Reimplemented from Log_event.
|
overridevirtual |
Reimplemented from Log_event.
|
friend |
|
protected |
|
protected |
Bitmap for columns available in the after image, if present.
These fields are only available for Update_rows events. Observe that the width of both the before image COLS vector and the after image COLS vector is the same: the number of columns of the table on the master.
|
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.
|
protected |
|
protected |
|
protected |
A spare buffer which will be used when saving the distinct keys for doing an index scan with HASH_SCAN search algorithm.
|
protected |
|
protected |
Hash table that will hold the entries for while using HASH_SCAN algorithm to search and update/delete rows.
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
Bitmap denoting columns available in the image as they appear in the table setup.
On some setups, the number and order of columns may differ from master to slave so, a bitmap for local available columns is computed using ReplicatedColumnsView utility class.
|
protected |
Bitmap denoting columns available in the after-image as they appear in the table setup.
On some setups, the number and order of columns may differ from master to slave so, a bitmap for local available columns is computed using ReplicatedColumnsView utility class.
|
protected |
| uint Rows_log_event::m_row_count |
|
protected |
|
protected |
|
protected |
|
protected |
The algorithm to use while searching for rows using the before image.
|
protected |
|
private |
This bitmap is used as a backup for the write set while we calculate the values for any hidden generated columns (functional indexes).
In order to calculate the values, the columns must be marked in the write set. After the values are calculated, we set the write set back to its original value.
1.9.2