UoW 的 nHibernate [TransactionAttribute] 与存储库模式冲突

Question

在研究设计 IRepository 结构的最佳方法时，我在浏览一些论坛时发现了一个名为“Whiteboard”的项目 (http://whiteboardchat.codeplex.com/) >NHProf。

我研究了它的源代码一段时间，发现了一个非常有趣的 MVC 属性，称为 TransactionAttribute，定义如下； （我做了简短的调整以适应我的 IoC 解决方案）

using System;
using System.Linq;

using Ninject;

namespace System.Web.Mvc
{
    /// <summary>
    /// This will allow ASP.NET MVC to apply Transactions to the controllers.
    /// </summary>
    [AttributeUsage(AttributeTargets.Method | AttributeTargets.Class)]
    public class TransactionAttribute : ActionFilterAttribute
    {
        [Inject]
        public NHibernate.ISession Session 
        { 
            get; 
            set; 
        } 

        public override void OnActionExecuting(ActionExecutingContext filterContext)
        {
            Session.BeginTransaction();
        }

        public override void OnActionExecuted(ActionExecutedContext filterContext)
        {
            if (Session.Transaction.IsActive)
            {
                if (filterContext.Exception == null)
                {
                    Session.Flush();
                    Session.Transaction.Commit();
                }
                else
                {
                    Session.Transaction.Rollback();
                }
            }
        }
    }
}

这真的很有趣；而且很有用，但是它的某些内容让我烦恼。当我使用 NHProf 运行查询时，它会向我发出有关“未正确使用事务”的警告，并建议我将所有查询包装在 Transaction 中。好吧，那很好……

那么我就去装饰我的 Repository; ： IRepository 像这样的类...

    public T Update(T instance)
    {
        using (var transaction = session.BeginTransaction())
        {
            // attempt to perform the given update
            session.SaveOrUpdate(instance);

            try
            {
                // commit the transaction to the database
                transaction.Commit();

                // update succeeded, so we'll return true
                return instance;
            }
            catch
            {
                // restore the database to its previous state if we failed.
                transaction.Rollback();

                // update failed, so return a null object
                return default(T);
            }
        }
    }

这是我遇到的问题。

在我阅读的所有地方，常见做法是始终使用存储库来添加到集合中。然而，TransactionAttribute 本身是由 Ayende Rahien 的博客引起我注意的，据我所知，他是 NHProf 的主要开发人员之一 以及从事此 Whiteboard 项目的人员之一，假设您正在 MVC 控制器级别执行存储库 命令。

那么是哪一个呢？我现在完全困惑我的事务逻辑应该在哪里实现最佳实践。我确实找到了相互矛盾的答案，并且在某些情况下来自同一个人。

Answer 1

您不应该处理存储库内的事务。控制器（就像您拥有的）或 HTTP 模块应该启动并提交/回滚事务。保存或更新不应单独完成。它们将由控制器在操作结束时提交。这样您就可以利用 ADO 批处理和其他 NHibernate 功能。

另外，请确保将 nhibernate ISession 的 FlushMode 设置为 Commit。

Answer 2

您是否使用 [Transaction] 属性来装饰您的操作方法或控制器类？如果不是，则甚至不会调用此操作过滤器代码。

此外，您还需要确保将会话对象也[注入]到您的存储库中，并且会话对象的范围仅限于请求。

例如：

public class MyRepository
{
    [Inject]
    public ISession Session { get; set; }

    public void Save(MyModel model) { Session.Save(model); }
}

public class MyController : Controller
{
    [Inject]
    public MyRepository MyRepository { get; set; }

    [Transaction]
    public ActionResult Save(MyModel model)
    {
        MyRepository.Save(model);
    }
}

在注册您的会话时；

var configuration = new NHibernateConfiguration();
Bind<ISessionFactory>().ToConstant(configuration.GetSessionFactory());
Bind<ISession>().ToMethod(x => x.Kernel.Get<ISessionFactory>().OpenSession()).InRequestScope();

注意 InRequestScope() 部分

Answer 3

为@Fatal 发布此内容。

最初的回答回答了我的问题，但这不可避免地是我最终所做的以避免使用方法级属性。

我没有在属性中声明控制事务的代码，而是将其直接包含在 Ninject 的 ISession 管理中。

        Bind<ISession>()
            .ToMethod(c => OpenSession())
            .InRequestScope()
            .OnActivation(session =>
            {
                session.BeginTransaction();
                session.FlushMode = FlushMode.Commit;
            })
            .OnDeactivation(session =>
            {
                if (session.Transaction.IsActive)
                {
                    try
                    {
                        session.Transaction.Commit();
                    }
                    catch
                    {
                        session.Transaction.Rollback();
                    }
                }
            });

其作用是在注入 ISession 的每个请求中打开新的 ISession，并且当它被激活时，它会开始一个新事务。此时，Ninject 现在跟踪状态并处理回滚状态的后果，从而实现非常简单的工作单元模式。

我不知道这是否是世界上最好的方法，但我已经向一些人展示了它，并且它没有因为不好的做法而被否决，而且到目前为止对我来说效果很好。