Entity Famework 的通過IOC註入實現

1、前言最近剛換了一家公司，由於之前的公司代碼並沒有用到項目框架，需要我整理下NHibernate與Entity Framework之間的區別及適用性。並寫出相關的示例代碼面試的時候吹的牛，得把他填上啊。剛剛整完相應的EF code first的示例代碼，需要連接oracle，那個資料庫遷移 ...

1、前言

　　最近剛換了一家公司，由於之前的公司代碼並沒有用到項目框架，需要我整理下NHibernate與Entity Framework之間的區別及適用性。並寫出相關的示例代碼

面試的時候吹的牛，得把他填上啊。

剛剛整完相應的EF code first的示例代碼，需要連接oracle，那個資料庫遷移整的我不要不要的，最後還沒搞出來。對於EF 調用oralce的存儲過程，也沒有搞出來。

有這方面資料的園友，請告知啊。

2、思路

先把基於DBcontext的類，進行繼承，創建出基於Tclass的base類，創建出基於T的操作方法。好吧，我也講不明白了，大神求教。然後所有的方法調用，通過IOC進行註入

3、準備條件

　　VS2013、oracle11g

4、代碼

　　OracleDBContext類繼承與DBContext

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using System.Xml.Linq;
using System.Data.Common;
using System.Data.Entity;
using System.Data.Entity.Core.Objects;
using System.Data.Entity.Migrations;
using System.Data.Entity.Infrastructure;
using System.Data.Entity.Migrations.History;
using System.ComponentModel.DataAnnotations;
using System.ComponentModel.DataAnnotations.Schema;

namespace DALClass
{
    public class OracleDBContext : DbContext
    {


        //public DbSet<CAT> cat { get; set; }

        //public DbSet<FOOD> food { get; set; }

        public OracleDBContext()
            : base("OracleDbContext")
        {
            Database.SetInitializer<OracleDBContext>(null);
        }

        public OracleDBContext(string connString)
            : base(connString)
        {
            Database.SetInitializer<OracleDBContext>(null);
        }
        public override string ToString()
        {
            return base.ToString();
        }
        protected override void OnModelCreating(DbModelBuilder modelBuilder)
        {
            modelBuilder.HasDefaultSchema("CNBLOGS");
        }
    }
}

OracleDBContext

OracleDbSetBase<T>繼承與OracleDBContext

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using System.Xml.Linq;
using System.Data.Common;
using System.Data.Entity;
using System.Data.Entity.Core.Objects;
using System.Data.Entity.Migrations;
using System.Data.Entity.Infrastructure;
using System.Data.Entity.Migrations.History;
using System.ComponentModel.DataAnnotations;
using System.ComponentModel.DataAnnotations.Schema;


namespace DALClass
{
    public  class OracleDbSetBase<T> : OracleDBContext where T : class
    {
        public OracleDbSetBase(string connString) : // 資料庫鏈接字元串
            base(connString)
        {
            Database.SetInitializer<OracleDbSetBase<T>>(null);//設置為空，防止自動檢查和生成
        }

        public DbSet<T> Entities { get; set; }
    }
}

OracleDbSetBase

IOracleDbDAL 資料庫操作方法介面（暫時只定義一個方法，方便大家看）

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using System.Linq.Expressions;

namespace CommonClass
{
    public interface  IOracleDbDAL
    {
        
        bool Add<T>(T entity,string connstring) where T:class;

        //bool Update<T>(T entity) where T : class;

        //bool Delete<T>(T entity) where T : class;


    }
}

IOracleDbDAL

OracleDbDAL 類基於IOracleDbDAL

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using System.Xml.Linq;
using System.Data.Common;
using System.Data.Entity;
using System.Data.Entity.Core.Objects;
using System.Data.Entity.Migrations;
using System.Data.Entity.Infrastructure;
using System.Data.Entity.Migrations.History;
using System.ComponentModel.DataAnnotations;
using System.ComponentModel.DataAnnotations.Schema;
using System.Linq.Expressions;
using CommonClass;

namespace DALClass
{
    public  class OracleDbDAL :IOracleDbDAL
    {

        //public string connstring { get; set; }

        ////public OracleDbDAL()
        ////{
        ////    this.connstring = "OracleDbContext";
        ////}
        //public OracleDbDAL(string connString)
        //{
        //    this.connstring = connString;
        //}


