Module events 

Constants

DIALECT 🔒

Functions

drop_table_identifiers 🔒

Handles parsing table names from “DROP TABLE [IF EXISTS] table1, table2, table3”.

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.

mysql_table_name 🔒

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.

table_ident_from_object_name 🔒

This function has the same intent as table_ident except handles the object name type parsed out of the sql by sqlparser rather than a raw string. The ObjectName type is more flexible than the constraints for an identifier in mysql. i.e. it has a function type, which appears to only be supported in snowflake. It also has a vector for identifier components, however a table identifier from the binlog should only have 1 or 2 components - never 0 or more than 2