（25）ASP.NET Core EF查詢（複雜查詢運算符、原生SQL查詢、非同步查詢）

来源:https://www.cnblogs.com/wzk153/archive/2019/11/13/11850712.html
-Advertisement-
Play Games

1.複雜查詢運算符 在生產場景中，我們經常用到LINQ運算符進行查詢獲取數據，現在我們就來瞭解下生產場景經常出現幾種複雜查詢運算符。 1.1聯接（INNER JOIN） 藉助LINQ Join運算符，可根據每個源的鍵選擇器連接兩個數據源，併在鍵匹配時生成值的元組。 SQL： SQL Server P ...


1.複雜查詢運算符

在生產場景中，我們經常用到LINQ運算符進行查詢獲取數據，現在我們就來瞭解下生產場景經常出現幾種複雜查詢運算符。

1.1聯接（INNER JOIN）

藉助LINQ Join運算符，可根據每個源的鍵選擇器連接兩個數據源，併在鍵匹配時生成值的元組。

var query = from blog in _context.Set<Blog>()
            join post in _context.Set<Post>()
                on blog.BlogId equals post.BlogId
            select new { blog, post };

SQL：

SELECT [blog].[BlogId], [blog].[Createtime], [blog].[Updatetime], [blog].[Url], [post].[PostId], [post].[BlogId], [post].[Content], [post].[Title]
FROM [Blog] AS [blog]
INNER JOIN [Post] AS [post] ON [blog].[BlogId] = [post].[BlogId]

SQL Server Profiler：

1.2左聯接（Left Join）

雖然Left Join不是LINQ運算符，但關係資料庫具有常用於查詢的Left Join的概念。LINQ查詢中的特定模式提供與伺服器上的LEFT JOIN相同的結果。 

var query = from blog in _context.Set<Blog>()
            join post in _context.Set<Post>()
                on blog.BlogId equals post.BlogId into grouping
            from post in grouping.DefaultIfEmpty()
            select new { blog, post };

SQL:

SELECT [blog].[BlogId], [blog].[Createtime], [blog].[Updatetime], [blog].[Url], [post].[PostId], [post].[BlogId], [post].[Content], [post].[Title]
FROM [Blog] AS [blog]
LEFT JOIN [Post] AS [post] ON [blog].[BlogId] = [post].[BlogId]

SQL Server Profiler：

1.3分組（GroupBy）

LINQ GroupBy運算符創建IGrouping<TKey, TElement>類型的結果，其中TKey和TElement可以是任意類型。此外，IGrouping實現了IEnumerable<TElement>，這意味著可在分組後使用任意LINQ運算符來對其進行組合。

var query = from blog in _context.Set<Blog>()
            group blog by blog.Url into g
            select new
            {
                g.Key,
                Count = g.Count()
            };

SQL:

SELECT [blog].[Url] AS [Key], COUNT(*) AS [Count]
FROM [Blog] AS [blog]
GROUP BY [blog].[Url]

SQL Server Profiler：


分組的聚合運算符出現在Where或OrderBy（或其他排序方式）LINQ運算符中。它在SQL中將Having子句用於Where子句。

var query = from blog in _context.Set<Blog>()
            group blog by blog.Url into g
            where g.Count() > 0
            orderby g.Key
            select new
            {
                g.Key,
                Count = g.Count()
            };

SQL:

SELECT [blog].[Url] AS [Key], COUNT(*) AS [Count]
FROM [Blog] AS [blog]
GROUP BY [blog].[Url]
HAVING COUNT(*) > 0
ORDER BY [Key]

SQL Server Profiler：

EF Core支持的聚合運算符如下所示：
●Avg
●Count
●LongCount
●Max
●Min
●Sum

1.4SelectMany

藉助LINQ SelectMany運算符，可為每個外部元素枚舉集合選擇器，並從每個數據源生成值的元組。

var query0 = from b in _context.Set<Blog>()
                from p in _context.Set<Post>()
                select new { b, p };

var query1 = from b in _context.Set<Blog>()
                from p in _context.Set<Post>().Where(p => b.BlogId == p.BlogId).DefaultIfEmpty()
                select new { b, p };

var query2 = from b in _context.Set<Blog>()
                from p in _context.Set<Post>().Select(p => b.Url + "=>" + p.Title).DefaultIfEmpty()
                select new { b, p };

SQL:

SELECT [b].[BlogId], [b].[Createtime], [b].[Updatetime], [b].[Url], [p].[PostId], [p].[BlogId], [p].[Content], [p].[Title]
FROM [Blog] AS [b]
CROSS JOIN [Post] AS [p]

