# основной пакет
PM> Install-Package ShardingCore
# драйвер SQL Server
PM> Install-Package Microsoft.EntityFrameworkCore.SqlServer
# драйвер MySQL
#PM> Install-Package Pomelo.EntityFrameworkCore.MySql
# используйте другой драйвер базы данных, если он поддерживается efcore

    /// <summary>
    /// таблица заказов
    /// </summary>
    public class Order
    {
        /// <summary>
        /// идентификатор заказа
        /// </summary>
        public string Id { get; set; }
        /// <summary>
        /// идентификатор плательщика
        /// </summary>
        public string Payer { get; set; }
        /// <summary>
        /// сумма платежа центами
        /// </summary>
        public long Money { get; set; }
        /// <summary>
        /// регион
        /// </summary>
        public string Area { get; set; }
        /// <summary>
        /// статус заказа
        /// </summary>
        public OrderStatusEnum OrderStatus { get; set; }
        /// <summary>
        /// время создания
        /// </summary>
        public DateTime CreationTime { get; set; }
    }
    public enum OrderStatusEnum
    {
        NotPaid = 1,
        Paying = 2,
        Paid = 3,
        PaymentFailed = 4
    }

    public class MyDbContext : AbstractShardingDbContext, IShardingTableDbContext
    {
        public MyDbContext(DbContextOptions<MyDbContext> options) : base(options)
        {
        }

        protected override void OnModelCreating(ModelBuilder modelBuilder)
        {
            base.OnModelCreating(modelBuilder);
            modelBuilder.Entity<Order>(entity =>
            {
                entity.HasKey(o => o.Id);
                entity.Property(o => o.Id).IsRequired().IsUnicode(false).HasMaxLength(50);
                entity.Property(o => o.Payer).IsRequired().IsUnicode(false).HasMaxLength(50);
                entity.Property(o => o.Area).IsRequired().IsUnicode(false).HasMaxLength(50);
                entity.Property(o => o.OrderStatus).HasConversion<int>();
                // настоящее имя таблицы Order_202101, Order_202102, Order_202103...
                entity.ToTable(nameof(Order));
            });
        }
        /// <summary>
        /// пустое выполнение, если используется шардинг таблиц
        /// </summary>
        public IRouteTail RouteTail { get; set; }
    }

// Конструктор маршрута поддерживает внедрение зависимостей, то есть область жизни является `Singleton`

    public class OrderVirtualTableRoute : AbstractSimpleShardingMonthKeyDateTimeVirtualTableRoute<Order>
    {
        //private readonly IServiceProvider _serviceProvider;

        //public OrderVirtualTableRoute(IServiceProvider serviceProvider)
        //{
            //_serviceProvider = serviceProvider;
        //}
        /// <summary>
        /// фиксированное значение, не использовать DateTime.Now, так как при перезапуске приложения это значение может измениться
        /// </summary>
        /// <returns></returns>
        public override DateTime GetBeginTime()
        {
            return new DateTime(2021, 1, 1);
        }
        /// <summary>
        /// настройте свойство шардинга
        /// </summary>
        /// <param name="builder"></param>

        public override void Configure(EntityMetadataTableBuilder<Order> builder)
        {
            builder.ShardingProperty(o => o.CreationTime);
        }
        /// <summary>
        /// включите задачу автоматической генерации таблиц
        /// </summary>
        /// <returns></returns>

        public override bool AutoCreateTableByTime()
        {
            return true;
        }
    }

        public void ConfigureServices(IServiceCollection services)
        {

            // настройки шардинга
            services.AddShardingDbContext<MyDbContext>()
                .UseRouteConfig(op =>
                {
                    op.AddShardingTableRoute<OrderVirtualTableRoute>();
                }).UseConfig(op =>
                {
                    op.UseShardingQuery((connStr, builder) =>
                    {
                        // connStr — входящий параметр делегата
                        builder.UseSqlServer(connStr);
                    });
                    op.UseShardingTransaction((connection, builder) =>
                    {
                        // connection — входящий параметр делегата
                        builder.UseSqlServer(connection);
                    });
                    // используйте вашу строку подключения к базе данных
                    op.AddDefaultDataSource(Guid.NewGuid().ToString("n"),
                        "Data Source=localhost;Initial Catalog=EFCoreShardingTableDB;Integrated Security=True;");
                }).AddShardingCore();
        }
