34 lines
1006 B
C#
34 lines
1006 B
C#
using DD.Persistence.Repositories;
|
|
using Mapster;
|
|
using Microsoft.EntityFrameworkCore;
|
|
|
|
namespace DD.Persistence.Repository.Repositories;
|
|
public class RelatedDataRepository<TDto, TEntity> : IRelatedDataRepository<TDto>
|
|
where TDto : class, new()
|
|
where TEntity : class, new()
|
|
{
|
|
protected DbContext db;
|
|
public RelatedDataRepository(DbContext db)
|
|
{
|
|
this.db = db;
|
|
}
|
|
protected virtual IQueryable<TEntity> GetQueryReadOnly() => db.Set<TEntity>();
|
|
|
|
public virtual async Task Add(TDto dataSourceSystemDto, CancellationToken token)
|
|
{
|
|
var entity = dataSourceSystemDto.Adapt<TEntity>();
|
|
|
|
await db.Set<TEntity>().AddAsync(entity, token);
|
|
await db.SaveChangesAsync(token);
|
|
}
|
|
|
|
public virtual async Task<IEnumerable<TDto>> Get(CancellationToken token)
|
|
{
|
|
var query = GetQueryReadOnly();
|
|
var entities = await query.ToArrayAsync(token);
|
|
var dtos = entities.Select(e => e.Adapt<TDto>());
|
|
|
|
return dtos;
|
|
}
|
|
}
|