public void ConfigureServices(IServiceCollection services)
{ ......
services.AddShardingDbContext()
.UseRouteConfig(o =>
{//定义分表路由
o.AddShardingDataSourceRoute();
}).UseConfig((sp,o) =>
{ ......
//指定主从数据库
o.AddDefaultDataSource("ds0","server=127.0.0.1;port=3306;database=db1;userid=root;password=root;");
o.AddExtraDataSource(sp => new Dictionary()
{ { "ds1", "server=127.0.0.1;port=3306;database=db2;userid=root;password=root;" }, { "ds2", "server=127.0.0.1;port=3306;database=db3;userid=root;password=root;" } });
o.UseShardingMigrationConfigure(b =>
{ b.ReplaceService();
});
}).ReplaceService()
.AddShardingCore();
}