pub async fn cleanup_change_table(
client: &mut Client,
capture_instance: &str,
low_water_mark: &Lsn,
max_deletes: u32,
) -> Result<(), SqlServerError>
Expand description
Cleans up the change table associated with the specified capture_instance
by
deleting max_deletes
entries with a start_lsn
less than low_water_mark
.
Note: At the moment cleanup is kind of “best effort”. If this query succeeds
then at most max_delete
rows were deleted, but the number of actual rows
deleted is not returned as part of the query. The number of rows should be
present in an informational message (i.e. a Notice) that is returned, but
tiberius
doesn’t expose these to us.
TODO(sql_server2): Update tiberius
to return informational messages so we
can determine how many rows got deleted.