Entity Framework異步查詢和保存

EF6開始提供了通過async和await關鍵字實現異步查詢和保存的支持（.net 4.5及更高版本）。雖然不是所有的操作都能從異步中獲益，但是耗時的操作、網絡或IO密集型任務中，使用異步可以提升客戶端性能和增強服務器的擴展性。

本文將覆蓋一下主題：

• 實例演練異步操作
• 創建模型
• 創建同步程序
• 改為異步操作

實例演練異步操作

下面演練將通過對比，很容易的觀察異步操作和同步操作，該演練目的不是說明何時才是異步操作的關鍵場景。

創建模型

下面使用CodeFirst的流程創建模型並生成數據庫，不過異步方法可以很好的工作於所有EF模型，包括EF設計器生成的模型。

創建一個控制台應用程序AsyncDemo。

添加EntityFramework NuGet包到項目中。

添加Model.cs到項目中,代碼如下：

using System.Collections.Generic; 
using System.Data.Entity; 
 
namespace AsyncDemo 
{ 
    public class BloggingContext : DbContext 
    { 
        public DbSet<Blog> Blogs { get; set; } 
        public DbSet<Post> Posts { get; set; } 
    } 
 
    public class Blog 
    { 
        public int BlogId { get; set; } 
        public string Name { get; set; } 
 
        public virtual List<Post> Posts { 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 virtual Blog Blog { get; set; } 
    } 
}

 

創建同步程序

有了EF模型，下面通過代碼模擬數據庫存取。

using System; 
using System.Linq; 
 
namespace AsyncDemo 
{ 
    class Program 
    { 
        static void Main(string[] args) 
        { 
            PerformDatabaseOperations(); 
 
            Console.WriteLine(); 
            Console.WriteLine("Quote of the day"); 
            Console.WriteLine(" Don't worry about the world coming to an end today... "); 
            Console.WriteLine(" It's already tomorrow in Australia."); 
 
            Console.WriteLine(); 
            Console.WriteLine("Press any key to exit..."); 
            Console.ReadKey(); 
        } 
 
        public static void PerformDatabaseOperations() 
        { 
            using (var db = new BloggingContext()) 
            { 
                // Create a new blog and save it 
                db.Blogs.Add(new Blog 
                { 
                    Name = "Test Blog #" + (db.Blogs.Count() + 1) 
                }); 
                db.SaveChanges(); 
 
                // Query for all blogs ordered by name 
                var blogs = (from b in db.Blogs 
                            orderby b.Name 
                            select b).ToList(); 
 
                // Write all blogs out to Console 
                Console.WriteLine(); 
                Console.WriteLine("All blogs:"); 
                foreach (var blog in blogs) 
                { 
                    Console.WriteLine(" " + blog.Name); 
                } 
            } 
        } 
    } 
}

上面代碼通過調用PerformDatabaseOperations() 保存一個Blog對象到數據庫中，然后從數據庫中檢索所有Blog，並顯示到控制台，然后顯示一行文本”Quote of the day“。

由於上面程序是同步執行的，所有可以觀察到程序按下面流程執行：

1. SaveChanges保存Blog對象到數據庫中。
2. SaveChanges完成。
3. 發送查詢Blog請求到數據庫。
4. 查詢返回結果，並寫入控制台。
5. 顯示文本“Quote of the day”到控制台。

 

改造為異步操作

對上面程序加以修改，使用async和await關鍵字實現異步操作。

using System; 
using System.Data.Entity; 
using System.Linq; 
using System.Threading.Tasks; 
 
namespace AsyncDemo 
{ 
    class Program 
    { 
        static void Main(string[] args) 
        { 
            var task = PerformDatabaseOperations(); 
 
            Console.WriteLine("Quote of the day"); 
            Console.WriteLine(" Don't worry about the world coming to an end today... "); 
            Console.WriteLine(" It's already tomorrow in Australia."); 
 
            task.Wait(); 
 
            Console.WriteLine(); 
            Console.WriteLine("Press any key to exit..."); 
            Console.ReadKey(); 
        } 
 
        public static async Task PerformDatabaseOperations() 
        { 
            using (var db = new BloggingContext()) 
            { 
                // Create a new blog and save it 
                db.Blogs.Add(new Blog 
                { 
                    Name = "Test Blog #" + (db.Blogs.Count() + 1) 
                }); 
                Console.WriteLine("Calling SaveChanges."); 
                await db.SaveChangesAsync(); 
                Console.WriteLine("SaveChanges completed."); 
 
                // Query for all blogs ordered by name 
                Console.WriteLine("Executing query."); 
                var blogs = await (from b in db.Blogs 
                            orderby b.Name 
                            select b).ToListAsync(); 
 
                // Write all blogs out to Console 
                Console.WriteLine("Query completed with following results:"); 
                foreach (var blog in blogs) 
                { 
                    Console.WriteLine(" - " + blog.Name); 
                } 
            } 
        } 
    } 
}

現在程序變為異步執行，可以觀察到異步執行順序為：

1. 發送SaveChanges請求到數據庫。
2. 該請求發送給數據庫時，當前線程不在占用CPU時間，從方法PerformDatabaseOperations中返回（雖然該方法還沒有執行完成），控制權返回給主線程執行。
3. 顯示字符串“Quote of the day ”到控制台。
4. SaveChanges完成。
5. 發起查詢Blogs請求到數據庫。
6. 查詢完成返回結果，並顯示到控制台。