使用 Castle AutoTx 设施和 NHibernate 设施的事务

Question

我正在尝试将 Castle NHibernate 设施 与 AutoTx 设施一起使用。作为测试，我在服务中间抛出异常，以确保事务回滚。但是，数据仍然保留在数据库中。

我的服务接口 IActivityService 使用 TransactionAttribute：

public interface IActivityService
{
    [Transaction]
    Activity CreateActivity(Activity activity);
}

CreateActivity 的实现。我在这里抛出一个异常，期望回滚 AddActivity 中添加的数据：

public virtual Activity CreateActivity(Activity activity)
{
    activityDAO.AddActivity(activity);
    throw new Exception("This should rollback the transaction");
    return activity;
}

AddActivity 的实现。 SessionManager 是一个注入的ISessionManager。

public void AddActivity(Activity activity)
{
    using (ISession session = SessionManager.OpenSession())
    {
        session.Save(activity);
    }
}

最后，这是我配置 Windsor 容器的方法。 NHibernateInstaller 直接来自 指南，交换了我流畅的nhibernate配置：

container = new WindsorContainer().Install(FromAssembly.This());

// set up ISessionManager injection for DAOs
container
    .AddFacility<AutoTxFacility>()
    .Register(Component
        .For<INHibernateInstaller>()
        .ImplementedBy<NHibernateInstaller>()
        .LifeStyle.Singleton)
    .AddFacility<NHibernateFacility>(f => 
        f.DefaultLifeStyle = DefaultSessionLifeStyleOption.SessionPerWebRequest);

配置看起来相当简单，但我不知道我错过了什么。感谢您的任何帮助。

Answer 1

您没有显示服务实现类的类声明代码，因此您可能已经这样做了，但如果您想要声明式事务，则需要使用 [Transactional] 属性注释事务类。

[Transactional]    
public class ActivityServiceImpl {

    [Transaction]
    public Activity CreateActivity(Activity activity) {
        // ... implementation here
    }
}

如果您不在实现类中包含 [Transactional] 属性，则 AutoTx 工具不知道为该类创建包装器。

我倾向于将 [Transaction] 属性放在实现方法上，而不是放在接口定义中。我不知道注释接口方法声明是否有效。

您可能还需要尝试一件事。我注意到，当您配置容器时，您首先要安装，然后添加 AutoTx 设施。我认为您应该在调用安装程序之前先添加设施。

Answer 2

首先，会话管理器和活动服务之间必须具有直接依赖关系。会话管理器应该注入到活动服务中。只有在这种情况下该设施才能影响 NHibernate 事务。

    [Transactional]
    public class ActionService : IActionService
    {
        private ISessionManager _sessionManager;

        [Transaction]
        public void AddActivity(Activity activity)
        {
            using (ISession session = _sessionManager.OpenSession())
            {
                using (ITransaction tran = session.BeginTransaction())
                {
                        session.Save(activity);
                    tran.Commit();
                }
            }       
        }
        public ActionService(ISessionManager sessionManager)
    {
            _sessionManager = sessionManager;       
        }
    }
    _container.Register(Component.For<IActionService>()
            .ImplementedBy<ActionService>.LifestylePerWebRequest());

还要检查您是否对 SessionManager、服务器、DAO 和其他依赖对象使用相同的生活方式。