        #region
        public bool Add<T>(T entity,string connstring) where T : class
        {
            using (OracleDbSetBase<T> db = new OracleDbSetBase<T>(connstring))
            {
                db.Entry<T>(entity).State = EntityState.Added;
                return db.SaveChanges() > 0;
            }
        }
        ///// <summary>
        ///// 修改
        ///// </summary>
        ///// <param name="entity">實體</param>
        ///// <returns>返回受影響行數</returns>
        //public bool Update<T>(T entity) where T : class
        //{
        //    using (OracleDbSetBase<T> db = new OracleDbSetBase<T>(connstring))
        //    {
        //        db.Set<T>().Attach(entity);
        //        db.Entry<T>(entity).State = EntityState.Modified;
        //        return db.SaveChanges() > 0;
        //    }
        //}

        ///// <summary>
        ///// 刪除
        ///// </summary>
        ///// <param name="entity">實體</param>
        ///// <returns>返回受影響行數</returns>
        //public bool Delete<T>(T entity) where T : class
        //{
        //    using (OracleDbSetBase<T> db = new OracleDbSetBase<T>(connstring))
        //    {
        //        db.Set<T>().Attach(entity);
        //        db.Entry<T>(entity).State = EntityState.Deleted;
        //        return db.SaveChanges() > 0;
        //    }
        //}

        ///// <summary>
        ///// 根據條件刪除
        ///// </summary>
        ///// <param name="deleWhere">刪除條件</param>
        ///// <returns>返回受影響行數</returns>
        //public bool DeleteByConditon<T>(Expression<Func<T, bool>> deleWhere) where T : class
        //{
        //    using (OracleDbSetBase<T> db = new OracleDbSetBase<T>(connstring))
        //    {
        //        List<T> entitys = db.Set<T>().Where(deleWhere).ToList();
        //        entitys.ForEach(m => db.Entry<T>(m).State = EntityState.Deleted);
        //        return db.SaveChanges() > 0;
        //    }
        //}

        ///// <summary>
        ///// 查找單個
        ///// </summary>
        ///// <param name="id">主鍵</param>
        ///// <returns></returns>
        //public T GetSingleById<T>(int id) where T : class
        //{
        //    using (OracleDbSetBase<T> db = new OracleDbSetBase<T>(connstring))
        //    {
        //        return db.Set<T>().Find(id);
        //    }
        //}

        ///// <summary>
        ///// 查找單個
        ///// </summary>
        ///// <param name="seleWhere">查詢條件</param>
        ///// <returns></returns>
        //public T GetSingle<T>(Expression<Func<T, bool>> seleWhere) where T : class
        //{
        //    using (OracleDbSetBase<T> db = new OracleDbSetBase<T>(connstring))
        //    {
        //        return db.Set<T>().FirstOrDefault(seleWhere);
        //    }
        //}

        ///// <summary>
        ///// 獲取所有實體集合
        ///// </summary>
        ///// <returns></returns>
        //public List<T> GetAll<T>() where T : class
        //{
        //    using (OracleDbSetBase<T> db = new OracleDbSetBase<T>(connstring))
        //    {
        //        return db.Set<T>().ToList<T>();
        //    }
        //}

        ///// <summary>
        ///// 獲取所有實體集合(單個排序)
        ///// </summary>
        ///// <returns></returns>
        //public List<T> GetAll<T, Tkey>(Expression<Func<T, Tkey>> orderWhere, bool isDesc) where T : class
        //{
        //    using (OracleDbSetBase<T> db = new OracleDbSetBase<T>(connstring))
        //    {
        //        return CommonSort(db.Set<T>(), orderWhere, isDesc).ToList<T>();
        //    }
        //}


        ///// <summary>
        ///// 單個排序通用方法
        ///// </summary>
        ///// <typeparam name="Tkey">排序欄位</typeparam>
        ///// <param name="data">要排序的數據</param>
        ///// <param name="orderWhere">排序條件</param>
        ///// <param name="isDesc">是否倒序</param>
        ///// <returns>排序後的集合</returns>
        //public IQueryable<T> CommonSort<T, Tkey>(IQueryable<T> data, Expression<Func<T, Tkey>> orderWhere, bool isDesc) where T : class
        //{
        //    if (isDesc)
        //    {
        //        return data.OrderByDescending(orderWhere);
        //    }
        //    else
        //    {
        //        return data.OrderBy(orderWhere);
        //    }
        //}

        ///// <summary>
        ///// 根據條件查詢實體集合
        ///// </summary>
        ///// <param name="seleWhere">查詢條件 lambel表達式</param>
        ///// <returns></returns>
        //public List<T> GetList<T>(Expression<Func<T, bool>> seleWhere) where T : class
        //{
        //    using (OracleDbSetBase<T> db = new OracleDbSetBase<T>(connstring))
        //    {
        //        return db.Set<T>().Where(seleWhere).ToList();
        //    }
        //}