SELECT [b].[BlogId], [b].[Createtime], [b].[Updatetime], [b].[Url], [t0].[PostId], [t0].[BlogId], [t0].[Content], [t0].[Title]
FROM [Blog] AS [b]
CROSS APPLY (
    SELECT [t].[PostId], [t].[BlogId], [t].[Content], [t].[Title]
    FROM (
        SELECT NULL AS [empty]
    ) AS [empty]
    LEFT JOIN (
        SELECT [p].[PostId], [p].[BlogId], [p].[Content], [p].[Title]
        FROM [Post] AS [p]
        WHERE [b].[BlogId] = [p].[BlogId]
    ) AS [t] ON 1 = 1
) AS [t0]

SELECT [b].[BlogId], [b].[Createtime], [b].[Updatetime], [b].[Url], [t0].[c]
FROM [Blog] AS [b]
CROSS APPLY (
    SELECT [t].[c]
    FROM (
        SELECT NULL AS [empty]
    ) AS [empty]
    LEFT JOIN (
        SELECT ([b].[Url] + N'=>') + [p].[Title] AS [c]
        FROM [Post] AS [p]
    ) AS [t] ON 1 = 1
) AS [t0]

SQL Server Profiler：


好了，這裡就不多寫關於LINQ其他示例了，如果需要瞭解的小伙伴們，可以移步“101個LINQ示例”這裡瞭解。

2.原生SQL查詢

有一些複雜業務場景，使用LINQ查詢可能會導致SQL查詢效率低下並不適用，那麼這時候就需要到原生SQL查詢了。EF Core為我們提供FromSql擴展方法基於原始SQL查詢。 FromSql只能在直接位於DbSet<>上的查詢根上使用。

var blogs = _context.Blog.FromSql("SELECT * FROM dbo.Blog").ToList();

原生SQL查詢可用於執行存儲過程。

var blogs = _context.Blog
    .FromSql("EXECUTE dbo.GetMostPopularBlogs")
    .ToList();

2.1原始SQL查詢使用參數化

向原始SQL查詢引入任何用戶提供的值時，必須註意防範SQL註入攻擊。除了驗證確保此類值不包含無效字元，還要將值與SQL文本參數化處理。
下麵的示例通過在SQL查詢字元串中包含形參占位符並提供額外的實參，將單個形參傳遞到存儲過程。雖然此語法可能看上去像String.Format語法，但提供的值包裝在DbParameter中，且生成的參數名稱插入到指定{0}占位符的位置。

var url = "http://blogs.msdn.com/webdev";
var blogs = _context.Blog
    .FromSql("EXECUTE dbo.GetMostPopularBlogForUrl {0}", url)
.ToList();

SQL:

exec sp_executesql N'EXECUTE dbo.GetMostPopularBlogForUrl @p0
',N'@p0 nvarchar(4000)',@p0=N'http://blogs.msdn.com/webdev'

SQL Server Profiler：


還可以構造DbParameter並將其作為參數值提供。由於使用了常規SQL參數占位符而不是字元串占位符，因此可安全地使用FromSql：

var urlParams = new SqlParameter("Url", "http://blogs.msdn.com/webdev");
var blogs = _context.Blog
    .FromSql("EXECUTE dbo.GetMostPopularBlogForUrl @Url", urlParams)
.ToList();

SQL:

exec sp_executesql N'EXECUTE dbo.GetMostPopularBlogForUrl @Url
',N'@Url nvarchar(28)',@Url=N'http://blogs.msdn.com/webdev'

SQL Server Profiler：

2.2使用LINQ編寫SQL

可使用LINQ運算符在初始的原始SQL查詢基礎上進行組合。EF Core將其視為子查詢，併在資料庫中對其進行組合。下麵的示例使用原始SQL查詢，該查詢從表值函數 (TVF) 中進行選擇。然後，使用LINQ進行篩選和排序，從而對其進行組合。

var searchTerm = "http://blogs.msdn.com/visualstudio";
var blogs = _context.Blog
    .FromSql($"SELECT * FROM dbo.Blog")
    .Where(b => b.Url == searchTerm)
    .Include(c=>c.Post)
    .OrderByDescending(b => b.Createtime)
.ToList();

SQL:

exec sp_executesql N'SELECT [b].[BlogId], [b].[Createtime], [b].[Updatetime], [b].[Url]
FROM (
    SELECT * FROM dbo.Blog
) AS [b]
WHERE [b].[Url] = @__searchTerm_1
ORDER BY [b].[Createtime] DESC, [b].[BlogId]',N'@__searchTerm_1 nvarchar(4000)',@__searchTerm_1=N'http://blogs.msdn.com/visualstudio'

