使用 Castle AutoTx Facility 和 NHibernate Facility 的交易

Question

我正在尝试将 Castle NHibernate Facility 与 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 直接来自 the guide，我的流畅的 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

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

[交易] 公共类 ActionService : IActionService { 私人 ISessionManager _sessionManager; [交易] 公共无效AddActivity（活动活动） { 使用 (ISession 会话 = _sessionManager.OpenSession()) { 使用 (ITransaction tran = session.BeginTransaction()) { session.Save（活动）； tran.Commit(); } } } 公共 ActionService(ISessionManager sessionManager) { _sessionManager = 会话管理器； } } _container.Register(Component.For() .ImplementedBy.LifestylePerWebRequest());

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