经验总结

  1. 首页 > 生活 > >

EFCore分表实现

生活百科EFCore分表实现

实现原理当我们new一个上下文DbContext 后， 每次执行CURD方式时 ，都会依次调用OnConfiguring(),OnModelCreating()两个方法 。

  • OnConfiguring() 我们将用来替换一些服务实现，以支持分表的工作
  • OnModelCreating() 我们将用来重新实现 实体与数据库表 的映射关系
每次调用OnModelCreating()时，会判断实体与数据库表的映射关系有没有改变，如果改变则采用新的映射关系 。
【EFCore分表实现】判断是否发生改变，通过替换 IModelCacheKeyFactory接口的实现来完成 。详情可见：在具有相同 DbContext 类型的多个模型之间进行交替
IModelCacheKeyFactory 实现DbContextBase 是一个DbContext的实现,，ShardingRule是DbContextBase的一个共有属性 。根据分表规则的不同，每次的映射关系也会不同 。
public class DynamicModelCacheKeyFactoryDesignTimeSupport : IModelCacheKeyFactory {public object Create(DbContext context, bool designTime)=> context is DbContextBase dynamicContext? (context.GetType(), dynamicContext.ShardingRule, designTime): (object)context.GetType();public object Create(DbContext context)=> Create(context, false); }OnConfiguring() 替换接口实现
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder) {base.OnConfiguring(optionsBuilder);//如果分页规则有 ，代表需要分页， 那么需要替换对应的服务实现if (!string.IsNullOrEmpty(this.ShardingRule)){optionsBuilder.ReplaceService<IModelCacheKeyFactory, DynamicModelCacheKeyFactoryDesignTimeSupport>();} }ModelCustomizer 实现在每次调用 OnModelCreating() 时，方法内部会调用实现IModelCustomizer的 ModelCustomizer.cs的Customize()方法，我们可以将映射关系写在此方法内 。
通过继承实现：IShardingTypeFinder 是一个类型查找器，请自行实现 。
public class ShardingModelCustomizer : ModelCustomizer{public ShardingModelCustomizer(ModelCustomizerDependencies dependencies) : base(dependencies){}public override void Customize(ModelBuilder modelBuilder, DbContext context){base.Customize(modelBuilder, context);var dbContextBase = context as DbContextBase;var shardingTypeFinder = dbContextBase.ServiceProvider.GetService<IShardingTypeFinder>();//查找需要重新映射表名的类var shardingTypes = shardingTypeFinder.FindAll(true);if (shardingTypes != null && shardingTypes.Count() > 0){if (context is DbContextBase contextBase){if (!string.IsNullOrEmpty(contextBase.ShardingRule)){foreach (var type in shardingTypes){switch (contextBase.DbContextOptions.DatabaseType){case DatabaseType.SqlServer:modelBuilder.Entity(type).ToTable($"{type.Name}_{contextBase.ShardingRule}");break;case DatabaseType.Sqlite:modelBuilder.Entity(type).ToTable($"{type.Name}_{contextBase.ShardingRule}");break;case DatabaseType.MySql:modelBuilder.Entity(type).ToTable($"{type.Name}_{contextBase.ShardingRule}".ToMySQLName());break;case DatabaseType.Oracle:modelBuilder.Entity(type).ToTable($"{type.Name}_{contextBase.ShardingRule}".ToOracleName());break;default:modelBuilder.Entity(type).ToTable($"{type.Name}_{contextBase.ShardingRule}");break;}}}}}}}OnConfiguring() 替换接口实现
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder){base.OnConfiguring(optionsBuilder);//如果分页规则有 ，代表需要分页， 那么需要替换对应的服务实现if (!string.IsNullOrEmpty(this.ShardingRule)){optionsBuilder.ReplaceService<IModelCacheKeyFactory, DynamicModelCacheKeyFactoryDesignTimeSupport>().ReplaceService<IModelCustomizer, ShardingModelCustomizer>();}}DbContextBase

经验总结扩展阅读


上一篇：微信解封不用好友辅助

下一篇：网络图的构成要素有哪些