Tôi làm cách nào để upsert một bản ghi trong ADO.NET EF 4.1?

Question

Tôi đang cố gắng thực hiện điều gì đó thật sự đơn giản và tôi không thể tìm thấy cách thực hiện bằng cách sử dụng Entity Framework 4.1.

Tôi muốn một phương pháp điều khiển chấp nhận một đối tượng và sau đó thực hiện một UPSERT (hoặc chèn hoặc cập nhật tùy thuộc vào việc bản ghi có tồn tại trong cơ sở dữ liệu) hay không.

Tôi đang sử dụng khóa tự nhiên, vì vậy không có cách nào để tôi xem POCO của mình và cho biết đó có phải là mới hay không.

Đây là cách tôi làm việc đó, và có vẻ như không đúng với tôi:

[HttpPost] 
public JsonResult SaveMyEntity(MyEntity entity) 
{    
    MyContainer db = new MyContainer(); // DbContext 
    if (ModelState.IsValid) 
    { 
     var existing = 
      db.MyEntitys.Find(entity.MyKey); 
     if (existing == null) 
     { 
      db.MyEntitys.Add(entity); 
     } 
     else 
     { 
      existing.A = entity.A; 
      existing.B = entity.B; 
      db.Entry(existing).State = EntityState.Modified; 
     } 
     db.SaveChanges(); 
     return Json(new { Result = "Success" }); 
    } 
} 

Lý tưởng nhất, toàn bộ điều chỉ sẽ là một cái gì đó như thế này:

db.MyEntities.AddOrModify(entity); 

Answer 1

Đáng tiếc là không có cách nào để làm điều này mà không cần truy vấn cơ sở dữ liệu hoặc sử dụng thủ tục lưu trữ. Mã Minimalistic nên là:

public void AddOrModify<T>(T entity, string key) where T : class, IEntity // Implements MyKey 
{ 
    using (var context = new MyContainer()) 
    { 
     if (context.Set<T>().Any(e => e.MyKey == key)) 
     { 
       context.Entry(entity).State = EntityState.Modified; 
     } 
     else 
     { 
       context.Entry(entity).State = EntityState.Added; 
     } 

     context.SaveChanges(); 
    } 
} 

Answer 2

Trong hầu hết các trường hợp, bạn làm không cần đặt rõ ràng EntityState.Modified trừ khi bạn đã tắt theo dõi thay đổi.

Các giải pháp chúng tôi đã là để kiểm tra giá trị của nhận dạng thực thể:

if (entity.Id == default(int)) { 
    // transient entity so insert 
} else { 
    // update 
} 

Answer 3

thực sự có một cách để bối cảnh informa db rằng thực thể bạn đang cố gắng để chèn được thay đổi và bây giờ mới một

_context.MyEntity.Attach(entity); 
_context.MyEntity(entity).State = System.Data.EntityState.Modified; 

Answer 4

Để thực hiện một hoạt động UPSERT, Bạn có thể muốn xem xét việc tạo một SP thực hiện một MERGE.

http://www.databasejournal.com/features/mssql/article.php/3739131/UPSERT-Functionality-in-SQL-Server-2008.htm

Bất cứ cách nào bạn chọn các hoạt động phải có nguyên tử hoặc bạn sẽ có một điều kiện chủng tộc. SP của bạn có thể sẽ cần một HOLDLOCK để làm mất hiệu lực này ...

http://weblogs.sqlteam.com/dang/archive/2009/01/31/UPSERT-Race-Condition-With-MERGE.aspx

Answer 5

Tôi biết câu hỏi này là cũ và có một câu trả lời được chấp nhận, nhưng tôi nghĩ rằng có một giải pháp tốt hơn: nó không đòi hỏi một thêm giao diện được triển khai hoặc loại khóa được xác định.

public static class DbSetExtensions 
{ 
    public static EntityEntry<TEnt> AddIfNotExists<TEnt, TKey>(this DbSet<TEnt> dbSet, TEnt entity, Func<TEnt, TKey> predicate) where TEnt : class 
    { 
     var exists = dbSet.Any(c => predicate(entity).Equals(predicate(c))); 
     return exists 
      ? null 
      : dbSet.Add(entity); 
    } 

    public static void AddRangeIfNotExists<TEnt, TKey>(this DbSet<TEnt> dbSet, IEnumerable<TEnt> entities, Func<TEnt, TKey> predicate) where TEnt : class 
    { 
     var entitiesExist = from ent in dbSet 
      where entities.Any(add => predicate(ent).Equals(predicate(add))) 
      select ent; 

     dbSet.AddRange(entities.Except(entitiesExist)); 
    } 
} 

Vì vậy, sau đó nó có thể được sử dụng như thế này:

using (var context = new MyDbContext()) 
{ 
    var user1 = new User { Name = "Peter", Age = 32 }; 
    context.Users.AddIfNotExists(user1, u => u.Name); 

    var user2 = new User { Name = "Joe", Age = 25 }; 
    context.Users.AddIfNotExists(user2, u => u.Age); 

    // Adds user1 if there is no user with name "Peter" 
    // Adds user2 if there is no user with age 25 
    context.SaveChanges(); 
}