Librame.Extensions.Data.EntityFrameworkCore 7.0.898.201

Librame.Extensions.Data.EntityFrameworkCore

Install Extension

PM> Install-Package Librame.Extensions.Data.EntityFrameworkCore

Register Extension

services.AddLibrame()
    .AddData(options =>
    {
        // Multi-Tenancy, Reading and writing separation
        options.DefaultTenant.DefaultConnectionString = "default database connection string";
        options.DefaultTenant.WritingConnectionString = "write database connection string";
        options.DefaultTenant.WritingSeparation = true;
    })
    .AddAccessor<TestDbContextAccessor>((options, optionsBuilder) =>
    {
        // Install-Package Microsoft.EntityFrameworkCore.SqlServer
        optionsBuilder.UseSqlServer(options.DefaultTenant.DefaultConnectionString,
            sql => sql.MigrationsAssembly("AssemblyName"));
    })
    .AddStoreHubWithAccessor<TestStoreHub>()
    .AddInitializerWithAccessor<TestStoreInitializer>()
    .AddIdentifier<TestStoreIdentifier>()
    .AddDbDesignTime<SqlServerDesignTimeServices>();

Test Extension

// StoreHub
public class TestStoreHub : StoreHubBase<TestDbContextAccessor>
{
    public TestStore(IAccessor accessor, IStoreInitializer<TestDbContextAccessor> initializer)
        : base(accessor, initializer)
    {
    }
    
    
    public IList<Category> GetCategories()
    {
        return Accessor.Categories.ToList();
    }

    public IPageable<Article> GetArticles()
    {
        return Accessor.Articles.AsDescendingPagingByIndex(1, 10);
    }


    public TestStoreHub UseWriteDbConnection()
    {
        Accessor.TryChangeDbConnection(t => t.WritingConnectionString);
        return this;
    }

    public TestStoreHub UseDefaultDbConnection()
    {
        Accessor.TryChangeDbConnection(t => t.DefaultConnectionString);
        return this;
    }
}

// DbContextAccessor
public class TestDbContextAccessor : DbContextAccessor
{
    public TestDbContextAccessor(DbContextOptions options)
        : base(options)
    {
    }


    public DbSet<Category> Categories { get; set; }

    public DbSet<Article> Articles { get; set; }


    protected override void OnModelCreating(ModelBuilder modelBuilder)
    {
        base.OnModelCreating(modelBuilder);

        ......
    }
}

// Test
using (var stores = serviceProvider.GetRequiredService<TestStoreHub>())
{
    var categories = stores.GetCategories();
    Assert.Empty(categories);

    categories = stores.UseWriteDbConnection().GetCategories();
    Assert.NotEmpty(categories);

    var articles = stores.UseDefaultDbConnection().GetArticles();
    Assert.Empty(articles);

    articles = stores.UseWriteDbConnection().GetArticles();
    Assert.True(articles.Total >= 0); // If enable sharding table, the articles of this table may be empty
}
......
// Librame.Extensions.Data.Tests.DbContextAccessorTests