hcq/MaxScale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

MXS-1881: Add table creation method to RowEventHandler

Browse Source 
The new method is called for each new CREATE TABLE statement that is
processed as well as all ALTER TABLE statemets that modify the table
structure.

Right now the entry point not in use but it opens up the possibility of
persisting the CREATE TABLE statements at creation time. Currently the
tables are only persisted when the first actual event for the table is
received.
This commit is contained in:
Markus Mäkelä
2018-06-11 20:03:14 +03:00
parent c27529c9a4
commit 3417842e75
3 changed files with 20 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
server/modules/routing/avrorouter/avro_file.cc
View File

@ -756,7 +756,7 @@ bool is_alter_table_statement(pcre2_code* alter_table_re, char* ptr, size_t len)
*/
bool Rpl::save_and_replace_table_create(STableCreateEvent created)
{
std::string table_ident = created->database + "." + created->table;
std::string table_ident = created->id();
auto it = m_created_tables.find(table_ident);
if (it != m_created_tables.end())
@ -772,7 +772,7 @@ bool Rpl::save_and_replace_table_create(STableCreateEvent created)
m_created_tables[table_ident] = created;
ss_dassert(created->columns.size() > 0);
return true;
return m_handler->create_table(created);
}
void unify_whitespace(char *sql, int len)
@ -909,7 +909,7 @@ void Rpl::handle_query_event(REP_HEADER *hdr, uint8_t *ptr)
if (it != m_created_tables.end())
{
table_create_alter(it->second.get(), sql, sql + len);
table_create_alter(it->second, sql, sql + len);
}
else
{