前言：這是對本文系統一次重要的革新，很久就想要重構數據訪問層了，數據訪問層重復代碼太多。主要集中增刪該查每個模塊都有，所以本次是為封裝相同接口方法
如果你想了解怎么重構普通的接口DAL層請查看第二節點
如果你只想了解利用T4鏈接EF生成代碼，可以忽略前兩節，之后跳后最后T4模版的使用。
（代碼在最后）
補充：
最后必須讓初學者理解一個知識點：分部類 partial 關鍵字，因為我們的重構是圍繞分部類而實現，包括接口
partial 關鍵字指示可在命名空間中定義該類、結構或接口的其他部分。所有部分都必須使用 partial 關鍵字。在編譯時，各個部分都必須可用來形成最終的類型。各個部分必須具有相同的可訪問性，如 public、private 等。
如果將任意部分聲明為抽象的，則整個類型都被視為抽象的。如果將任意部分聲明為密封的，則整個類型都被視為密封的。如果任意部分聲明基類型，則整個類型都將繼承該類。
指定基類的所有部分必須一致，但忽略基類的部分仍繼承該基類型。各個部分可以指定不同的基接口，最終類型將實現所有分部聲明所列出的全部接口。在某一分部定義中聲明的任何類、結構或接口成員可供所有其他部分使用。最終類型是所有部分在編譯時的組合。
下列聲明:
partial class Earth : Planet, IRotate { }
partial class Earth : IRevolve { }
等效於下列聲明：
class Earth : Planet, IRotate, IRevolve { }
知識點：
- 改變EF代碼生成策略
- 改變生成策略為T4
- 添加TT模版
- 重構DAL層
- 創建ICommonRepository<T>接口
- 實現ICommonRepository<T>方法
- T4模版的使用
1.改變EF代碼生成策略舊的ObjectContext改為T4（如果你的項目已經是DBContext API模式請跳過）（操作前備份項目）
在此之前我們也該改變一下代碼生成策略，為什么會這個改變。這個項目我最初開始創建的時候用的EF版本為EF4.0當時EF4.0只提供了ObjectContext API接口模式
這個訪問方式只能對於DataBase Frist用，不能用於Code Frist.所以一直用到這里，這個並不是很重要，最終都不會影響我們的功能開發
但是DBContext API的亮點，和現在教材都是基於DBContext策略的方式(EF4.1版本之后)，我們有必要與時俱進。
操作方式很簡單：
第一步：
從舊的ObjectContext改為T4（操作前備份項目）
第二步：
第三步：
->
最后看到DB.emdx下生成了很多模型類。根據表而生成的！這時代碼編譯將出錯，根據出錯的類庫添加NUGET包。EntityFramework6.1.3版本，添加完之后還會繼續報錯。
因為ObjectContext有些方法和屬性在DBContext已經不能用了
ObjectContext和ObjectSet都提供了AddObject的功能：
比如 context.AddObject("Students", newStudent):
context.Students.AddObject(newStudent):
而 DBContext中則只有DBSet有這個功能，並且名稱為成了Add
context.Students.Add(newStudent):
也包括DeleteObject，ObjectStateManager等。
（忽略所有錯誤。這些錯誤將在我們重構DAL層被解決）
2.重構DAL層，下面我們來看一張圖
圖中綠色部分為本次重構部分，再利用成T4連接EF 生成通用分部類部分。這樣我們下次不用手動創建繼承類，只需要創建其他操作的分部類，很是簡單。來看代碼才明白
在第一節下載17
講代碼
我們來看現有代碼，以SysSample 模塊的IDAL和DAL為例子
using Apps.Models; using System.Linq; namespace Apps.IDAL { public interface ISysSampleRepository { IQueryable<SysSample> GetList(DBContainer db); int Create(SysSample entity); int Delete(string id); void Delete(DBContainer db, string[] deleteCollection); /// <param name="entity">實體</param> int Edit(SysSample entity); SysSample GetById(string id); bool IsExist(string id); } }
using System; using System.Linq; using Apps.IDAL; using Apps.Models; using System.Data; namespace Apps.DAL { public class SysSampleRepository : ISysSampleRepository, IDisposable { public IQueryable<SysSample> GetList(DBContainer db) { IQueryable<SysSample> list = db.SysSample.AsQueryable(); return list; } public int Create(SysSample entity) { using (DBContainer db = new DBContainer()) { db.SysSample.AddObject(entity); return db.SaveChanges(); } } public int Delete(string id) { using (DBContainer db = new DBContainer()) { SysSample entity = db.SysSample.SingleOrDefault(a => a.Id == id); if (entity != null) { db.SysSample.DeleteObject(entity); } return db.SaveChanges(); } } public int Delete(DBContainer db, string[] deleteCollection) { IQueryable<SysSample> collection = from f in db.SysSample where deleteCollection.Contains(f.Id) select f; foreach (var deleteItem in collection) { db.SysSample.DeleteObject(deleteItem); } } public int Edit(SysSample entity) { using (DBContainer db = new DBContainer()) { db.SysSample.Attach(entity); db.ObjectStateManager.ChangeObjectState(entity, EntityState.Modified); return db.SaveChanges(); } } public SysSample GetById(string id) { using (DBContainer db = new DBContainer()) { return db.SysSample.SingleOrDefault(a => a.Id == id); } } public bool IsExist(string id) { using (DBContainer db = new DBContainer()) { SysSample entity = GetById(id); if (entity != null) return true; return false; } } public void Dispose() { } } }
看到我們其他模塊也都必須實現類似代碼。其中不同之處只有SysSample模型
好在.net提供索引訪問對象的強類型List<T>這里的T代表SysSamle。是可變的
1.接下來我們實現通用接口在IDAL層
using System; using System.Collections.Generic; using System.Linq; using System.Linq.Expressions; using System.Text; using System.Threading.Tasks; namespace Apps.IDAL { public interface ICommonRepository<T> where T :class { bool Create(T model); bool Edit(T model); bool Delete(T model); /// <summary> /// 按主鍵刪除 /// </summary> /// <param name="keyValues"></param> int Delete(params object[] keyValues); T GetById(params object[] keyValues); /// <summary> /// 獲得所有數據 /// </summary> /// <returns></returns> IQueryable<T> GetList(); /// <summary> /// 根據表達式獲取數據 /// </summary> /// <param name="whereLambda"></param> /// <returns></returns> IQueryable<T> GetList(Func<T, bool> whereLambda);bool IsExist(string id); int SaveChanges(); } }
代碼解析：接口實現了增刪改查通用接口，並聲明 where T :class 【T必須是一個類（class）類型】
2.接下來我們實現通用方法DAL層 按照重構圖所示，應該繼承ICommonRepository接口，並實現接口方法
using Apps.IDAL; using Apps.Models; using System; using System.Collections.Generic; using System.Data.Entity; using System.Linq; using System.Linq.Expressions; using System.Text; using System.Threading.Tasks; namespace Apps.DAL { public abstract class CommonRepository<T> : ICommonRepository<T> where T:class { DBContainer db; public CommonRepository(DBContainer context) { this.db = context; } public DBContainer Context { get { return db; } } public virtual bool Create(T model) { db.Set<T>().Add(model); return db.SaveChanges()>0; } public virtual bool Edit(T model) { if (db.Entry<T>(model).State == EntityState.Modified) { return db.SaveChanges() > 0; } else if (db.Entry<T>(model).State == EntityState.Detached) { try { db.Set<T>().Attach(model); db.Entry<T>(model).State = EntityState.Modified; } catch (InvalidOperationException) { //T old = Find(model._ID); //db.Entry<old>.CurrentValues.SetValues(model); } return db.SaveChanges()>0; } return false; } public virtual bool Delete(T model) { db.Set<T>().Remove(model); return db.SaveChanges()>0; } public virtual int Delete(params object[] keyValues) { T model = GetById(keyValues); if(model!=null) { db.Set<T>().Remove(model); return db.SaveChanges(); } return -1; } public virtual T GetById(params object[] keyValues) { return db.Set<T>().Find(keyValues); } public virtual IQueryable<T> GetList() { return db.Set<T>(); } public virtual IQueryable<T> GetList(Func<T, bool> whereLambda) { return db.Set<T>().Where(whereLambda).AsQueryable(); } public virtual bool IsExist(string id) { return GetById(id)!=null; } public int SaveChanges() { return db.SaveChanges(); } } }
OK.全是DBContext API 操作EF方法。增刪改查
3.T4生成分部類
接下來我們來看這么用這個接口
我們IDAL所有表（即模塊）都要實現ICommonRepository接口好調用其中的增刪改查做擴展
刪掉ISysSampleRepository中的原來代碼變為：
using Apps.Models; using System.Linq; namespace Apps.IDAL { public interface ISysSampleRepository : ICommonRepository<SysSample> { } }
觀察到這里也是重復代碼，因為同理我們所有表都要實現這樣的接口，這樣我們可以利用T4來生成這種的重復代碼
我以前寫過一篇文章是關於T4鏈接數據庫的。構建ASP.NET MVC4+EF5+EasyUI+Unity2.x注入的后台管理系統（29）-T4模版
這里我們是直接鏈接edmx的。同理
1.新建一個文件夾。如下圖所示並創建一個TT模版
創建后會產生2個文件。刪掉Context.tt，因為在Apps.Models已經有了
配置第五行的inputFile為上面所描述，可能因為環境不同你們EF路徑有所不同。保存后TT模版會自動生成
tt模版如果沒有高亮顯示的。要安裝一些工具。因為我是一邊改一邊發文章的。我這里也是沒有的，下載T4Editor 安裝高亮，什么版本就下什么就可以了（或者通過VS工具------擴展與更新 搜索）
http://t4-editor.tangible-engineering.com/Download_T4Editor_Plus_ModelingTools.html
tangible T4 Editor 2.3.0 plus modeling tools for Visual Studio 2015Download from Visual Studio Gallery
tangible T4 Editor 2.3.0 plus modeling tools for Visual Studio 2013Download from Visual Studio Gallery
按照ISysSampleRepository接口為例子。修改TT模版后代碼
<#@ template language="C#" debug="false" hostspecific="true"#> <#@ include file="EF6.Utility.CS.ttinclude"#><#@ output extension=".cs"#><# const string inputFile = @"../../Apps.Models/DB.edmx"; var textTransform = DynamicTextTransformation.Create(this); var code = new CodeGenerationTools(this); var ef = new MetadataTools(this); var typeMapper = new TypeMapper(code, ef, textTransform.Errors); var fileManager = EntityFrameworkTemplateFileManager.Create(this); var itemCollection = new EdmMetadataLoader(textTransform.Host, textTransform.Errors).CreateEdmItemCollection(inputFile); var codeStringGenerator = new CodeStringGenerator(code, typeMapper, ef); if (!typeMapper.VerifyCaseInsensitiveTypeUniqueness(typeMapper.GetAllGlobalItems(itemCollection), inputFile)) { return string.Empty; } WriteHeader(codeStringGenerator, fileManager); foreach (var entity in typeMapper.GetItemsToGenerate<EntityType>(itemCollection)) { fileManager.StartNewFile("I"+entity.Name + "Repository.cs"); #> using Apps.Models; namespace Apps.IDAL { public partial interface I<#=entity.Name #>Repository:ICommonRepository<<#=entity.Name #>> { } <# EndNamespace(code); } fileManager.Process(); #> <#+ public void WriteHeader(CodeStringGenerator codeStringGenerator, EntityFrameworkTemplateFileManager fileManager) { fileManager.StartHeader(); #> //------------------------------------------------------------------------------ // <auto-generated> // <#=CodeGenerationTools.GetResourceString("Template_GeneratedCodeCommentLine1")#> // // <#=CodeGenerationTools.GetResourceString("Template_GeneratedCodeCommentLine2")#> // <#=CodeGenerationTools.GetResourceString("Template_GeneratedCodeCommentLine3")#> // </auto-generated> //------------------------------------------------------------------------------ <#=codeStringGenerator.UsingDirectives(inHeader: true)#> <#+ fileManager.EndBlock(); } public void BeginNamespace(CodeGenerationTools code) { var codeNamespace = code.VsNamespaceSuggestion(); if (!String.IsNullOrEmpty(codeNamespace)) { #> namespace <#=code.EscapeNamespace(codeNamespace)#> { <#+ PushIndent(" "); } } public void EndNamespace(CodeGenerationTools code) { if (!String.IsNullOrEmpty(code.VsNamespaceSuggestion())) { PopIndent(); #> } <#+ } } public const string TemplateId = "CSharp_DbContext_Types_EF6"; public class CodeStringGenerator { private readonly CodeGenerationTools _code; private readonly TypeMapper _typeMapper; private readonly MetadataTools _ef; public CodeStringGenerator(CodeGenerationTools code, TypeMapper typeMapper, MetadataTools ef) { ArgumentNotNull(code, "code"); ArgumentNotNull(typeMapper, "typeMapper"); ArgumentNotNull(ef, "ef"); _code = code; _typeMapper = typeMapper; _ef = ef; } public string Property(EdmProperty edmProperty) { return string.Format( CultureInfo.InvariantCulture, "{0} {1} {2} {{ {3}get; {4}set; }}", Accessibility.ForProperty(edmProperty), _typeMapper.GetTypeName(edmProperty.TypeUsage), _code.Escape(edmProperty), _code.SpaceAfter(Accessibility.ForGetter(edmProperty)), _code.SpaceAfter(Accessibility.ForSetter(edmProperty))); } public string NavigationProperty(NavigationProperty navProp) { var endType = _typeMapper.GetTypeName(navProp.ToEndMember.GetEntityType()); return string.Format( CultureInfo.InvariantCulture, "{0} {1} {2} {{ {3}get; {4}set; }}", AccessibilityAndVirtual(Accessibility.ForNavigationProperty(navProp)), navProp.ToEndMember.RelationshipMultiplicity == RelationshipMultiplicity.Many ? ("ICollection<" + endType + ">") : endType, _code.Escape(navProp), _code.SpaceAfter(Accessibility.ForGetter(navProp)), _code.SpaceAfter(Accessibility.ForSetter(navProp))); } public string AccessibilityAndVirtual(string accessibility) { return accessibility + (accessibility != "private" ? " virtual" : ""); } public string EntityClassOpening(EntityType entity) { return string.Format( CultureInfo.InvariantCulture, "{0} {1}partial class {2}{3}", Accessibility.ForType(entity), _code.SpaceAfter(_code.AbstractOption(entity)), _code.Escape(entity), _code.StringBefore(" : ", _typeMapper.GetTypeName(entity.BaseType))); } public string EnumOpening(SimpleType enumType) { return string.Format( CultureInfo.InvariantCulture, "{0} enum {1} : {2}", Accessibility.ForType(enumType), _code.Escape(enumType), _code.Escape(_typeMapper.UnderlyingClrType(enumType))); } public void WriteFunctionParameters(EdmFunction edmFunction, Action<string, string, string, string> writeParameter) { var parameters = FunctionImportParameter.Create(edmFunction.Parameters, _code, _ef); foreach (var parameter in parameters.Where(p => p.NeedsLocalVariable)) { var isNotNull = parameter.IsNullableOfT ? parameter.FunctionParameterName + ".HasValue" : parameter.FunctionParameterName + " != null"; var notNullInit = "new ObjectParameter(\"" + parameter.EsqlParameterName + "\", " + parameter.FunctionParameterName + ")"; var nullInit = "new ObjectParameter(\"" + parameter.EsqlParameterName + "\", typeof(" + TypeMapper.FixNamespaces(parameter.RawClrTypeName) + "))"; writeParameter(parameter.LocalVariableName, isNotNull, notNullInit, nullInit); } } public string ComposableFunctionMethod(EdmFunction edmFunction, string modelNamespace) { var parameters = _typeMapper.GetParameters(edmFunction); return string.Format( CultureInfo.InvariantCulture, "{0} IQueryable<{1}> {2}({3})", AccessibilityAndVirtual(Accessibility.ForMethod(edmFunction)), _typeMapper.GetTypeName(_typeMapper.GetReturnType(edmFunction), modelNamespace), _code.Escape(edmFunction), string.Join(", ", parameters.Select(p => TypeMapper.FixNamespaces(p.FunctionParameterType) + " " + p.FunctionParameterName).ToArray())); } public string ComposableCreateQuery(EdmFunction edmFunction, string modelNamespace) { var parameters = _typeMapper.GetParameters(edmFunction); return string.Format( CultureInfo.InvariantCulture, "return ((IObjectContextAdapter)this).ObjectContext.CreateQuery<{0}>(\"[{1}].[{2}]({3})\"{4});", _typeMapper.GetTypeName(_typeMapper.GetReturnType(edmFunction), modelNamespace), edmFunction.NamespaceName, edmFunction.Name, string.Join(", ", parameters.Select(p => "@" + p.EsqlParameterName).ToArray()), _code.StringBefore(", ", string.Join(", ", parameters.Select(p => p.ExecuteParameterName).ToArray()))); } public string FunctionMethod(EdmFunction edmFunction, string modelNamespace, bool includeMergeOption) { var parameters = _typeMapper.GetParameters(edmFunction); var returnType = _typeMapper.GetReturnType(edmFunction); var paramList = String.Join(", ", parameters.Select(p => TypeMapper.FixNamespaces(p.FunctionParameterType) + " " + p.FunctionParameterName).ToArray()); if (includeMergeOption) { paramList = _code.StringAfter(paramList, ", ") + "MergeOption mergeOption"; } return string.Format( CultureInfo.InvariantCulture, "{0} {1} {2}({3})", AccessibilityAndVirtual(Accessibility.ForMethod(edmFunction)), returnType == null ? "int" : "ObjectResult<" + _typeMapper.GetTypeName(returnType, modelNamespace) + ">", _code.Escape(edmFunction), paramList); } public string ExecuteFunction(EdmFunction edmFunction, string modelNamespace, bool includeMergeOption) { var parameters = _typeMapper.GetParameters(edmFunction); var returnType = _typeMapper.GetReturnType(edmFunction); var callParams = _code.StringBefore(", ", String.Join(", ", parameters.Select(p => p.ExecuteParameterName).ToArray())); if (includeMergeOption) { callParams = ", mergeOption" + callParams; } return string.Format( CultureInfo.InvariantCulture, "return ((IObjectContextAdapter)this).ObjectContext.ExecuteFunction{0}(\"{1}\"{2});", returnType == null ? "" : "<" + _typeMapper.GetTypeName(returnType, modelNamespace) + ">", edmFunction.Name, callParams); } public string DbSet(EntitySet entitySet) { return string.Format( CultureInfo.InvariantCulture, "{0} virtual DbSet<{1}> {2} {{ get; set; }}", Accessibility.ForReadOnlyProperty(entitySet), _typeMapper.GetTypeName(entitySet.ElementType), _code.Escape(entitySet)); } public string UsingDirectives(bool inHeader, bool includeCollections = true) { return inHeader == string.IsNullOrEmpty(_code.VsNamespaceSuggestion()) ? string.Format( CultureInfo.InvariantCulture, "{0}using System;{1}" + "{2}", inHeader ? Environment.NewLine : "", includeCollections ? (Environment.NewLine + "using System.Collections.Generic;") : "", inHeader ? "" : Environment.NewLine) : ""; } } public class TypeMapper { private const string ExternalTypeNameAttributeName = @"http://schemas.microsoft.com/ado/2006/04/codegeneration:ExternalTypeName"; private readonly System.Collections.IList _errors; private readonly CodeGenerationTools _code; private readonly MetadataTools _ef; public TypeMapper(CodeGenerationTools code, MetadataTools ef, System.Collections.IList errors) { ArgumentNotNull(code, "code"); ArgumentNotNull(ef, "ef"); ArgumentNotNull(errors, "errors"); _code = code; _ef = ef; _errors = errors; } public static string FixNamespaces(string typeName) { return typeName.Replace("System.Data.Spatial.", "System.Data.Entity.Spatial."); } public string GetTypeName(TypeUsage typeUsage) { return typeUsage == null ? null : GetTypeName(typeUsage.EdmType, _ef.IsNullable(typeUsage), modelNamespace: null); } public string GetTypeName(EdmType edmType) { return GetTypeName(edmType, isNullable: null, modelNamespace: null); } public string GetTypeName(TypeUsage typeUsage, string modelNamespace) { return typeUsage == null ? null : GetTypeName(typeUsage.EdmType, _ef.IsNullable(typeUsage), modelNamespace); } public string GetTypeName(EdmType edmType, string modelNamespace) { return GetTypeName(edmType, isNullable: null, modelNamespace: modelNamespace); } public string GetTypeName(EdmType edmType, bool? isNullable, string modelNamespace) { if (edmType == null) { return null; } var collectionType = edmType as CollectionType; if (collectionType != null) { return String.Format(CultureInfo.InvariantCulture, "ICollection<{0}>", GetTypeName(collectionType.TypeUsage, modelNamespace)); } var typeName = _code.Escape(edmType.MetadataProperties .Where(p => p.Name == ExternalTypeNameAttributeName) .Select(p => (string)p.Value) .FirstOrDefault()) ?? (modelNamespace != null && edmType.NamespaceName != modelNamespace ? _code.CreateFullName(_code.EscapeNamespace(edmType.NamespaceName), _code.Escape(edmType)) : _code.Escape(edmType)); if (edmType is StructuralType) { return typeName; } if (edmType is SimpleType) { var clrType = UnderlyingClrType(edmType); if (!IsEnumType(edmType)) { typeName = _code.Escape(clrType); } typeName = FixNamespaces(typeName); return clrType.IsValueType && isNullable == true ? String.Format(CultureInfo.InvariantCulture, "Nullable<{0}>", typeName) : typeName; } throw new ArgumentException("edmType"); } public Type UnderlyingClrType(EdmType edmType) { ArgumentNotNull(edmType, "edmType"); var primitiveType = edmType as PrimitiveType; if (primitiveType != null) { return primitiveType.ClrEquivalentType; } if (IsEnumType(edmType)) { return GetEnumUnderlyingType(edmType).ClrEquivalentType; } return typeof(object); } public object GetEnumMemberValue(MetadataItem enumMember) { ArgumentNotNull(enumMember, "enumMember"); var valueProperty = enumMember.GetType().GetProperty("Value"); return valueProperty == null ? null : valueProperty.GetValue(enumMember, null); } public string GetEnumMemberName(MetadataItem enumMember) { ArgumentNotNull(enumMember, "enumMember"); var nameProperty = enumMember.GetType().GetProperty("Name"); return nameProperty == null ? null : (string)nameProperty.GetValue(enumMember, null); } public System.Collections.IEnumerable GetEnumMembers(EdmType enumType) { ArgumentNotNull(enumType, "enumType"); var membersProperty = enumType.GetType().GetProperty("Members"); return membersProperty != null ? (System.Collections.IEnumerable)membersProperty.GetValue(enumType, null) : Enumerable.Empty<MetadataItem>(); } public bool EnumIsFlags(EdmType enumType) { ArgumentNotNull(enumType, "enumType"); var isFlagsProperty = enumType.GetType().GetProperty("IsFlags"); return isFlagsProperty != null && (bool)isFlagsProperty.GetValue(enumType, null); } public bool IsEnumType(GlobalItem edmType) { ArgumentNotNull(edmType, "edmType"); return edmType.GetType().Name == "EnumType"; } public PrimitiveType GetEnumUnderlyingType(EdmType enumType) { ArgumentNotNull(enumType, "enumType"); return (PrimitiveType)enumType.GetType().GetProperty("UnderlyingType").GetValue(enumType, null); } public string CreateLiteral(object value) { if (value == null || value.GetType() != typeof(TimeSpan)) { return _code.CreateLiteral(value); } return string.Format(CultureInfo.InvariantCulture, "new TimeSpan({0})", ((TimeSpan)value).Ticks); } public bool VerifyCaseInsensitiveTypeUniqueness(IEnumerable<string> types, string sourceFile) { ArgumentNotNull(types, "types"); ArgumentNotNull(sourceFile, "sourceFile"); var hash = new HashSet<string>(StringComparer.InvariantCultureIgnoreCase); if (types.Any(item => !hash.Add(item))) { _errors.Add( new CompilerError(sourceFile, -1, -1, "6023", String.Format(CultureInfo.CurrentCulture, CodeGenerationTools.GetResourceString("Template_CaseInsensitiveTypeConflict")))); return false; } return true; } public IEnumerable<SimpleType> GetEnumItemsToGenerate(IEnumerable<GlobalItem> itemCollection) { return GetItemsToGenerate<SimpleType>(itemCollection) .Where(e => IsEnumType(e)); } public IEnumerable<T> GetItemsToGenerate<T>(IEnumerable<GlobalItem> itemCollection) where T: EdmType { return itemCollection .OfType<T>() .Where(i => !i.MetadataProperties.Any(p => p.Name == ExternalTypeNameAttributeName)) .OrderBy(i => i.Name); } public IEnumerable<string> GetAllGlobalItems(IEnumerable<GlobalItem> itemCollection) { return itemCollection .Where(i => i is EntityType || i is ComplexType || i is EntityContainer || IsEnumType(i)) .Select(g => GetGlobalItemName(g)); } public string GetGlobalItemName(GlobalItem item) { if (item is EdmType) { return ((EdmType)item).Name; } else { return ((EntityContainer)item).Name; } } public IEnumerable<EdmProperty> GetSimpleProperties(EntityType type) { return type.Properties.Where(p => p.TypeUsage.EdmType is SimpleType && p.DeclaringType == type); } public IEnumerable<EdmProperty> GetSimpleProperties(ComplexType type) { return type.Properties.Where(p => p.TypeUsage.EdmType is SimpleType && p.DeclaringType == type); } public IEnumerable<EdmProperty> GetComplexProperties(EntityType type) { return type.Properties.Where(p => p.TypeUsage.EdmType is ComplexType && p.DeclaringType == type); } public IEnumerable<EdmProperty> GetComplexProperties(ComplexType type) { return type.Properties.Where(p => p.TypeUsage.EdmType is ComplexType && p.DeclaringType == type); } public IEnumerable<EdmProperty> GetPropertiesWithDefaultValues(EntityType type) { return type.Properties.Where(p => p.TypeUsage.EdmType is SimpleType && p.DeclaringType == type && p.DefaultValue != null); } public IEnumerable<EdmProperty> GetPropertiesWithDefaultValues(ComplexType type) { return type.Properties.Where(p => p.TypeUsage.EdmType is SimpleType && p.DeclaringType == type && p.DefaultValue != null); } public IEnumerable<NavigationProperty> GetNavigationProperties(EntityType type) { return type.NavigationProperties.Where(np => np.DeclaringType == type); } public IEnumerable<NavigationProperty> GetCollectionNavigationProperties(EntityType type) { return type.NavigationProperties.Where(np => np.DeclaringType == type && np.ToEndMember.RelationshipMultiplicity == RelationshipMultiplicity.Many); } public FunctionParameter GetReturnParameter(EdmFunction edmFunction) { ArgumentNotNull(edmFunction, "edmFunction"); var returnParamsProperty = edmFunction.GetType().GetProperty("ReturnParameters"); return returnParamsProperty == null ? edmFunction.ReturnParameter : ((IEnumerable<FunctionParameter>)returnParamsProperty.GetValue(edmFunction, null)).FirstOrDefault(); } public bool IsComposable(EdmFunction edmFunction) { ArgumentNotNull(edmFunction, "edmFunction"); var isComposableProperty = edmFunction.GetType().GetProperty("IsComposableAttribute"); return isComposableProperty != null && (bool)isComposableProperty.GetValue(edmFunction, null); } public IEnumerable<FunctionImportParameter> GetParameters(EdmFunction edmFunction) { return FunctionImportParameter.Create(edmFunction.Parameters, _code, _ef); } public TypeUsage GetReturnType(EdmFunction edmFunction) { var returnParam = GetReturnParameter(edmFunction); return returnParam == null ? null : _ef.GetElementType(returnParam.TypeUsage); } public bool GenerateMergeOptionFunction(EdmFunction edmFunction, bool includeMergeOption) { var returnType = GetReturnType(edmFunction); return !includeMergeOption && returnType != null && returnType.EdmType.BuiltInTypeKind == BuiltInTypeKind.EntityType; } } public static void ArgumentNotNull<T>(T arg, string name) where T : class { if (arg == null) { throw new ArgumentNullException(name); } } #>
核心代碼解析：
foreach (var entity in typeMapper.GetItemsToGenerate<EntityType>(itemCollection)) { fileManager.StartNewFile("I"+entity.Name + "Repository.cs"); #> using Apps.Models; namespace Apps.IDAL { public partial interface I<#=entity.Name #>Repository:ICommonRepository<<#=entity.Name #>> { } <# EndNamespace(code); } fileManager.Process(); #>
循環生成。達到預期效果
TT模版里面太多代碼很難看懂，需要看官方幫助文檔才行。但是我們可以提取公共部分。以后寫TT就引入。看圖
在WriteHeder方法后都是通用的訪問代碼。我們提取之后的代碼。因為安裝了T4高亮。我只能調淺色，深色效果太差
在Apps.Models創建 Common.ttinclude來做公共部分（你可以創建在其他路徑，到時候是引入路徑為准）
最后修改：ICommonRepository.tt第二行代碼：
<#@ include file="../../Apps.Models/Common.ttinclude"#><#@
OK。看起來間接很多了，以后創建其他tt文件就可以直接引用公共部分，如果不提取tt模版也是沒有問題的。
同理我們創建DAL層的公共部分，生成后的代碼如下，同樣是一個分部類CommonRepository
<#@ template language="C#" debug="false" hostspecific="true"#> <#@ include file="../../Apps.Models/Common.ttinclude"#><#@ output extension=".cs"#> <# const string inputFile = @"../../Apps.Models/DB.edmx"; var textTransform = DynamicTextTransformation.Create(this); var code = new CodeGenerationTools(this); var ef = new MetadataTools(this); var typeMapper = new TypeMapper(code, ef, textTransform.Errors); var fileManager = EntityFrameworkTemplateFileManager.Create(this); var itemCollection = new EdmMetadataLoader(textTransform.Host, textTransform.Errors).CreateEdmItemCollection(inputFile); var codeStringGenerator = new CodeStringGenerator(code, typeMapper, ef); if (!typeMapper.VerifyCaseInsensitiveTypeUniqueness(typeMapper.GetAllGlobalItems(itemCollection), inputFile)) { return string.Empty; } WriteHeader(codeStringGenerator, fileManager); foreach (var entity in typeMapper.GetItemsToGenerate<EntityType>(itemCollection)) { fileManager.StartNewFile("I"+entity.Name + "Repository.cs"); #> using Apps.Models; using Apps.DAL; namespace Apps.IDAL { public partial class <#=entity.Name #>Repository:CommonRepository<<#=entity.Name #>> { public <#=entity.Name #>Repository(DBContainer db):base(db) { } } <# EndNamespace(code); } fileManager.Process(); #>
//------------------------------------------------------------------------------ // <auto-generated> // 此代碼已從模板生成。 // // 手動更改此文件可能導致應用程序出現意外的行為。 // 如果重新生成代碼，將覆蓋對此文件的手動更改。 // </auto-generated> //------------------------------------------------------------------------------ using Apps.Models; using Apps.DAL; namespace Apps.IDAL { public partial class SysSampleRepository:CommonRepository<SysSample> { public SysSampleRepository(DBContainer db):base(db) { } } }
接下來原來很長的ISysSampleRepository接口最后變成了一個分部接口
using Apps.Models; using System.Linq; namespace Apps.IDAL { public partial interface ISysSampleRepository { //處理通用部分外的業務 } }
SysSampleRepository變成了一個分部類
using System; using System.Linq; using Apps.IDAL; using Apps.Models; using System.Data; namespace Apps.DAL { public class SysSampleRepository {
//處理通用部分外的業務
} }
可以處理通用部分外的業務
這樣我們關注點真的很專注了。Ye...
關於業務層，肯定還是報錯的狀態，這時候我們就來修改一下
例如：
變為
最后業務層代碼：
//------------------------------------------------------------------------------ // <auto-generated> // 此代碼由T4模板自動生成 // 生成時間 2013-04-22 10:41:47 by App // 對此文件的更改可能會導致不正確的行為，並且如果 // 重新生成代碼，這些更改將會丟失。 // </auto-generated> //------------------------------------------------------------------------------ using System; using System.Collections.Generic; using System.Linq; using Microsoft.Practices.Unity; using Apps.Models; using Apps.Common; using System.Transactions; using Apps.Models.Sys; using Apps.IBLL; using Apps.IDAL; using Apps.BLL.Core; using Apps.Locale; namespace Apps.BLL { public class SysSampleBLL : BaseBLL, ISysSampleBLL { [Dependency] public ISysSampleRepository m_Rep { get; set; } public List<SysSampleModel> GetList(ref GridPager pager, string queryStr) { IQueryable<SysSample> queryData = null; if (!string.IsNullOrWhiteSpace(queryStr)) { queryData = m_Rep.GetList(a => a.Name.Contains(queryStr) || a.Note.Contains(queryStr)); } else { queryData = m_Rep.GetList(); } pager.totalRows = queryData.Count(); //排序 queryData = LinqHelper.SortingAndPaging(queryData, pager.sort, pager.order, pager.page, pager.rows); return CreateModelList(ref queryData); } private List<SysSampleModel> CreateModelList(ref IQueryable<SysSample> queryData) { List<SysSampleModel> modelList = (from r in queryData select new SysSampleModel { Id = r.Id, Name = r.Name, Age = r.Age, Bir = r.Bir, Photo = r.Photo, Note = r.Note, CreateTime = r.CreateTime, }).ToList(); return modelList; } public bool Create(ref ValidationErrors errors, SysSampleModel model) { try { SysSample entity = m_Rep.GetById(model.Id); if (entity != null) { errors.Add(Resource.PrimaryRepeat); return false; } entity = new SysSample(); entity.Id = model.Id; entity.Name = model.Name; entity.Age = model.Age; entity.Bir = model.Bir; entity.Photo = model.Photo; entity.Note = model.Note; entity.CreateTime = model.CreateTime; if (m_Rep.Create(entity)) { return true; } else { errors.Add(Resource.InsertFail); return false; } } catch (Exception ex) { errors.Add(ex.Message); ExceptionHander.WriteException(ex); return false; } } public bool Delete(ref ValidationErrors errors, string id) { try { if (m_Rep.Delete(id) == 1) { return true; } else { return false; } } catch (Exception ex) { errors.Add(ex.Message); ExceptionHander.WriteException(ex); return false; } } public bool Delete(ref ValidationErrors errors, string[] deleteCollection) { try { if (deleteCollection != null) { using (TransactionScope transactionScope = new TransactionScope()) { m_Rep.Delete(deleteCollection); if (db.SaveChanges() == deleteCollection.Length) { transactionScope.Complete(); return true; } else { Transaction.Current.Rollback(); return false; } } } return false; } catch (Exception ex) { errors.Add(ex.Message); ExceptionHander.WriteException(ex); return false; } } public bool Edit(ref ValidationErrors errors, SysSampleModel model) { try { SysSample entity = m_Rep.GetById(model.Id); if (entity == null) { errors.Add(Resource.Disable); return false; } entity.Name = model.Name; entity.Age = model.Age; entity.Bir = model.Bir; entity.Photo = model.Photo; entity.Note = model.Note; if (m_Rep.Edit(entity)) { return true; } else { errors.Add(Resource.EditFail); return false; } } catch (Exception ex) { errors.Add(ex.Message); ExceptionHander.WriteException(ex); return false; } } public bool IsExists(string id) { if (db.SysSample.SingleOrDefault(a => a.Id == id) != null) { return true; } return false; } public SysSampleModel GetById(string id) { if (IsExist(id)) { SysSample entity = m_Rep.GetById(id); SysSampleModel model = new SysSampleModel(); model.Id = entity.Id; model.Name = entity.Name; model.Age = entity.Age; model.Bir = entity.Bir; model.Photo = entity.Photo; model.Note = entity.Note; model.CreateTime = entity.CreateTime; return model; } else { return null; } } public bool IsExist(string id) { return m_Rep.IsExist(id); } } }
--------------------------------------------------------------------------------寫在最后--------------------------------------------------------------------------------
可以對比以前DAL層的代碼，明顯的減少很多（雖然業務層沒有減少）。也許在以后業務層也有必要的重構！
最后我完全修改了我項目的DAL層。用數據直接說話
整整少了兩萬行。卻完成了相同的功能。（代碼類型.cs，與事實可能有點差別，但是可以效果明顯）
代碼參考下載。重構后的架構（VS2013）執行根目錄下的script.sql腳本。並修改web.config數據庫鏈接即可查看
如查看重構前代碼可以到第一節下載17節代碼
https://yunpan.cn/cYUdjssbmiLrL 提取碼 e622
