Entity Framework 查漏補缺 （二）

来源:https://www.cnblogs.com/qiuguochao/archive/2019/01/12/10162291.html
-Advertisement-
Play Games

數據載入 如下這樣的一個lamda查詢語句，不會立馬去查詢資料庫，只有當需要用時去調用（如取某行，取某個欄位、聚合），才會去操作資料庫，EF中本身的查詢方法返回的都是IQueryable介面。 鏈接：IEnumerable和IQueryable介面說明 其中聚合函數會影響數據載入，諸如：toList ...


數據載入

 如下這樣的一個lamda查詢語句，不會立馬去查詢資料庫，只有當需要用時去調用（如取某行，取某個欄位、聚合），才會去操作資料庫，EF中本身的查詢方法返回的都是IQueryable介面。

鏈接：IEnumerable和IQueryable介面說明

其中聚合函數會影響數據載入，諸如：toList()，sum(),Count(),First()能使數據立即查詢載入。

IQueryable中的Load方法

 一般情況，我們都是使用ToList或First來完成預先載入數據操作。但在EF中還可以使用Load() 方法來顯式載入，將獲取的數據放到EF Context中，緩存起來備用。和ToList()很像，只是它不創建列表只是把數據緩存到EF Context中而已，開銷較少。

using (var context = new TestDB())
{
    context.Place.Where(t=>t.PlaceID==9).Load();
}

VS中的方法說明：

延遲載入

用之前的Place類和People為例

Place對象如下：

public class Place
{
    [Key]
    public int PlaceID { get; set;}

    public string Provice { get; set; }

    public string City { get; set; }
    //導航屬性
    public virtual List<People> Population { get; set; }

}

下麵查詢，不會主動去查詢出導航屬性（Population ）關聯的數據

using (var context = new TestDB())
{
    var obj = context.Place.Where(t => t.PlaceID == 9).FirstOrDefault();
}

可以看到Population為null

只有用到Population對象時，EF才會發起到資料庫的查詢；

當然導航數據必須標記virtual，配置延遲載入

//導航屬性
public virtual Place Place { get; set; }

要註意的事：在延遲載入條件下，經常以為導航數據也載入了，從而在迴圈中去遍歷導航屬性，造成多次訪問資料庫。

立即載入

除了前面所說的，使用聚合函數（sum等）外來立即預載入數據，還可以使用Include方法

在上面的查詢中，想要查詢place以及關聯的Population數據如下:

using (var context = new TestDB())
{
    var obj = context.Place.Where(t => t.PlaceID == 9).Include(p=>p.Population).FirstOrDefault();
}

事務

 在EF中，saveChanges()預設是開啟了事務的，在調用saveChanges()之前，所有的操作都在同一個事務中，同一次資料庫連接。若使用同一DbContext對象，EF的預設事務處理機制基本滿足使用。

除此之外，以下兩種情況怎麼使用事務：

  1. 數據分階段保存，多次調用saveChanges()
  2. 使用多個DbContext對象（儘量避免）

第一種情況：顯式事務

using (var context = new TestDB())
{
    using (var tran=context.Database.BeginTransaction())
    {
        try
        {
            context.Place.Add(new Place { City = "beijing", PlaceID = 11 });
            context.SaveChanges();
            context.People.Add(new People { Name = "xiaoli" });
            context.SaveChanges();
            tran.Commit();
        }
        catch (Exception)
        {
            tran.Rollback();
        }
    }
}

註意的是，不調用commit()提交，沒有異常事務也不會預設提交。

第二種情況：TransactionScope分散式事務

  • 引入System.Transactions.dll
  • Windows需要開啟MSDTC
  • TransactionScope也於適用於第一種情況。這裡只討論連接多個DBcontext的事務使用
  • 需要調用Complete()，否則事務不會提交
  • 在事務內，報錯會自動回滾
using (var tran = new TransactionScope())
{
    try
    {
        using (var context = new TestDB())
        {
            context.Place.Add(new Place { City = "5555"});
            context.SaveChanges();
        }
        using (var context2 = new TestDB2())
        {
            context2.Student.Add(new Student { Name="li"});
            context2.SaveChanges();
        }
        throw new Exception();
        tran.Complete();
    }
    catch (Exception)
    {
                    
    }
}

