菜鳥級三層框架（EF+MVC）項目實戰之 系列二 對數據訪問層的抽象中

概要：1、實現EF上線文線程唯一，有效避免了臟數據問題。

         2、實現IBaseDao中定義的CRUD方法

一、創建數據訪問層程序集

      1.1 在解決方案中創建Implements文件夾，以存放實現體部分的程序集          

          

      1.2 在Implements文件夾中創建Cnblogs.Rdst.Dao程序集

         

      1.3 添加如下引用

          

二、創建ObjectContextFactory獲取EF上下文

      2.1 在Cnblogs.Rdst.Dao程序集中創建ObjectContextFactory類，用來獲取EF上下文。

            當數據庫更換為Mysql或其他數據庫時，在這個類中可以實現替換。

            當網站訪問量增大時，為避免EF產生的臟數據問題，我們使用System.Runtime.Remoting.Messaging 命名空間下的CallContext來解決線程內上下文唯一。

            CallContex更多了解http://msdn.microsoft.com/zh-cn/library/system.runtime.remoting.messaging.callcontext(v=VS.80).aspx

     2.2  在ObjectContextFactory類中定義一個靜態方法，用於對EF上下文進行處理

using System;
using System.Collections.Generic;
using System.Data.Objects;
using System.Linq;
using System.Runtime.Remoting.Messaging;
using System.Text;
using Cnblogs.Rdst.Domain;
using Cnblogs.Rdst.IDAO;

namespace Cnblogs.Rdst.Dao
{
   public class ObjectContextFactory
    {
        public static System.Data.Objects.ObjectContext GetCurrentObjectContext()
        {
            //從CallContext數據槽中獲取EF上下文
            ObjectContext objectContext = CallContext.GetData(typeof (ObjectContextFactory).FullName) as ObjectContext;
            if (objectContext==null)
            {
                //如果CallContext數據槽中沒有EF上下文，則創建EF上下文，並保存到CallContext數據槽中
                objectContext = new ModelContainer();//當數據庫替換為MySql等，只要在次出EF更換上下文即可。
                CallContext.SetData(typeof(ObjectContextFactory).FullName,objectContext);
            }
            return objectContext;
        }
    }
}

 

三、創建BaseDao,並實現CRUD方法

      3.1 創建BaseDao類，實現IBaseDao中定義方法，用於所有實體類繼承此基類。

           

     3.2 BaseDao類實現代碼

           EF應用中需要注意：1、增加和查詢是不需要附加實體的，如果刪除和更新不是從上下文獲取的實體，就需要先附加，再進行狀態更改。

                                     2、處理查詢，增刪改都需要調用SaveChange()提交操作。

using System;
using System.Collections.Generic;
using System.Data.Objects;
using System.Linq;
using System.Text;
using Cnblogs.Rdst.IDAO;


namespace Cnblogs.Rdst.Dao
{
   public  class BaseDao<T>
                 where T:class,
                 new()
                    
   {
       ObjectContext objectContext= ObjectContextFactory.GetCurrentObjectContext() as ObjectContext;//獲取EF上下文

       /// <summary>
       /// 加載實體集合
       /// </summary>
       /// <param name="whereLambda"></param>
       /// <returns></returns>
       public virtual IQueryable<T> LoadEntites(Func<T,bool> whereLambda)
       {
          return objectContext.CreateObjectSet<T>().Where<T>(whereLambda).AsQueryable<T>();
       }

       /// <summary>
       /// 分頁加載數據
       /// </summary>
       /// <param name="whereLambda">過濾條件</param>
       /// <param name="pageIndex">頁碼</param>
       /// <param name="pageSize">頁大小</param>
       /// <param name="totalCount">總記錄數</param>
       /// <returns></returns>
       public virtual IQueryable<T> LoadEntites(Func<T,bool> whereLambda, int pageIndex, int pageSize, out int totalCount)
       {
          var tmp= objectContext.CreateObjectSet<T>().Where<T>(whereLambda);
          totalCount = tmp.Count();

          return tmp.Skip<T>(pageSize * (pageIndex - 1))//跳過行數，最終生成的sql語句是Top(n)
                    .Take<T>(pageSize) //返回指定數量的行
                    .AsQueryable<T>();
       }

       /// <summary>
       /// 添加實體
       /// </summary>
       /// <param name="entity"></param>
       /// <returns>返回更新后的實體</returns>
       public virtual T AddEntity(T entity)
       {
           objectContext.CreateObjectSet<T>().AddObject(entity);
           objectContext.SaveChanges();
           return entity;
       }

       /// <summary>
       /// 更新實體
       /// </summary>
       /// <param name="entity"></param>
       /// <returns>返回更新后的實體</returns>
       public virtual T UpdateEntity(T entity)
       {
           objectContext.CreateObjectSet<T>().Attach(entity);
           objectContext.ObjectStateManager.ChangeObjectState(entity, System.Data.EntityState.Modified);//將附加的對象狀態更改為修改
           objectContext.SaveChanges();
           return entity;
       }

       /// <summary>
       /// 刪除實體
       /// </summary>
       /// <param name="entity"></param>
       /// <returns></returns>
       public virtual bool DelEntity(T entity)
       {
           objectContext.CreateObjectSet<T>().Attach(entity);
           objectContext.ObjectStateManager.ChangeObjectState(entity, System.Data.EntityState.Deleted);//將附加的實體狀態更改為刪除
           if (objectContext.SaveChanges()>0)
           {
               return true;//刪除成功
           }
           else
           {
               return false;//刪除失敗
           }
       }

       /// <summary>
       /// 根據條件刪除對象
       /// </summary>
       /// <param name="whereLambda">條件</param>
       /// <returns></returns>
       public virtual bool DelEntityByWhere(Func<T, bool> whereLambda)
       {
          var tmp= objectContext.CreateObjectSet<T>().Where<T>(whereLambda);//根據條件從數據庫中獲取對象集合
          foreach (var entity in tmp)
          {
              objectContext.CreateObjectSet<T>().DeleteObject(entity);//標記對象為刪除狀態刪除
          }
          if (objectContext.SaveChanges() > 0) 
          {
              return true;
          }
          else
          {
              return false;
          }
       }
   }
}

 

四、使用T4模版生成所有實體對象的實現

      4.1 和系列二中的方法一樣創建T4模版，生成所有的實體類繼承自BaseDao並實現各自的接口

           以下是T4模版中的代碼，需要更改相應的EF edmx模型路徑、引用命名空間等。

<#@ 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.IDAO;
using Cnblogs.Rdst.Domain;

namespace Cnblogs.Rdst.Dao
{
<#
foreach (EntityType entity in ItemCollection.GetItems<EntityType>().OrderBy(e => e.Name))
{#>    
    public partial class <#=entity.Name#>Dao:BaseDao<<#=entity.Name#>>,I<#=entity.Name#>Dao
    {
      
    }
<#};#>
}

      4.2 T4模版編輯完成后，ctrl+s保存並運行，就生成了所有實體類的實現了

 

至此也就實現了數據訪問層的增刪改查以及分頁查詢。

菜鳥級三層框架（EF+MVC）項目實戰之 系列二 對數據訪問層的抽象下 將實現數據訪問層對業務層的統一入口