ITPub博客

首页 > Linux操作系统 > Linux操作系统 > Entity Framework在三层架构中的使用

Entity Framework在三层架构中的使用

原创 Linux操作系统 作者:iDotNetSpace 时间:2010-05-10 14:29:10 0 删除 编辑

本系列的前3篇文章已经向大家介绍了如何使用Entity Framework4(以下简称EF4)创建数据库并进行增删改查操作,还介绍了存储过程的调用方法。在以前的例子中,我们没对代码进行分层,只是简单的介绍实现各种操作的方式。今天我们就来谈谈在三层架构中使用EF4 ,想必很多人已经对三层有过了解。 当然,三层不一定适合所有应用开发,但分层的思想是值得借鉴的。

本文所有的Web页面都和以前一样,不同的是采用了三层架构。我们对应用进行了逻辑分层,各层分别为:界面层(UI),业务逻辑层(BLL)和数据访问层(DAL)。而在数据交互环境下的实体对象此时将扮演数据访问层(DAL)和业务逻辑层(BLL)数据传输的对象(DTO)。在以前,我们可能需要花时间编写DTO的代码,而现在EF4能帮我们省去这一部分时间了。

好吧,下面跟随我的步骤一起完成这个应用。

步骤1.创建数据库

为可简单起见,我们在SQL Server中新建一个OrderSystem数据库,并且创建一个单独的表UserAccounts,该表的字段如下,注意将Id作为主键,并设置为标识列以便自增。

仍然采用存储过程操作表的数据,我们创建的存储过程如下:

1.UserAccounts_SelectAll查询表中所有数据

  1. CREATE PROCEDURE [dbo].[UserAccounts_SelectAll]    
  2. AS  
  3.     SET NOCOUNT ON  
  4.     
  5.     SELECT Id, FirstName, LastName, AuditFields_InsertDate, AuditFields_UpdateDate   
  6.       FROM UserAccounts   
  7.     
  8.     RETURN  

2.UserAccounts_SelectById通过Id查询单条表数据

  1. CREATE PROCEDURE [dbo].[UserAccounts_SelectById]         
  2. (   
  3.     @Id int    
  4. )   
  5.     
  6. AS  
  7.     SET NOCOUNT ON    
  8.     
  9.     SELECT Id, FirstName, LastName, AuditFields_InsertDate, AuditFields_UpdateDate   
  10.       FROM UserAccounts   
  11.      WHERE Id = @Id   
  12. RETURN  
  13.    

3.UserAccounts_Insert插入一条表数据

  1. CREATE PROCEDURE [dbo].[UserAccounts_Insert]   
  2. (   
  3.     @FirstName nvarchar(50),   
  4.     @LastName nvarchar(50),   
  5.     @AuditFields_InsertDate datetime,   
  6.     @AuditFields_UpdateDate datetime   
  7. )        
  8. AS  
  9.     INSERT INTO UserAccounts (FirstName, LastName, AuditFields_InsertDate,    
  10.                               AuditFields_UpdateDate)   
  11.     VALUES (@FirstName, @LastName, @AuditFields_InsertDate,    
  12.             @AuditFields_UpdateDate)   
  13.     
  14.     SELECT CAST(SCOPE_IDENTITY() AS INT) AS Id  

4.UserAccounts_Update更新单条表数据

  1. CREATE PROCEDURE [dbo].[UserAccounts_Update]   
  2. (   
  3.     @Id int,   
  4.     @FirstName nvarchar(50),   
  5.     @LastName nvarchar(50),      
  6.     @AuditFields_UpdateDate datetime   
  7. )        
  8. AS  
  9.     SET NOCOUNT ON  
  10.     
  11.     UPDATE UserAccounts   
  12.        SET FirstName = @FirstName,   
  13.            LastName = @LastName,   
  14.            AuditFields_UpdateDate = @AuditFields_UpdateDate   
  15.      WHERE Id = @Id   
  16.     
  17.     RETURN  

