網站首頁 編程語言 正文
注意:我使用的是 Entity Framework Core 2.0 (2.0.0-preview2-final)。正式版發布后,功能可能存在變動。
繼續探索Entity Framework Core 2.0,今天我將探討如何輕松使用軟刪除(或邏輯刪除)。我的意思是以透明的方式實現軟刪除,例如,您是物理上的刪除行。
要實現軟刪除,您需要添加一列以指示該行數據是否被邏輯刪除。如果您想知道該行被刪除,可以使用布爾列,如果您想知道刪除的時間,可以使用日期列。其次是更改所有查詢,使用此列過濾結果集;您還需要將刪除語句替換成為更新語句。
現在我們來看看如何用 Entity Framework Core 來實現這兩件事!
添加IsDeleted列
實體框架核心提供了非常靈活的映射。在上一篇關于跟蹤列的博客中,您將找到映射列的3種方法。在介紹中,我已經說過軟刪除應該是透明的,所以我決定在類型中不暴露IsDeleted
屬性。類型定義如下:
public class Blog { public int BlogId { get; set; } public string Url { get; set; } public ListPosts { get; set; } } public class Post { public int PostId { get; set; } public string Title { get; set; } public string Content { get; set; } public int BlogId { get; set; } public Blog Blog { get; set; } }
現在,我們需要向 Entity Framework Core 指明類型有一個附加列:
public class BloggingContext : DbContext { public DbSetBlogs { get; set; } public DbSet Posts { get; set; } protected override void OnModelCreating(ModelBuilder modelBuilder) { base.OnModelCreating(modelBuilder); modelBuilder.Entity () .Property ("IsDeleted"); } }
更改插入、刪除查詢
Entity Framework Core 使用ChangeTracker
存儲所有的更改。您可以在EF生成SQL語句和執行這些語句之前修改ChangeTracker
。
public class BloggingContext : DbContext { public override int SaveChanges(bool acceptAllChangesOnSuccess) { OnBeforeSaving(); return base.SaveChanges(acceptAllChangesOnSuccess); } public override TaskSaveChangesAsync(bool acceptAllChangesOnSuccess, CancellationToken cancellationToken = default(CancellationToken)) { OnBeforeSaving(); return base.SaveChangesAsync(acceptAllChangesOnSuccess, cancellationToken); } private void OnBeforeSaving() { foreach (var entry in ChangeTracker.Entries ()) { switch (entry.State) { case EntityState.Added: entry.CurrentValues["IsDeleted"] = false; break; case EntityState.Deleted: entry.State = EntityState.Modified; entry.CurrentValues["IsDeleted"] = true; break; } } } }
現在生成以下代碼執行的SQL語句:
using (var context = new BloggingContext()) { var post = new Post { Blog = blog }; context.Posts.Add(post); context.SaveChanges(); }
exec sp_executesql N'SET NOCOUNT ON; INSERT INTO [Posts] ([BlogId], [Content], [IsDeleted], [Title]) VALUES (@p1, @p2, @p3, @p4); SELECT [PostId] FROM [Posts] WHERE @@ROWCOUNT = 1 AND [PostId] = scope_identity(); -- @p3 is 0 (false) ',N'@p1 int,@p2 nvarchar(4000),@p3 bit,@p4 nvarchar(4000)',@p1=1,@p2=NULL,@p3=0,@p4=NULL
context.Posts.Remove(post); context.SaveChanges();
exec sp_executesql N'SET NOCOUNT ON; UPDATE [Posts] SET [BlogId] = @p0, [Content] = @p1, [IsDeleted] = @p2, [Title] = @p3 WHERE [PostId] = @p4; SELECT @@ROWCOUNT; ',N'@p4 int,@p0 int,@p1 nvarchar(4000),@p2 bit,@p3 nvarchar(4000)',@p4=1,@p0=1,@p1=NULL,@p2=1,@p3=NULL
插入和刪除請求已經被處理,您現在還必須更改所有查詢語句。
更改查詢語句
Entity Framework Core 2.0 引入了一個新的概念:查詢過濾器。查詢過濾器總是在生成的查詢語句后面追加一個的where
子句。這意味著,您可以在模型創建時聲明一個實體的過濾器,然后將此過濾器隱式添加到使用該表的生成的每個查詢語句中。
public class BloggingContext : DbContext { protected override void OnModelCreating(ModelBuilder modelBuilder) { base.OnModelCreating(modelBuilder); modelBuilder.Entity() .Property ("IsDeleted"); modelBuilder.Entity () .HasQueryFilter(post => EF.Property (post, "IsDeleted") == false); } }
讓我們看看查詢過濾器的作用:
var posts = context.Posts.ToList();
SELECT [p].[PostId], [p].[BlogId], [p].[Content], [p].[IsDeleted], [p].[Title] FROM [Posts] AS [p] WHERE [p].[IsDeleted] = 0 -- Query filter
查詢過濾器也可以用于關聯查詢:
var blogs = context.Blogs.Include(_ => _.Posts);
SELECT [_].[BlogId], [_].[Url] FROM [Blogs] AS [_] ORDER BY [_].[BlogId] SELECT [p].[PostId], [p].[BlogId], [p].[Content], [p].[IsDeleted], [p].[Title] FROM [Posts] AS [p] INNER JOIN ( SELECT [_0].[BlogId] FROM [Blogs] AS [_0] ) AS [t] ON [p].[BlogId] = [t].[BlogId] WHERE [p].[IsDeleted] = 0 -- Query filter ORDER BY [t].[BlogId]
通過查詢過濾器實現軟刪除非常容易
查詢軟刪除的行
如果您要還原已刪除的行,您必須能夠查詢到這些數據。這意味著您需要臨時刪除查詢過濾器。EF已經添加了一種新方法IgnoreQueryFilters
來表明您不希望將查詢過濾器用于當前查詢。
var deletedPosts = context.Posts.IgnoreQueryFilters() .Where(post => EF.Property(post, "IsDeleted") == true);
恢復已刪除的帖子有點啰嗦,您需要更改跟蹤器中查詢并更新IsDeleted
屬性。
var deletedPosts = context.Posts.IgnoreQueryFilters().Where(post => EF.Property(post, "IsDeleted") == true); foreach (var deletedPost in deletedPosts) { var postEntry = context.ChangeTracker.Entries ().First(entry => entry.Entity == deletedPost); postEntry.Property("IsDeleted").CurrentValue = false; } context.SaveChanges();
總結
使用Entity Framework Core 2.0實現軟刪除模式非常簡單,并且可以是透明的。實際上,您可以無需更改LINQ代碼的情況下,將軟刪除添加到現有模型中。
原文鏈接:https://www.cnblogs.com/tdfblog/p/entity-framework-core-soft-delete-using-query-filters.html
相關推薦
- 2022-03-05 Flutter基本組件Basics?Widget學習_Android
- 2021-12-10 C#實現簡易灰度圖和酷炫HeatMap熱力圖winform(附DEMO)_C#教程
- 2022-04-24 redis用list做消息隊列的實現示例_Redis
- 2022-12-15 redis分布式鎖與zk分布式鎖的對比分析_Redis
- 2022-06-08 優化使用Feign進行Rpc調用,支持對象傳參自動轉換
- 2022-05-12 Echarts x軸標簽太長解決方案
- 2022-11-28 詳解如何使用C++寫一個線程安全的單例模式_C 語言
- 2022-04-12 Python數據可視化Pyecharts庫的使用教程_python
- 最近更新
-
- window11 系統安裝 yarn
- 超詳細win安裝深度學習環境2025年最新版(
- Linux 中運行的top命令 怎么退出?
- MySQL 中decimal 的用法? 存儲小
- get 、set 、toString 方法的使
- @Resource和 @Autowired注解
- Java基礎操作-- 運算符,流程控制 Flo
- 1. Int 和Integer 的區別,Jav
- spring @retryable不生效的一種
- Spring Security之認證信息的處理
- Spring Security之認證過濾器
- Spring Security概述快速入門
- Spring Security之配置體系
- 【SpringBoot】SpringCache
- Spring Security之基于方法配置權
- redisson分布式鎖中waittime的設
- maven:解決release錯誤:Artif
- restTemplate使用總結
- Spring Security之安全異常處理
- MybatisPlus優雅實現加密?
- Spring ioc容器與Bean的生命周期。
- 【探索SpringCloud】服務發現-Nac
- Spring Security之基于HttpR
- Redis 底層數據結構-簡單動態字符串(SD
- arthas操作spring被代理目標對象命令
- Spring中的單例模式應用詳解
- 聊聊消息隊列,發送消息的4種方式
- bootspring第三方資源配置管理
- GIT同步修改后的遠程分支