当在 Entity Framework 中先删除实体、再修改其ID 、然后重新添加时发现的 ...

问题描述

当在 Entity Framework Core 中先删除实体、再修改其ID 、然后重新添加时发现的实体未被删除。
问题代码示例

1. using MediatR;
2. using Microsoft.EntityFrameworkCore;
3. using Microsoft.Extensions.DependencyInjection;
4. using System.ComponentModel.DataAnnotations.Schema;
5. using System.Diagnostics;
7. var serviceCollection = new ServiceCollection();
9. serviceCollection.AddDbContext<DbContext, TestDB>(opt => opt.UseInMemoryDatabase("test"));
10. serviceCollection.AddScoped<PostRepo>();
12. var serviceProvider = serviceCollection.BuildServiceProvider();
14. var id = Guid.NewGuid();
16. using (var scope = serviceProvider.CreateScope())
17. {
19.     PostRepo repo = scope.ServiceProvider.GetRequiredService<PostRepo>();
20.     DbContext db = scope.ServiceProvider.GetRequiredService<DbContext>();
22.     repo.Save(new Post()
23.     {
24.         Id = id,
25.         Name = "123",
26.         Tags = new List<Tag>() { new Tag() { PostId = id, TagName = "Tag1" } }
27.     });
29.     db.SaveChanges();
30. }
32. using (var scope = serviceProvider.CreateScope())
33. {
34.     PostRepo repo = scope.ServiceProvider.GetRequiredService<PostRepo>();
35.     DbContext db = scope.ServiceProvider.GetRequiredService<DbContext>();
37.     var entity = repo.QueryById(id);
39.     repo.Save(entity);
41.     db.SaveChanges();
42. }
45. using (var scope = serviceProvider.CreateScope())
46. {
47.     PostRepo repo = scope.ServiceProvider.GetRequiredService<PostRepo>();
48.     DbContext db = scope.ServiceProvider.GetRequiredService<DbContext>();
50.     var entity = repo.QueryById(id);
52.     Console.WriteLine($"post.Tag Count {entity?.Tags.Count()}");
53. }
55. public class TestDB : DbContext
56. {
57.     public TestDB(DbContextOptions options) : base(options)
58.     {
59.     }
62.     protected override void OnModelCreating(ModelBuilder modelBuilder)
63.     {
66.         base.OnModelCreating(modelBuilder);
68.     }
70.     public DbSet<Post> Posts { get; set; }
71.     public DbSet<Tag> Tags { get; set; }
72. }
74. public class Post
75. {
76.     public Guid Id { get; set; }
77.     public string Name { get; set; }
79.     [NotMapped]
80.     public List<Tag> Tags { get; set; }
81. }
82. public class Tag
83. {
84.     public Guid Id { get; set; }
85.     public Guid PostId { get; set; }
86.     public string TagName { get; set; }
87. }
89. public class PostRepo
90. {
91.     private readonly DbContext _db;
92.     public PostRepo(DbContext db)
93.     {
94.         _db = db;
95.     }
97.     public Post? QueryById(Guid id)
98.     {
99.         var post = _db.Set<Post>().Where(x => x.Id == id).FirstOrDefault();
100.         if (post == null)
101.             return null;
102.         var tags = _db.Set<Tag>().Where(x => x.PostId == id).ToList();
104.         post.Tags = tags;
105.         return post;
106.     }
108.     public void Save(Post entity)
109.     {
110.         var isExist = _db.Set<Post>().Where(x => x.Id == entity.Id).Any();
111.         if (isExist)
112.         {
113.             _db.Update(entity);
114.         }
115.         else
116.         {
117.             _db.Add(entity);
118.         }
120.         if (entity.Tags != null)
121.         {
122.             var temp = _db.Set<Tag>().Where(x => x.PostId == entity.Id).ToList();
124.             //clean old
125.             _db.RemoveRange(temp);
127.             // renew id
128.             entity.Tags.ForEach(x => { x.Id = Guid.NewGuid(); });
130.             // add as new ,this cause old entity state to add
131.             _db.AddRange(entity.Tags);
132.         }
133.     }
134. }

复制代码

问题分析

当我第一次调用RemoveRange时，ChangeTracker 将 tag 标志为 Delete
ChangeTracker的Debug View 如下所示

1. Tag {Id: 3cb7d0a8-e044-4818-9afd-4f09c20ae60a} Deleted

复制代码

当执行完 entity.Tags.ForEach(x=>{ x.Id =  Guid.NewGuid();}); 后
ChangeTracker的Debug View 如下所示

1. Tag {Id: ac9d9fc7-5a8d-4b2e-9ac7-ca1a2778af8d} Deleted

复制代码

可以看到 Tag 的Id 产生了变革，这说明 ChangeTracker 追踪的是对象,自此tag的Id产生了变革，便无法删除了对于Id的数据了
当执行后续的AddRanage时，tag就酿成了Add
ChangeTracker的Debug View 如下所示

1. Tag {Id: ac9d9fc7-5a8d-4b2e-9ac7-ca1a2778af8d} Added

复制代码

所以就导致了原先想要删除Tag的删除信息丢失。
根本原因： 就是 add和remove的都是同一个对象的引用，变动Id导致了数据的错位。
办理方案

自行选择

• 使用clone方案
  

1. var items =  entity.Tags.Select(x=>x.Clone()).ToList().ForEach(x => { x.Id = Guid.NewGuid(); });
2. _db.AddRange(items);

复制代码

• 对于一样Id的使用更新
  

1. var childItems = entity.Tags;
2. var deleteItem = temp.ExceptBy(childItems.Select(x => x.Id), x => x.Id);
3. var addItem = childItems.ExceptBy(temp.Select(x => x.Id), x => x.Id);
4. var update = childItems.IntersectBy(temp.Select(x => x.Id), x => x.Id);
7. _db.RemoveRange(deleteItem);
8. _db.AddRange(addItem);
9. _db.UpdateRange(update);

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。