5.UserAccounts_Delete删除单条表数据

  1. CREATE PROCEDURE [dbo].[UserAccounts_Delete]   
  2. (   
  3.     @Id int    
  4. )   
  5.          
  6. AS  
  7.     SET NOCOUNT ON  
  8.     
  9.     DELETE    
  10.       FROM UserAccounts   
  11.      WHERE Id = @Id   
  12.     
  13.     RETURN  

步骤2.创建数据访问层

下来在VS 2010中创建一个新的类库项目,它将作为数据访问层。

1.打开VS,选择文件->新项目。

2.选择“C#类库”项目,将名字改为OrederSystemDAL

3.选中“为项目创建目录”,将左边输入框内容改为“OrderSystem”,点“OK”。

4.添加数据视图模型,OrderSystemDAL项目上右键,选择Add->New Item..

5.从项目模板中选择“ADO.NET Entity Data Mode”,将它名字改为“OrderSystemDataModel.edmx”,点“Add”。

6.将会看到视图数据模型向导,选择“Generate from database”,点“Next”。

7.选择数据库连接,我们创建一个新连接,选择“New connection”,填写好登陆信息并选择OrderSystem数据后,点“OK”,再点“Next”。

8.选择数据库对象,选择刚创建的UserAccounts表和5个存储过程,点“Finish”。

接下来是创建调用这些存储过程的方法了。

9.展开存储过程文件夹,右击“UserAccounts_Delete”存储过程,选择“ Add Function Import”。

10.弹出“Function Import”框后,保持默认参数,点击“OK”。

11.UserAccounts_Insert存储过程上右击,由于它将返回新插入的数据的Id,所以我们要将“Returns a Collection Of”的Scalars参数设置为Int32,然后点“OK”。

12.对其他存储过程重复同样操作,对于SelectAll 和SelectById存储过程,“Returns a Collection Of”中的Entity参数设置为UserAccount,Update存储过程保持默认即可。

实体数据模型就创建好了,下面要在数据访问层中创建一个类来管理这些存储过程的调用。

13.添加一个新的类文件,将其名字改为“UserAccountsData.cs”,将类声明为公共的和静态的。

  1. public static class UserAccountsData  

14.给类添加以下方法:

  1. public static int Insert(string firstName, string lastName, DateTime insertDate)   
  2. {   
  3.     using (OrderSystemEntities db = new OrderSystemEntities())   
  4.     {   
  5.         return Insert(db, firstName, lastName, insertDate);   
  6.     }   
  7. }   
  8.     
  9. public static int Insert(OrderSystemEntities db, string firstName,    
  10.                          string lastName, DateTime insertDate)   
  11. {   
  12.     return db.UserAccounts_Insert(firstName, lastName, insertDate, insertDate).ElementAt(0).Value;   
  13. }   
  14.     
  15. public static void Update(int id, string firstName, string lastName,    
  16.                           DateTime updateDate)   
  17. {   
  18.     using (OrderSystemEntities db = new OrderSystemEntities())   
  19.     {   
  20.         Update(db, id, firstName, lastName, updateDate);   
  21.     }   
  22. }   
  23.     
  24. public static void Update(OrderSystemEntities db, int id, string firstName,    
  25.                           string lastName, DateTime updateDate)   
  26. {   
  27.     db.UserAccounts_Update(id, firstName, lastName, updateDate);   
  28. }   
  29.     
  30. public static void Delete(int id)   
  31. {   
  32.     using (OrderSystemEntities db = new OrderSystemEntities())   
  33.     {   
  34.         Delete(db, id);   
  35.     }   
  36. }   
  37.     
  38. public static void Delete(OrderSystemEntities db, int id)   
  39. {   
  40.     db.UserAccounts_Delete(id);   
  41. }   
  42.     
  43. public static UserAccount SelectById(int id)   
  44. {   
  45.     using (OrderSystemEntities db = new OrderSystemEntities())   
  46.     {   
  47.         return SelectById(db, id);   
  48.     }   
  49. }   
  50.     
  51. public static UserAccount SelectById(OrderSystemEntities db, int id)   
  52. {   
  53.     return db.UserAccounts_SelectById(id).ElementAtOrDefault(0);   
  54. }   
  55.     
  56. public static List SelectAll()   
  57. {   
  58.     using (OrderSystemEntities db = new OrderSystemEntities())   
  59.     {   
  60.         return SelectAll(db);   
  61.     }   
  62. }   
  63.     
  64. public static List SelectAll(OrderSystemEntities db)   
  65. {   
  66.     return db.UserAccounts_SelectAll().ToList();   
  67. }  

