NHibernate的Session和事务的处理

时间：2010-10-02 来源：Gu

最初写Nhibernate例子的时候,只考虑了单个方法的事务

   public interface IRepository<T>
    {
        T GetById(object Id);
        void Delete(T entity);
        void Save(T entity);
    }         public void Delete(T entity)
        {
   ISession _session = NHelper.GetSession();
            using (ITransaction tx = _session.BeginTransaction())
            {
                _session.Delete(entity);
                tx.Commit();
            }

}

但是有很多时候,一个事务要跨多个对象的多个方法. 最初的想法是加一个ISession的参数,Delete(T entity,ISession s),

但是这样很丑陋,每个方法都要重写一次,而且和NHibernate绑定的太死了.

看了CodeProject上面一篇文章http://www.codeproject.com/KB/architecture/NHibernateArchitecture.aspx?msg=2185964

用到了SessionManager和TransactionBlock 2个类来包装, 代码变得优雅很多.

根据改文章,做了如下改动:

public void Delete(T entity)

{

ISession _session = NHibernateSessionManager.Instance.GetSession();

_session.Delete(entity);

_session.Flush();

}

去掉了Using (ISession xxx) ,因为这样Session才能交给NHibernateSessionManager这个类去管理,而不会Dispose关掉

另外单个方法里面去掉了ITransaction ,这样事务才能交给TransactionBlock 这个类来接管. 单个方法的提交改用Session.Flush();

事务调用的方法,我做了个嵌套事务的单元测试如下:

        [Test]
        public void Test_NestTransaction()
        {
            CompanyRepositoryImp CompanyBO = new CompanyRepositoryImp();
            //只有所有嵌套的事務都成功(成功的标志是手工设置tran.IsValid=true),才提交修改到数据库
            using (TransactionBlock tran = new TransactionBlock())
            {
                Company c = new Company();
                c.ID = "CO_02";
                c.ModifyDate = DateTime.Now;
                c.DefaultCurrency = "RMB";
                CompanyBO.Save(c);
                using (TransactionBlock tran1 = new TransactionBlock())
                {
                    tran1.IsValid = false;
                }
                tran.IsValid = true;
            }
        }

相关阅读更多 +