《Entity Framework 6 Recipes》中文翻譯系列 (13) -----第三章 查詢之使用Entity SQL

翻譯的初衷以及為什么選擇《Entity Framework 6 Recipes》來學習，請看本系列開篇

3-4使用實體SQL查詢模型

問題

　　你想通過執行Entity SQL語句來查詢你的實體數據模型並返回強類型的對象。

解決方案

　　假設你有圖3-5所示的模型，它包含一個Customer實體類型。這個實體類型有一個Name屬性和Email屬性。你要使用Entiyt SQL查詢這個模型。

圖3-5 包含一個Customer實體類型的模型

 

 　　使用Entity SQL（eSQL)查詢模型，Entity SQL是SQL在實體框架中實現的一種方言，代碼清單3-8中的模式正是使用這種方式。當在查詢底層數據存儲時，你也許更青睞LINQ-to-Entity。由於LINQ提供了許多特性以及強類型的編程體驗。Entity SQL在通過實體數據模型，構建動態查詢底層數據存儲時提供了靈活性。

代碼清單3-8. 使用Object Services和EntityClient執行一個Entity SQL語句

using (var context = new EFRecipesEntities())
            {
                // 刪除測試數據
                context.Database.ExecuteSqlCommand("delete from chapter3.customer");
                // 添加新的測試數據
                var cus1 = new Customer
                {
                    Name = "Robert Stevens",
                    Email = "[e-mail]"
                };
                var cus2 = new Customer
                {
                    Name = "Julia Kerns",
                    Email = "[e-mail]"
                };
                var cus3 = new Customer
                {
                    Name = "Nancy Whitrock",
                    Email = "[e-mail]"
                };
                context.Customers.Add(cus1);
                context.Customers.Add(cus2);
                context.Customers.Add(cus3);
                context.SaveChanges();
            }

            //使用ObjectContext對象中的 object services
            using (var context = new EFRecipesEntities())
            {
                Console.WriteLine("Querying Customers with eSQL Leveraging Object Services...");
                string esql = "select value c from Customers as c";
                // 將DbContext轉換為底層的ObjectContext, 因為DbContext沒有提供對Entity SQL查詢的支持
                var customers = ((IObjectContextAdapter)context).ObjectContext.CreateQuery<Customer>(esql);
                foreach (var customer in customers)
                {
                    Console.WriteLine("{0}'s email is: {1}",
                                       customer.Name, customer.Email);
                }
            }

            Console.WriteLine(System.Environment.NewLine);

            //使用 EntityClient
            using (var conn = new EntityConnection("name=EFRecipesEntities"))
            {
                Console.WriteLine("Customers Customers with eSQL Leveraging Entity Client...");
                var cmd = conn.CreateCommand();
                conn.Open();
                cmd.CommandText = "select value c from EFRecipesEntities.Customers as c";
                using (var reader = cmd.ExecuteReader(CommandBehavior.SequentialAccess))
                {
                    while (reader.Read())
                    {
                        Console.WriteLine("{0}'s email is: {1}",
                                           reader.GetString(1), reader.GetString(2));
                    }
                }
            }

            Console.WriteLine("\nPress <enter> to continue...");
            Console.ReadLine();
        }

下面是代碼清單3-8的輸出：

Querying Customers with eSQL Leveraging Object Services...
Robert Stevens's email is: [e-mail]
Julia Kerns's email is: [e-mail]
Nancy Whitrock's email is: [e-mail]
Customers Customers with eSQL Leveraging Entity Client...
Robert Stevens's email is: [e-mail]
Julia Kerns's email is: [e-mail]
Nancy Whitrock's email is: [e-mail]

　　

原理

　　有代碼清單3-8中，一開始，我們刪除了之前數據庫中的測試數據。然后我們創建了三個customers,並將其添加到上下文對象中，並調用SaveChanges()將數據插入到數據庫。

