RavenDB Catch 22 - 乐观并发并查看其他客户端的变化

Question

使用RavenDB，在应用程序启动时创建一个IDocumentSession（并且在应用程序关闭之前永远不会关闭它），允许我通过执行以下操作来使用乐观并发：

public class GenericData : DataAccessLayerBase, IGenericData
{
    public void Save<T>(T objectToSave)
    {
        Guid eTag = (Guid)Session.Advanced.GetEtagFor(objectToSave);
        Session.Store(objectToSave, eTag);
        Session.SaveChanges();
    }
}

如果另一个用户更改了该对象，则保存将正确失败。

但是，当在应用程序的整个生命周期中使用一个会话时，我无法看到应用程序的其他实例（例如，距离五个隔间的乔）对文档所做的更改。当我这样做时，我看不到 Joe 的更改：

public class CustomVariableGroupData : DataAccessLayerBase, ICustomVariableGroupData
{
    public IEnumerable<CustomVariableGroup> GetAll()
    {
        return Session.Query<CustomVariableGroup>();
    }
}

注意：我也尝试过此操作，但它也没有显示 Joe 的更改：

return Session.Query<CustomVariableGroup>().Customize(x => x.WaitForNonStaleResults());

现在，如果我采取其他方式，并创建一个 IDocumentSession 在访问数据库的每个方法中，那么我就会遇到相反的问题。因为我有一个新会话，所以我可以看到 Joe 的变化。 Buuuuuuut...然后我就失去了乐观并发性。当我在保存之前创建新会话时，此行会生成一个空 GUID，因此会失败：

Guid eTag = (Guid)Session.Advanced.GetEtagFor(objectToSave);

我缺少什么？如果不应在每个方法中创建会话，也不应在应用程序级别创建会话，那么正确的范围是什么？在执行 Session.Query() 时，如何才能获得乐观并发的好处以及查看其他人更改的能力？

Answer 1

您不会看到更改，因为您使用相同的会话。更多详情请看我其他人的回复

Answer 2

免责声明：我知道这不是长期方法，因此不会成为此处可接受的答案。然而，我现在只需要让一些东西工作起来，然后我就可以重构。我也知道有些人会对这种方法感到厌恶，哈哈，但就这样吧。似乎正在发挥作用。我每次查询（新会话）都会获得新数据，并且乐观并发也能正常工作。

最重要的是，我回到了每种数据访问方法一个会话。每当数据访问方法执行某种类型的获取/加载/查询时，我都会将 eTag 存储在静态字典中：

public IEnumerable<CustomVariableGroup> GetAll()
{
    using (IDocumentSession session = Database.OpenSession())
    {
        IEnumerable<CustomVariableGroup> groups = session.Query<CustomVariableGroup>();
        CacheEtags(groups, session);
        return groups;
    }
}

然后，当我保存数据时，我会从缓存中获取 eTag。如果另一个实例修改了数据，这会导致并发异常，这正是我想要的。

public void Save(EntityBase objectToSave)
{
    if (objectToSave == null) { throw new ArgumentNullException("objectToSave"); }

    Guid eTag = Guid.Empty;

    if (objectToSave.Id != null)
    {
        eTag = RetrieveEtagFromCache(objectToSave);
    }

    using (IDocumentSession session = Database.OpenSession())
    {
        session.Advanced.UseOptimisticConcurrency = true;
        session.Store(objectToSave, eTag);
        session.SaveChanges();
        CacheEtag(objectToSave, session);  // We have a new eTag after saving.
    }
}

从长远来看，我绝对想以正确的方式做到这一点，但我还不知道那是什么。

编辑：我将把它作为公认的答案，直到找到更好的方法。

Answer 3

Bob，为什么不在每次想要刷新数据时打开一个新会话呢？

为每个请求打开新会话需要进行许多权衡，并且您的乐观并发解决方案（在您自己的单例字典中管理标签）表明它从未打算以这种方式使用。

你说你有一个 WPF 应用程序。好的，启动时打开一个新会话。加载和查询您想要的任何内容，但在您想要刷新数据之前不要关闭会话（例如订单列表、客户，我不知道......）。然后，当您想要刷新它时（在用户单击按钮后，触发计时器事件或其他事件）处理会话并打开一个新会话。这对你有用吗？