Module mz_storage::source::mysql::replication::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.