DALQueryChain позволяет упростить работу с DAL уровнем, предоставляя гибкую систему составления запроса, закрытым от прямого доступа к ORM и IQueryable.
В 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); //Мягкое удаление (необходимо переопределение в репозитории)
