述：业务逻辑层封装相对数据访问层来说较为简单，我们分为以下几步：
1、抽象基接口定义CRUD方法
2、应用T4模版生成所有实体接口
3、接口实现
一、接口定义
1.1、创建名为Cnblogs.Rdst.IBLL的程序集，主要用于业务逻辑层接口定义
并引用Cnblogs.Rdst.Domain和System.Data.Entity。这里需要注意，只要是用到EF实体，就需要添加System.Data.Entity引用。
1.2、创建IBaseService接口定义CRUD方法
这里可以直接将IBaseDao中定义的方法拷贝过来。
1 using System; 2 using System.Collections.Generic; 3 using System.Linq; 4 using System.Text; 5 6 namespace Cnblogs.Rdst.IBLL 7 { 8 public interface IBaseService<T> 9 where T:class, 10 new () 11 { 12 //根据条件获取实体对象集合 13 IQueryable<T> LoadEntites(Func<T, bool> whereLambda); 14 15 //根据条件获取实体对象集合分页 16 IQueryable<T> LoadEntites(Func<T, bool> whereLambda, int pageIndex, int pageSize, out int totalCount); 17 18 //增加 19 T AddEntity(T entity); 20 21 //更新 22 T UpdateEntity(T entity); 23 24 //删除 25 bool DelEntity(T entity); 26 27 //根据条件删除 28 bool DelEntityByWhere(Func<T, bool> whereLambda); 29 } 30 }
1.3、创建名为IServiceExt的T4模版，用于自动生成所有实体对象的接口，并继承自IBaseService接口
以下是T4模版中的代码：
<#@ template language="C#" debug="false" hostspecific="true"#> <#@ include file="EF.Utility.CS.ttinclude"#><#@ output extension=".cs"#> <# CodeGenerationTools code = new CodeGenerationTools(this); MetadataLoader loader = new MetadataLoader(this); CodeRegion region = new CodeRegion(this, 1); MetadataTools ef = new MetadataTools(this); string inputFile = @"..\\Cnblogs.Rdst.Domain\\Model.edmx"; EdmItemCollection ItemCollection = loader.CreateEdmItemCollection(inputFile); string namespaceName = code.VsNamespaceSuggestion(); EntityFrameworkTemplateFileManager fileManager = EntityFrameworkTemplateFileManager.Create(this); #> using System; using System.Collections.Generic; using System.Linq; using System.Text; using Cnblogs.Rdst.Domain; namespace Cnblogs.Rdst.IBLL { <# foreach (EntityType entity in ItemCollection.GetItems<EntityType>().OrderBy(e => e.Name)) {#> public interface I<#=entity.Name#>Service : IBaseService<<#=entity.Name#>> { } <#};#> }
以下是T4模版运行后,自动为我们生成的代码：
至此，业务逻辑层的接口就定义完成了。
二、抽象出业务逻辑层的基类
2.1、创建名为Cnblogs.Rdst.BLL程序集，并添加DAO、Domain、IBLL、IDAO、System.Data.Entity程序集引用，如下图
2.2、接下来是我们的重点，创建名为BaseService基类。该基类中实现了对数据访问层的调用，也实现了CRUD
步骤： 1、先将IDBSessionFactory封装为属性，用于获取IDBSession
2、再将IDBSession封装为属性,用于获取EF上下文对象
3、定义IBaseDao类型的CurrentDao属性，用于属性获取具体的实体对象
4、定义抽象方法 SetCurrentDao()，用于子类设置实现，为CurrentDao属性赋具体的实体对象
以下是这部分代码实现：
1 using System; 2 using System.Collections.Generic; 3 using System.Linq; 4 using System.Text; 5 using Cnblogs.Rdst.IDAO; 6 using Cnblogs.Rdst.Dao; 7 8 9 namespace Cnblogs.Rdst.BLL 10 { 11 public class BaseService<T> 12 where T : class, 13 new() 14 { 15 //构造函数 16 public BaseService() 17 { 18 //调用SetCurrentDao()方法，要求子类必须实现 19 SetCurrentDao(); 20 } 21 22 //获取EF实体工厂 23 IDBSessionFactory _dbSessionFactory; 24 IDBSession _dbSession; 25 26 public IDBSessionFactory DbSessionFactory 27 { 28 get 29 { 30 if (_dbSessionFactory == null) 31 { 32 _dbSessionFactory = new DBSessionFactory(); 33 } 34 return _dbSessionFactory; 35 } 36 set { _dbSessionFactory = value; } 37 } 38 39 40 public IDBSession DbSession 41 { 42 get 43 { 44 if (_dbSession == null) 45 { 46 _dbSession = DbSessionFactory.GetCurrentDBSession();//通过数据访问层提供的工厂获取EF实体对象 47 } 48 return _dbSession; 49 } 50 set { _dbSession = value; } 51 } 52 //数据访问层基接口类型可以接收数据访问层的所有实体Dao 53 public IBaseDao<T> CurrentDao { get; set; } 54 55 //该方法用于子类实现，其作用是设置相应的实体Dao 56 public abstract void SetCurrentDao();
//以下是CRUD实现
2.3、实现CRUD
有了EF上下文，我们就可以实现CRUD
在实现增加和更新方法是，我们这时调用DBSessin中封装的SaveChanges()方法进行提交，主要目的是实现业务层控制提交。
由于EF具有延迟加载特性，因此我们利用此特性，实现批量操作时，一次提交数据库，已提程序高性能。
因此我们这时需要将BaseDao中的增加和更新方法中的SaveChange()方法注视掉，在此我就不贴出此部分代码了。
以下是CRUD实现代码：
1 //以下是CRUD实现 2 3 public virtual IQueryable<T> LoadEntites(Func<T, bool> whereLambda) 4 { 5 return this.CurrentDao.LoadEntites(whereLambda); 6 } 7 8 9 public virtual IQueryable<T> LoadEntites(Func<T, bool> whereLambda, int pageIndex, int pageSize, out int totalCount) 10 { 11 return this.CurrentDao.LoadEntites(whereLambda, pageIndex, pageSize, out totalCount); 12 } 13 14 15 public virtual T AddEntity(T entity) 16 { 17 var tmp= this.CurrentDao.AddEntity(entity); 18 this.DbSession.SaveChange(); 19 return tmp; 20 } 21 22 23 public virtual T UpdateEntity(T entity) 24 { 25 var tmp= this.CurrentDao.UpdateEntity(entity); 26 this.DbSession.SaveChange(); 27 return tmp; 28 } 29 30 31 public virtual bool DelEntity(T entity) 32 { 33 return this.CurrentDao.DelEntity(entity); 34 } 35 36 37 public virtual bool DelEntityByWhere(Func<T, bool> whereLambda) 38 { 39 return this.DelEntityByWhere(whereLambda); 40 } 41 } 42 }
至此，BaseService业务逻辑层基类就封装完成，接下来使用T4模版自动生成所有实体。
2.4、创建名为ServiceExt的T4模版
以下是模版中的代码：
<#@ template language="C#" debug="false" hostspecific="true"#> <#@ include file="EF.Utility.CS.ttinclude"#><#@ output extension=".cs"#> <# CodeGenerationTools code = new CodeGenerationTools(this); MetadataLoader loader = new MetadataLoader(this); CodeRegion region = new CodeRegion(this, 1); MetadataTools ef = new MetadataTools(this); string inputFile = @"..\\Cnblogs.Rdst.Domain\\Model.edmx"; EdmItemCollection ItemCollection = loader.CreateEdmItemCollection(inputFile); string namespaceName = code.VsNamespaceSuggestion(); EntityFrameworkTemplateFileManager fileManager = EntityFrameworkTemplateFileManager.Create(this); #> using System; using System.Collections.Generic; using System.Linq; using System.Text; using Cnblogs.Rdst.IBLL; using Cnblogs.Rdst.Domain; namespace Cnblogs.Rdst.BLL { <# foreach (EntityType entity in ItemCollection.GetItems<EntityType>().OrderBy(e => e.Name)) {#> public partial class <#=entity.Name#>Service : BaseService<<#=entity.Name#>>, I<#=entity.Name#>Service { public override void SetCurrenDao() { this.CurrentDao = this.DbSession.<#=entity.Name#>Dao; } } <#};#> }
以下是运行T4模版后自动生成的代码：
这时我们就对业务逻辑层封装完成，系列四中使用MVC3.0简单实现增删改查以及分页功能。
标签: EF
作者：Leo_wl
出处：http://www.cnblogs.com/Leo_wl/
本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，否则保留追究法律责任的权利。
版权信息