AppStd/DigitalData.Core
Template
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat(Repository): CreateAsync-Methoden für DTO wurden in Erweiterungsmethoden konvertiert

Browse Source
This commit is contained in:
Developer 02 2025-04-22 11:21:21 +02:00
parent 5465fe5b49
commit 3c1bbc1151
3 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
DigitalData.Core.Abstractions/Infrastructure/Extensions.cs
View File

@ -4,6 +4,21 @@ namespace DigitalData.Core.Abstractions.Infrastructure;
public static class Extensions public static class Extensions
{ {
#region Create
public static Task<TEntity> CreateAsync<TEntity, TDto>(this IRepository<TEntity> repository, TDto dto, CancellationToken ct = default)
{
var entity = repository.Mapper.Map(dto);
return repository.CreateAsync(entity, ct);
}
public static Task<IEnumerable<TEntity>> CreateAsync<TEntity, TDto>(this IRepository<TEntity> repository, IEnumerable<TDto> dtos, CancellationToken ct = default)
{
var entities = dtos.Select(dto => repository.Mapper.Map(dto));
return repository.CreateAsync(entities, ct);
}
#endregion
#region Read
public static async Task<TEntity?> ReadFirstOrDefaultAsync<TEntity>(this IRepository<TEntity> repository, Expression<Func<TEntity, bool>>? expression = null) public static async Task<TEntity?> ReadFirstOrDefaultAsync<TEntity>(this IRepository<TEntity> repository, Expression<Func<TEntity, bool>>? expression = null)
=> (await repository.ReadAsync(expression)).FirstOrDefault(); => (await repository.ReadAsync(expression)).FirstOrDefault();
@ -15,4 +30,5 @@ public static class Extensions
public static async Task<TEntity> ReadSingleAsync<TEntity>(this IRepository<TEntity> repository, Expression<Func<TEntity, bool>>? expression = null) public static async Task<TEntity> ReadSingleAsync<TEntity>(this IRepository<TEntity> repository, Expression<Func<TEntity, bool>>? expression = null)
=> (await repository.ReadAsync(expression)).Single(); => (await repository.ReadAsync(expression)).Single();
#endregion
} }

4
DigitalData.Core.Abstractions/Infrastructure/IRepository.cs
View File

@ -10,10 +10,6 @@ public interface IRepository<TEntity>
public Task<IEnumerable<TEntity>> CreateAsync(IEnumerable<TEntity> entities, CancellationToken ct = default); public Task<IEnumerable<TEntity>> CreateAsync(IEnumerable<TEntity> entities, CancellationToken ct = default);
public Task<TEntity> CreateAsync<TDto>(TDto dto, CancellationToken ct = default);
public Task<IEnumerable<TEntity>> CreateAsync<TDto>(IEnumerable<TDto> dtos, CancellationToken ct = default);
public Task<IEnumerable<TEntity>> ReadAsync(Expression<Func<TEntity, bool>>? expression = null, CancellationToken ct = default); public Task<IEnumerable<TEntity>> ReadAsync(Expression<Func<TEntity, bool>>? expression = null, CancellationToken ct = default);
public Task UpdateAsync<TDto>(TDto dto, Expression<Func<TEntity, bool>> expression, CancellationToken ct = default); public Task UpdateAsync<TDto>(TDto dto, Expression<Func<TEntity, bool>> expression, CancellationToken ct = default);

12
DigitalData.Core.Infrastructure/DbRepository.cs
View File

@ -32,18 +32,6 @@ public class DbRepository<TDbContext, TEntity> : IRepository<TEntity> where TDbC
return entities; return entities;
} }
public virtual Task<TEntity> CreateAsync<TDto>(TDto dto, CancellationToken ct = default)
{
var entity = Mapper.Map(dto);
return CreateAsync(entity, ct);
}
public virtual Task<IEnumerable<TEntity>> CreateAsync<TDto>(IEnumerable<TDto> dtos, CancellationToken ct = default)
{
var entities = dtos.Select(dto => Mapper.Map(dto));
return CreateAsync(entities, ct);
}
public virtual async Task<IEnumerable<TEntity>> ReadAsync(Expression<Func<TEntity, bool>>? expression = null, CancellationToken ct = default) public virtual async Task<IEnumerable<TEntity>> ReadAsync(Expression<Func<TEntity, bool>>? expression = null, CancellationToken ct = default)
=> expression is null => expression is null
? await Entities.AsNoTracking().ToListAsync(ct) ? await Entities.AsNoTracking().ToListAsync(ct)