A plugin for Microsoft.EntityFrameworkCore to support repository, unit of work patterns, and multiple database with distributed transaction supported.
In MySQL, physically, a schema is synonymous with a database. You can substitute the keyword SCHEMA instead of DATABASE in MySQL SQL syntax, for example using CREATE SCHEMA instead of CREATE DATABASE. Some other database products draw a distinction. For example, in the Oracle Database product, a schema represents only a part of a database: the tables and other objects owned by a single user.
So, for MySQL, the easy way to support this feature is to dynamically change the SCHEMA at the runtime.
After v1.1.2 had support MySQL multiple databases/tables sharding in the same model in the same machine. For different machine, you can use DbContextFactory to dynamically create DbContext. You can use Pomelo.EntityFrameworkCore.MySql to test this feature. @PomeloFoundation
public void ConfigureServices(IServiceCollection services)
{
// use in memory for testing.
services
.AddDbContext<QuickStartContext>(opt => opt.UseInMemoryDatabase())
.AddUnitOfWork<QuickStartContext>()
.AddCustomRepository<Blog, CustomBlogRepository>();
}
private readonly IUnitOfWork _unitOfWork;
// 1. IRepositoryFactory used for readonly scenario;
// 2. IUnitOfWork used for read/write scenario;
// 3. IUnitOfWork<TContext> used for multiple databases scenario;
public ValuesController(IUnitOfWork unitOfWork)
{
_unitOfWork = unitOfWork;
// Change database only work for MySQL right now.
unitOfWork.ChangeDatabase($"uow_db_{DateTime.Now.Year}");
var userRepo = unitOfWork.GetRepository<User>();
var postRepo = unitOfWork.GetRepository<Post>();
var ym = DateTime.Now.ToString("yyyyMM");
userRepo.ChangeTable($"user_{ym}");
postRepo.ChangeTable($"post_{ym}");
var user = new User
{
UserName = "rigofunc",
Password = "password"
};
userRepo.Insert(user);
var post = new Post
{
UserId = user.UserId,
Content = "What a piece of junk!"
};
postRepo.Insert(post);
unitOfWork.SaveChanges();
var find = userRepo.Find(user.UserId);
find.Password = "p@ssword";
unitOfWork.SaveChanges();
// projection
}// projection
var pagedList = _unitOfWork.GetRepository<Blog>().GetPagedList(b => new { Name = b.Title, Link = b.Url }, pageIndex: pageIndex, pageSize: pageSize);
var projection = _unitOfWork.GetRepository<Blog>().GetFirstOrDefault(b => new { Name = b.Title, Link = b.Url }, predicate: x => x.Title.Contains(term));
// including
[HttpGet]
public async Task<IPagedList<Blog>> Get()
{
return await _unitOfWork.GetRepository<Blog>().GetPagedListAsync(include: source => source.Include(blog => blog.Posts).ThenInclude(post => post.Comments));
}