　　使用數據庫中的客戶數據，我們演示了兩種不同的，使用Entity SQL獲取數據的方法。在第一種方法中，我們用CreateQuery()方法，該方法是在遺留的ObjectContext上下文對象中公布的，使用它創建一個ObjectQuery對象。 注意，我們是如何將DbContext轉換成一個ObjectContextAdapter類型，並通過它得到底層的ObjectContext類型(記住，最新的DbContext包裝了老的Objetcontext，以此改善開發者的編程體驗）。我們這樣做是因為DbContext不提供對 eSQL查詢的直接支持。同時也需注意，我們使用占位符value代替Customer類型，然后將esql作為參數傳遞給CreateQuery()方法。當我們枚舉customers集合時，查詢在數據庫被執行，同時，我們把結果集合輸出到控制台。因為集合中的每個元素都是Customer實體類型的一個實例，所以，我們可以獲得強類型的方式來使用每個元素的屬性。

　　在第二種方法中，我們使用EntityClinet庫，它和我們使用SqlClient或者ADO.NET提供的別的Client相似。 先創建一個數據庫連接，然后創建一個command對象，並打開數據庫連接。接下來，我們用要執行的Entity SQL語句來初始化command對象。使用ExecuteReader()方法來執行command,並獲得一個EntityDataReader，它與DbDataReader相似。最后，我們使用Read()方法枚舉結果集。

　　注意，在代碼清單3-8中，Entity SQL語句使用的value關鍵字。 當我們需要獲取完整的實體時，這個關鍵字非常有用。如果我們的Entity SQL 語句投影列的一個子集（也就是說，我們使用Entity SQL 表達式使用或創建部分列）我們無需使用value關鍵字。這意味着像代碼清單3-9所演示的一樣，直接使用DbDataRecord.

代碼清單3-9. 使用Object Services 和EntityClient投影

 // 使用object ervices，無value關鍵字
            using (var context = new EFRecipesEntities())
            {
                Console.WriteLine("Customers...");
                string esql = "select c.Name, c.Email from Customers as c";
                var records = ((IObjectContextAdapter)context).ObjectContext.CreateQuery<DbDataRecord>(esql);
                foreach (var record in records)
                {
                    var name = record[0] as string;
                    var email = record[1] as string;
                    Console.WriteLine("{0}'s email is: {1}", name, email);
                }
            }
            Console.WriteLine();
            //使用EntityClient，無value關鍵字
            using (var conn = new EntityConnection("name=EFRecipesEntities"))
            {
                Console.WriteLine("Customers...");
                var cmd = conn.CreateCommand();
                conn.Open();
                cmd.CommandText = @"select c.Name, C.Email from
EFRecipesEntities.Customers as c";
                using (var reader = cmd.ExecuteReader(CommandBehavior.SequentialAccess))
                {
                    while (reader.Read())
                    {
                        Console.WriteLine("{0}'s email is: {1}",
                        reader.GetString(0), reader.GetString(1));
                    }
                }
            }

 

　　當你使用Entity SQL 投影，返回的結果集是一個包含投影中的所有列的DbDataRecord。使用value關鍵字，查詢返回的單獨對象，是DbDataRecord中的第一個元素。

 

3-5 查找主從復合結構關系中的擁有從表記錄的主表記錄

問題
　　你有兩個一對多關聯（主從復合結構關系）的實體。你要查詢所有的至少擁有一個實體與它關聯的實體。

解決方案

　　假設你有一個擁有博客（BlogPost）和與之關聯的評論(Comment)的模型。一些博客有很多評論，一些有少量或是沒有評論。這個模型看起像圖3-6。

圖3-6 一個擁有博客（BlogPost）和與之關聯的評論(Comment)的模型

　　

　　你要找出所有有評論的博客，可以使用LINQ to Entities 或者 Entity SQL。按代碼清單3-10所演示的模式進行。

using (var context = new EFRecipesEntities())
            {
                // 刪除測試數據
                context.Database.ExecuteSqlCommand("delete from chapter3.comment");
                context.Database.ExecuteSqlCommand("delete from chapter3.blogpost");
                // 添加新的測試數據
                var post1 = new BlogPost
                {
                    Title = "The Joy of LINQ",
                    Description = "101 things you always wanted to know about LINQ"
                };
                var post2 = new BlogPost
                {
                    Title = "LINQ as Dinner Conversation",
                    Description = "What wine goes with a Lambda expression?"
                };
                var post3 = new BlogPost
                {
                    Title = "LINQ and our Children",
                    Description = "Why we need to teach LINQ in High School"
                };
                var comment1 = new Comment
                {
                    Comments = "Great post, I wish more people would talk about LINQ"
                };
                var comment2 = new Comment
                {
                    Comments = "You're right, we should teach LINQ in high school!"
                };
                post1.Comments.Add(comment1);
                post3.Comments.Add(comment2);
                context.BlogPosts.Add(post1);
                context.BlogPosts.Add(post2);
                context.BlogPosts.Add(post3);
                context.SaveChanges();
            }

            using (var context = new EFRecipesEntities())
            {
                Console.WriteLine("Blog Posts with comments...(LINQ)");
                var posts = from post in context.BlogPosts
                    where post.Comments.Any()
                    select post;
                foreach (var post in posts)
                {
                    Console.WriteLine("Blog Post: {0}", post.Title);
                    foreach (var comment in post.Comments)
                    {
                        Console.WriteLine("\t{0}", comment.Comments);
                    }
                }
            }

            Console.WriteLine();

            using (var context = new EFRecipesEntities())
            {
                Console.WriteLine("Blog Posts with comments...(eSQL)");
                var esql = "select value p from BlogPosts as p where exists(p.Comments)";
                var posts = ((IObjectContextAdapter) context).ObjectContext.CreateQuery<BlogPost>(esql);
                foreach (var post in posts)
                {
                    Console.WriteLine("Blog Post: {0}", post.Title);
                    foreach (var comment in post.Comments)
                    {
                        Console.WriteLine("\t{0}", comment.Comments);
                    }
                }
            }

            Console.WriteLine("\nPress <enter> to continue...");
            Console.ReadLine();
        }

