27#error "Don't include this C++ header file from a non-C++ file!"
33#include <unordered_map>
94 uint, std::unique_ptr<HASH_ROW_ENTRY, hash_slave_rows_free_entry>>::
220 uint, std::unique_ptr<HASH_ROW_ENTRY, hash_slave_rows_free_entry>>
303 for (uint i = 0; i <
size(); i++)
328 switch (source_type) {
330 int real_type = source_metadata >> 8;
389 return ((
m_null_bits[(index / 8)] & (1 << (index % 8))) ==
430 TABLE **conv_table_var);
457 bool replica_has_gipk)
const;
513 const char *table_name_arg,
size_t table_name_length_arg,
515 :
Table_ref(db_name_arg, db_length_arg, table_name_arg,
516 table_name_length_arg, alias_arg, lock_type_arg) {}
570#define DBUG_PRINT_BITSET(N, FRM, BS) \
574 for (i = 0; i < std::min(uint{sizeof(buf) - 1}, (BS)->n_bits); i++) \
575 buf[i] = bitmap_is_set((BS), i) ? '1' : '0'; \
577 DBUG_PRINT((N), ((FRM), buf)); \
Definition: rpl_utility.h:523
bool is_empty()
Definition: rpl_utility.cc:1284
int add(Log_event *ev)
Definition: rpl_utility.cc:1278
~Deferred_log_events()
Definition: rpl_utility.cc:1276
bool execute(Relay_log_info *rli)
Definition: rpl_utility.cc:1286
void rewind()
Definition: rpl_utility.cc:1300
Prealloced_array< Log_event *, 32 > m_array
Definition: rpl_utility.h:525
Deferred_log_events()
Definition: rpl_utility.cc:1273
Definition: rpl_utility.h:108
malloc_unordered_multimap< uint, std::unique_ptr< HASH_ROW_ENTRY, hash_slave_rows_free_entry > > m_hash
The hashtable itself.
Definition: rpl_utility.h:221
bool del(HASH_ROW_ENTRY *entry)
Deletes the entry pointed by entry.
Definition: rpl_utility.cc:1161
HASH_ROW_ENTRY * get(TABLE *table, MY_BITMAP *cols)
Gets the entry, from the hash table, that matches the data in table->record[0] and signaled using col...
Definition: rpl_utility.cc:1095
HASH_ROW_ENTRY * make_entry()
Allocates an empty entry to be added to the hash table.
Definition: rpl_utility.cc:1024
bool next(HASH_ROW_ENTRY **entry)
Gets the entry that stands next to the one pointed to by entry.
Definition: rpl_utility.cc:1120
bool deinit(void)
De-initializes the hash table.
Definition: rpl_utility.cc:1016
int size()
Returns the number of entries in the hash table.
Definition: rpl_utility.cc:1022
uint make_hash_key(TABLE *table, MY_BITMAP *cols)
Auxiliary and internal method used to create an hash key, based on the data in table->record[0] buffe...
Definition: rpl_utility.cc:1169
bool init(void)
Initializes the hash table.
Definition: rpl_utility.cc:1014
bool put(TABLE *table, MY_BITMAP *cols, HASH_ROW_ENTRY *entry)
Puts data into the hash table.
Definition: rpl_utility.cc:1074
bool is_empty(void)
Checks if the hash table is empty or not.
Definition: rpl_utility.cc:1008
This is the abstract base class for binary log events.
Definition: log_event.h:542
A typesafe replacement for DYNAMIC_ARRAY.
Definition: prealloced_array.h:70
Definition: rpl_rli.h:202
Sentry class for managing the need to create and dispose of a local THD instance.
Definition: rpl_utility.h:603
bool m_is_locally_initialized
Tells whether or not the active THD object was created in this object constructor.
Definition: rpl_utility.h:636
THD_instance_guard(THD *thd)
If the given THD object pointer is nullptr, a new instance will be initialized within the constructor...
Definition: rpl_utility.cc:1328
THD * m_target
The active THD object pointer.
Definition: rpl_utility.h:631
virtual ~THD_instance_guard()
If a new instance of THD was created in the constructor, it will be disposed here.
Definition: rpl_utility.cc:1340
For each client connection we create a separate thread with THD serving as a thread/connection descri...
Definition: sql_lexer_thd.h:33
std::unordered_multimap, but with my_malloc, so that you can track the memory used using PSI memory k...
Definition: map_helpers.h:188
A (partial) implementation of std::deque allocating its blocks on a MEM_ROOT.
Definition: mem_root_deque.h:109
A table definition from the master.
Definition: rpl_utility.h:247
int m_json_column_count
Definition: rpl_utility.h:500
ulong filtered_size(bool replica_has_gipk) const
Return the number of fields there is type data for minus the GIPK field if this field does not exist ...
Definition: rpl_utility.h:285
ulong m_size
Definition: rpl_utility.h:493
bool compatible_with(THD *thd, Relay_log_info *rli, TABLE *table, TABLE **conv_table_var)
Decide if the table definition is compatible with a table.
Definition: rpl_utility.cc:466
uint32 calc_field_size(uint col, const uchar *master_data) const
Definition: rpl_utility.cc:95
bool compute_source_table_gipk_info(THD &thd, TABLE *table)
Evaluates if the source table might contain a GIPK.
Definition: rpl_utility.cc:792
enum_field_types type(ulong index) const
Definition: rpl_utility.h:319
table_def()=default
No-op constructor.
bool * m_is_array
Definition: rpl_utility.h:501
uchar * m_memory
Definition: rpl_utility.h:499
int json_column_count() const
Return the number of JSON columns in this table.
Definition: rpl_utility.h:299
ulong size() const
Return the number of fields there is type data for.
Definition: rpl_utility.h:277
unsigned char * m_type
Definition: rpl_utility.h:494
uint m_field_metadata_size
Definition: rpl_utility.h:495
TABLE * create_conversion_table(THD *thd, Relay_log_info *rli, TABLE *target_table, bool replica_has_gipk) const
Create a virtual in-memory temporary table structure.
Definition: rpl_utility.cc:646
uint * m_field_metadata
Definition: rpl_utility.h:496
enum_field_types binlog_type(ulong index) const
Definition: rpl_utility.h:294
bool m_is_gipk_on_table
Definition: rpl_utility.h:503
bool m_is_gipk_set
Definition: rpl_utility.h:502
uint16 m_flags
Definition: rpl_utility.h:498
bool is_array(uint index) const
Returns whether or not the field at index is a typed array.
Definition: rpl_utility.h:375
bool is_gipk_present_on_source_table() const
Checks if the table contains a GIPK.
Definition: rpl_utility.cc:787
~table_def()
Definition: rpl_utility.cc:980
bool maybe_null(uint index) const
Definition: rpl_utility.h:387
uchar * m_null_bits
Definition: rpl_utility.h:497
uint field_metadata(uint index) const
Definition: rpl_utility.h:364
This file contains the field type.
enum_field_types
Column types for MySQL Note: Keep include/mysql/components/services/bits/stored_program_bits....
Definition: field_types.h:54
@ MYSQL_TYPE_SET
Definition: field_types.h:81
@ MYSQL_TYPE_NEWDATE
Internal to MySQL.
Definition: field_types.h:69
@ MYSQL_TYPE_JSON
Definition: field_types.h:78
@ MYSQL_TYPE_STRING
Definition: field_types.h:87
@ MYSQL_TYPE_ENUM
Definition: field_types.h:80
@ MYSQL_TYPE_DATE
Definition: field_types.h:65
static int flags[50]
Definition: hp_test1.cc:39
Some integer typedefs for easier portability.
unsigned char uchar
Definition: my_inttypes.h:51
uint16_t uint16
Definition: my_inttypes.h:64
uint32_t uint32
Definition: my_inttypes.h:66
static bool replace
Definition: mysqlimport.cc:69
static PFS_engine_table_share_proxy table
Definition: pfs.cc:60
const byte * find(const Pages *pages, const page_id_t &page_id) noexcept
Find a doublewrite copy of a page.
Definition: buf0dblwr.cc:3574
mutable_buffer buffer(void *p, size_t n) noexcept
Definition: buffer.h:419
PSI_memory_key key_memory_HASH_ROW_ENTRY
Definition: psi_memory_key.cc:50
required uint64 version
Definition: replication_group_member_actions.proto:40
bool is_immediate_server_gipk_ready(THD &thd)
Checks if the immediate_server_version supports GIPKs or not.
Definition: rpl_utility.cc:1430
bool is_require_row_format_violation(const THD *thd)
This method shall evaluate if a command being executed goes against any of the restrictions of server...
Definition: rpl_utility.cc:1356
void rename_fields_use_old_replica_source_terms(THD *thd, mem_root_deque< Item * > &field_list)
This function shall blindly replace some deprecated terms used in the field names with more recent on...
Definition: rpl_utility.cc:1420
std::string replace_all_in_str(std::string from, std::string find, std::string replace)
Replaces every occurrence of the string find by the string replace, within the string from and return...
Definition: rpl_utility.cc:1309
bool does_source_table_contain_gipk(Relay_log_info const *rli, TABLE *table)
Returns if the replicated table contains a GIPK or not.
Definition: rpl_utility.cc:1435
std::string decimal_numeric_version_to_string(uint32 version)
Returns a string representation for a given version.
Definition: rpl_utility.cc:1443
std::pair< my_off_t, std::pair< uint, bool > > read_field_metadata(const uchar *buffer, enum_field_types binlog_type)
Decode field metadata from a char buffer (serialized form) into an int (packed form).
Definition: rpl_utility.cc:864
Definition: rpl_utility.h:103
HASH_ROW_POS * positions
Definition: rpl_utility.h:105
HASH_ROW_PREAMBLE * preamble
Definition: rpl_utility.h:104
Hash table used when applying row events on the slave and there is no index on the slave's table.
Definition: rpl_utility.h:59
const uchar * bi_start
Points at the position where the row starts in the event buffer (ie, area in memory before unpacking ...
Definition: rpl_utility.h:65
const uchar * bi_ends
Definition: rpl_utility.h:66
Internal structure that acts as a preamble for HASH_ROW_POS in memory structure.
Definition: rpl_utility.h:82
malloc_unordered_multimap< uint, std::unique_ptr< HASH_ROW_ENTRY, hash_slave_rows_free_entry > >::const_iterator search_state
The search state used to iterate over multiple entries for a given key.
Definition: rpl_utility.h:95
bool is_search_state_inited
whether this search_state is usable or not.
Definition: rpl_utility.h:100
uint hash_value
Definition: rpl_utility.h:87
HASH_ROW_PREAMBLE()=default
Definition: my_bitmap.h:42
Extend the normal Table_ref with a few new fields needed by the slave thread, but nowhere else.
Definition: rpl_utility.h:511
RPL_Table_ref(const char *db_name_arg, size_t db_length_arg, const char *table_name_arg, size_t table_name_length_arg, const char *alias_arg, enum thr_lock_type lock_type_arg)
Definition: rpl_utility.h:512
table_def m_tabledef
Definition: rpl_utility.h:519
bool m_tabledef_valid
Definition: rpl_utility.h:518
TABLE * m_conv_table
Definition: rpl_utility.h:520
Definition: completion_hash.h:34
Definition: rpl_utility.h:71
void operator()(HASH_ROW_ENTRY *entry) const
Utility methods for handling row based operations.
Definition: rpl_utility.cc:996
thr_lock_type
Definition: thr_lock.h:50