For Contact Us Please Send Mail Or Call To : Tel : +989301919109 Mail : mehrannoruzi@gmail.com
License
—
Deps
8
Install Size
—
Vulns
✓ 0
Published
Dec 24, 2025
Get Started
$ dotnet add package Bat.EntityFrameworkCoreReadme
For use Bat.EntityFrameworkCore just do it :
1- Install Bat.EntityFrameworkCore on your project
2- Register IEFGenericRepo to service container for example :
builder.Services.AddTransient<IEFGenericRepo<User>, EFGenericRepo<User>>();
builder.Services.AddTransient<IEFGenericRepo<Address>, EFGenericRepo<Address>>();
builder.Services.AddScoped<AppUnitOfWork>();
3- Use it in bussiness logic for example :
// Create DbContext
public class AppDbContext : BatDbContext
{
public AppDbContext() { }
public AppDbContext(DbContextOptions<AppDbContext> options) : base(options) { }
protected override void OnModelCreating(ModelBuilder builder)
{
builder.ApplyConfigurationsFromAssembly(typeof(AppUnitOfWork).Assembly);
base.OnModelCreating(builder);
}
public DbSet<User> Users { get; set; }
public DbSet<Address> Addresses { get; set; }
}
// Create UnitOfWork
public class AppUnitOfWork : IBatUnitOfWork
{
private readonly AppDbContext _appDbContext;
private readonly IServiceProvider _serviceProvider;
public AppUnitOfWork(AppDbContext appDbContext, IServiceProvider serviceProvider)
{
_appDbContext = appDbContext;
_serviceProvider = serviceProvider;
}
public EFGenericRepo<User> UserRepo => (EFGenericRepo<User>)_serviceProvider.GetRequiredService<IEFGenericRepo<User>>();
public EFGenericRepo<Address> AddressRepo => (EFGenericRepo<Address>)_serviceProvider.GetRequiredService<IEFGenericRepo<Address>>();
public DatabaseFacade Database { get => _appDbContext.Database; }
public ChangeTracker ChangeTracker { get => _appDbContext.ChangeTracker; }
public EFGenericRepo<T> GetRepository<T>() where T : class, IBaseEntity
=> EFGenericRepo<T>)_serviceProvider.GetRequiredService<IEFGenericRepo<T>>();
public async Task<IEnumerable<T>> ExecuteProcedure<T>(string sqlQuery, params object[] parameter) where T : class
=> await _appDbContext.ExecuteProcedure<T>(sqlQuery, parameter);
public Task<SaveChangeResult> BatSaveChangesAsync(CancellationToken cancellationToken = default)
=> _appDbContext.BatSaveChangesAsync(cancellationToken);
public void Dispose()
{
_appDbContext.Dispose();
GC.SuppressFinalize(this);
}
}
// Use power Off EFGenericRepo
public class UserService : IUserService
{
private readonly AppUnitOfWork _appUow;
public UserService(AppUnitOfWork appUnitOfWork)
{
_appUow = appUnitOfWork;
}
public async Task ExecuteSample()
{
var x0 = await _appUow.GetRepository<User>().AnyAsync();
var x1 = await _appUow.AddressRepo.CountAsync();
var x2 = await _appUow.UserRepo
.Include(x => x.Families)
.Select(x => new GetUserDto { UserId = x.UserId, Name = x.Name, Families = x.Families })
.FirstOrDefaultAsync(x => x.UserId > 1);
var xxx1 = await _appUow.UserRepo
.Where(x => x.UserId > 1).ToListAsync();
var xxx2 = await _appUow.UserRepo
.Include(x => x.Families).ToListAsync();
var xxx3 = await _appUow.UserRepo
.Where(x => x.UserId > 1)
.Include(x => x.Families.Where(x => x.FamilyId > 0))
.ThenInclude(x => x.Addresses)
.OrderByDescending(x => x.UserId)
.ToListAsync();
var xxx4 = await _appUow.UserRepo
.Select(x => new { x.UserId, x.Name }).ToListAsync();
var xxx5 = await _appUow.UserRepo
.Include(x => x.Families)
.Select(x => new { x.UserId, x.Name, x.Families }).ToListAsync();
var xxx6 = await _appUow.UserRepo
.Include(x => x.Families)
.Where(x => x.UserId > 1)
.Select(x => new { x.UserId, x.Name, x.Families }).ToListAsync();
var xxx7 = await _appUow.UserRepo
.Include(x => x.Families)
.ThenInclude(x => x.Addresses)
.OrderByDescending(x => x.UserId)
.Select(x => new { x.UserId, x.Name, x.Families })
.FirstOrDefaultAsync();
var xxx8 = await _appUow.UserRepo.AsNoTracking().FirstOrDefaultAsync(x => x.UserId > 1);
var xxx9 = await _appUow.UserRepo.OrderBy(x => x.UserId).FirstOrDefaultAsync(x => x.UserId > 1);
var xxx10 = await _appUow.UserRepo.Where(x => x.UserId > 1).ToPagingListDetailsAsync(pagingParameter);
var xxx11 = await _appUow.UserRepo.Include(x => x.Families).Where(x => x.UserId > 1).ToPagingListDetailsAsync(pagingParameter);
var xxx12 = await _appUow.UserRepo.Select(x => new { x.UserId, x.Name }).OrderByDescending(x => x.UserId).ToPagingListDetailsAsync(pagingParameter);
var xxx13 = await _appUow.UserRepo.AnyAsync(x => x.UserId > 1);
var xxx14 = await _appUow.UserRepo.Include(x => x.Families).AnyAsync();
var xxx15 = await _appUow.UserRepo.Include(x => x.Families).AnyAsync(x => x.UserId > 1);
var xxx16 = await _appUow.UserRepo.CountAsync();
var xxx17 = await _appUow.UserRepo.Include(x => x.Families).CountAsync();
var xxx18 = await _appUow.UserRepo.Include(x => x.Families).CountAsync(x => x.UserId > 1);
var user0 = await _appUow.UserRepo.FirstOrDefaultAsync(
new QueryFilterWithSelector<User, int>
{
Conditions = x => x.UserId > 0,
ThenIncludeProperties = a => a.Include(a => a.Families).ThenInclude(a => a.Addresses),
Selector = x => x.UserId
});
var user00 = await _appUow.UserRepo.FirstOrDefaultAsync(
new QueryFilterWithSelector<User, string>
{
Conditions = x => x.UserId > 0,
ThenIncludeProperties = a => a.Include(a => a.Families).ThenInclude(a => a.Addresses),
Selector = x => x.Name
});
var user001 = await _appUow.UserRepo.FirstOrDefaultAsync(
new QueryFilter<User>
{
Conditions = x => x.UserId > 1,
ThenIncludeProperties = a => a.Include(a => a.Families).ThenInclude(a => a.Addresses),
});
var user002 = await _appUow.UserRepo.GetPagingAsync(
new QueryFilter<User>
{
Conditions = x => x.UserId > 0,
PagingParameter = new PagingParameter(2, 2),
ThenIncludeProperties = a => a.Include(a => a.Families).ThenInclude(a => a.Addresses)
});
var user003 = await _appUow.UserRepo.GetAsync(
new QueryFilter<User>
{
Conditions = x => x.UserId > 0,
ThenIncludeProperties = a => a.Include(a => a.Families).ThenInclude(a => a.Addresses)
});
var query = "EXEC [Auth].[GetUserMenu] @UserId, @Type";
var userMenu = await _appUow.ExecuteProcedure<MenuModel>(query,
new SqlParameter("@UserId", userId),
new SqlParameter("@Type", RoleType.Online));
}
}