使用 NHibernate Castle 设施进行延迟加载

Question

我是否必须关闭 Castle 的 ISessionManager 为 NHibernate 生成的 ISession？ 我如何处理这些 ISession 的事务？ 我对 NHibernate 还是很陌生。

编辑：我想要延迟加载，但收到此消息：

初始化[懒惰地失败 初始化角色集合： , 否 会话或会话已关闭”

这是我的通用存储库，我继承它来实现特定实例。

[Transactional]
public class Repository<TKey, TModel>
    : IRepository<TKey, TModel>
    where TKey : IComparable
    where TModel : class
{
    private readonly ISessionManager _sessionManager;

    protected ISession Session { get { return _sessionManager.OpenSession(); } }

    public Repository(ISessionManager sessionManager)
    {
        _sessionManager = sessionManager;
    }
    #region IRepository<TKey,TModel> Members

    public virtual TModel Select(TKey key)
    {
        using (var session = _sessionManager.OpenSession())
        {
            return session.Get<TModel>(key);
        }
    }

    public virtual IList<TModel> SelectWhere(Func<TModel, bool> query)
    {
        using (var session = Session)
        {
            return session.Linq<TModel>().Where(query).ToList();
        }
    }

    public virtual TModel Single(Func<TModel, bool> query)
    {
        using (var session = Session)
        {
            return session.Linq<TModel>().SingleOrDefault(query);
        }
    }

    public virtual TModel First(Func<TModel, bool> query)
    {
        using (var session = Session)
        {
            return session.Linq<TModel>().FirstOrDefault(query);
        }
    }

    public virtual IList<TModel> All()
    {
        using (var session = Session)
        {
            return session.Linq<TModel>().ToList();
        }
    }

    [Transaction(TransactionMode.Requires)]
    public virtual void Store(TModel entity)
    {
        using (var session = Session)
        {
            session.SaveOrUpdate(entity);
        }
    }

    [Transaction(TransactionMode.Requires)]
    public virtual void Store(IEnumerable<TModel> entities)
    {
        using (var session = Session)
        {
            foreach (TModel entity in entities)
                session.SaveOrUpdate(entity);
        }
    }


    [Transaction(TransactionMode.Requires)]
    public virtual void Remove(TModel entity)
    {
        using (var session = Session)
        {
            session.Delete(entity);
        }

    }

    public virtual void Remove(Func<TModel, bool> query)
    {
        IEnumerable<TModel> entities = SelectWhere(query);
        Remove(entities);
    }

    [Transaction(TransactionMode.Requires)]
    public virtual void Remove(IEnumerable<TModel> entities)
    {
        using (var session = Session)
        {
            foreach (TModel entity in entities)
                session.Delete(entity);
        }
    }

    #endregion
}

public class Repository<TModel>
    : Repository<Guid, TModel>, IRepository<TModel>
    where TModel : class
{
    public Repository(ISessionManager sessionManager) : base(sessionManager) { }
}

public class Repository
    : Repository<ulong, object>, IRepository
{
    public Repository(ISessionManager sessionManager) : base(sessionManager) { }
}

这是该存储库的调用示例：

IUserRepository userRepository = new UserRepository(); // This is actually provided by my IoC

var users = userRepository.All();
foreach (var user in Users)
{
    foreach (var picture in user.Pictures)
    {
        // I get exceptions when I do stuff like this.
    }
}

Answer 1

是的，始终处置 ISession。 请参阅有关ISessionManager用法的文档< /a>.

对于交易，请考虑使用自动交易工具。

SessionManager 是 ATM 感知的，因此它将处理 < code>ISession 在需要时巧妙地考虑事务，即使您显然已经处理了 ISession。

这里有一个快速指南 使用 ASP.NET MVC + Castle 自动事务设施 + NHibernate 设施的脏示例应用程序

Answer 2

我们使用带有 using 语句的事务来处理处置。

public void Save<K>(K entity)
        {

            if (entity == null)
                throw new ArgumentNullException("item", "The item being saved cannot be null.");

            using (ISession session = GetSession())
            {
                using (ITransaction tx = session.BeginTransaction())
                {
                    session.SaveOrUpdate(entity);
                    tx.Commit();
                }
            }
        }

如果我在同一操作中进行修改后访问对象，我仍然会收到延迟加载错误。 我已通过保存后不访问对象来修复该错误。 这是一个解释： NHibernate.LazyInitializationException

我相信这是由于没有正确保存层次结构造成的。 我还没有测试过它，但如果您想访问父对象，也许保存它们可以解决问题。 只需将保存后需要访问的信息放入保存前的局部变量中似乎就可以解决我的问题。