文章摘要
这篇文章详细讲解了如何优雅地使用EFCore框架进行ORM操作，避免重复编写数据库类型（DBSet），并展示了如何构建高效的仓库接口以支持微服务架构。以下是文章的总结：
### 项目概述
- **项目结构**：使用了一个控制台项目，主程序启动一个Web服务和Swagger文档页面。
- **数据库**：使用本地Mysql数据库，框架支持开发和生产环境的配置。
### 实体继承与反射机制
- **统一接口**：创建了IEFEntity接口及其实现类AggregateRoot，实现了主键字段。
- **动态注册**：通过EFEntityInfo类获取所有实体类，并在OnModelCreating方法中注册到DBContext，实现自动注册，无需手动编写DBSet。
### 表配置与优雅设计
- **表配置**：使用IEntityConfiguration接口及其实现类，如UserConfig和BookConfig，将表的属性（如最大字段长度、索引、唯一键等）统一配置。
- **优雅性**：通过类方法和注解，将表的配置集中管理，避免代码耦合。
### 仓库接口与微服务支持
- **接口定义**：引入了IAsyncRepository和GenericRepository接口，实现了统一的查询功能。
- **模块注入**：通过EFCoreEleganceUseDomainModule和EFCoreEleganceUseEFCoreModule，将仓库模块注入到项目中，支持微服务架构。
- **微服务架构**：项目结构支持多个微服务，每个服务启动一个Web服务，便于扩展和管理。
### 其他功能
- **调试与日志**：开发环境启用日志记录和错误详细显示，便于调试。
- **代码库**：提供的代码库（https://github.com/BruceQiu1996/EFCoreDemo）展示了项目的完整实现，供参考。
### 总结
文章通过实际示例展示了如何利用EFCore和反射机制简化ORM操作，构建优雅的仓库接口，支持微服务架构。内容适合希望深入理解EFCore高级功能的开发者。
目录正文DBSet清除计划IEntityTypeConfiguration(表配置)Repository(仓储)Autofac数据库配置项目架构和源码
EFCore是微软官方的一款ORM框架，主要是用于实体和数据库对象之间的操作。功能非常强大，在老版本的时候叫做EF，后来.net core问世，EFCore也随之问世。
本文我们将用一个控制台项目Host一个web服务，并且使用本地Mysql作为数据库，使用EFCore的Code First模式进行数据操作。
以前使用EF/EFCore的开发者应该都记得，需要在DBContext里写好多DBSet，一个表对应一个DBSet，然后在其他地方操作这些DBSet对相关的表进行增删改查。作为一个开发，这些重复操作都是我们希望避免的，我们可以利用反射机制将这些类型通过框架自带的方法循环注册进去。
1.EF实体继承统一的接口，方便我们反射获取所有EF实体，接口可以设置一个泛型，来泛化我们的主键类型，因为可能存在不同的表的主键类型也不一样。
统一的EF实体接口
public interface IEFEntity<TKey>
{
public TKey Id { get; set; }
}
统一的接口实现类
public abstract class AggregateRoot<TKey> : IEFEntity<TKey>
{
public TKey Id { get; set; }
}
用户实体类
public class User : AggregateRoot<string>
{
public string UserName { get; set; }
public DateTime Birthday { get; set; }
public virtual ICollection<Book> Books { get; set; }
}
2.利用反射获取某个程序集下所有的实体类
public class EFEntityInfo
{
public (Assembly Assembly, IEnumerable<Type> Types) EFEntitiesInfo=> (GetType().Assembly, GetEntityTypes(GetType().Assembly));
private IEnumerable<Type> GetEntityTypes(Assembly assembly)
{
//获取当前程序集下所有的实现了IEFEntity的实体类
var efEntities=assembly.GetTypes().Where(m=> m.FullName !=null
&& Array.Exists(m.GetInterfaces(), t=> t.IsGenericType && t.GetGenericTypeDefinition()==typeof(IEFEntity<>))
&& !m.IsAbstract && !m.IsInterface).ToArray();
return efEntities;
}
}
3.DBContext实现类中OnModelCreating方法中注册这些类型
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
//循环实体类型，并且通过Entity方法注册类型
foreach (var entityType in Types)
{
modelBuilder.Entity(entityType);
}
base.OnModelCreating(modelBuilder);
}
至此为止所有的实体类都被注册到DBContext中作为DBSets,再也不需要一个个写DBSet了，可以用过DbContext.Set<User>()获取用户的DBSet。
用数据库创建过表的同学都知道，在设计表的时候，可以给表添加很多配置和约束，在Code First模式中，很多同学都是在对象中通过注解的方式配置字段。如下就配置了用户名是不能为NULL和最大长度为500
[Required]
[MaxLength(500)]
public string UserName { get; set; }
也有的同学在DbContext中的OnModelCreating方法配置
modelBuilder.Entity<User>().Property(x=> x.UserName).IsRequired();
这两种方法，前者入侵行太强，直接代码耦合到实体类中了，后者不够清楚，把一大堆表的配置写在一个方法里，当然了很多人说可以拆分不同的方法或者使用注释分开。但是！不够优雅！
我们可以使用IEntityTypeConfiguration接口实现我们所想的优雅的表配置。
1.创建一个配置基类，继承自IEntityTypeConfiguration，做一些通用的配置，比如设置主键，一般都是id啦，还有软删除等。public abstract class EntityTypeConfiguration<TEntity, TKey> : IEntityTypeConfiguration<TEntity>
where TEntity : AggregateRoot<TKey>
{
public virtual void Configure(EntityTypeBuilder<TEntity> builder)
{
var entityType=typeof(TEntity);
builder.HasKey(x=> x.Id);
if (typeof(ISoftDelete).IsAssignableFrom(entityType))
{
builder.HasQueryFilter(d=> EF.Property<bool>(d, “IsDeleted”)==false);
}
}
}
2.创建用户实体/表独有的配置，比如设置用户名的最大长度，以及seed一些数据
public class UserConfig : EntityTypeConfiguration<User, string>
{
public override void Configure(EntityTypeBuilder<User> builder)
{
base.Configure(builder);
builder.Property(x=> x.UserName).HasMaxLength(50);
//mock一条数据
builder.HasData(new User()
{
Id=”090213204″,
UserName=”Bruce”,
Birthday=DateTime.Parse(“1996-08-24”)
});
}
}
当然还有很多配置可以设置，比如索引，导航属性，唯一键等。如下图书实体
public class BookConfig : EntityTypeConfiguration<Book, long>
{
public override void Configure(EntityTypeBuilder<Book> builder)
{
base.Configure(builder);
builder.Property(x=> x.Id).ValueGeneratedOnAdd(); //设置book的id自增
builder.Property(x=> x.BookName).HasMaxLength(500).IsRequired();
builder.HasIndex(x=> x.Author);//作者添加索引
builder.HasIndex(x=> x.SN).IsUnique();//序列号添加唯一索引
builder.HasOne(r=> r.User).WithMany(x=>x.Books)
.HasForeignKey(r=> r.UserId).IsRequired();//导航属性，本质就是创建外键，虽然查询很方便，生产中不建议使用！！！
}
}
3.DBContext中应用配置
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
modelBuilder.HasCharSet(“utf8mb4 “);
var (Assembly, Types)=_efEntitysInfo.EFEntitiesInfo;
foreach (var entityType in Types)
{
modelBuilder.Entity(entityType);
}
//只需要将配置类所在的程序集给到，它会自动加载
modelBuilder.ApplyConfigurationsFromAssembly(Assembly);
base.OnModelCreating(modelBuilder);
}
这个不过分介绍，特别是基于http的微服务中基本都有这个。
1.创建一个仓储基类，对于不同的实体，创建一样的增删改查方法。
简单写几个查询的方法定义。
public interface IAsyncRepository<TEntity, Tkey> where TEntity : class
{
IQueryable<TEntity> All();
IQueryable<TEntity> All(string[] propertiesToInclude);
IQueryable<TEntity> Where(Expression<Func<TEntity, bool>> filter);
IQueryable<TEntity> Where(Expression<Func<TEntity, bool>> filter, string[] propertiesToInclude);
}
2.创建仓储实现类，将DBContext注入到构造中
public class GenericRepository<TEntity, Tkey> : IAsyncRepository<TEntity, Tkey> where TEntity : class
{
protected readonly LibraryDbContext _dbContext;
public GenericRepository(LibraryDbContext dbContext)
{
_dbContext=dbContext;
}
~GenericRepository()
{
_dbContext?.Dispose();
}
public virtual IQueryable<TEntity> All()
{
return All(null);
}
public virtual IQueryable<TEntity> All(string[] propertiesToInclude)
{
var query=_dbContext.Set<TEntity>().AsNoTracking();
if (propertiesToInclude !=null)
{
foreach (var property in propertiesToInclude.Where(p=> !string.IsNullOrWhiteSpace(p)))
{
query=query.Include(property);
}
}
return query;
}
}
1.注入DBContext到Repository的构造方法中，并且注入Repository
public class EFCoreEleganceUseEFCoreModule : Module
{
protected override void Load(ContainerBuilder builder)
{
base.Load(builder);
builder.RegisterModule<EFCoreEleganceUseDomainModule>(); //注入domain模块
builder.RegisterGeneric(typeof(GenericRepository<,>))//将dbcontext注入到仓储的构造中
.UsingConstructor(typeof(LibraryDbContext))
.AsImplementedInterfaces()
.InstancePerDependency();
builder.RegisterType<WorkUnit>().As<IWorkUnit>().InstancePerDependency();
}
}
2.Domain注入EFEntityInfo
public class EFCoreEleganceUseDomainModule : Module
{
protected override void Load(ContainerBuilder builder)
{
builder.RegisterType<EFEntityInfo>().SingleInstance();
}
}
1.注入DBContext，从配置文件读取数据库配置，然后根据开发/生产环境做一些特殊处理
var mysqlConfig=hostContext.Configuration.GetSection(“Mysql”).Get<MysqlOptions>();
var serverVersion=new MariaDbServerVersion(new Version(mysqlConfig.Version));
services.AddDbContextFactory<LibraryDbContext>(options=>
{
options.UseMySql(mysqlConfig.ConnectionString, serverVersion, optionsBuilder=>
{
optionsBuilder.MinBatchSize(4);
optionsBuilder.CommandTimeout(10);
optionsBuilder.MigrationsAssembly(mysqlConfig.MigrationAssembly);//迁移文件所在的程序集
optionsBuilder.UseQuerySplittingBehavior(QuerySplittingBehavior.SplitQuery);
}).UseQueryTrackingBehavior(QueryTrackingBehavior.NoTracking);
//开发环境可以打开日志记录和显示详细的错误
if (hostContext.HostingEnvironment.IsDevelopment())
{
options.EnableSensitiveDataLogging();
options.EnableDetailedErrors();
}
});
项目只是一个demo架构，并不适用于生产，主程序是一个控制台项目，只需要引用相关的包和模块，就可以启动一个web host.
全部代码已经全部上传到github:https://github.com/BruceQiu1996/EFCoreDemo该项目是一个可以启动运行的基于.net6的控制台项目，启动后会启动一个web host和一个swagger页面。
以上就是.net如何优雅的使用EFCore实例详解的详细内容，更多关于.net使用EFCore的资料请关注脚本之家其它相关文章！
您可能感兴趣的文章:.Net Core中使用EFCore生成反向工程ASP.NET Core WebSocket集群实现思路详解asp.net core 认证和授权实例详解ASP.NET?Core自定义中间件的方式详解ASP.NET?Core?6最小API中使用日志和DI示例详解ASP.NET?Core获取正确查询字符串参数示例