以上就是我们用来操作UserAccounts表数据的类了。

步骤3.创建业务逻辑层

业务逻辑层是介于界面层和数据访问层的,它体现了应用的业务逻辑和一些数据验证规则。

1.添加一个新的C#类库项目,将它的名字改为“OrderSystemBLL”

2.给该项目添加DAL项目引用和System.Data.Entity引用。

3.将项目中的“Class1.cs”文件改名为“UserAccountEO”。EO的意思编辑对象(Edit Object),添加EO后缀是为了将其和数据访问层的类区分开。

4.添加命名空间。

  1. using System.Collections;   
  2. using OrderSystemDAL;  

5.添加属性声明

  1. public int Id { get; set; }   
  2. public string FirstName { get; set; }   
  3. public string LastName { get; set; }   
  4. public DateTime InsertDate { get; set; }   
  5. public DateTime UpdateDate { get; set; }   
  6.     
  7. public string FullName   
  8. {   
  9.     get  
  10.     {   
  11.         return LastName + ", " + FirstName;   
  12.     }   
  13. }  

6.添加下面的代码用来将数据保持到数据库,该方法根据对象Id是否赋值来判断是更新还是插入操作,并且还会进行一系列的验证,如果验证不通过,则不能进行数据的插入或更新,相关的错误还会返回给它的调用者。

  1. public bool Save(ref ArrayList validationErrors)   
  2. {   
  3.     ValidateSave(ref validationErrors);   
  4.     
  5.     if (validationErrors.Count == 0)   
  6.     {   
  7.         if (Id == 0)   
  8.         {   
  9.             Id = UserAccountsData.Insert(FirstName, LastName, DateTime.Now);   
  10.         }   
  11.         else  
  12.         {   
  13.             UserAccountsData.Update(Id, FirstName, LastName, DateTime.Now);   
  14.         }   
  15.         return true;   
  16.     }   
  17.     else  
  18.     {   
  19.         return false;   
  20.     }   
  21. }   
  22. private void ValidateSave(ref ArrayList validationErrors)   
  23. {   
  24.     if (FirstName.Trim() == "")   
  25.     {   
  26.         validationErrors.Add("The First Name is required.");   
  27.     }   
  28.     
  29.     if (LastName.Trim() == "")   
  30.     {   
  31.         validationErrors.Add("The Last Name is required.");   
  32.     }   
  33. }  

7.添加用来删除数据的方法,如果要进行验证可以采取如下的方式

  1. public void Delete(ref ArrayList validationErrors)   
  2. {   
  3.     ValidateDelete(ref validationErrors);   
  4.     
  5.     if (validationErrors.Count == 0)   
  6.     {   
  7.         UserAccountsData.Delete(Id);   
  8.     }   
  9. }   
  10.     
  11. private void ValidateDelete(ref ArrayList validationErrors)   
  12. {   
  13.     //Check for referential integrity.   
  14. }  

8.添加用来查询单条数据的方法

  1. public bool Select(int id)   
  2. {   
  3.     UserAccount userAccount = UserAccountsData.SelectById(id);   
  4.     
  5.     if (userAccount != null)   
  6.     {   
  7.         MapData(userAccount);   
  8.         return true;   
  9.     }   
  10.     else  
  11.     {   
  12.         return false;   
  13.     }   
  14. }   
  15.     
  16. internal void MapData(UserAccount userAccount)   
  17. {   
  18.     Id = userAccount.Id;   
  19.     FirstName = userAccount.FirstName;   
  20.     LastName = userAccount.LastName;   
  21.     InsertDate = userAccount.AuditFields_InsertDate;   
  22.     UpdateDate = userAccount.AuditFields_UpdateDate;   
  23. }  

