0

在尝试修改子对象然后保存父对象时，我的 ASP.NET WebForms 应用程序中的 Fluent Nhibernate 遇到了一些严重问题。

我的解决方案目前由 2 个项目组成：

  • 核心：所有实体和存储库类都位于的类库
  • 网站：ASP.NET 4.5 WebForms 应用程序

这是我的 Employee 对象的简单映射：

public class EmployeeMap : ClassMap<Employee>
{
    public EmployeeMap()
    {
        Id(x => x.Id).GeneratedBy.Identity();
        Map(x => x.DateCreated);
        Map(x => x.Username);
        Map(x => x.FirstName);
        Map(x => x.LastName);
        HasMany(x => x.TimeEntries).Inverse().Cascade.All().KeyColumn("Employee_id");
    }
}

这是我对 TimeEntry 对象的映射：

public class TimeEntryMap : ClassMap<TimeEntry>
{
    public TimeEntryMap()
    {
        Id(x => x.Id).GeneratedBy.Identity();
        Map(x => x.DateCreated);
        Map(x => x.Date);
        Map(x => x.Length);
        References(x => x.Employee).Column("Employee_id").Not.Nullable();
    }
}

如标题所述，我在我的网络应用程序中使用每个请求一个会话，在 Gobal.asax 中使用此代码：

    public static ISessionFactory SessionFactory = Core.SessionFactoryManager.CreateSessionFactory();

    public static ISession CurrentSession
    {
        get { return (ISession)HttpContext.Current.Items["current.session"]; }
        set { HttpContext.Current.Items["current.session"] = value; }
    }

    protected Global()
    {
        BeginRequest += delegate
        {
            System.Diagnostics.Debug.WriteLine("New Session");
            CurrentSession = SessionFactory.OpenSession();
        };
        EndRequest += delegate
        {
            if (CurrentSession != null)
                CurrentSession.Dispose();
        };
    }

另外，这是我的 SessionFactoryManager 类：

public class SessionFactoryManager
{
    public static ISession CurrentSession;

    public static ISessionFactory CreateSessionFactory()
    {
        return Fluently.Configure()
        .Database(MsSqlConfiguration.MsSql2008.ConnectionString(c => c.FromConnectionStringWithKey("Website.Properties.Settings.WebSiteConnString")))
        .Mappings(m => m
        .FluentMappings.AddFromAssembly(Assembly.GetExecutingAssembly()))
        .ExposeConfiguration(cfg => new SchemaUpdate(cfg).Execute(false, true))
        .BuildSessionFactory();
    }

    public static ISession GetSession()
    {
        return (ISession)HttpContext.Current.Items["current.session"];
    }
}

这是我的存储库类之一，我用来处理 Employee 的对象数据操作：

public class EmployeeRepository<T> : IRepository<T> where T : Employee
{
    private readonly ISession _session;

    public EmployeeRepository(ISession session)
    {
        _session = session;
    }

    public T GetById(int id)
    {
        T result = null;
        using (ITransaction tx = _session.BeginTransaction())
        {
            result = _session.Get<T>(id);
            tx.Commit();
        }
        return result;
    }

    public IList<T> GetAll()
    {
        IList<T> result = null;
        using (ITransaction tx = _session.BeginTransaction())
        {
            result = _session.Query<T>().ToList();
            tx.Commit();
        }
        return result;
    }

    public bool Save(T item)
    {
        var result = false;
        using (ITransaction tx = _session.BeginTransaction())
        {
            _session.SaveOrUpdate(item);
            tx.Commit();
            result = true;
        }
        return result;
    }

    public bool Delete(T item)
    {
        var result = false;
        using (ITransaction tx = _session.BeginTransaction())
        {
            _session.Delete(_session.Load(typeof (T), item.Id));
            tx.Commit();
            result = true;
        }
        return result;
    }

    public int Count()
    {
        var result = 0;
        using (ITransaction tx = _session.BeginTransaction())
        {
            result = _session.Query<T>().Count();
            tx.Commit();
        }
        return result;
    }
}

现在，这是我的问题。当我尝试插入员工时，一切都很好。更新也是完美的......好吧，只要我不更新Employee的“TimeEntries”属性中引用的TimeEntry对象之一......

这是引发异常的地方（在 Web 项目的 ASPX 文件中）：

            var emp = new Employee(1);
            foreach (var timeEntry in emp.TimeEntries)
            {
                timeEntry.Length += 1;
            }
            emp.Save();

这是引发的异常：

[NonUniqueObjectException：具有相同标识符值的不同对象已与会话相关联：1，实体：Core.Entities.Employee]

基本上，每当我尝试

  1. 加载员工和
  2. 修改一个已保存的TimeEntry，我得到了那个异常。

仅供参考，我尝试将SaveOrUpdate()存储库中的Merge(). 它做得很好，但是在使用创建对象时Merge()，我的对象永远不会设置它的 ID。

我还尝试在我的存储库的每个函数中创建和刷新ISession。这是没有意义的，因为一旦我试图加载TimeEntries一个 Employee 的属性，就会引发一个异常，说当 ISession 关闭时，该对象不能被延迟加载......

我迷路了，希望能得到一些帮助。也欢迎对我的存储库提出任何建议，因为我对此很陌生。

谢谢你们！

4

2 回答 2

1

这个StackOverflow 答案对使用合并给出了很好的描述。

但...

我相信您在为您的应用程序设置正确的会话模式时遇到了问题。

我建议您查看每个请求的会话模式，在该模式中，您为每个请求创建一个 NHibernate 会话对象。会话在收到请求时打开，并在生成响应时关闭/刷新。

还要确保不要使用SessionFactory.OpenSession()来获取会话，而是尝试使用SessionFactory.GetCurrentSession()它来承担 NHibernate 的责任，以向您返回当前正确的会话。

我希望这能把你推向正确的方向。

于 2013-04-07T13:48:33.287 回答
1

这段代码

    var emp = new Employee(1);
    foreach (var timeEntry in emp.TimeEntries)
    {
        timeEntry.Length += 1;
    }
    emp.Save();

正在创建一个新的 Employee 对象，假定通过构造函数传递的 ID 为 1。您应该从数据库中加载 Employee，并且您的 Employee 对象不应允许设置 ID，因为您使用的是标识列。此外，新 Employee 不会有任何 TimeEntries 并且错误消息清楚地指出 Employee 实例是问题所在。

我不喜欢存储库中的事务，我真的不喜欢通用存储库。为什么您的 EmployeeRepository 是通用的？难道不应该

public class EmployeeRepository : IRepository<Employee>

我认为您的代码应该类似于：

var repository = new EmployeeRepository(session);
var emp = repository.GetById(1);
foreach (var timeEntry in emp.TimeEntries)
{
    timeEntry.Length += 1;
}
repository.Save(emp);

我个人更喜欢直接使用 ISession：

using (var txn = _session.BeginTransaction())
{
    var emp = _session.Get<Employee>(1);
    foreach (var timeEntry in emp.TimeEntries)
    {
        timeEntry.Length += 1;
    }
    txn.Commit();
}
于 2013-04-07T14:45:23.887 回答