在Saas系统下多租户零脚本分表分库读写分离解决方案

　　前言
　　您是否有以下场景：多租户系统，数据库级别隔离大数据量，需要分表分库（动态添加），分库分表全自动维护处理租户之前可能需要使用不同的数据库模式，譬如有些租户要求用oracle，或者mmsql，或者mysql或者pgsql多租户系统在不同的数据库环境下需要维护的表结构复杂繁琐，需要维护许多脚本业务代码需要进行大范围的妥协来适应上述支持系统需要支持读写分离（动态添加）无需停机状态实时添加租户（租户线上签约）
　　当然我是一开始想先写这篇文章，但是写着写着发现有些时候这个问题就来了，譬如多数据库下efcore默认不支持迁移，经过不断地努力，大脑的思维宫殿我下意识就发现了解决方案，最终用一天时间解决了就是前面的一篇文章EFCore高级Saas系统下单DbContext如何支持不同数据库的迁移那么我们话不多说马上开始
　　接下来我们将实现A，B，C三个租户，其中A租户我们使用MSSQL的订单表使用按月分表，B租户我们使用MYSQL的订单表我们采用Id取模分表，C租户我们使用MSSQL也是使用订单按月分表但是起始时间和A不一样管理租户数据
　　首先我们新建一个DbContext用来管理我们的租户信息租户用户表
　　首先我们新建一张租户登录的用户表，每个用户就是我们对外的租户publicclassSysUser｛publicstringId｛get；set；｝publicstringName｛get；set；｝publicstringPassword｛get；set；｝publicDateTimeCreationTime｛get；set；｝publicboolIsDeleted｛get；set；｝｝租户配置表
　　然后我们新建一张租户的配置信息表用来后续初始化配置publicclassSysUserTenantConfig｛publicstringId｛get；set；｝publicstringUserId｛get；set；｝summary添加ShardingTenantOptions的Json包summarypublicstringConfigJson｛get；set；｝publicDateTimeCreationTime｛get；set；｝publicboolIsDeleted｛get；set；｝｝定义租户配置为了满足上述需求我们需要对数据库和订单分片方式进行区分publicclassShardingTenantOptions｛summary默认数据源名称summarypublicstringDefaultDataSourceName｛get；set；｝summary默认数据库地址summarypublicstringDefaultConnectionString｛get；set；｝summary数据库类型summarypublicDbTypeEnumDbType｛get；set；｝summary分片模式取模还是按月summarypublicOrderShardingTypeEnumOrderShardingType｛get；set；｝summary按月分片其实时间summarypublicDateTimeBeginTimeForSharding｛get；set；｝summary分片迁移的命名空间summarypublicstringMigrationNamespace｛get；set；｝｝publicenumDbTypeEnum｛MSSQL1，MYSQL2｝publicenumOrderShardingTypeEnum｛Mod1，ByMonth2｝租户持久化DbContext
　　新建一个dbcontext用来存储我们的租户信息，当然你也可以使用文件或者redis之类的都行publicclassIdentityDbContext：DbContext｛publicIdentityDbContext（DbContextOptionsIdentityDbContextoptions）：base（options）｛｝protectedoverridevoidOnModelCreating（ModelBuildermodelBuilder）｛base。OnModelCreating（modelBuilder）；modelBuilder。ApplyConfiguration（newSysUserMap（））；modelBuilder。ApplyConfiguration（newSysUserTenantConfigMap（））；｝｝
　　这样我们就完成了租户信息的存储租户管理者
　　我们拥有了租户信息持久化的数据后需要对租户信息的使用进行配置
　　首先我们新建一个接口可以用来管理租户信息publicinterfaceITenantManager｛summary获取所有的租户summaryreturnsreturnsListstringGetAll（）；summary获取当前租户summaryreturnsreturnsTenantContextGetCurrentTenantContext（）；summary添加租户信息summaryparamnametenantIdparamparamnameshardingRuntimeContextparamreturnsreturnsboolAddTenantSharding（stringtenantId，IShardingRuntimeContextshardingRuntimeContext）；summary创建租户环境summaryparamnametenantIdparamreturnsreturnsTenantScopeCreateScope（stringtenantId）；｝租户的默认管理实现publicclassDefaultTenantManager：ITenantManager｛privatereadonlyITenantContextAccessortenantContextAccessor；privatereadonlyConcurrentDictionarystring，IShardingRuntimeContextcachenew（）；publicDefaultTenantManager（ITenantContextAccessortenantContextAccessor）｛tenantContextAccessortenantContextAccessor；｝publicListstringGetAll（）｛returncache。Keys。ToList（）；｝publicTenantContextGetCurrentTenantContext（）｛returntenantContextAccessor。TenantContext；｝publicboolAddTenantSharding（stringtenantId，IShardingRuntimeContextshardingRuntimeContext）｛returncache。TryAdd（tenantId，shardingRuntimeContext）；｝publicTenantScopeCreateScope（stringtenantId）｛if（！cache。TryGetValue（tenantId，outvarshardingRuntimeContext））｛thrownewInvalidOperationException（未找到对应租户的配置）；｝tenantContextAccessor。TenantContextnewTenantContext（shardingRuntimeContext）；returnnewTenantScope（tenantContextAccessor）；｝｝当前租户上下文访问者publicinterfaceITenantContextAccessor｛TenantContext？TenantContext｛get；set；｝｝当前租户上下文访问者实现publicclassTenantContextAccessor：ITenantContextAccessor｛privatestaticreadonlyAsyncLocalTenantContext？tenantContextnewAsyncLocalTenantContext？（）；publicTenantContext？TenantContext｛gettenantContext。Value；settenantContext。Valuevalue；｝｝租户上下文publicclassTenantContext｛privatereadonlyIShardingRuntimeContextshardingRuntimeContext；publicTenantContext（IShardingRuntimeContextshardingRuntimeContext）｛shardingRuntimeContextshardingRuntimeContext；｝publicIShardingRuntimeContextGetShardingRuntimeContext（）｛returnshardingRuntimeContext；｝｝用来切换实现当前操作租户环境publicclassTenantScope：IDisposable｛publicTenantScope（ITenantContextAccessortenantContextAccessor）｛TenantContextAccessortenantContextAccessor；｝publicITenantContextAccessorTenantContextAccessor｛get；｝publicvoidDispose（）｛｝｝折叠构思ShardingCore如何不通过依赖注入使用
　　其实ShardingCore可以默认不在依赖注入中进行依赖注入，首先我们看下普通情况下ShardingCore如何实现非依赖注入获取分片上下文varshardingRuntimeContextnewShardingRuntimeBuilderDefaultShardingDbContext（）。UseRouteConfig（o｛o。AddShardingTableRouteSysUserTableRoute（）；｝）。UseConfig（o｛o。ThrowIfQueryRouteNotMatchfalse；o。UseShardingQuery（（conStr，builder）｛builder。UseMySql（conStr，newMySqlServerVersion（newVersion（）））。UseLoggerFactory（efLogger）。UseQueryTrackingBehavior（QueryTrackingBehavior。NoTracking）；｝）；o。UseShardingTransaction（（connection，builder）｛builder。UseMySql（connection，newMySqlServerVersion（newVersion（）））。UseLoggerFactory（efLogger）。UseQueryTrackingBehavior（QueryTrackingBehavior。NoTracking）；｝）；o。AddDefaultDataSource（ds0，server127。0。0。1；port3306；databasedbdbd0；useridroot；passwordroot；）；o。UseShardingMigrationConfigure（b｛b。ReplaceServiceIMigrationsSqlGenerator，ShardingMySqlMigrationsSqlGenerator（）；｝）；｝）。ReplaceServiceITableEnsureManager，MySqlTableEnsureManager（ServiceLifetime。Singleton）。Build（）；
　　这样我们就获得了IShardingRuntimeContext，将不同的IShardingRuntimeContext放到不同的数据库中我们就可以实现不同的租户了订单表publicclassOrder｛publicstringId｛get；set；｝publicstringName｛get；set；｝publicDateTimeCreationTime｛get；set；｝publicboolIsDeleted｛get；set；｝｝租户DbContextpublicclassTenantDbContext：AbstractShardingDbContext，IShardingTableDbContext｛publicTenantDbContext（DbContextOptionsTenantDbContextoptions）：base（options）｛｝protectedoverridevoidOnModelCreating（ModelBuildermodelBuilder）｛base。OnModelCreating（modelBuilder）；modelBuilder。ApplyConfiguration（newOrderMap（））；｝publicIRouteTailRouteTail｛get；set；｝｝创建订单路由订单按月分片路由
　　注意这边我们简单的通过采用一个静态字段来实现publicclassOrderMonthTableRoute：AbstractSimpleShardingMonthKeyDateTimeVirtualTableRouteOrder｛privatereadonlyShardingTenantOptionsshardingTenantOptions；publicOrderMonthTableRoute（ShardingTenantOptionsshardingTenantOptions）｛shardingTenantOptionsshardingTenantOptions；｝publicoverridevoidConfigure（EntityMetadataTableBuilderOrderbuilder）｛builder。ShardingProperty（oo。CreationTime）；｝publicoverrideboolAutoCreateTableByTime（）｛returntrue；｝publicoverrideDateTimeGetBeginTime（）｛returnshardingTenantOptions。BeginTimeForSharding；｝｝订单取模分片路由publicclassOrderModTableRoute：AbstractSimpleShardingModKeyStringVirtualTableRouteOrder｛privatereadonlyShardingTenantOptionsshardingTenantOptions；publicOrderModTableRoute（ShardingTenantOptionsshardingTenantOptions）：base（2，5）｛shardingTenantOptionsshardingTenantOptions；｝publicoverridevoidConfigure（EntityMetadataTableBuilderOrderbuilder）｛builder。ShardingProperty（oo。Id）；｝｝实现多数据库的codefirst迁移
　　具体参考之前的博客EFCore高级Saas系统下单DbContext如何支持不同数据库的迁移
　　https：www。cnblogs。comxuejiamingp16510482。html分片创建者publicinterfaceIShardingBuilder｛IShardingRuntimeContextBuild（ShardingTenantOptionstenantOptions）；｝publicclassDefaultShardingBuilder：IShardingBuilder｛publicstaticreadonlyILoggerFactoryefLoggerLoggerFactory。Create（builder｛builder。AddFilter（（category，level）categoryDbLoggerCategory。Database。Command。NamelevelLogLevel。Information）。AddConsole（）；｝）；privatereadonlyIServiceProviderserviceProvider；publicDefaultShardingBuilder（IServiceProviderserviceProvider）｛serviceProviderserviceProvider；｝publicIShardingRuntimeContextBuild（ShardingTenantOptionstenantOptions）｛varshardingRuntimeBuildernewShardingRuntimeBuilderTenantDbContext（）。UseRouteConfig（o｛if（tenantOptions。OrderShardingTypeOrderShardingTypeEnum。Mod）｛o。AddShardingTableRouteOrderModTableRoute（）；｝if（tenantOptions。OrderShardingTypeOrderShardingTypeEnum。ByMonth）｛o。AddShardingTableRouteOrderMonthTableRoute（）；｝｝）。UseConfig（o｛o。ThrowIfQueryRouteNotMatchfalse；o。UseShardingQuery（（conStr，builder）｛if（tenantOptions。DbTypeDbTypeEnum。MYSQL）｛builder。UseMySql（conStr，newMySqlServerVersion（newVersion（）））。UseMigrationNamespace（newMySqlMigrationNamespace（））；｝if（tenantOptions。DbTypeDbTypeEnum。MSSQL）｛builder。UseSqlServer（conStr）。UseMigrationNamespace（newSqlServerMigrationNamespace（））；｝builder。UseLoggerFactory（efLogger）。UseQueryTrackingBehavior（QueryTrackingBehavior。NoTracking）。ReplaceServiceIMigrationsAssembly，MultiDatabaseMigrationsAssembly（）；｝）；o。UseShardingTransaction（（connection，builder）｛if（tenantOptions。DbTypeDbTypeEnum。MYSQL）｛builder。UseMySql（connection，newMySqlServerVersion（newVersion（）））；。UseMigrationNamespace（newMySqlMigrationNamespace（））；迁移只会用connectionstring创建所以可以不加｝if（tenantOptions。DbTypeDbTypeEnum。MSSQL）｛builder。UseSqlServer（connection）；。UseMigrationNamespace（newSqlServerMigrationNamespace（））；｝builder。UseLoggerFactory（efLogger）。UseQueryTrackingBehavior（QueryTrackingBehavior。NoTracking）；｝）；o。AddDefaultDataSource（tenantOptions。DefaultDataSourceName，tenantOptions。DefaultConnectionString）；注意这个迁移必须要十分重要注意这个迁移必须要十分重要注意这个迁移必须要十分重要注意这个迁移必须要十分重要o。UseShardingMigrationConfigure（b｛if（tenantOptions。DbTypeDbTypeEnum。MYSQL）｛b。ReplaceServiceIMigrationsSqlGenerator，ShardingMySqlMigrationsSqlGenerator（）；｝if（tenantOptions。DbTypeDbTypeEnum。MSSQL）｛b。ReplaceServiceIMigrationsSqlGenerator，ShardingSqlServerMigrationsSqlGenerator（）；｝｝）；｝）。AddServiceConfigure（s｛IShardingRuntimeContext内部的依赖注入s。AddSingleton（tenantOptions）；｝）；if（tenantOptions。DbTypeDbTypeEnum。MYSQL）｛shardingRuntimeBuilder。ReplaceServiceITableEnsureManager，MySqlTableEnsureManager（ServiceLifetime。Singleton）；｝if（tenantOptions。DbTypeDbTypeEnum。MSSQL）｛shardingRuntimeBuilder。ReplaceServiceITableEnsureManager，SqlServerTableEnsureManager（ServiceLifetime。Singleton）；｝returnshardingRuntimeBuilder。Build（serviceProvider）；｝｝折叠
　　到此为止基本上我们已经完成了多租户的大部分配置了，jwt部分就不在这边赘述了因为之前有实现过Startup
　　主要关键的启动点我们应该怎么配置呢启动初始化租户
　　首先我们需要针对程序启动后进行租户的初始化操作publicstaticclassTenantExtension｛publicstaticvoidInitTenant（thisIServiceProviderserviceProvider）｛vartenantManagerserviceProvider。GetRequiredServiceITenantManager（）；varshardingBuilderserviceProvider。GetRequiredServiceIShardingBuilder（）；using（varscopeserviceProvider。CreateScope（））｛varidentityDbContextscope。ServiceProvider。GetRequiredServiceIdentityDbContext（）；identityDbContext。Database。Migrate（）；varsysUserTenantConfigsidentityDbContext。SetSysUserTenantConfig（）。ToList（）；if（sysUserTenantConfigs。Any（））｛foreach（varsysUserTenantConfiginsysUserTenantConfigs）｛varshardingTenantOptionsJsonConvert。DeserializeObjectShardingTenantOptions（sysUserTenantConfig。ConfigJson）；varshardingRuntimeContextshardingBuilder。Build（shardingTenantOptions）；tenantManager。AddTenantSharding（sysUserTenantConfig。UserId，shardingRuntimeContext）；｝｝｝vartenantIdstenantManager。GetAll（）；foreach（vartenantIdintenantIds）｛using（tenantManager。CreateScope（tenantId））using（varscopeserviceProvider。CreateScope（））｛varshardingRuntimeContexttenantManager。GetCurrentTenantContext（）。GetShardingRuntimeContext（）；开启定时任务shardingRuntimeContext。UseAutoShardingCreate（）；vartenantDbContextscope。ServiceProvider。GetServiceTenantDbContext（）；tenantDbContext。Database。Migrate（）；补偿表shardingRuntimeContext。UseAutoTryCompensateTable（）；｝｝｝｝请求租户中间件
　　为了让我们的所有请求都可以使用指定对应的租户数据库publicclassTenantSelectMiddleware｛privatereadonlyRequestDelegatenext；privatereadonlyITenantManagertenantManager；publicTenantSelectMiddleware（RequestDelegatenext，ITenantManagertenantManager）｛nextnext；tenantManagertenantManager；｝summary1。中间件的方法必须叫Invoke，且为public，非static。2。Invoke方法第一个参数必须是HttpContext类型。3。Invoke方法必须返回Task。4。Invoke方法可以有多个参数，除HttpContext外其它参数会尝试从依赖注入容器中获取。5。Invoke方法不能有重载。summaryAuthor：NapoleonCreated：202013021：30publicasyncTaskInvoke（HttpContextcontext）｛if（context。Request。Path。ToString（）。StartsWith（apitenant，StringComparison。CurrentCultureIgnoreCase））｛if（！context。User。Identity。IsAuthenticated）｛awaitnext（context）；return；｝vartenantIdcontext。User。Claims。FirstOrDefault（（o）o。Typeuid）？。Value；if（string。IsNullOrWhiteSpace（tenantId））｛awaitDoUnAuthorized（context，notfoundtenantid）；return；｝using（tenantManager。CreateScope（tenantId））｛awaitnext（context）；｝｝else｛awaitnext（context）；｝｝privateasyncTaskDoUnAuthorized（HttpContextcontext，stringmsg）｛context。Response。StatusCode403；awaitcontext。Response。WriteAsync（msg）；｝｝折叠编写登录注册操作
　　startup处配置〔Route（api〔controller〕〔action〕）〕〔ApiController〕〔AllowAnonymous〕publicclassPassportController：ControllerBase｛privatereadonlyIServiceProviderserviceProvider；privatereadonlyIdentityDbContextidentityDbContext；privatereadonlyITenantManagertenantManager；privatereadonlyIShardingBuildershardingBuilder；publicPassportController（IServiceProviderserviceProvider，IdentityDbContextidentityDbContext，ITenantManagertenantManager，IShardingBuildershardingBuilder）｛serviceProviderserviceProvider；identityDbContextidentityDbContext；tenantManagertenantManager；shardingBuildershardingBuilder；｝〔HttpPost〕publicasyncTaskIActionResultRegister（RegisterRequestrequest）｛if（awaitidentityDbContext。SetSysUser（）。AnyAsync（oo。Namerequest。Name））returnBadRequest（usernotexists）；varsysUsernewSysUser（）｛IdGuid。NewGuid（）。ToString（n），Namerequest。Name，Passwordrequest。Password，CreationTimeDateTime。Now｝；varshardingTenantOptionsnewShardingTenantOptions（）｛DbTyperequest。DbType，OrderShardingTyperequest。OrderShardingType，BeginTimeForShardingrequest。BeginTimeForSharding。Value，DefaultDataSourceNameds0，DefaultConnectionStringGetDefaultString（request。DbType，sysUser。Id）｝；varsysUserTenantConfignewSysUserTenantConfig（）｛IdGuid。NewGuid（）。ToString（n），UserIdsysUser。Id，CreationTimeDateTime。Now，ConfigJsonJsonConvert。SerializeObject（shardingTenantOptions）｝；awaitidentityDbContext。AddAsync（sysUser）；awaitidentityDbContext。AddAsync（sysUserTenantConfig）；awaitidentityDbContext。SaveChangesAsync（）；varshardingRuntimeContextshardingBuilder。Build（shardingTenantOptions）；tenantManager。AddTenantSharding（sysUser。Id，shardingRuntimeContext）；using（tenantManager。CreateScope（sysUser。Id））using（varscopeserviceProvider。CreateScope（））｛varruntimeContexttenantManager。GetCurrentTenantContext（）。GetShardingRuntimeContext（）；runtimeContext。UseAutoShardingCreate（）；启动定时任务vartenantDbContextscope。ServiceProvider。GetServiceTenantDbContext（）；tenantDbContext。Database。Migrate（）；runtimeContext。UseAutoTryCompensateTable（）；｝returnOk（）；｝〔HttpPost〕publicasyncTaskIActionResultLogin（LoginRequestrequest）｛varsysUserawaitidentityDbContext。SetSysUser（）。FirstOrDefaultAsync（oo。Namerequest。Nameo。Passwordrequest。Password）；if（sysUsernull）returnBadRequest（nameorpassworderror）；秘钥，就是标头，这里用Hmacsha256算法，需要256bit的密钥varsecurityKeynewSigningCredentials（newSymmetricSecurityKey（Encoding。ASCII。GetBytes（123123！！123123）），SecurityAlgorithms。HmacSha256）；Claim，JwtRegisteredClaimNames中预定义了好多种默认的参数名，也可以像下面的Guid一样自己定义键名。ClaimTypes也预定义了好多类型如role、email、name。Role用于赋予权限，不同的角色可以访问不同的接口相当于有效载荷varclaimsnewClaim〔〕｛newClaim（JwtRegisteredClaimNames。Iss，https：localhost：5000），newClaim（JwtRegisteredClaimNames。Aud，api），newClaim（id，Guid。NewGuid（）。ToString（n）），newClaim（uid，sysUser。Id），｝；SecurityTokensecurityTokennewJwtSecurityToken（signingCredentials：securityKey，expires：DateTime。Now。AddHours（2），过期时间claims：claims）；vartokennewJwtSecurityTokenHandler（）。WriteToken（securityToken）；returnOk（token）；｝privatestringGetDefaultString（DbTypeEnumdbType，stringuserId）｛switch（dbType）｛caseDbTypeEnum。MSSQL：return34；DataSourcelocalhost；InitialCatalogDB｛userId｝；IntegratedSecurityTrue；；caseDbTypeEnum。MYSQL：return34；server127。0。0。1；port3306；databaseDB｛userId｝；useridroot；passwordL6yBtV6qNENrwBy7；；default：thrownewNotImplementedException（）；｝｝｝publicclassRegisterRequest｛publicstringName｛get；set；｝publicstringPassword｛get；set；｝publicDbTypeEnumDbType｛get；set；｝publicOrderShardingTypeEnumOrderShardingType｛get；set；｝publicDateTime？BeginTimeForSharding｛get；set；｝｝publicclassLoginRequest｛publicstringName｛get；set；｝publicstringPassword｛get；set；｝｝折叠启动配置varbuilderWebApplication。CreateBuilder（args）；Addservicestothecontainer。builder。Services。AddControllers（）；builder。Services。AddAuthentication（）；region用户系统配置builder。Services。AddDbContextIdentityDbContext（oo。UseSqlServer（DataSourcelocalhost；InitialCatalogIdDb；IntegratedSecurityTrue；））；生成密钥varkeyByteArrayEncoding。ASCII。GetBytes（123123！！123123）；varsigningKeynewSymmetricSecurityKey（keyByteArray）；认证参数builder。Services。AddAuthentication（Bearer）。AddJwtBearer（o｛o。TokenValidationParametersnewTokenValidationParameters｛ValidateIssuerSigningKeytrue，IssuerSigningKeysigningKey，ValidateIssuertrue，ValidIssuerhttps：localhost：5000，ValidateAudiencetrue，ValidAudienceapi，ValidateLifetimetrue，ClockSkewTimeSpan。Zero，RequireExpirationTimetrue，｝；｝）；endregionbuilder。Services。AddSingletonITenantManager，DefaultTenantManager（）；builder。Services。AddSingletonITenantContextAccessor，TenantContextAccessor（）；builder。Services。AddSingletonIShardingBuilder，DefaultShardingBuilder（）；region配置ShardingCorevarproviderbuilder。Configuration。GetValue（Provider，UnKnown）；AddMigrationInitialCreateContextTenantDbContextOutputDirMigrationsSqlServerArgsproviderSqlServerAddMigrationInitialCreateContextTenantDbContextOutputDirMigrationsMySqlArgsproviderMySqlbuilder。Services。AddDbContextTenantDbContext（（sp，b）｛vartenantManagersp。GetRequiredServiceITenantManager（）；varcurrentTenantContexttenantManager。GetCurrentTenantContext（）；如果有上下文那么创建租户dbcontext否则就是启动命令AddMigrationif（currentTenantContext！null）｛varshardingRuntimeContextcurrentTenantContext。GetShardingRuntimeContext（）；b。UseDefaultShardingTenantDbContext（shardingRuntimeContext）；｝if（args。IsNotEmpty（））｛命令启动时为了保证AddMigration正常运行if（providerMySql）｛b。UseMySql（server127。0。0。1；port3306；databaseTenantDb；useridroot；passwordL6yBtV6qNENrwBy7；，newMySqlServerVersion（newVersion（）））。UseMigrationNamespace（newMySqlMigrationNamespace（））。ReplaceServiceIMigrationsAssembly，MultiDatabaseMigrationsAssembly（）；return；｝if（providerSqlServer）｛b。UseSqlServer（DataSourcelocalhost；InitialCatalogTenantDb；IntegratedSecurityTrue；）。UseMigrationNamespace（newSqlServerMigrationNamespace（））。ReplaceServiceIMigrationsAssembly，MultiDatabaseMigrationsAssembly（）；return；｝｝｝）；endregionvarappbuilder。Build（）；初始化启动配置租户信息app。Services。InitTenant（）；app。UseAuthorization（）；在认证后启用租户选择中间件app。UseMiddlewareTenantSelectMiddleware（）；app。MapControllers（）；app。Run（）；折叠添加迁移脚本
　　持久化identity迁移
　　多租户SqlServer版本
　　多租户MySql版本
　　启动程序
　　启动程序我们发现IdentityDbContext已经创建好了，并且支持了自动迁移
　　创建A租户｛Name：A，Password：A，DbType：1，OrderShardingType：2，BeginTimeForSharding：20220101，MigrationNamespace：ShardingCoreMultiTenantSys。Migrations。SqlServer｝
　　注意：MigrationNamespace应该自动生成，这边只是为了演示方便没写
　　完成创建B租户｛Name：B，Password：B，DbType：2，OrderShardingType：1，BeginTimeForSharding：20220101，MigrationNamespace：ShardingCoreMultiTenantSys。Migrations。Myql｝
　　完美创建
　　创建C租户｛Name：C，Password：C，DbType：1，OrderShardingType：2，BeginTimeForSharding：20220601，MigrationNamespace：ShardingCoreMultiTenantSys。Migrations。SqlServer｝
　　C租户完美创建并且和A租户采用一样的分片规则不一样的分片起始时间
　　分别对abc进行crud
　　首先获取token，然后插入
　　A租户
　　B租户
　　C租户
　　最后完成
　　文章来自https：www。cnblogs。comxuejiamingp16508446。html