        ///// <summary>
        ///// 根據條件查詢實體集合(單個欄位排序)
        ///// </summary>
        ///// <param name="seleWhere">查詢條件 lambel表達式</param>
        ///// <returns></returns>
        //public List<T> GetList<T, Tkey>(Expression<Func<T, bool>> seleWhere, Expression<Func<T, Tkey>> orderWhere, bool isDesc) where T : class
        //{
        //    using (OracleDbSetBase<T> db = new OracleDbSetBase<T>(connstring))
        //    {
        //        return CommonSort(db.Set<T>().Where(seleWhere), orderWhere, isDesc).ToList();
        //    }
        //}


        ///// <summary>
        ///// 獲取分頁集合(無條件無排序)
        ///// </summary>
        ///// <returns></returns>
        //public List<T> GetListPaged<T, Tkey>(int pageIndex, int pageSize, out int totalcount) where T : class
        //{
        //    using (OracleDbSetBase<T> db = new OracleDbSetBase<T>(connstring))
        //    {
        //        totalcount = db.Set<T>().Count();//獲取總數
        //        //需要增加AsExpandable(),否則查詢的是所有數據到記憶體，然後再排序  AsExpandable是linqkit.dll中的方法
        //        return db.Set<T>().Skip((pageIndex - 1) * pageSize).Take(pageSize).ToList();
        //    }
        //}

        ///// <summary>
        ///// 獲取分頁集合(無條件單個排序)
        ///// </summary>
        ///// <returns></returns>
        //public List<T> GetListPaged<T, Tkey>(int pageIndex, int pageSize, Expression<Func<T, Tkey>> orderWhere, bool isDesc, out int totalcount) where T : class
        //{
        //    using (OracleDbSetBase<T> db = new OracleDbSetBase<T>(connstring))
        //    {
        //        totalcount = db.Set<T>().Count();//獲取總數
        //        //需要增加AsExpandable(),否則查詢的是所有數據到記憶體，然後再排序  AsExpandable是linqkit.dll中的方法
        //        return CommonSort(db.Set<T>(), orderWhere, isDesc).Skip((pageIndex - 1) * pageSize).Take(pageSize).ToList();
        //    }
        //}



        ///// <summary>
        ///// 獲取分頁集合(有條件無排序)
        ///// </summary>
        ///// <returns></returns>
        //public List<T> GetListPaged<T, Tkey>(int pageIndex, int pageSize, Expression<Func<T, bool>> seleWhere, out int totalcount) where T : class
        //{
        //    using (OracleDbSetBase<T> db = new OracleDbSetBase<T>(connstring))
        //    {
        //        totalcount = db.Set<T>().Where(seleWhere).Count();//獲取總數
        //        //需要增加AsExpandable(),否則查詢的是所有數據到記憶體，然後再排序  AsExpandable是linqkit.dll中的方法
        //        return db.Set<T>().Where(seleWhere).Skip((pageIndex - 1) * pageSize).Take(pageSize).ToList();
        //    }
        //}

        ///// <summary>
        ///// 獲取分頁集合(有條件單個排序)
        ///// </summary>
        ///// <returns></returns>
        //public List<T> GetListPaged<T, Tkey>(int pageIndex, int pageSize, Expression<Func<T, bool>> seleWhere,
        //    Expression<Func<T, Tkey>> orderWhere, bool isDesc, out int totalcount) where T : class
        //{
        //    using (OracleDbSetBase<T> db = new OracleDbSetBase<T>(connstring))
        //    {
        //        totalcount = db.Set<T>().Where(seleWhere).Count();//獲取總數
        //        //需要增加AsExpandable(),否則查詢的是所有數據到記憶體，然後再排序  AsExpandable是linqkit.dll中的方法
        //        return CommonSort(db.Set<T>().Where(seleWhere), orderWhere, isDesc).Skip((pageIndex - 1) * pageSize).Take(pageSize).ToList();
        //    }
        //}

        //#endregion

        //#region 原始sql操作
        ///// <summary>
        ///// 執行操作
        ///// </summary>
        ///// <param name="sql"></param>
        ///// <param name="paras"></param>
        //public void ExecuteSql(string sql, params object[] paras) 
        //{
        //    using (OracleDBContext db = new OracleDBContext(connstring))
        //    {
        //        db.Database.ExecuteSqlCommand(sql, paras);
        //    }
        //}

        ///// <summary>
        ///// 查詢列表
        ///// </summary>
        ///// <typeparam name="T"></typeparam>
        ///// <param name="sql"></param>
        ///// <param name="paras"></param>
        ///// <returns></returns>
        //public List<T> QueryList<T>(string sql, params object[] paras) where T : class
        //{
        //    using (OracleDBContext db = new OracleDBContext(connstring))
        //    {
        //        return db.Database.SqlQuery<T>(sql, paras).ToList();
        //    }
        //}

