如何使用 NHibernate 插入或更新（或覆盖）记录？

Question

我需要将一行写入数据库，无论它是否已经存在。 在使用 NHibernate 之前，这是通过存储过程完成的。 该过程将尝试更新，如果没有行被修改，它将回退到插入。 这很有效，因为应用程序并不关心记录是否存在。

对于 NHibernate，我发现的解决方案需要加载实体并修改它，或者删除实体以便插入新实体。 应用程序必须关心记录是否已经存在。 有办法解决这个问题吗？

身份证重要吗？

分配的 ID

该对象有一个关键字作为分配的 id，并且是表中的主键。

据我了解，SaveOrUpdate() 将根据 Id 适当调用 Save() 或 Update() 方法。 使用指定的 id，这将不起作用，因为 id 不是未保存的值。 然而，版本或时间戳字段可以用作指示符。 实际上，这并不相关，因为这仅反映内存中的对象是否已与数据库中的记录关联； 它并不表明该记录是否存在于数据库中。

生成的 ID

如果分配的 id 确实是问题的原因，我可以使用生成的 id 而不是关键字作为主键。 这将避免 NHibernate 插入/更新问题，因为它总是有效地插入。 但是，我仍然需要防止重复的关键字。 使用关键字列上的唯一索引，即使主键不同，它仍然会抛出重复关键字的异常。

另一种方法？

也许问题并不在于 NHibernate，而在于其建模方式。 与应用程序的其他领域不同，它更以数据为中心，而不是以对象为中心。 NHibernate 使读/写变得容易并且消除了存储过程，这很好。 但是，不考虑现有值而简单地编写的愿望与对象身份模型的模型不太相符。 有更好的方法来解决这个问题吗？

Answer 1

我正在使用，

    public IList<T> GetByExample<T>(T exampleInstance)
    {
        return _session.CreateCriteria(typeof(T))
                    .Add(Example.Create(exampleInstance))
                    .List<T>();
    }

    public void InsertOrUpdate<T>(T target)
    {
        ITransaction transaction = _session.BeginTransaction();
        try
        {
            var res=GetByExample<T>(target);
            if( res!=null && res.Count>0 )
                _session.SaveOrUpdate(target);
            else
               _session.Save(target); 
            transaction.Commit();
        }
        catch (Exception)
        {
            transaction.Rollback();
            throw;
        }
        finally
        {
            transaction.Dispose();
        }
    }

但 FindByExample 方法返回所有类似的对象，而不是具有确切 ID 的对象，您有何建议？ 因为我只有对象作为参数，所以我无法访问其特定 ID 字段，因此无法使用 session.get(Object.class(), id);

Answer 2

通常，NHibernate 可以依靠未保存的值来确定是否应该插入或创建实体。 然而，由于您正在分配 ID，因此 NHibernate 看起来您的实体已经被持久化了。 因此，您需要依靠对象的版本控制来让 NHibernate 知道它是一个新对象。 有关如何对实体进行版本控制的信息，请参阅以下链接：

http://web.archive.org/web/20090831032934/http://devlicio.us/blogs/mike_nichols /archive/2008/07/29/when-flushing-goes-bad-assigned-ids-in-nhibernate.aspx

Answer 3

使用 session.SaveOrUpdate(object) 方法。

Answer 4

你可以做

Obj j = session.get(Object.class(), id);
if (j != null)
   session.merge(myObj);
else
   session.saveOrUpdate(myObj);

Answer 5

查询关键字 = x 的对象，取 FirstOrDefault。 如果为空，则添加新对象，如果存在，则更新您获得的对象并对其调用 saveOrUpdate 。

Answer 6

这对我有用：

实现

    public void InsertOrUpdate<TEntity, TId>(TEntity entity) where TEntity : IIdentificableNh<TId>
    {
        var anyy = session.Get<TEntity>(entity.Id);
        if (anyy != null)
        {
            session.Evict(anyy); //dispatch all data loaded, to allow updating 'entity' object.
            session.Update(entity);
        } 
        else
        {
            session.Save(entity);
        }
        
        session.Flush();
    }

实体

public class Caracteristica : IIdentificableNh<int>
{
    public virtual int Id { get; set; }

    public virtual string Descripcion { get; set; }
}

我必须创建一个接口（IIdentificableNh），它允许我访问 Id 属性值。

使用示例：

session.InsertOrUpdate<Caracteristica, int>(new Caracteristica { Id = 2, Descripcion = "Caracteristica2" });

Answer 7

调用 hibernate.saveOrUpdate() 它将检查该对象是否在数据库中，如果是则更新它，如果不是则保存（即插入）它。