mz_storage::source::mysql::replication

Module events

Source

Functions§

handle_query_event 🔒
Handles QueryEvents from the MySQL replication stream. Since we only use row-based replication, we only expect to see QueryEvents for DDL changes.
handle_rows_event 🔒
Handles RowsEvents from the MySQL replication stream. These events contain insert/update/delete events for a single transaction or committed statement.
table_ident 🔒
Returns the MySqlTableName for the given table name referenced in a SQL statement, using the current schema if the table name is unqualified.