Struct PrimaryKeyCache 

pub struct PrimaryKeyCache { /* private fields */ }

Cache of primary keys for tables

Implementations

impl PrimaryKeyCache

pub fn new() -> PrimaryKeyCache

Create a new empty cache

pub async fn discover_keys( &mut self, client: &mut Client<Compat<TcpStream>>, config: &MsSqlSourceConfig, ) -> Result<(), Error>

Discover primary keys from MS SQL system catalogs

Queries sys.indexes, sys.index_columns, sys.columns, and sys.tables to find primary key columns for all tables in the database.

pub fn get(&self, table: &str) -> Option<&Vec<String>>

Get primary key columns for a table Handles both “table” and “schema.table” formats

pub fn generate_element_id( &self, table: &str, row: &Row, ) -> Result<String, Error>

Generate element ID from a row using primary key values

Format: {table_name}:{key_values}

Arguments

• table - Table name
• row - Tiberius row with data

Returns

Element ID string

Errors

Returns an error if no primary key is configured for the table or if all primary key values are NULL. This is intentional - without a stable primary key, UPDATE and DELETE operations cannot be correctly matched to previous INSERT operations, breaking change tracking.

Trait Implementations

impl Default for PrimaryKeyCache

fn default() -> PrimaryKeyCache

Returns the “default value” for a type.