今天记录一下自己的EntityFramework数据访问层。这里用通过泛型Repository的方式实现了数据的访问。先上一张结构图。
Configuration文件夹里面的类是全部实体映射类。这些类全部继承至EntityConfigurationBase类。
EntityConfigurationBase又继承至 EntityTypeConfiguration类，这是EntityFramework的实体映射基类
using System.Data.Entity.ModelConfiguration;
using System.Data.Entity.ModelConfiguration.Configuration; using ZY.Core.Entities; namespace ZY.Repositories.EntityFramework
{
/// <summary>
/// 数据实体映射配置基类
/// </summary>
/// <typeparam name="TEntity"></typeparam>
/// <typeparam name="TKey"></typeparam>
public abstract class EntityConfigurationBase<TEntity, TKey> : EntityTypeConfiguration<TEntity>, IEntityMapper
where TEntity : class
{
//映射实体添加到数据上下文
public void RegistorTo(ConfigurationRegistrar configurations)
{
configurations.Add(this);
}
}
}
这里有个重要的方法就是RegistorTo(ConfigurationRegistrar configurations) 这个方法是将当前实体添加到数据上下文。这样不用在数据上下文写每一个实体的映射，将实体与上下文解耦出来了。在OnModelCreating(DbModelBuilder modelBuilder) 方法里面用到了反射，通过反射将所有实体映射关系添加到数据上下文中。这里可以优化一下就是，反射的时候可以用缓存。
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Data.Entity;
using System.Data.Entity.ModelConfiguration.Conventions;
using System.Reflection; namespace ZY.Repositories.EntityFramework
{
public class BaseDbContext : DbContext
{
public BaseDbContext()
: base("Default")
{ } public BaseDbContext(string connectionString)
:base(connectionString)
{ } protected override void OnModelCreating(DbModelBuilder modelBuilder)
{
//关闭级联删除
modelBuilder.Conventions.Remove<OneToManyCascadeDeleteConvention>();
//获取所有映射实体类
IEnumerable<IEntityMapper> entityMappers = GetEntityMappers().Select(type => Activator.CreateInstance(type) as IEntityMapper).ToList(); foreach (IEntityMapper mapper in entityMappers)
{
mapper.RegistorTo(modelBuilder.Configurations);
}
} /// <summary>
/// 通过反射 获取所有实体映射对象 优化的做法是保存在缓存中
/// </summary>
/// <returns></returns>
private Type[] GetEntityMappers()
{
Type[] mapperTypes = Assembly.GetExecutingAssembly().GetTypes()
.Where(type => !String.IsNullOrEmpty(type.Namespace))
.Where(type => type.BaseType != null && type.BaseType.IsGenericType &&
type.BaseType.GetInterface(typeof(IEntityMapper).Name) == typeof(IEntityMapper)).ToArray();
return mapperTypes;
}
}
}
数据迁移用了自动迁移，之前刚刚开始用EF的时候没有用自动迁移，遇到了很多坑，自从用了自动迁移，就没有管过迁移的事情了。
using System.Data.Entity.Migrations; namespace ZY.Repositories.EntityFramework.Migrations
{
/// <summary>
/// 自动迁移设置
/// </summary>
public class AutoMigrationsConfiguration : DbMigrationsConfiguration<BaseDbContext>
{
public AutoMigrationsConfiguration()
{
AutomaticMigrationsEnabled = true;//自动迁移
AutomaticMigrationDataLossAllowed = true;//允许数据丢失
}
}
}
Repository的代码在上一篇中已经贴出来了。实现了异步和同步的方法。
后续会将整个代码放到github上面