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

rename CancellationTokens

Browse Source
This commit is contained in:
tekh 2025-08-25 14:32:38 +02:00
parent 70e3fe5dd7
commit e80eb6aa1f
2 changed files with 18 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
DigitalData.Core.Abstraction.Application/Repository/IRepository.cs
View File

@ -6,19 +6,19 @@ public interface IRepository<TEntity>
{ {
public IEntityMapper<TEntity> Mapper { get; } public IEntityMapper<TEntity> Mapper { get; }
public Task<TEntity> CreateAsync(TEntity entity, CancellationToken cancellation = default); public Task<TEntity> CreateAsync(TEntity entity, CancellationToken cancel = default);
public Task<IEnumerable<TEntity>> CreateAsync(IEnumerable<TEntity> entities, CancellationToken cancellation = default); public Task<IEnumerable<TEntity>> CreateAsync(IEnumerable<TEntity> entities, CancellationToken cancel = default);
public IQueryable<TEntity> Read(); public IQueryable<TEntity> Read();
public IQueryable<TEntity> ReadOnly(); public IQueryable<TEntity> ReadOnly();
public Task UpdateAsync<TDto>(TDto dto, Expression<Func<TEntity, bool>> expression, CancellationToken cancellation = default); public Task UpdateAsync<TDto>(TDto dto, Expression<Func<TEntity, bool>> expression, CancellationToken cancel = default);
public Task UpdateAsync<TDto>(TDto dto, IQueryable<TEntity> query, CancellationToken cancellation = default); public Task UpdateAsync<TDto>(TDto dto, IQueryable<TEntity> query, CancellationToken cancel = default);
public Task DeleteAsync(Expression<Func<TEntity, bool>> expression, CancellationToken cancellation = default); public Task DeleteAsync(Expression<Func<TEntity, bool>> expression, CancellationToken cancel = default);
public Task DeleteAsync(IQueryable<TEntity> query, CancellationToken cancellation = default); public Task DeleteAsync(IQueryable<TEntity> query, CancellationToken cancel = default);
} }

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

@ -19,17 +19,17 @@ public class DbRepository<TDbContext, TEntity> : IRepository<TEntity> where TDbC
Mapper = mapper; Mapper = mapper;
} }
public virtual async Task<TEntity> CreateAsync(TEntity entity, CancellationToken ct = default) public virtual async Task<TEntity> CreateAsync(TEntity entity, CancellationToken cancel = default)
{ {
Entities.Add(entity); Entities.Add(entity);
await Context.SaveChangesAsync(ct); await Context.SaveChangesAsync(cancel);
return entity; return entity;
} }
public virtual async Task<IEnumerable<TEntity>> CreateAsync(IEnumerable<TEntity> entities, CancellationToken ct = default) public virtual async Task<IEnumerable<TEntity>> CreateAsync(IEnumerable<TEntity> entities, CancellationToken cancel = default)
{ {
Entities.AddRange(entities); Entities.AddRange(entities);
await Context.SaveChangesAsync(ct); await Context.SaveChangesAsync(cancel);
return entities; return entities;
} }
@ -37,11 +37,11 @@ public class DbRepository<TDbContext, TEntity> : IRepository<TEntity> where TDbC
public IQueryable<TEntity> ReadOnly() => Entities.AsNoTracking(); public IQueryable<TEntity> ReadOnly() => Entities.AsNoTracking();
public virtual Task UpdateAsync<TDto>(TDto dto, Expression<Func<TEntity, bool>> expression, CancellationToken ct = default) => UpdateAsync(dto, Entities.Where(expression), ct); public virtual Task UpdateAsync<TDto>(TDto dto, Expression<Func<TEntity, bool>> expression, CancellationToken cancel = default) => UpdateAsync(dto, Entities.Where(expression), cancel);
public virtual async Task UpdateAsync<TDto>(TDto dto, IQueryable<TEntity> query, CancellationToken ct = default) public virtual async Task UpdateAsync<TDto>(TDto dto, IQueryable<TEntity> query, CancellationToken cancel = default)
{ {
var entities = await query.ToListAsync(ct); var entities = await query.ToListAsync(cancel);
for (int i = entities.Count - 1; i >= 0; i--) for (int i = entities.Count - 1; i >= 0; i--)
{ {
@ -49,20 +49,20 @@ public class DbRepository<TDbContext, TEntity> : IRepository<TEntity> where TDbC
Entities.Update(entities[i]); Entities.Update(entities[i]);
} }
await Context.SaveChangesAsync(ct); await Context.SaveChangesAsync(cancel);
} }
public virtual Task DeleteAsync(Expression<Func<TEntity, bool>> expression, CancellationToken ct = default) => DeleteAsync(Entities.Where(expression), ct); public virtual Task DeleteAsync(Expression<Func<TEntity, bool>> expression, CancellationToken cancel = default) => DeleteAsync(Entities.Where(expression), cancel);
public virtual async Task DeleteAsync(IQueryable<TEntity> query, CancellationToken ct = default) public virtual async Task DeleteAsync(IQueryable<TEntity> query, CancellationToken cancel = default)
{ {
var entities = await query.ToListAsync(ct); var entities = await query.ToListAsync(cancel);
for (int i = entities.Count - 1; i >= 0; i--) for (int i = entities.Count - 1; i >= 0; i--)
{ {
Entities.Remove(entities[i]); Entities.Remove(entities[i]);
} }
await Context.SaveChangesAsync(ct); await Context.SaveChangesAsync(cancel);
} }
} }