9.最后是查询表所有数据的方法

  1. public static List SelectAll()   
  2. {   
  3.     List userAccounts   
  4.     =  new List();   
  5.     
  6.     List userAccountDTOs = UserAccountsData.SelectAll();   
  7.     
  8.     foreach (UserAccount userAccountDTO in userAccountDTOs)   
  9.     {   
  10.         UserAccountEO userAccountEO = new UserAccountEO();   
  11.         userAccountEO.MapData(userAccountDTO);   
  12.         userAccounts.Add(userAccountEO);   
  13.     }   
  14.     
  15.     return userAccounts;   
  16. }  

步骤4.创建Web表单

下面就是创建数据增删改查的页面了,就是我们所说的界面层

1.新建一个ASP.NET Web项目,命名为“OrderSystemUI”。

2.为该项目添加OrderSystemBLL项目的引用。

3.在web.config中添加connectionStrings配置节,代码如下:

  1. <connectionstrings>  
  2.     <add name="OrderSystemEntities" connectionstring="你的数据库连接字符串"    
  3.     providername="System.Data.EntityClient" />  
  4.   connectionstrings>  

4.添加一个WebForm,命名为“Users.aspx”。

5.转到代码视图,在div之间添加如下html代码

  1. <table>  
  2. <tbody>  
  3. <tr>  
  4. <td colspan="2">  
  5. <asp :label id="lblErrorLabel" runat="server" text="Please correct the following issues:" forecolor="Red" visible="false">asp>  
  6. <asp :label id="lblErrorMessages" runat="server" forecolor="Red" visible="false">asp>  
  7. td>  
  8. tr>  
  9. <tr>  
  10. <td>Select A User:td>  
  11. <td><asp :dropdownlist id="ddlUsers" runat="server" autopostback="True">asp>td>  
  12. tr>  
  13. <tr>  
  14. <td>First Name:td>  
  15. <td><asp :textbox id="txtFirstName" runat="server">asp>td>  
  16. tr>  
  17. <tr>  
  18. <td>Last Name:td>  
  19. <td><asp :textbox id="txtLastName" runat="server">asp>td>  
  20. tr><tr>  
  21. <td>Inserted:td><td><asp :label id="lblInserted" runat="server">asp>td>  
  22. tr><tr><td>Updated:td>  
  23. <td><asp :label id="lblUpdated" runat="server">asp>td>  
  24. tr>  
  25. tbody>  
  26. table>       
  27. <asp :button id="btnSave" runat="server" text="Save" />  
  28. <asp :button id="btnDelete" runat="server" text="Delete" />  

转到设计视图,可以看到效果如下:

步骤5.将查询的数据加载到Drop Down List

下面要做的是在页面加载时,将UserAccounts表的数据加载到Drop Down List,同时可以在Drop Down List中选择新增数据。

1.双击页面,创建Page_Load时间处理方法。

2.添加命名空间using OrderSystemBLL;。

3.Page_Load处理方法代码如下:

  1.     
  2. protected void Page_Load(object sender, EventArgs e)   
  3. {   
  4.     if (!IsPostBack)   
  5.     {   
  6.         LoadUserDropDownList();   
  7.     }   
  8. }  

4.添加LoadUserDropDownList方法

  1.     
  2.   
  3. private void LoadUserDropDownList()   
  4. {   
  5.   ddlUsers.DataSource = UserAccountEO.SelectAll();   
  6.     
  7.   ddlUsers.DataTextField = "FullName";   
  8.   ddlUsers.DataValueField = "Id";   
  9.   ddlUsers.DataBind();   
  10.     
  11.   ddlUsers.Items.Insert(0, new ListItem("Create New User", ""));   
  12. }  

步骤6.插入和更新数据

