Function snapshot

src/sql-server-util/src/inspect.rs:857–872

Return a [`Stream`] that is the entire snapshot of the specified table.

(
    client: &mut Client,
    table: &SqlServerTableRaw,
)

/// Return a [`Stream`] that is the entire snapshot of the specified table.
pub fn snapshot(
    client: &mut Client,
    table: &SqlServerTableRaw,
) -> impl Stream<Item = Result<tiberius::Row, SqlServerError>> {
    let cols = table
        .columns
        .iter()
        .map(|SqlServerColumnRaw { name, .. }| quote_identifier(name))
        .join(",");
    let query = format!(
        "SELECT {cols} FROM {schema_name}.{table_name};",
        schema_name = quote_identifier(&table.schema_name),
        table_name = quote_identifier(&table.name)
    );
    client.query_streaming(query, &[])
}

/// Returns the total number of rows present in the specified table.
pub async fn snapshot_size(