        ///// <summary>
        ///// 查詢單個
        ///// </summary>
        ///// <typeparam name="T"></typeparam>
        ///// <param name="sql"></param>
        ///// <param name="paras"></param>
        ///// <returns></returns>
        //public T QuerySingle<T>(string sql, params object[] paras) where T : class
        //{
        //    using (OracleDbSetBase<T> db = new OracleDbSetBase<T>(connstring))
        //    {
        //        return db.Database.SqlQuery<T>(sql, paras).FirstOrDefault();
        //    }
        //}

        ///// <summary>
        ///// 執行事務
        ///// </summary>
        ///// <param name="lsSql"></param>
        ///// <param name="lsParas"></param>
        //public void ExecuteTransaction(List<String> lsSql, List<Object[]> lsParas)
        //{
        //    using (OracleDBContext db = new OracleDBContext(connstring))
        //    {
        //        using (var tran = db.Database.BeginTransaction())
        //        {
        //            try
        //            {
        //                for (int i = 0; i < lsSql.Count; i++)
        //                {
        //                    if (lsParas != null && lsParas.Count > 0)
        //                    {
        //                        db.Database.ExecuteSqlCommand(lsSql[i], lsParas[i]);
        //                    }
        //                }
        //                foreach (String item in lsSql)
        //                {
        //                    db.Database.ExecuteSqlCommand(item);
        //                }

        //                tran.Commit();
        //            }
        //            catch (Exception ex)
        //            {
        //                tran.Rollback();
        //                throw ex;
        //            }
        //        }
        //    }
        //}
        //#endregion

        //#region 通用屬性
        ///// <summary>
        ///// 獲取資料庫伺服器當前時間。
        ///// </summary>
        //public DateTime ServerTime
        //{
        //    get
        //    {
        //        using (OracleDBContext db = new OracleDBContext(connstring))
        //        {
        //            String sql = "SELECT GETDATE()";
        //            Object objServerTime = db.Database.SqlQuery<Object>(sql);
        //            return Convert.ToDateTime(objServerTime);
        //        }
        //    }
        //}

        ///// <summary>
        ///// 獲取資料庫版本。
        ///// </summary>
        //public String DatabaseVersion
        //{
        //    get
        //    {
        //        using (OracleDBContext db = new OracleDBContext(connstring))
        //        {
        //            try
        //            {
        //                String sql = "SELECT Version FROM Sys_Version";
        //                Object objServerTime = db.Database.SqlQuery<Object>(sql);
        //                return Convert.ToString(objServerTime);
        //            }
        //            catch
        //            {
        //            }
        //            return String.Empty;
        //        }
        //    }
        //}
        #endregion
    }
}

OracleDbDAL

Ioc類（該用的是Unity）

using Microsoft.Practices.Unity;

namespace CommonClass
{
    public class Ioc
    {
        private static readonly UnityContainer _container;

        static Ioc()
        {
            _container = new UnityContainer();
        }

        public static void Register<TInterface, TImplementation>() where TImplementation : TInterface
        {

            _container.RegisterType<TInterface, TImplementation>();
        }

        public static void Register<TInterface, TImplementation>(TImplementation t) where TImplementation : TInterface
        {
            _container.RegisterInstance(t.GetType(), t);
        }
        //public static void Register<TInterface, TImplementation>(string  conn) where TImplementation : TInterface
        //{
        //    _container.RegisterType<TInterface, TImplementation>(new TImplementation(conn));
        //}

        public static T Get<T>()
        {
            return _container.Resolve<T>();
        }


    }
}

Ioc

接下來是進行實現了，通過註入IOC來進行數據添加

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using CommonClass;
using ModelClass;
using DALClass;

namespace FacadeClass
{
    public class Class1
    {
        public bool  AAA(FOOD INFO,string connstring)
        {

            Ioc.Register<IOracleDbDAL, OracleDbDAL>();
             var service =  Ioc.Get<IOracleDbDAL>();
             return service.Add(INFO, connstring);
        }
        
    }
}

Facade

最後是頁面的的調用展示

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using ModelClass;
using DALClass;
using FacadeClass;

namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {
            string connstring = "OracleDbContext";
            FOOD entity = new FOOD();
            entity.ID = Guid.NewGuid().ToString();
            entity.CODE = "M0005";
            entity.FOOTTYPE = "貓糧la5";
            entity.SUPPLIER = "非洲的5";
            entity.NAME = "喵吃糧食5";

            FacadeClass.Class1 c = new FacadeClass.Class1();