设计视图下,双击“Save”按钮,添加点击事件处理代码如下:

  1.     
  2. protected void btnSave_Click(object sender, EventArgs e)   
  3. {   
  4.     ArrayList validationErrors = new ArrayList();   
  5.     UserAccountEO userAccount = new UserAccountEO();   
  6.     
  7.     if (ddlUsers.SelectedItem.Value != "")   
  8.     {   
  9.         //Updating   
  10.         userAccount.Id = Convert.ToInt32(ddlUsers.SelectedValue);   
  11.     }   
  12.     
  13.     userAccount.FirstName = txtFirstName.Text;   
  14.     userAccount.LastName = txtLastName.Text;   
  15.     
  16.     userAccount.Save(ref validationErrors);   
  17.     
  18.     if (validationErrors.Count > 0)   
  19.     {   
  20.         ShowValidationMessages(validationErrors);   
  21.     }   
  22.     else  
  23.     {   
  24.         //Reload the drop down list   
  25.         LoadUserDropDownList();   
  26.       
  27.         //Select the one the user just saved.   
  28.         ddlUsers.Items.FindByValue(userAccount.Id.ToString()).Selected = true;   
  29.     
  30.         lblErrorLabel.Visible = false;   
  31.         lblErrorMessages.Visible = false;   
  32.     }   
  33. }    
  34.   
  35. private void ShowValidationMessages(ArrayList validationErrors)   
  36. {   
  37.     if (validationErrors.Count > 0)   
  38.     {   
  39.         lblErrorLabel.Visible = true;   
  40.         lblErrorMessages.Visible = true;   
  41.         lblErrorMessages.Text = "
    "
    ;   
  42.     
  43.         foreach (string message in validationErrors)   
  44.         {   
  45.             lblErrorMessages.Text += message + "
    "
    ;   
  46.         }   
  47.     }   
  48.     else  
  49.     {   
  50.         lblErrorLabel.Visible = false;   
  51.         lblErrorMessages.Visible = false;   
  52.     }   
  53. }  

这里代码和以前的代码不同之处是,多了一些验证的处理。

步骤7.查询数据

设计视图下,双击下拉框,给它添加SelectedIndexChanged事件处理方法,代码如下:

  1. txtFirstName.Text = "";   
  2. txtLastName.Text = "";   
  3. lblInserted.Text = "";   
  4. lblUpdated.Text = "";   
  5.     
  6. if (ddlUsers.SelectedValue != "")   
  7. {   
  8.     int userAccountId = Convert.ToInt32(ddlUsers.SelectedValue);   
  9.     
  10.     UserAccountEO userAccount = new UserAccountEO();   
  11.     if (userAccount.Select(userAccountId))   
  12.     {   
  13.         txtFirstName.Text = userAccount.FirstName;   
  14.         txtLastName.Text = userAccount.LastName;   
  15.         lblInserted.Text = userAccount.InsertDate.ToString();   
  16.         lblUpdated.Text = userAccount.UpdateDate.ToString();   
  17.     }   
  18. }  

步骤8.删除数据

视图设计下,双击“Delete”按钮,给它添加点击事件处理方法,代码如下:

  1. if (ddlUsers.SelectedItem.Value != "")   
  2. {   
  3.     ArrayList validationErrors = new ArrayList();   
  4.     UserAccountEO userAccount = new UserAccountEO();   
  5.     
  6.     userAccount.Id = Convert.ToInt32(ddlUsers.SelectedValue);   
  7.     userAccount.Delete(ref validationErrors);   
  8.     
  9.     if (validationErrors.Count > 0)   
  10.     {   
  11.         ShowValidationMessages(validationErrors);   
  12.     }   
  13.     else  
  14.     {   
  15.         LoadUserDropDownList();   
  16.         txtFirstName.Text = "";   
  17.         txtLastName.Text = "";   
  18.         lblInserted.Text = "";   
  19.         lblUpdated.Text = "";   
  20.         lblErrorLabel.Visible = false;   
  21.         lblErrorMessages.Visible = false;   
  22.     }   
  23. }  

总结

至此,如何在三层架构中使用EF4就像想你介绍完了,它应该能满足一般应用的要求。在EF4结合VS2010后,我们发现一个最大的好处是DTO对象不再需要我们自己编写了,加上调用存储过程智能感知的支持,确实非常方便。

项目文件:http://files.cnblogs.com/lloydsheng/OrderSystem4.zip

来自 “ ITPUB博客 ” ,链接:https://blog.itpub.net/12639172/viewspace-662342/ ,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论

注册时间:2008-01-04

  • 博文量
    2376
  • 访问量
    5766002