註意：上面代碼在同一個事務內使用了多個DBcontext，會造次多次連接關閉資料庫

題外話

如是多個DBcontext連著是同一個資料庫的話，可以將一個己打開的資料庫連接對象傳給它，並且需要指定EF在DbContext對象銷毀時不關閉資料庫連接。避免造成多次連接關閉資料庫

DbContext對象改造，增加重載構造函數;；傳入兩個參數

  • 資料庫連接DbConnection
  • contextOwnsConnection=false（DbContext對象銷毀時不關閉資料庫連接）：
public class TestDB2 : DbContext
{
    public TestDB2():base("name=Test")
    {
    }
    public TestDB2(DbConnection conn, bool contextOwnsConnection) : base(conn, contextOwnsConnection)
    {
    }
    public DbSet<Student> Student { get; set; }
}

事務代碼如下：

using (TransactionScope scope = new TransactionScope())
{
    String connStr = ……;
    using (var conn = SqlConnection(connStr))
    {
        try
        {
            conn.Open();
            using (var context1 = new MyDbContext(conn, contextOwnsConnection: false))
            {
                ……
                context1.SaveChanges();
            }
            using (var context2 = new MyDbContext(conn, contextOwnsConnection: false))
            {
                ……
                context2.SaveChanges();
            }
　　　　　　　scope.Complete();
         }
        catch (Exception e)
        {

        }
        finally
        {
            conn.Close();
        }
    }
}

DBcontent線程內唯一

 

鏈接：dbcontext實例創建問題

 

併發

在實際場景中，併發是很常見的事，同條記錄同時被不同的兩個用戶修改

在EF中有兩種常見的併發衝突檢測

方法一：ConcurrencyCheck特性

可以指定對象的一個或多個屬性用於併發檢測，在對應屬性加上ConcurrencyCheck特性

這裡我們指定Student 對象的屬性Name

public class Student
{
    [Key]
    public int ID { get; set; }
    [ConcurrencyCheck]
    public string Name { get; set; }
    public int Age { get; set; }
}

用個兩個線程同時去更新Student對象，模擬用戶併發操作

static void Main(string[] args)
{
    Task t1 = Task.Run(() => {
        using (var context = new TestDB2())
        {
            var obj = context.Student.First();
            obj.Name = "LiMing";
            context.SaveChanges();
        }
    });
    Task t2 = Task.Run(() => {
        using (var context = new TestDB2())
        {
            var obj = context.Student.First();
            obj.Age = 26;
            context.SaveChanges();
        }
    });
    Task.WaitAll(t1,t2);

}

併發衝突報錯：

 

查看了sql server profiler，發現加了[ConcurrencyCheck]的屬性名和值將出現在Where子句中

exec sp_executesql N'UPDATE [dbo].[Students]
SET [Age] = @0
WHERE (([ID] = @1) AND ([Name] = @2))
',N'@0 int,@1 int,@2 nvarchar(max) ',@0=26,@1=1,@2=N'WANG'

 很顯然：

t2再修改Age，根據併發檢測屬性Name的值已被改變，有其他用戶在修改同一條數據，併發衝突。

為每個實體類都單獨地設定檢測屬性實在太麻煩，應該由資料庫來設定特殊欄位值並維護更新會更好，下麵就是另一種方法

 方法二：timestamp

創建一個基類Base，指定一個特殊屬性值，SQL Server中相應的欄位類型為timestamp，自己項目中的實體類都可以繼承它，

public class Base
{
    [Timestamp]
    public byte[] RowVersion { get; set; }
}

Student先基礎base類，每次更新Student數據，RowVersion 欄位就會由資料庫生成一個新的值，根據這個特殊欄位來檢測併發衝突；實體類不再去考慮設置那個屬性值和更新。

 

併發處理

同時更新併發，EF會拋出：DbUpdateConcurrencyException

兩個更新線程如上：t1和t2

處理一

