mz_sql_server_util::inspect

Function get_changes_asc

Source 
pub fn get_changes_asc(
    client: &mut Client,
    capture_instance: &str,
    start_lsn: Lsn,
    end_lsn: Lsn,
    filter: RowFilterOption,
) -> impl Stream<Item = Result<Row, SqlServerError>> + Send
Expand description

Queries the specified capture instance and returns all changes from [start_lsn, end_lsn), ordered by start_lsn in an ascending fashion.

TODO(sql_server2): This presents an opportunity for SQL injection. We should create a stored procedure using QUOTENAME to sanitize the input for the capture instance provided by the user.