温莎 nHibernate ISession

Question

我有一个 MVC5 应用程序并像这样设置我的休眠内容：

  public class PersistenceInstaller : IWindsorInstaller
{

    public void Install(IWindsorContainer container, IConfigurationStore store)
    {


        container.Register(

            //Nhibernate session factory
            Component.For<ISessionFactory>().UsingFactoryMethod(CreateNhSessionFactory).LifeStyle.Singleton,


            Component.For<ISession>().UsingFactoryMethod(k => k.Resolve<ISessionFactory>().OpenSession()).LifestylePerWebRequest(),

            //All repoistories
            Classes.FromAssembly(Assembly.GetAssembly(typeof(HdtRepository))).InSameNamespaceAs<HdtRepository>().WithService.DefaultInterfaces().LifestyleTransient()




            );
    }

我的基础存储库如下所示：

  public abstract class RepositoryBase<TEntity, TPrimaryKey> : IRepository<TEntity, TPrimaryKey> where TEntity : Entity<TPrimaryKey>
{

    /// <summary>
    /// Gets the NHibernate session object to perform database operations.
    /// </summary>
    public ISession Session { get; set; }


    /// <summary>
    /// Used to get a IQueryable that is used to retrive object from entire table.
    /// </summary>
    /// <returns>IQueryable to be used to select entities from database</returns>
    public IQueryable<TEntity> GetAll()
    {
        return Session.Query<TEntity>();
    }

    /// <summary>
    /// Gets an entity.
    /// </summary>
    /// <param name="key">Primary key of the entity to get</param>
    /// <returns>Entity</returns>
    public TEntity Get(TPrimaryKey key)
    {
        return Session.Get<TEntity>(key);
    }

    /// <summary>
    /// Inserts a new entity.
    /// </summary>
    /// <param name="entity">Entity</param>
    public void Insert(TEntity entity)
    {
        Session.Save(entity);
    }

    /// <summary>
    /// Updates an existing entity.
    /// </summary>
    /// <param name="entity">Entity</param>
    public void Update(TEntity entity)
    {
        Session.Update(entity);
    }

    /// <summary>
    /// Deletes an entity.
    /// </summary>
    /// <param name="id">Id of the entity</param>
    public void Delete(TPrimaryKey id)
    {
        Session.Delete(Session.Load<TEntity>(id));
    }
}

当我插入实体时，一切正常。 当我将 Session.Flush() 添加到我的 Update 方法时，更新才起作用。

这是从 Ajax 调用并执行插入或更新的方法。

 [Authorize]
    [ValidateInput(false)]
    [ScriptMethod(ResponseFormat = ResponseFormat.Json)]
    public JsonNetResult CreateOrUpdateTimeRecord(TimeRecord tr)
    {

        TimeRecord trLocal;
        if (tr.Id == -1 || tr.Id == 0)
        {
            trLocal = new TimeRecord();

            trLocal.Description = tr.Description;
            trLocal.StartTime = tr.StartTime;
            trLocal.EndTime = tr.EndTime;

            trLocal.User = _userRepo.Get(tr.User.Id);
            trLocal.Hdt = _hdtRepo.Get(tr.Hdt.Id);

            _timeRepo.Insert(trLocal);
        }
        else
        {
            trLocal = _timeRepo.Get(tr.Id);

            trLocal.Description = tr.Description;
            trLocal.StartTime = tr.StartTime;
            trLocal.EndTime = tr.EndTime;

            _timeRepo.Update(trLocal);
        }



        return new JsonNetResult() { Data = trLocal};
    }

我不明白为什么这适用于插入而不适用于更新。 我必须关心交易和打开/关闭会话吗？ 我认为“LifestylePerWebRequest”会为我做到这一点。

干杯， 斯蒂芬

Answer 1

:edit:（我最初的回答部分错误）

您的实现实际上应该可以正常工作（刚刚测试过）。 尽管我可以重现尽管会话对象得到正确处理但更新未刷新的行为

LifestylePerWebRequest 实际上处理得很好，它会在请求结束时释放会话。因此，您必须将请求句柄添加到 web.config 等......所以 Windsor 的东西完全清楚 ISession 是一次性的并且它必须处理它......

这是因为会话的 FlushMode。

默认模式是自动，这可能不是您真正想要的，因为您不能依赖存储的更改（尤其是更新调用）。

您可以更改已创建会话对象的 FlushMode，或者，这是我推荐的，使用事务。

让我们看下面的例子：

var session = container.Resolve<ISession>();

var obj = new Paper()
{
    Author = "Author",
    Description = "Description",
};
session.Save(obj);

obj.Author = "Author2";
session.Update(obj);

在这种情况下，更新将永远不会刷新/存储在数据库中。我猜这就是你目前的行为。

现在让我们围绕它添加一个事务：

var session = container.Resolve<ISession>();
using (var transaction = session.BeginTransaction())
{
    var obj = new Paper()
    {
        Author = "Author",
        Description = "Description",
    };
    session.Save(obj);

    obj.Author = "Author2";
    session.Update(obj);

    transaction.Commit();
}

现在肯定会保存更改。