Task t1 = Task.Run(() => {
    using (var context = new TestDB())
    {
        try
        {
            var obj = context.Student.First();
            obj.Name = "LiMing2";
            context.SaveChanges();
        }
        catch (DbUpdateConcurrencyException ex)
        {
            //從資料庫重新載入數據並覆蓋當前保存失敗的對象
            ex.Entries.Single().Reload();
            context.SaveChanges();
        }
    }
});

也就是說，t1併發衝突更新失敗，會重新從資料庫拉取對象覆蓋當前失敗的對象，t1原本的更新被作廢，於此同時的其他用戶併發操作，如t2的更新將會被保存下來

處理二

Task t1 = Task.Run(() => {
    using (var context = new TestDB())
    {
        try
        {
            var obj = context.Student.First();
            obj.Name = "LiMing2";
            context.SaveChanges();
        }
        catch (DbUpdateConcurrencyException ex)
        {
            var entry = ex.Entries.Single();
            entry.OriginalValues.SetValues(entry.GetDatabaseValues());
            context.SaveChanges();
        }
    }
});

從資料庫重新獲取值來替換保存失敗的對象的屬性原始值，再次提交更改，資料庫就不會因為當前更新操作獲取的原始值與資料庫里現有值不同而產生異常（如檢測屬性的值已成一樣），t1的更新操作就能順利提交，其他併發操作如t2被覆蓋

 


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

-Advertisement-
Play Games
更多相關文章
  • .net mvc 分頁
    1 public static MvcHtmlString PageControl(this HtmlHelper html, PageData page) 2 { 3 if (page == null || page.totalpage == 0) 4 return MvcHtmlString.C... ...
  • 楊輝三角C#版
    class Program { static void Main(string[] args) { Console.WriteLine("please input a number:"); int n =int.Parse ( Console.ReadLine()); int [,] c=new i ...
  • Vue + WebApi 小項目：構造自己的線上 Markdown 筆記本應用
    Vue + WebApi 小項目：構造自己的線上 Markdown 筆記本應用 目錄 概要 知識點 完整示例圖 代碼與資源文件 流程步驟 概要 基於 MVP 最小可行性產品設計理念，我們先完成一個可以使用，並具備基本功能的 Markdown 筆記本應用，再進行逐步完善。 知識點 本文會指導初學者如何 ...
  • Docker的使用初探（二）：Docker與.NET Core的結合
    Docker的使用初探（二）：Docker與.NET Core的結合 [TOC] 在二者的結合上，微軟官方給予了很大的支持，從官方發佈的一些文章和VS 2017在建立.NET Core項目時自帶的Docker選項都可以看出來，這也與Core的跨平臺特性有很大的關係，而Docker正是可以選擇以Lin ...
  • .NET Core實戰項目之CMS 第十五章 各層聯動工作實現增刪改查業務
    連著兩天更新敘述性的文章大家可別以為我轉行了！哈哈！今天就繼續講講我們的.NET Core實戰項目之CMS系統的教程吧！這個系列教程拖得太久了，所以今天我就以菜單部分的增刪改查為例來講述下我的項目分層之間的協同工作吧！如果你覺得文中有任何不妥的地方還請留言或者加入DotNetCore實戰千人交流群6 ...
  • vb.net 分割byte數組的方法SplitBytes
    以下代碼隨手寫的 並沒有大量測試 效率也有待提升 如果需要C#的請自行轉換 ...
  • 超強問卷調查系統源碼購買及二次開發
    在學校以及企事業單位里由於各種調查研究的需要，經常會有各種各樣的調查問卷。在傳統的模式下人們不但要花費不少的時間印刷問卷，而且還要消耗大量的人力物力去發放和回收這些問卷，然後對調查問卷進行統計分析。由於人工操作調查問卷隨意性較大，容易產生遺漏問題。所以目前大多數的問卷調查都採用基於網頁的線上調查。 ...
  • 【譯】《C# Tips -- Write Better C#》
    【譯】《C# Tips -- Write Better C#》 《C# 奇淫巧技 -- 編寫更優雅的 C#》 目錄 介紹（Introduction） 第一部分：各種奇淫巧技（Part 1: Assorted Tips） 使用 LINQ 合併 IEnumerable 序列（Merging IEnume ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類