应用程序架构 - RavenDB 事务

Question

我正在一个项目中实现 RavenDB，在尝试数据库几天后，我现在正在构建这个应用程序，但我有一个问题。

我正在为每个实体（几乎）编写业务层，并且我有一个独特的存储库类来处理查询和 DocumentStore。 我对如何沿着服务层共享 DocumentStore 并处理事务感到困惑。

我正在展示一个示例，其中我尝试在单个事务中存储和读取文档。

存储库的一个示例：

public class RavenRepository
{
    private static DocumentStore _store;
    private IDocumentSession _session;

    public RavenRepository(DocumentStore store)
    {
        _store = (_store==null) ? new DocumentStore() { Url = "http://wsk-gcardoso:8081" } : store;           
    }
    public T SingleOrDefault<T>(Func<T, bool> predicate) where T : BaseModel
    {
        using (var session = _store.OpenSession())
        {
            return session.Query<T>().SingleOrDefault(predicate);
        }
    }
    public T Add<T>(T item) where T : BaseModel
    {            
        using (var session = _store.OpenSession())
        {
            session.Advanced.AllowNonAuthoritiveInformation = this.AllowNonAuthoritiveInformation;
            session.Store(item);
            session.SaveChanges();
        }
        return item;
    }
    public void Initialize() {
        _store.Initialize();
    }
    public void Dispose() {
        _store.Dispose();
    }
}

业务层如下所示：

public class NewsletterBusiness
{
    private RavenRepository repository;
    public NewsletterBusiness(RavenRepository ravenRepository)
    {       
        repository = (ravenRepository == null) ? RavenRepository(null) : ravenRepository;
    }

    public Newsletter Add(Newsletter newsletter)
    {
        Newsletter news = repository.Add(newsletter);
        return news;
    }
    public Newsletter GetById(long Id)
    {
        Newsletter news = repository.SingleOrDefault<Newsletter>(x => x.Id == Id);
        return news;
    }
}

现在我尝试在同一事务中保存并读取对象（新闻通讯）。 根据我的阅读，我必须将 documentStore 的 AllowNonAuthoritativeInformation 设置为 false 以等待事务完成。但是从我处理层和存储库的方式来看，我是否在单个事务中存储和查询数据库？

老实说，我认为我对 OpenSession 存储方法感到困惑。我认为我将会话与事务混淆了。

例如，这段代码：

var repository = new RavenRepository(null);
newsletterBusiness = new NewsletterBusiness(repository);
repository.Initialize();
using (var tx = new TransactionScope())
{
    Newsletter new = newsletterBusiness.Add(new Newsletter { Title = "Created by Tests", Content = "Created By Tests" });

    Newsletter objectCreated = newsletterBusiness.GetById(new.Id);
    repository.Dispose();
    tx.Complete();
}

如果我创建第二个业务层（例如图片）并设置picturesBusiness.repository =存储库（为businessLayer设置的相同“RavenRepository对象”）我将工作在 newsletterBusiness.repository 的同一会话中，

picturesBusiness = new PicturesBusiness(repository);
Picture pic = picturesBusiness.GetById(20);

我非常感谢有关此主题的帮助， 来自葡萄牙的欢呼！

Answer 1

您没有正确使用 RavenDB，这就是您遇到此问题的原因。
您可以将会话视为数据库连接。在您的模型中，您将为每种类型创建一个单独的会话。但你确实没有真正的理由要这样做。

事实上，您不想这样做，因为会话完全能够同时处理多种类型。
此外，您所做的实际上是减少会话机会来优化诸如向服务器发送一批更新之类的事情。

如果您希望进行跨类型的事务写入，根据您的架构，您必须使用 DTC，因为每个不同的会话都是与数据库的不同连接。如果您使用“Session per Request”模型，您将只有一个会话，并且只需调用一次 SaveChanges() 即可获得事务语义。

Answer 2

您试图通过存储库模式抽象 raven 的会话（基本上是一个工作单元）。

我建议您采用以下方法 - 创建一个 UnitOfWork 抽象，它将封装 ravenDB 会话并从中实例化存储库。这是一些伪代码：

public class RavenUnitOfWork {
    private IDocumentSession m_session;

    public UnitOfWork() {
        // initialize m_session here
    }

    public Repository<T> GetRepository() {
        return new Repository<T>(m_session);
    }

    public void Commit() {
        m_session.SaveChanges();
    }
}

public class RavenRepository<T> {
    public Repository(IDocumentSession session) {
        // Store the session
    }
    public T Load(string id) {...}
    public void Store(T entity) {...}
    public void Delete(T entity) {...}
    public IQueryable<T> Query() {...}
}

在这里您显式地实现这些模式。

PS：当然，您可以根据自己的喜好声明 IUnitOfWork 和 IRepository...