Function mz_storage::source::mysql::schemas::verify_schemas

source ยท 
pub(super) async fn verify_schemas<'a, Q, I>(
    conn: &mut Q,
    expected: BTreeMap<&'a MySqlTableName, I>,
) -> Result<Vec<(&'a SourceOutputInfo, DefiniteError)>, MySqlError>
where
    Q: Queryable,
    I: IntoIterator<Item = &'a SourceOutputInfo>,
Expand description

Given a map of tables and the expected schemas of their outputs, retrieve the current schema for each and verify they are compatible with the expected schema.

Returns a vec of outputs that have incompatible schema changes.