5

我是否必须关闭Castle为 NHibernateISession生成的 's ？ISessionManager我如何处理与那些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.
    }
}
4

2 回答 2

6

是的，总是处理ISession. 请参阅有关使用的文档ISessionManager。

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

SessionManager 是 ATM 感知的，因此它会ISession在需要时巧妙地处理，考虑到交易，即使您显然已经处理了ISession.

这是一个使用 ASP.NET MVC + Castle Automatic Transaction Facility + NHibernate 设施的快速而肮脏的示例应用程序

于 2009-07-13T13:19:48.410 回答
0

我们使用带有 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

我相信这是由于没有正确保存层次结构。我尚未对其进行测试，但如果您希望访问它们，可能保存父对象将解决问题。只需将保存后需要访问的信息放入本地变量中，然后保存似乎就可以解决我的问题。

于 2009-07-16T14:14:59.420 回答