Skip to main content

derive_connect_properties_for_cdc_table

Function derive_connect_properties_for_cdc_table 

Source
pub(crate) fn derive_connect_properties_for_cdc_table(
    source_with_properties: &WithOptionsSecResolved,
    external_table_name: String,
) -> Result<(WithOptionsSecResolved, String)>
Expand description

Derive the connect properties of a CDC table from the properties of its source and the external_table_name in its TABLE '...' clause.

Returns (connect_properties, external_table_name) where external_table_name keeps the user’s spelling:

  • For SQL Server: ‘schema.table’ (2 parts) gets the database name of the source prepended, so that it names the table the same way as Debezium’s topic, ‘database.schema.table’.
  • For MySQL/Postgres: Returns the original external_table_name unchanged.