exec sp_executesql N'SELECT [b.Post].[PostId], [b.Post].[BlogId], [b.Post].[Content], [b.Post].[Title]
FROM [Post] AS [b.Post]
INNER JOIN (
    SELECT [b0].[BlogId], [b0].[Createtime]
    FROM (
        SELECT * FROM dbo.Blog
    ) AS [b0]
    WHERE [b0].[Url] = @__searchTerm_1
) AS [t] ON [b.Post].[BlogId] = [t].[BlogId]
ORDER BY [t].[Createtime] DESC, [t].[BlogId]',N'@__searchTerm_1 nvarchar(4000)',@__searchTerm_1=N'http://blogs.msdn.com/visualstudio'

SQL Server Profiler：

3.非同步查詢

當在資料庫中執行查詢時，非同步查詢可避免阻止線程。非同步查詢對於在客戶端應用程式中保持響應式UI非常重要。 非同步查詢還可以增加Web應用程式中的吞吐量，即通過釋放線程，以處理其他Web應用程式中的請求。

public async Task<IActionResult> Index()
{
    var id1 = Thread.CurrentThread.ManagedThreadId.ToString();

    var blogs = await _context.Blog.ToListAsync();

    var id2 = Thread.CurrentThread.ManagedThreadId.ToString();

    return View(blogs);
}

當我們運行以上代碼時候，通過在關鍵字await上下文加入兩段獲取線程ID代碼，我們會看到如下結果：

看到兩段線程代碼輸出ID結果沒有？從上圖可以觀察到，當我們在進入某個視圖或者方法時候，執行到await某一個方法，當前線程不會一直等待下去，會立馬回收到線程池，供其他地方調用！當該await方法返回數據時候，才從線程池調用空閑線程執行await方法下文餘下的步驟。所以UI界面才不會進入假死狀態。

參考文獻：
複雜查詢運算符
原生SQL查詢
非同步查詢


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Java基礎第二天--多態、介面
    多態 多態的概述 同一個對象，在不同時刻表現出來的不同形態 多態的前提和體現 有繼承/實現關係 有方法重寫關係 有父類引用指向子類對象 多態中成員訪問特點 成員變數 ：編譯看左邊，執行看左邊 成員方法 ：編譯看左邊，執行看右邊 為什麼成員變數和成員方法訪問不一樣呢 因為成員方法有重寫，而成員變數不一 ...
  • Java——將前端的對象數組通過Json字元串傳到後端並轉換為對象集合
    本文主要記錄瞭如何將將前端的對象數組通過Json字元串傳到後端，併在後端將Json字元串轉換為對象集合。 ...
  • SpringBoot整合Mybatis關於分頁查詢的方法
    最近公司在用到SpringBoot整合Mybatis時當web端頁面數據增多時需要使用分頁查詢以方便來展示數據。本人對分頁查詢進行了一些步驟的總結，希望能夠幫助到有需要的博友。如有更好的方式，也希望評論留言，本人以作更好的改進。 SpringBoot+Mybatis+PageHelper實現分頁 以 ...
  • python基礎(24):面向對象三大特性一(繼承)
    1. 繼承 1.1 什麼是繼承 繼承是一種創建新類的方式，在python中，新建的類可以繼承一個或多個父類，父類又可稱為基類或超類，新建的類稱為派生類或子類。 python中類的繼承分為：單繼承和多繼承。 class ParentClass1: #定義父類 pass class ParentClas ...
  • 使用.net core中的類DispatchProxy實現AOP
    在軟體業，AOP為Aspect Oriented Programming的縮寫，意為：面向切麵編程，通過預編譯方式和運行期動態代理實現程式功能的統一維護的一種技術。AOP是軟體開發中的一個熱點，利用AOP可以對業務邏輯的各個部分進行隔離，從而使得業務邏輯各部分之間的耦合度降低，提高程式的可重用性。 ...
  • ELK分散式日誌+NLog在.NetCore中的應用
    一、ELK簡介 ELK是Elasticsearch、Logstash和Kibana首字母的縮寫。這三者均是開源軟體，這三套開源工具組合起來形成了一套強大的集中式日誌管理平臺 Elasticsearch是一個分散式搜索和分析引擎，具有高可伸縮、高可靠和易管理等特點，基於Apache Lucene構建， ...
  • DataGridView自動保存列的寬度和位置
    WinForm程式中表單的自動保存列的寬度和位置，是一種常見的功能，對於用戶體驗來說是非常好的。現記錄一下實現過程： 1、新建一個類，命為為：DataGridViewColumnStyle。 這個類實現的功能：當DataGridView的列寬或列的位置發生改變時，系統將自動記錄DataGridVie ...
  • EF中嵌套類的where查詢
    有一個訂單類：Order，在訂單Order類中有一個子類，訂單詳細類OrderDetail。 需求：根據訂單詳細類的欄位過濾數據 解決方案： ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類