Entity Framework 6 Recipes 2nd Edition（9-2）译-用WCF更新单独分离的实体
9-2. 用WCF更新單獨分離的實體
問題
你想通過WCF為一個數據存儲發布查詢，插入，刪除和修改，并且使這些操作盡可能地簡單
此外,你想通過Code First方式實現EF6的數據訪問管理
?
解決方案
假設有如Figure 9-2所示模型.
?
Figure 9-2. 博客的posts（博文）和comments（評論）模型
模型表示博客的文章和評論之間的關系. 為了簡化,我們去掉了很多屬性，像作者，發文時間等。我們想把所有的數據庫代碼封裝到WCF后，讓客戶端通過通過WCF讀取，更新，刪除，和插入Posts或Comments. 下面是創建WCF服務的步驟:
1. 創建一個新的Visual Studio 解決方案, 添加一個 c# 類庫項目.并命名為Recipe2.
2. 在“Recipe1.Service ”項目中添加EF6的引用。最好是借助 NuGet 包管理器來添加。在”引用”上右擊,選擇”管理 NuGet 程序包.從“聯機”標簽頁,定位并安裝EF6包。這樣將會下載，安裝并配置好EF6庫到你的項目中。
3. 向Recipe2項目添加三個類: Post, Comment, 和Recipe2Context. Post 和
Comment 用POCO 實體類，并直接遇到到Post 和 Comment 表. Recipe2Context是提供EF6服務的DbContext對象。確保WCF的實體類擁有
DataContract 和 DataMember 特性,如Listing 9-7所示.
Listing 9-7. POCO 類 Post, Comment,和 Recipe2Context
[DataContract(IsReference = true)]
public class Post
{
public Post()
{
Comments = new HashSet<Comment>();
}
[DataMember]
public int PostId { get; set; }
[DataMember]
public string Title { get; set; }
[DataMember]
public virtual ICollection<Comment> Comments { get; set; }
}
[DataContract(IsReference=true)]
public class Comment
{
[DataMember]
public int CommentId { get; set; }
[DataMember]
public int PostId { get; set; }
[DataMember]
public string CommentText { get; set; }
[DataMember]
public virtual Post Post { get; set; }
}
public class EFRecipesEntities : DbContext
{
public EFRecipesEntities()
: base("name= Recipe2ConnectionString")
{
}
???? public virtual DbSet<Post> Posts{get;set;}
???? public virtual DbSet<Comment> Comments{get;set;}
}
4. 向Recipe2項目中添加一個 App.config 文件,把如 Listing 9-8所示的連接字符串復制進去.
Listing 9-8. ??Recipe2類庫的連接字符串
<connectionStrings>
<add name="Recipe2ConnectionString"
connectionString="Data Source=.;
Initial Catalog=EFRecipes;
Integrated Security=True;
MultipleActiveResultSets=True"
providerName="System.Data.SqlClient" />
</connectionStrings>
5. 向解決方案中添加一個WCF服務應用程序. 使用默認名稱Service1（譯注：vs2013默認的是WcfService1）
. 用 Listing 9-9替換IService1.cs中的代碼
Listing 9-9. The Service Contract for Our Service
[ServiceContract]
public interface IService1
{
[OperationContract]
void Cleanup();
[OperationContract]
Post GetPostByTitle(string title);
[OperationContract]
Post SubmitPost(Post post);
[OperationContract]
Comment SubmitComment(Comment comment);
[OperationContract]
void DeleteComment(Comment comment);
}
6. 用Listing 9-10里的代碼替換 Service1.svc.cs 文件中的代碼. 添加對Recipe2類庫項目的引用，以便正確引用實體類. 添加EF6的引用.
用Listing 9-10所示代碼實現服務(確保項目引用了System.Data.Entity 和System.Security)
public class Service1 : IService
{
public void Cleanup()
{
using (var context = new EFRecipesEntities())
{
context.Database.ExecuteSqlCommand("delete from chapter9.comment");
context. Database.ExecuteSqlCommand ("delete from chapter9.post");
}
}
public Post GetPostByTitle(string title)
{
using (var context = new EFRecipesEntities())
{
context.Configuration.ProxyCreationEnabled = false;
var post = context.Posts.Include(p => p.Comments)
.Single(p => p.Title == title);
return post;
}
}
public Post SubmitPost(Post post)
{
using(var context=new EFRecipesEntities())//譯者：添加
{???????????????????????????????????????????????????????????????????????? //
context.Entry(post).State =
//id=0表示添加，其它情況表示更新
post.PostId == 0 ? EntityState.Added : EntityState.Modified;
context.SaveChanges();
return post;
}//譯者：添加
}
public Comment SubmitComment(Comment comment)
{
using (var context = new EFRecipesEntities())
{
context.Comments.Attach(comment);
if (comment.CommentId == 0)
{
// 插入
context.Entry(comment).State = EntityState.Added);
}
else
{
//設置單個屬性狀態為modified, 實體狀態也會是 modified, 但只更新單個的屬性，而不是整個實體
context.entry(comment).Property(x => x.CommentText).IsModified = true;
}
context.SaveChanges();
return comment;
}
}
public void DeleteComment(Comment comment)
{
using (var context = new EFRecipesEntities())
{
context.Entry(comment).State = EntityState.Deleted;
context.SaveChanges();
}
}
}
7.最后，添加一個windows控制臺項目，運用它來測試WCF服務，拷貝Listing 9-11里的代碼到Program類里，
. 右擊控制臺項目里的“引用”，選擇“添加服務引用”, 并選擇Service1 服務（譯注：在添加引用前，最好先生成一次服務，不然可能出現引用不了的情況）
. 還需要添加第一步創建的Recipe2類庫項目.
Listing 9-11. Our Windows Console Application That Serves as Our Test Client
class Program
{
static void Main(string[] args)
{
using (var client = new ServiceReference2.Service1Client())
{
//清除之前的數據
client.Cleanup();
//插入一個Post
var post = new Post { Title = "POCO Proxies" };
post = client.SubmitPost(post);
// 更新這個 post
post.Title = "Change Tracking Proxies";
client.SubmitPost(post);
// 添加一個 comment
var comment1 = new Comment {
CommentText = "Virtual Properties are cool!",
PostId = post.PostId };
var comment2 = new Comment {
CommentText = "I use ICollection<T> all the time",
PostId = post.PostId };
comment1 = client.SubmitComment(comment1);
comment2 = client.SubmitComment(comment2);
?
// 更新一個 comment
comment1.CommentText = "How do I use ICollection<T>?";
client.SubmitComment(comment1);
// 刪除comment 1
client.DeleteComment(comment1);
//獲取 posts的所有 comments
var p = client.GetPostByTitle("Change Tracking Proxies");
Console.WriteLine("Comments for post: {0}", p.Title);
foreach (var comment in p.Comments)
{
Console.WriteLine("\tComment: {0}", comment.CommentText);
}
}
}
}
?
譯注：有兩個地方一定要注意，1，Post,Comment類與數據庫的映射以及它們之間的關系，上述代碼中并未列出。2，需要把步驟4列出的連接字符串復制到Service1項目的web.config里.另：僅從9-1和9-2來看，發現原書有不少錯誤，甚至是代碼上的，有些地方我直接修改過來，也沒特別作說明。
控制臺輸出的結果如下面的 Listing 9-11所示:
========================================================
Comments for post: Change Tracking Proxies
Comment: I use ICollection<T> all the time
========================================================
它是如何工作的？
啟動我們用來測試WCF服務的控制臺項目，,創建一個WCF服務實例，因為使用using{}塊，所以可以確保代碼執行出此塊，會立即調用Dispose()。防止引起異常，我們調用Cleanup()方法，先把數據庫里已有的數據刪除，接下來兩行代碼，我們調用服務的SubmitPost()方法，（這個方法的實現查看Listing 9-10）,該方法里先判斷PostId的值，如果為0，表示是一個新添加的Post對象，并把它的狀態設置為Added. 否則,它就是一個已存在于數據庫的Post對象，我們要對它進行更新操作，因為把它的狀態設置Modified. 盡管有幾分粗糙，但這種方法能判定Post對象狀態（是新的還是已存在的）,相比ID依賴于整型在運行時初始值為0，一個更好的方法是，傳遞一個額外的參數到SubmitPost()方法，或是創建一個單獨的InsertPost()方法。
最佳實踐：如果要插入這個post, 把它的state設置成EntityState.Added. 否則, 把它的state設置成EntityState.Modified. 根據EntityState值會產生一條Insert或是update的SQL語句。
在這個post對象插入后，該對象的PostId會變更成正確的值.
插入Comment或更新Comment一個單獨的屬性類似于插入或更新post，但有一個很在的不同:我們的業務規則是只更新comment的CommentText 屬性.該屬性包含comment的主體, 且我們不想更新其它屬性.因此,我們給CommentText 作上 modified標志.EF將會生成一個簡單的只更新CommentText列的Sql語句.如果我們修改Comment多個屬性,我們就需要想辦法跟蹤到哪個屬性在客戶端被修改了. 但是用這種方式我們就不需要在客戶端用一個復雜的方法來跟蹤實體的哪個屬性發生變化。
?
為了刪除一個 comment,我們調用context 對象的Entity() 方法, 并傳遞一個state被設置成Deleted 的 comment 作為參數, 因為comment 被設置為Deleted，所以保存時會生成一條delete的SQL語句。
最后, GetPostByTitle() 為每個符合條件的Post預先加載所有，以post和相關的comments對象圖的形式返回. 因為我們應用了POCO類, 我們想要EF返回一個包含post和comment類的動態代理對象.可惜的是, WCF 不能序列化一個代理對象. 然而我們把 ProxyCreationEnabled 設置成false, 就可以簡單的使代理類不質疑EF實際返回的對象。如果我們企圖序列這個代理對象,會收到如下的錯誤信息:
基礎連接已經關閉: 服務器關閉了本應保持活動狀態的連接（譯注：測試過）。我們甚至可以在構造函數中使用 ?ProxyCreationEnabled = false，迫使它在所有對所有服務方法有效果
在本節, 我們通過WCF利用POCO對象進行CRUD操作. 由于沒有保存客戶端的狀態信息，我們只能分別創建插入，修改，刪除post和comment的方法。
.在本章的其它節里我們將減少服務端的方法來簡化客戶端與服務器的通信。
附：創建示例用到的數據庫的腳本文件
?
總結
以上是生活随笔為你收集整理的Entity Framework 6 Recipes 2nd Edition（9-2）译-用WCF更新单独分离的实体的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 身为DATASHUO大数据工程师，我亲手
- 下一篇： 分享：一个基于NPOI的excel导入导