下面是代碼清單3-10的輸出：

Blog Posts with comments...(LINQ)
Blog Post: The Joy of LINQ
Great post, I wish more people would talk about LINQ
Blog Post: LINQ and our Children
You're right, we should teach LINQ in high school!
Blog Posts with comments...(ESQL)
Blog Post: The Joy of LINQ
Great post, I wish more people would talk about LINQ
Blog Post: LINQ and our Children
You're right, we should teach LINQ in high school! 

 

原理

　　在代碼清單3-10中，我們先刪除之前的測試數據，然后插入新的博客和評論到數據庫，為了確保查詢正確，我們讓其中一篇博客沒有任何評論。

　　在LINQ查詢中，我們在where從句中憑借LINQ擴展方法Any()，來判斷給定的博客是否有評論。 查找所有Any()方法返回true的博客。在這種用法中，我們枚舉Any()方法返回true的每一篇有評論的博客。而且，這正是我們所需要的：至少包含一個評論的博客。

　　在Entity SQL 方法中，我們在where從句中使用了SQL exist()操作符，來判斷給定的博客是否有評論。

　　當然，我們還有別的方法也能獲取到相同的結果。例如，我們可以在LINQ查詢的where從句中使用Count()方法，來檢查評論的數量是否大於0.在Entity SQL 方法中，我們可以在where從句中使用count(select value 1 from p.Comments)>0。這兩種方法都可以正常運行，但是，代碼清單3-10中的方法更加簡潔，從性能的角度來看，Any()和Exist()不需要在服務器中枚舉整個集合（意思是說，當找到第一個評論后，處理過程就開始轉移到下一篇博客）。然而Count()需要在服務器中枚舉整個集合（意思是說，盡管已經查到了一條評論了，仍然要枚舉每一條評論）。

 

實體框架交流QQ群:  458326058，歡迎有興趣的朋友加入一起交流

謝謝大家的持續關注，我的博客地址：http://www.cnblogs.com/VolcanoCloud/