获取现有实体（如果存在）或创建一个新实体

Question

我正在导入的数据可能已存在于我的数据库中，也可能不存在。我希望 NHibernate 将任何实体与现有数据库实体关联（如果存在）（可能只是设置主键/id），或者创建一个新实体（如果不存在）。我的框架使用 S#arp 架构（MVC 2、NHibernate、Fluent）。

我已将 [HasUniqueDomainSignature] 属性添加到该类，并将 [DomainSignature] 属性添加到我想要用于比较的属性。我能想到的唯一方法（这不是一个可接受的解决方案，甚至可能不起作用）如下（伪 C#）：

foreach (Book importedBook in importedBooks){
    foreach (Author author in importedBook.Authors){
        if (!author.IsValid()){  // NHibernate Validator will check DomainSignatures
            author = _authorRepository.GetByExample(author);  // This would be to get the db object with the same signature, 
                                 //but I don't think I could even update this as I iterate through it.
        }
}

}

正如您所看到的，这既混乱又无意义。除此之外，我对这本书有六个联想（主题、格式等），但它没有任何意义。一定有一种我缺少的简单方法可以做到这一点。我不是 NHibernate 的新手，但我绝对不是专家。

Answer 1

我可能不明白这个问题，但是数据如何“可能存在于数据库中，也可能不存在”？例如，如果一本书有 2 个作者，如果作者不存在，那么如何在数据库级别存储关系？

看起来好像您正在尝试使用 NHibernate 导入数据（或者创建一个实体，如果它不存在），这似乎不正确。

Answer 2

大多数数据库实现都支持条件 UPDATE-or-INSERT 语法。例如，Oracle 有一个 MERGE 命令。结合映射中的 Hibernate 块，您应该能够解决问题。我不知道 Fluent，但我认为它也支持这一点。

Answer 3

只是意识到我从未给出过答案或批准了别人的答案。我最终只是编写了一个新的 SaveOrUpdate ，它需要一个参数来在持久化之前检查是否存在。我还在域模型中添加了一个属性，以便在保存/更新时进行覆盖（尽管回想起来，只有在更新时才会覆盖）。

这是代码，如果它可以帮助其他人解决这个困境：

       public TEntity SaveOrUpdate<TEntity>(TEntity entity, bool checkForExistingEntity)
    {
        IRepository<TEntity> repository = new Repository<TEntity>();
        if (checkForExistingEntity) {

            if (entity is Entity) {
                IEnumerable<PropertyInfo> props = (entity as Entity).GetSignatureProperties();
                Dictionary<string, object> parameters =
                    props.ToDictionary(propertyInfo => propertyInfo.Name, propertyInfo => propertyInfo.GetValue(entity, null));
                TEntity duplicateEntity = repository.FindOne(parameters);
                if (duplicateEntity != null) {
                    // Update any properties with the OverwriteOnSaveUpdate attribute
                    foreach (var property in RepositoryHelper.GetUpdatableProperties(typeof(TEntity)))
                    {
                        object initialValue = property.GetValue(entity, null);
                        property.SetValue(duplicateEntity, initialValue, null);
                    }
                    // Fill in any blank properties on db version
                    foreach (var property in typeof(TEntity).GetProperties())
                    {
                        if (property.GetValue(duplicateEntity, null) == null) {
                            object initialValue = property.GetValue(entity, null);
                            property.SetValue(duplicateEntity, initialValue, null);
                        }
                    }
                    return duplicateEntity;
                }
            }
        }
        return SaveOrUpdate(entity);
    }