DALQueryChain

DALQueryChain позволяет упростить работу с DAL уровнем, предоставляя гибкую систему составления запроса, закрытым от прямого доступа к ORM и IQueryable.

Начало работы:

Установка основного пакета из NuGet:

• Install-Package DALQueryChain

Дополнительные пакеты:

Для Linq2Db ORM:

• Install-Package DALQueryChain.Linq2Db

Для EntityFramework ORM:

• Install-Package DALQueryChain.EntityFramework

Конфигурация проекта:

В Startup/Program прописать регистрацию DALQueryChain

public class Startup { public IConfiguration Configuration { get; } public void ConfigureServices(IServiceCollection services) { //... services.AddQueryChain(Assembly.GetAssembly("DALAssemblyName")); //... } }

Использование библиотеки:

Забираем из DI:

IDALQueryChain<TestContext> queryChain

Или создаем экземпляр:

using var queryChain = new BuildQuery<TestContext>(_context, _serviceProvider);

Примеры использования:

Get:

var maxUserId = queryChain.For<User>().Get.Select(x => x.Id).Max(); //Получение максимального Id var activeUsers = await queryChain.For<User>().Get.Where(x => x.IsActive).ToListAsync(); //Получение активных записей var workspaces = queryChain.For<Workspace>().Get.LoadWith(x => x.Permissions).ThenLoad(x => x.Users); //Получение записей с зависимостями

Insert:

var user = new User { AccessFailedCount = 1, CreateAt = DateTime.Now, DeleteAt = DateTime.Now, Email = Guid.NewGuid().ToString(), EmailConfirmed = false, ModifyAt = DateTime.Now, PasswordHash = "", PhoneConfirmed = false, RoleId = 1, Salt = "", IsActive = true, Username = Guid.NewGuid().ToString() }; var user = await queryChain.For<User>().Insert.InsertWithObjectAsync(user); // Вставка записи в таблицу с ее возвратом

Delete:

await queryChain.For<User>().Delete.DeleteAsync(x => true); //Удаление всех записей в таблице await _qs.For<User>().Delete.BulkSoftDeleteAsync(users); //Мягкое удаление (необходимо переопределение в репозитории)

Update:

queryChain.For<User>().Update.BulkUpdate(object); //Массовое обновление записей _qs.For<User>().Update .Where(x => true) .Set(x => x.Email, () => Guid.NewGuid().ToString()) .Update(); //Обновление указанных полей в записях

Репозитории и триггеры:

UserRepository:

public class UserRepository : BaseRepository<TestContext, User> { private readonly ITestDI _testDI; public UserRepository(TestContext context, ITestDI testDI) : base(context) { _testDI = testDI; } protected override async Task OnBeforeDelete(CancellationToken ctn = default) { var deletedEntities = await GetTriggerData(ctn); //Some Actions... } protected override async Task OnAfterDelete(CancellationToken ctn = default) { var deletedEntities = await GetTriggerData(ctn); //Some Actions... } protected override async Task OnBeforeUpdate(CancellationToken ctn = default) { var updatedEntities = await GetTriggerData(ctn); //Some Actions... } protected override async Task OnAfterUpdate(CancellationToken ctn = default) { var updatedEntities = await GetTriggerData(ctn); //Some Actions... } protected override async Task OnBeforeInsert(CancellationToken ctn = default) { var insertedEntities = await GetTriggerData(ctn); //Some Actions... } protected override async Task OnAfterInsert(CancellationToken ctn = default) { var insertedEntities = await GetTriggerData(ctn); //Some Actions... } protected override Task SoftBulkDelete(IEnumerable<User> model, CancellationToken ctn = default) { //Some Actions... } protected override Task SoftDelete(Expression<Func<User, bool>> predicate, CancellationToken ctn = default) { //Some Actions... } protected override Task SoftBulkDelete(Expression<Func<User, bool>> predicate, CancellationToken ctn = default) { //Some Actions... } protected override Task SoftDelete(User model, CancellationToken ctn = default) { //Some Actions... } public void Method() { _testDI.Test(); } }

Использование:

var repository = queryChain.Repository<UserRepository>(); repository.Method();