使用实体框架实现更新行（如果存在），否则插入新行逻辑的最有效方法是什么？或者有什么模式？
【问题讨论】：
标签： c# entity-framework
如果您正在使用附加对象（从上下文的同一实例加载的对象），您可以简单地使用：
if (context.ObjectStateManager.GetObjectStateEntry(myEntity).State == EntityState.Detached)
{
context.MyEntities.AddObject(myEntity);
}
// Attached object tracks modifications automatically
context.SaveChanges();
如果您可以使用有关对象键的任何知识，则可以使用以下内容：
if (myEntity.Id != 0)
{
context.MyEntities.Attach(myEntity);
context.ObjectStateManager.ChangeObjectState(myEntity, EntityState.Modified);
}
else
{
context.MyEntities.AddObject(myEntity);
}
context.SaveChanges();
如果您无法通过其 Id 确定对象的存在，则必须执行查找查询：
var id = myEntity.Id;
if (context.MyEntities.Any(e => e.Id == id))
{
context.MyEntities.Attach(myEntity);
context.ObjectStateManager.ChangeObjectState(myEntity, EntityState.Modified);
}
else
{
context.MyEntities.AddObject(myEntity);
}
context.SaveChanges();
【讨论】：
using 块中。将上下文留在内存中一段时间可以吗？例如，在 Windows 窗体的生命周期中？我通常会尝试清理数据库对象以确保数据库上的负载最小。等待销毁我的 EF 上下文没有问题吗？
从 Entity Framework 4.3 开始，在命名空间 System.Data.Entity.Migrations 中有一个 AddOrUpdate 方法：
public static void AddOrUpdate<TEntity>(
this IDbSet<TEntity> set,
params TEntity[] entities
)
where TEntity : class
doc：
在调用 SaveChanges 时按键添加或更新实体。相等的 从数据库术语到“upsert”操作。这种方法可以 在使用 Migrations 播种数据时很有用。
为了回答comment by @Smashing1978，我将从@Colin提供的链接中粘贴相关部分
AddOrUpdate 的工作是确保您不会创建重复项 当您在开发过程中播种数据时。
首先，它将在您的数据库中执行查询以查找记录 您作为键（第一个参数）提供的任何内容与 AddOrUpdate 中提供的映射列值（或值）。所以这 匹配时有点松散，但播种非常好 设计时数据。
更重要的是，如果找到匹配项，则更新将更新所有 并清除任何不在您的 AddOrUpdate 中的内容。
也就是说，我有一种情况，我从外部服务中提取数据并通过主键插入或更新现有值（我的消费者本地数据是只读的） - 在生产中使用 AddOrUpdate 以获得更多信息现在超过 6 个月，到目前为止没有任何问题。
【讨论】：
调用SaveChanges() 时会发生魔法，这取决于当前的EntityState。如果实体有EntityState.Added，它将被添加到数据库中，如果它有EntityState.Modified，它将在数据库中更新。所以你可以实现一个InsertOrUpdate()方法如下：
public void InsertOrUpdate(Blog blog)
{
using (var context = new BloggingContext())
{
context.Entry(blog).State = blog.BlogId == 0 ?
EntityState.Added :
EntityState.Modified;
context.SaveChanges();
}
}
如果您无法检查Id = 0 以确定它是否为新实体，请检查answer of Ladislav Mrnka。
【讨论】：
如果您知道您使用的是相同的上下文并且没有分离任何实体，您可以制作这样的通用版本：
public void InsertOrUpdate<T>(T entity, DbContext db) where T : class
{
if (db.Entry(entity).State == EntityState.Detached)
db.Set<T>().Add(entity);
// If an immediate save is needed, can be slow though
// if iterating through many entities:
db.SaveChanges();
}
db 当然可以是类字段，或者方法可以是静态的和扩展，但这是基础。
【讨论】：
Ladislav 的回答很接近，但我必须进行一些修改才能使其在 EF6（数据库优先）中工作。我用我的 on AddOrUpdate 方法扩展了我的数据上下文，到目前为止，这似乎与分离的对象很好地配合：
using System.Data.Entity;
[....]
public partial class MyDBEntities {
public void AddOrUpdate(MyDBEntities ctx, DbSet set, Object obj, long ID) {
if (ID != 0) {
set.Attach(obj);
ctx.Entry(obj).State = EntityState.Modified;
}
else {
set.Add(obj);
}
}
[....]
【讨论】：
使用 Any 检查现有行。
public static void insertOrUpdateCustomer(Customer customer)
{
using (var db = getDb())
{
db.Entry(customer).State = !db.Customer.Any(f => f.CustomerId == customer.CustomerId) ? EntityState.Added : EntityState.Modified;
db.SaveChanges();
}
}
【讨论】：
在我看来，值得一提的是，使用新发布的EntityGraphOperations for Entity Framework Code First，您可以避免编写一些重复代码来定义图中所有实体的状态。我是这个产品的作者。我已将其发布在github、code-project（包括分步演示和可供下载的示例项目）和nuget。
它将自动设置实体的状态为Added 或Modified。如果实体不再存在，您将手动选择必须删除的实体。
示例：
假设我有一个Person 对象。 Person 可以有很多电话、一个文档并且可以有一个配偶。
public class Person
{
public int Id { get; set; }
public string FirstName { get; set; }
public string LastName { get; set; }
public string MiddleName { get; set; }
public int Age { get; set; }
public int DocumentId {get; set;}
public virtual ICollection<Phone> Phones { get; set; }
public virtual Document Document { get; set; }
public virtual PersonSpouse PersonSpouse { get; set; }
}
我想确定图中包含的所有实体的状态。
context.InsertOrUpdateGraph(person)
.After(entity =>
{
// Delete missing phones.
entity.HasCollection(p => p.Phones)
.DeleteMissingEntities();
// Delete if spouse is not exist anymore.
entity.HasNavigationalProperty(m => m.PersonSpouse)
.DeleteIfNull();
});
您也知道，唯一的关键属性可以在定义电话实体的状态时发挥作用。对于这种特殊用途，我们有ExtendedEntityTypeConfiguration<> 类，它继承自EntityTypeConfiguration<>。如果我们想使用这样的特殊配置，那么我们必须从ExtendedEntityTypeConfiguration<> 继承我们的映射类，而不是EntityTypeConfiguration<>。例如：
public class PhoneMap: ExtendedEntityTypeConfiguration<Phone>
{
public PhoneMap()
{
// Primary Key
this.HasKey(m => m.Id);
…
// Unique keys
this.HasUniqueKey(m => new { m.Prefix, m.Digits });
}
}
就是这样。
【讨论】：
插入否则更新两者
public void InsertUpdateData()
{
//Here TestEntities is the class which is given from "Save entity connection setting in web.config"
TestEntities context = new TestEntities();
var query = from data in context.Employee
orderby data.name
select data;
foreach (Employee details in query)
{
if (details.id == 1)
{
//Assign the new values to name whose id is 1
details.name = "Sanjay";
details. Surname="Desai";
details.address=" Desiwadi";
}
else if(query==null)
{
details.name="Sharad";
details.surname=" Chougale ";
details.address=" Gargoti";
}
}
//Save the changes back to database.
context.SaveChanges();
}
【讨论】：
@LadislavMrnka 答案的替代方案。这适用于实体框架 6.2.0。
如果您有特定的DbSet 和需要更新或创建的项目：
var name = getNameFromService();
var current = _dbContext.Names.Find(name.BusinessSystemId, name.NameNo);
if (current == null)
{
_dbContext.Names.Add(name);
}
else
{
_dbContext.Entry(current).CurrentValues.SetValues(name);
}
_dbContext.SaveChanges();
但是，这也可以用于具有单个主键或复合主键的通用 DbSet。
var allNames = NameApiService.GetAllNames();
GenericAddOrUpdate(allNames, "BusinessSystemId", "NameNo");
public virtual void GenericAddOrUpdate<T>(IEnumerable<T> values, params string[] keyValues) where T : class
{
foreach (var value in values)
{
try
{
var keyList = new List<object>();
//Get key values from T entity based on keyValues property
foreach (var keyValue in keyValues)
{
var propertyInfo = value.GetType().GetProperty(keyValue);
var propertyValue = propertyInfo.GetValue(value);
keyList.Add(propertyValue);
}
GenericAddOrUpdateDbSet(keyList, value);
//Only use this when debugging to catch save exceptions
//_dbContext.SaveChanges();
}
catch
{
throw;
}
}
_dbContext.SaveChanges();
}
public virtual void GenericAddOrUpdateDbSet<T>(List<object> keyList, T value) where T : class
{
//Get a DbSet of T type
var someDbSet = Set(typeof(T));
//Check if any value exists with the key values
var current = someDbSet.Find(keyList.ToArray());
if (current == null)
{
someDbSet.Add(value);
}
else
{
Entry(current).CurrentValues.SetValues(value);
}
}
【讨论】：
试试这个算法
public void InsertOrUpdate(Item item)
{
using (var context = new ItemContext())
{
var existedItem = context.Items.Where(x => x.Id==item.Id).FirstOrDefault();
if(existedItem != null)
{
context.Entry(existedItem).CurrentValues.SetValues(item);
//or only if you want to update some special properties
existedItem.Prop1=item.Prop1;
existedItem.Prop2=item.Prop2
context.Entry(existedItem).State =EntityState.Modified;
//-----------
}
else
{
context.Items.Add(item);
}
context.SaveChanges();
}
}
【讨论】：
else 块说existedItem = new Item(); context.Items.Add(existedItem);，然后将更新existedItem 属性的代码移到else 块下方。
更正
public static void InsertOrUpdateRange<T, T2>(this T entity, List<T2> updateEntity)
where T : class
where T2 : class
{
foreach(var e in updateEntity)
{
context.Set<T2>().InsertOrUpdate(e);
}
}
public static void InsertOrUpdate<T, T2>(this T entity, T2 updateEntity)
where T : class
where T2 : class
{
if (context.Entry(updateEntity).State == EntityState.Detached)
{
if (context.Set<T2>().Any(t => t == updateEntity))
{
context.Set<T2>().Update(updateEntity);
}
else
{
context.Set<T2>().Add(updateEntity);
}
}
context.SaveChanges();
}
【讨论】：
T 没有使用，第二个InsertOrUpdate 必须是DbSet 上的扩展方法，context.Set<T2>().Any(t => t == updateEntity) 会给出运行时错误。请在发布前测试代码！