```        public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
        {
            if (env.IsDevelopment())
            {
                app.UseDeveloperExceptionPage();
            }
            // Необязательно, включение проверки отсутствующих таблиц и автоматической генерации
            app.ApplicationServices.UseAutoTryCompensateTable();
            // Другие настройки...
        }

[Route("api/[controller]")]
public class ValuesController : Controller
{
        private readonly MyDbContext _myDbContext;

        public ValuesController(MyDbContext myDbContext)
        {
            _myDbContext = myDbContext;
        }

        [HttpGet]
        public async Task<IActionResult> Get()
        {
            
            //_myDbContext.Add(order);
            //_myDbContext.Update(order);
            //_myDbContext.Remove(order);
            //_myDbContext.SaveChanges();
            var order = await _myDbContext.Set<Order>().FirstOrDefaultAsync(o => o.Id == "2");
            return Ok(order);
        }
}

<PackageReference Include="ShardingCore" Version="5.LastVersion" />
или
<PackageReference Include="ShardingCore" Version="3.LastVersion" />
или
<PackageReference Include="ShardingCore" Version="2.LastVersion" />

public class SysUserMod
{
    /// <summary>
    /// ID пользователя для распределения таблиц
    /// </summary>
    public string Id { get; set; }

    /// <summary>
    /// Имя пользователя
    /// </summary>
    public string Name { get; set; }

    /// <summary>
    /// Возраст пользователя
    /// </summary>
    public int Age { get; set; }
}

public class SysUserModVirtualTableRoute : AbstractSimpleShardingModKeyStringVirtualRoute<SysUserMod>
{
    // Длина хвоста: 00, 01, 02......99
    // Хэш-код % 3: [0, 1, 2]
    public SysUserModVirtualTableRoute() : base(2, 3)
    {
    }

    public override void Configure(EntityMetadataTableBuilder<SysUserMod> builder)
    {
        builder.ShardingProperty(o => o.Id);
    }
}

``````markdown
  //DefaultTableDbContext является фактическим контекстом выполнения
    public class DefaultShardingDbContext : AbstractShardingDbContext, IShardingTableDbContext
    {
        public DefaultShardingDbContext(DbContextOptions<DefaultShardingDbContext> options) : base(options)
        {
        }

        protected override void OnModelCreating(ModelBuilder modelBuilder)
        {
            base.OnModelCreating(modelBuilder);
            modelBuilder.ApplyConfiguration(new SysUserModMap());
        }
        public IRouteTail RouteTail { get; set; }

    }

        public void ConfigureServices(IServiceCollection services)
        {
            services.AddControllers();
            // если вы хотите использовать операцию без шардинга
            // services.AddDbContext<DefaultTableDbContext>(o => o.UseSqlServer("Data Source=localhost;Initial Catalog=ShardingCoreDB;Integrated Security=True"));
```### Операции с базой данных

#### Добавление записей в контекст базы данных
```csharp
_defaultShardingDbContext.AddRange(userMods);
await _defaultShardingDbContext.SaveChangesAsync();

public async Task ToList_All()
{
    var mods = await _defaultShardingDbContext.Set<SysUserMod>().ToListAsync();
    Assert.Equal(1000, mods.Count);
}
```    var modOrders1 = await _defaultShardingDbContext.Set<SysUserMod>().OrderBy(o => o.Age).ToListAsync();
    int ascAge = 1;
    foreach (var sysUserMod in modOrders1)
    {
        Assert.Equal(ascAge, sysUserMod.Age);
        ascAge++;
    }

    var modOrders2 = await _defaultShardingDbContext.Set<SysUserMod>().OrderByDescending(o => o.Age).ToListAsync();
    int descAge = 1000;
    foreach (var sysUserMod in modOrders2)
    {
        Assert.Equal(descAge, sysUserMod.Age);
        descAge--;
    }
}

public class SysUserModVirtualTableRoute : AbstractSimpleShardingModKeyStringVirtualTableRoute<SysUserMod>
{
    protected override bool EnableHintRoute => true;

    public SysUserModVirtualTableRoute() : base(2, 3)
    {
    }
}

using (_shardingRouteManager.CreateScope())
{
    _shardingRouteManager.Current.TryCreateOrAddMustTail<SysUserMod>("00");

    var mod00s = await _defaultTableDbContext.Set<SysUserMod>().Skip(10).Take(11).ToListAsync();
}

await _defaultShardingDbContext.SaveChangesAsync();

using (var tran = _defaultTableDbContext.Database.BeginTransaction())
{
    ...
    _defaultTableDbContext.SaveChanges();
    tran.Commit();
}

var list = new List<SysUserMod>();

var dbContexts = _defaultTableDbContext.BulkShardingEnumerable(list);

foreach (var dataSourceMap in dbContexts)
{
    foreach (var tailMap in dataSourceMap.Value)
    {
        tailMap.Key.BulkInsert(tailMap.Value.ToList());
        //tailMap.Key.BulkDelete(tailMap.Value.ToList());
        //tailMap.Key.BulkUpdate(tailMap.Value.ToList());
    }
}

_defaultTableDbContext.SaveChanges();

//или использовать транзакцию
using (var tran = _defaultTableDbContext.Database.BeginTransaction())
{
    foreach (var dataSourceMap in dbContexts)
    {
        foreach (var tailMap in dataSourceMap.Value)
        {
            tailMap.Key.BulkInsert(tailMap.Value.ToList());
            //tailMap.Key.BulkDelete(tailMap.Value.ToList());
            //tailMap.Key.BulkUpdate(tailMap.Value.ToList());
        }
    }
    _defaultTableDbContext.SaveChanges();
    tran.Commit();
}

