Crate mz_mysql_util

MySQL utility library.

Re-exports

• pub use schemas::schema_info;
• pub use schemas::MySqlTableSchema;
• pub use schemas::QualifiedTableRef;
• pub use schemas::SchemaRequest;
• pub use schemas::SYSTEM_SCHEMAS;
• pub use privileges::validate_source_privileges;
• pub use decoding::pack_mysql_row;

Modules

• decoding
• desc 🔒
• privileges
• replication 🔒
• schemas
• tunnel 🔒

Structs

• Config
  Configuration for MySQL connections.
• MissingPrivilege
• MySqlColumnDesc
• MySqlConn
  A MySQL connection with an optional SSH tunnel handle.
• MySqlKeyDesc
• MySqlTableDesc
• ProtoMySqlColumnDesc
• ProtoMySqlKeyDesc
• ProtoMySqlTableDesc
• TimeoutConfig
• UnsupportedDataType

Enums

• MySqlError
• TunnelConfig
  Configures an optional tunnel for use when connecting to a MySQL database.

Constants

• DEFAULT_SNAPSHOT_LOCK_WAIT_TIMEOUT
• DEFAULT_SNAPSHOT_MAX_EXECUTION_TIME
• DEFAULT_TCP_KEEPALIVE
• ER_NO_SUCH_TABLE
• ER_SOURCE_FATAL_ERROR_READING_BINLOG_CODE

Functions

• ensure_full_row_binlog_format
• ensure_gtid_consistency
• ensure_replication_commit_order
  In case this is a MySQL replica, we ensure that the replication settings are such that the replica would commit all transactions in the order they were committed on the primary. We don’t really know that this is a replica, but if the settings indicate multi-threaded replication and the preserve-commit-order setting is not on, then it could be a replica with correctness issues. We used to check performance_schema.replication_connection_configuration to determine if this was in-fact a replica but that requires non-standard privileges. Before MySQL 8.0.27, single-threaded was default and preserve-commit-order was not, and after 8.0.27 multi-threaded is default and preserve-commit-order is default on. So both of those default scenarios are fine. Unfortunately on some versions of MySQL on RDS, the default parameters use multi-threading without the preserve-commit-order setting on.
• query_sys_var
  Query a MySQL System Variable