Nhibernate:在session.update()和session.delete()之后数据库值保持不变

本文关键字：session 数据库 update Nhibernate delete 之后 | 更新日期: 2023-09-27 18:32:11

Session.queryover（） 和 session.save（） 运行良好。从数据库获取数据或将数据保存到数据库的所有逻辑都运行良好。通过 session.update（） 和 session.delete（） 对数据库所做的更改不会反映出来。没有抛出任何解释。使用会话。SaveOrUpdate 没有解决这个问题。这是我的映射

[Serializable]
public class Requirement
{
   public virtual int Id { get; set; }
   public virtual int CreditRequired { get; set; }
   public virtual string Name { get; set; }
   public virtual IList<CourseRequirement> CourseRequirements
   {
       get
       {
           return new RequirementBC().getCourseRequirement(Id);
       }
   }

   public Requirement()
   { }
   public Requirement(DataRow row)
   {
       Id = int.Parse(row["Id"].ToString());
       CreditRequired = int.Parse(row["CreditRequired"].ToString());
       Name = row["Name"].ToString();
   }
}
public class RequirementMap : ClassMapping<Requirement>
{
    public RequirementMap()
    {
        Table("Requirements");
        Id<int>(x => x.Id, m => { m.Column("Id"); m.Generator(Generators.Native); });
        Property<int>(x => x.CreditRequired, m => { m.Column("CreditRequired");});
        Property<string>(x => x.Name, m => { m.Column("Name"); });
    }
}

这是我的逻辑

[Serializable]
public class RequirementBC 
{
    ISession session = NHibernateHelper.GetCurrentSession();
    public void UpdateRequirement(int reqId, string newName, int creditsRequired)
    {
         session.BeginTransaction();
            var req = session.QueryOver<Requirement>().Where(x => x.Id == reqId).SingleOrDefault<Requirement>();
            var old = session.QueryOver<Requirement>().Where(x => x.Name == newName && x.Id != reqId).SingleOrDefault<Requirement>();
            if (old != null)
                throw new Exception("Requirement with that name already exists");
             req.Name = newName;
             req.CreditRequired = creditsRequired;
             session.Update(req);
             session.Flush();
         session.Transaction.Commit();     
    }
}

获取当前会话的逻辑

public static ISession GetCurrentSession()
{
    HttpContext context = HttpContext.Current;
    ISession currentSession = context.Items[CURRENT_NHIBERNATE_SESSION_KEY] as ISession;
    if (currentSession == null)
    {
        currentSession = sessionFactory.OpenSession();
        context.Items[CURRENT_NHIBERNATE_SESSION_KEY] = currentSession;
    }
    if (currentSession.Connection.State == System.Data.ConnectionState.Closed)
    {
        currentSession = sessionFactory.OpenSession();
    }
    if (!currentSession.IsConnected)
    {
        currentSession = sessionFactory.OpenSession();
    }
    if (!currentSession.IsOpen)
    {
        currentSession = sessionFactory.OpenSession();
    }
    if (currentSession.IsDirty())
    {
        currentSession.Clear();
    }
    return currentSession;
}

从我在这个论坛和其他论坛上的搜索来看，那些遇到这种情况的人得到了一个或另一个例外，但在我自己的案例中没有抛出任何例外，这使得问题难以追踪。任何帮助将不胜感激。

Nhibernate:在session.update()和session.delete()之后数据库值保持不变

如果您使用的是事务，则不必刷新会话。 我也不确定您用于事务的语法。 如果我这样做，它将如下所示：

public void UpdateRequirement(int reqId, string newName, int creditsRequired)
{
    using(ISession session = NHibernateHelper.GetCurrentSession())
    {
        using(ITransaction transaction = session.BeginTransaction())
        {
            var req = session.QueryOver<Requirement>().Where(x => x.Id == reqId).SingleOrDefault<Requirement>();
            var old = session.QueryOver<Requirement>().Where(x => x.Name == newName && x.Id != reqId).SingleOrDefault<Requirement>();
            if (old != null)
                throw new Exception("Requirement with that name already exists");
            req.Name = newName;
            req.CreditRequired = creditsRequired;
            transaction.Commit();     
        }
    }
}
  • 不需要对会话已跟踪的对象调用 Update（）。（并且 Update（） 不一定会执行 UPDATE SQL 语句。
  • 在哪里打开并提交交易？
  • 你的GetCurrentSession（）看起来很奇怪 - 到目前为止，我觉得没有必要让所有这些检查我的"当前会话"方法。特别是如果脏那么清晰看起来很奇怪。我通常希望能够在工作单元中多次调用"获取当前会话"，而不会产生丢弃任何更改的副作用。
相关文章：