services.AddShardingDbContext<DefaultShardingDbContext>((conStr, builder) => builder.UseSqlServer(conStr).UseLoggerFactory(efLogger)).Begin(o =>
{
    o.CreateShardingTableOnStart = true;
    o.EnsureCreatedWithOutShardingTable = true;
}).AddShardingTransaction((connection, builder) => builder.UseSqlServer(connection).UseLoggerFactory(efLogger)).AddDefaultDataSource("ds0", "Data Source=localhost;Initial Catalog=ShardingCoreDB1;Integrated Security=True;").AddShardingTableRoute(o => { o.AddShardingTableRoute<SysUserModVirtualTableRoute>(); }).AddReadWriteSeparation(o => { return new Dictionary<string, ISet<string>>() { { "ds0", new HashSet<string>() { "Data Source=localhost;Initial Catalog=ShardingCoreDBReadOnly1;Integrated Security=True;", "Data Source=localhost;Initial Catalog=ShardingCoreDBReadOnly2;Integrated Security=True;" } }; }; }, ReadStrategyEnum.Loop, defaultEnable: true).End();

                # решает проблему задержки чтения/записи данных при отсутствии данных
                # dbcontext использует соединение с базой данных для записи
            _virtualDbContext.ReadWriteSeparationWriteOnly();

public class SysUserSalaryPaginationConfiguration : IPaginationConfiguration<SysUserSalary>
{
    public void Configure(PaginationBuilder<SysUserSalary> builder)
    {
        builder.PaginationSequence(o => o.Id)
            .UseRouteCompare(Comparer<string>.Default)
            .UseQueryMatch(PaginationMatchEnum.Owner | PaginationMatchEnum.Named | PaginationMatchEnum.PrimaryMatch);
        builder.PaginationSequence(o => o.DateOfMonth)
            .UseQueryMatch(PaginationMatchEnum.Owner | PaginationMatchEnum.Named | PaginationMatchEnum.PrimaryMatch).UseAppendIfOrderNone(10);
        builder.PaginationSequence(o => o.Salary)
            .UseQueryMatch(PaginationMatchEnum.Owner | PaginationMatchEnum.Named | PaginationMatchEnum.PrimaryMatch).UseAppendIfOrderNone();
        builder.ConfigReverseShardingPage(0.5d, 10000L);
    }
}

public override IPaginationConfiguration<SysUserSalary> CreatePaginationConfiguration()
{
    return new SysUserSalaryPaginationConfiguration();
}

var shardingPageResultAsync = await _defaultTableDbContext.Set<SysUserMod>().OrderBy(o => o.Age).ToShardingPageAsync(pageIndex, pageSize);

public class OrderCreateTimeVirtualTableRoute : AbstractSimpleShardingMonthKeyDateTimeVirtualTableRoute<Order>
{
    // Включение кэширования выражений
    public override bool EnableRouteParseCompileCache => true;
}

public virtual Func<string, bool> CachingCompile(Expression<Func<string, bool>> parseWhere)
{
    if (EnableRouteParseCompileCache)
    {
        var doCachingCompile = DoCachingCompile(parseWhere);
        if (doCachingCompile != null)
            return doCachingCompile;
        doCachingCompile = CustomerCachingCompile(parseWhere);
        if (doCachingCompile != null)
            return doCachingCompile;
    }
    return parseWhere.Compile();
}

protected virtual Func<string, bool> DoCachingCompile(Expression<Func<string, bool>> parseWhere)
{
    var shouldCache = ShouldCache(parseWhere);
    if (shouldCache)
        return _routeCompileCaches.GetOrAdd(parseWhere, key => parseWhere.Compile());
    return null;
}

protected virtual Func<string, bool> CustomerCachingCompile(Expression<Func<string, bool>> parseWhere)
{
    return null;
}

return optionsBuilder.UseShardingWrapMark()
    .ReplaceService<IDbSetSource, ShardingDbSetSource>()
    .ReplaceService<IQueryCompiler, ShardingQueryCompiler>()
    .ReplaceService<IDbContextTransactionManager, ShardingRelationalTransactionManager<TShardingDbContext>>()
    .ReplaceService<IRelationalTransactionFactory, ShardingRelationalTransactionFactory<TShardingDbContext>>();

return optionsBuilder.ReplaceService<IModelCacheKeyFactory, ShardingModelCacheKeyFactory>()
    .ReplaceService<IModelCustomizer, ShardingModelCustomizer<TShardingDbContext>>();

// Поддерживает окончательное изменение
var sresult = _defaultTableDbContext.Set<SysUserMod>().ToList();

var sysUserMod98 = result.FirstOrDefault(o => o.Id == "98");
sysUserMod98.Name = "name_update" + new Random().Next(1, 99) + "_98";
await _defaultTableDbContext.SaveChangesAsync();
-- лог информации
Executed DbCommand (1ms) [Parameters=[@p1='?' (Size = 128), @p0='?' (Size = 128)], CommandType='Text', CommandTimeout='30']
SET NOCOUNT ON;
UPDATE [SysUserMod_02] SET [Name] = @p0
WHERE [Id] = @p1;
SELECT @@ROWCOUNT;