RavenDB：异步 SaveChanges 会影响以后的更新吗？

Question

作为学习 RavenDB 的一部分，我尝试根据每晚下载的列表更新股票集合。

我有一个 Stock 类，其中 Id 是股票代码：

public class Stock
{
    public string Id { get; set; }
    public StockStatus Status { get; set; }
}

我正在尝试使用此算法同步列表：

1. 更新或插入现在下载的所有股票为“StillActive”。
2. 上次状态为“活跃”的任何股票都意味着它们不在更新中，需要“删除”。
3. 所有仍然“仍然活跃”的股票成为新的“活跃”股票。

下面是实现：

List<Stock> stocks = DownloadStocks();

using (var session = RavenContext.Store.OpenSession())
{
    foreach (Stock stock in stocks)
    {
        stock.Status = StockStatus.StillActive;
        session.Store(stock);
    }

    session.SaveChanges();

    session.PatchUpdateCutoffNow("Stocks/ByStatus", "Status:Active", "Status", StockStatus.Deleted);
    session.PatchUpdateCutoffNow("Stocks/ByStatus", "Status:StillActive", "Status", StockStatus.Active);
}

PatchUpdateCutoffNow 是一个扩展方法，它使用现在的截止值执行 UpdateByIndex：

public static void PatchUpdateCutoffNow(this IDocumentSession session, string indexName, string query, string name, object val)
{
    session.Advanced.DatabaseCommands.UpdateByIndex(indexName, 
        new IndexQuery() { Query = query, Cutoff = DateTime.Now },
        new[]
        {
            new PatchRequest
            {
                Type = PatchCommandType.Set,
                Name = name,
                Value = val.ToString()
            }
        });
}

我最终删除了很多不应该删除的股票。我的猜测是 SaveChanges 是异步的，并且在 PatchUpdateCutoffNow 启动时尚未完成，因此我最终得到了一些状态为“已删除”的股票，而它们应该是“活动”的。我猜想 IndexQuery 截止值不适用，因为 SaveChanges 并不直接针对“Stocks/ByStatus”索引。

有没有办法使 SaveChanges 同步或其他更适合 NoSQL/RavenDB 思维方式的方法？

Answer 1

文档会立即存储，但修补命令适用于尚未更新的索引。也许这会有所帮助，插入到 SaveChanges() 和修补之间：

using (var s = RavenContext.Store.OpenSession()) {
    s
        .Query<Stock>("Stocks/ByStatus")
        .Customize(c => c.WaitForNonStaleResultsAsOfNow())
        .Take(0)
        .ToArray();
}

顺便说一句，您不需要 DatabaseCommands 会话，您可以直接在商店上调用它们。