feat: Add bulk update and delete methods to IGenericRepository and EntityFrameworkGenericRepository

Author: vp

…tityFramework/ActiveRecord/PMS-Design.md docs/designs/design-activeentity-pms.mdtests/Infrastructure.IntegrationTests/EntityFramework/ActiveRecord/PMS-Design.md renamed to docs/designs/design-activeentity-pms.md tests/Infrastructure.IntegrationTests/EntityFramework/ActiveRecord/PMS-Design.md renamed to docs/designs/design-activeentity-pms.md

@@ -16,7 +16,8 @@ current issues:
 
 improvements:
 
- - easier to inherit/extend with new query methods. including that behaviors still work.
- - better support for transactions and result types.
- - native filtering support on repositories, no queryoptions needed then.
- -
+- easier to inherit/extend with new query methods. including that behaviors still work.
+- better support for transactions and result types.
+- native filtering support on repositories, no queryoptions needed then.
+- ef only repositories, no need to support in-memory or other providers, so we can use ef features like tracking, etc. and also easier to maintain.
+- better support for testing, no need to mock extension methods, etc.

docs/designs/design-domain-repositories-vnext.md

@@ -188,6 +188,90 @@ var customerNames = await repository.ProjectAllAsync(
     cancellationToken);
 ```
 
+### Bulk Updates And Deletes
+
+Use `UpdateSetAsync` and `DeleteSetAsync` for set-based operations that run directly in the repository provider without loading each entity instance first.
+
+> Bulk operations are ideal for administrative tasks or background jobs that need to update or delete large numbers of entities without loading them into memory.
+
+```csharp
+var affected = await repository.UpdateSetAsync(
+    set => set
+        .Set(c => c.IsActive, false)
+        .Set(c => c.LastName, "Archived")
+        .Set(c => c.LoginCount, c => c.LoginCount + 1),
+    cancellationToken: cancellationToken);
+
+var deleted = await repository.DeleteSetAsync(cancellationToken: cancellationToken);
+```
+
+You can limit the affected rows with one or more specifications:
+
+```csharp
+var affected = await repository.UpdateSetAsync(
+    new CustomerIsInactiveSpecification(),
+    set => set
+        .Set(c => c.IsActive, false)
+        .Set(c => c.LoginCount, c => c.LoginCount + 1),
+    cancellationToken: cancellationToken);
+
+var deleted = await repository.DeleteSetAsync(
+[
+    new CustomerCountrySpecification("DE"),
+    new CustomerIsInactiveSpecification()
+], cancellationToken: cancellationToken);
+```
+
+Expression-based forwarding overloads are also available through `RepositoryExtensions`:
+
+```csharp
+var affected = await repository.UpdateSetAsync(
+    c => c.IsActive,
+    set => set
+        .Set(c => c.LastName, "Archived")
+        .Set(c => c.LoginCount, c => c.LoginCount + 1),
+    cancellationToken: cancellationToken);
+
+var deleted = await repository.DeleteSetAsync(
+    c => !c.IsActive,
+    cancellationToken: cancellationToken);
+```
+
+`FilterModel`-based extension overloads translate the query filters into specifications before forwarding them to the repository:
+
+```csharp
+var filter = new FilterModel
+{
+    Filters =
+    [
+        new FilterCriteria
+        {
+            Field = nameof(Customer.IsActive),
+            Operator = FilterOperator.Equal,
+            Value = false
+        }
+    ]
+};
+
+var affected = await repository.UpdateSetAsync(
+    filter,
+    set => set
+        .Set(c => c.LastName, "Archived")
+        .Set(c => c.LoginCount, c => c.LoginCount + 1),
+    cancellationToken: cancellationToken);
+
+var deleted = await repository.DeleteSetAsync(filter, cancellationToken: cancellationToken);
+```
+
+#### Key Points For Bulk Set Operations
+
+- Filtering for `UpdateSetAsync` and `DeleteSetAsync` comes from specification instances, including specifications generated from a `FilterModel`.
+- `FindOptions` continue to shape the query only; they do not define the `WHERE` clause.
+- `UpdateSetAsync` supports both constant assignments such as `.Set(c => c.IsActive, false)` and computed assignments such as `.Set(c => c.LoginCount, c => c.LoginCount + 1)`.
+- Only `EntityFrameworkGenericRepository<TEntity>` and `InMemoryRepository<TEntity>` currently provides a real implementation for repository bulk updates and deletes.
+- Other repository implementations expose the same API for consistency but currently throw `NotImplementedException`.
+- With Entity Framework, set-based operations execute directly in the database and do not synchronize already tracked entities in the current `DbContext`. If you need the updated database state immediately afterwards, re-query using `NoTracking` or use a fresh context/repository instance.
+
 ## Appendix A: Optimistic Concurrency Support
 
 ### Overview
@@ -202,12 +286,12 @@ sequenceDiagram
 
     User1->>Repo: Get TodoItem (Version=A)
     User2->>Repo: Get TodoItem (Version=A)
-    
+
     User1->>Repo: Update TodoItem
     Note over Repo: Generate new Version B
     Repo->>DB: Save (Version A→B)
     DB-->>Repo: Success
-    
+
     User2->>Repo: Update TodoItem
     Note over Repo: Generate new Version C
     Repo->>DB: Save (Version A→C)
@@ -226,7 +310,7 @@ public class TodoItem : AuditableAggregateRoot<TodoItemId>, IConcurrency
     // Entity properties
     public string Title { get; set; }
     public TodoStatus Status { get; set; }
-    
+
     // Concurrency token
     public Guid ConcurrencyVersion { get; set; }
 }
@@ -244,7 +328,7 @@ public class TodoItemEntityTypeConfiguration : IEntityTypeConfiguration<TodoItem
         builder.Property(e => e.ConcurrencyVersion)
             .IsConcurrencyToken()
             .ValueGeneratedOnAddOrUpdate();
-            
+
         // Other configuration...
     }
 }
@@ -263,7 +347,7 @@ public class TodoItemEntityTypeConfiguration : IEntityTypeConfiguration<TodoItem
 ```csharp
 public async Task UpdateTodoItemAsync(TodoItem item)
 {
-    try 
+    try
     {
         await _repository.UpdateAsync(item);
     }
@@ -311,9 +395,9 @@ sequenceDiagram
     Gen->>DB: NEXT VALUE FOR OrderNumbers
     DB-->>Gen: 1001
     Gen-->>App: Result<long>.Success(1001)
-    
+
     Note over App,DB: Thread-safe with internal locking
-    
+
     App->>Gen: GetSequenceInfoAsync("OrderNumbers")
     Gen->>DB: Query metadata
     DB-->>Gen: {Current: 1001, Increment: 1, ...}
@@ -345,7 +429,7 @@ Register the appropriate generator for your database provider using the provided
 ```csharp
 // In ConfigureServices
 services.AddDbContext<YourDbContext>(options => options.UseSqlServer(connectionString))
-    .WithSequenceNumberGenerator(new SequenceNumberGeneratorOptions 
+    .WithSequenceNumberGenerator(new SequenceNumberGeneratorOptions
     {
         LockTimeout = TimeSpan.FromSeconds(60)
     });

docs/features-domain-repositories.md

@@ -66,6 +66,35 @@ public RepositoryDomainEventMediatorPublisherBehavior(
 
     protected IGenericRepository<TEntity> Inner { get; }
 
+    /// <inheritdoc />
+    public async Task<long> UpdateSetAsync(
+        Action<IEntityUpdateSet<TEntity>> set,
+        IFindOptions<TEntity> options = null,
+        CancellationToken cancellationToken = default)
+    {
+        return await this.Inner.UpdateSetAsync(set, options, cancellationToken).AnyContext();
+    }
+
+    /// <inheritdoc />
+    public async Task<long> UpdateSetAsync(
+        ISpecification<TEntity> specification,
+        Action<IEntityUpdateSet<TEntity>> set,
+        IFindOptions<TEntity> options = null,
+        CancellationToken cancellationToken = default)
+    {
+        return await this.Inner.UpdateSetAsync(specification, set, options, cancellationToken).AnyContext();
+    }
+
+    /// <inheritdoc />
+    public async Task<long> UpdateSetAsync(
+        IEnumerable<ISpecification<TEntity>> specifications,
+        Action<IEntityUpdateSet<TEntity>> set,
+        IFindOptions<TEntity> options = null,
+        CancellationToken cancellationToken = default)
+    {
+        return await this.Inner.UpdateSetAsync(specifications, set, options, cancellationToken).AnyContext();
+    }
+
     public async Task<RepositoryActionResult> DeleteAsync(object id, CancellationToken cancellationToken = default)
     {
         var entity = await this.Inner
@@ -92,6 +121,32 @@ await entity.DomainEvents.GetAll()
         return result;
     }
 
+    /// <inheritdoc />
+    public async Task<long> DeleteSetAsync(
+        IFindOptions<TEntity> options = null,
+        CancellationToken cancellationToken = default)
+    {
+        return await this.Inner.DeleteSetAsync(options, cancellationToken).AnyContext();
+    }
+
+    /// <inheritdoc />
+    public async Task<long> DeleteSetAsync(
+        ISpecification<TEntity> specification,
+        IFindOptions<TEntity> options = null,
+        CancellationToken cancellationToken = default)
+    {
+        return await this.Inner.DeleteSetAsync(specification, options, cancellationToken).AnyContext();
+    }
+
+    /// <inheritdoc />
+    public async Task<long> DeleteSetAsync(
+        IEnumerable<ISpecification<TEntity>> specifications,
+        IFindOptions<TEntity> options = null,
+        CancellationToken cancellationToken = default)
+    {
+        return await this.Inner.DeleteSetAsync(specifications, options, cancellationToken).AnyContext();
+    }
+
     public async Task<TEntity> FindOneAsync(
         object id,
         IFindOptions<TEntity> options = null,
@@ -232,4 +287,4 @@ public async Task<long> CountAsync(
     {
         return await this.Inner.CountAsync(specifications, cancellationToken).AnyContext();
     }
-}
+}

src/Domain.Mediator/RepositoryDomainEventMediatorPublisherBehavior.cs

@@ -51,6 +51,35 @@ public RepositoryAuditStateBehavior(IGenericRepository<TEntity> ínner)
 
     protected IGenericRepository<TEntity> Inner { get; }
 
+    /// <inheritdoc />
+    public async Task<long> UpdateSetAsync(
+        Action<IEntityUpdateSet<TEntity>> set,
+        IFindOptions<TEntity> options = null,
+        CancellationToken cancellationToken = default)
+    {
+        return await this.Inner.UpdateSetAsync(set, options, cancellationToken).AnyContext();
+    }
+
+    /// <inheritdoc />
+    public async Task<long> UpdateSetAsync(
+        ISpecification<TEntity> specification,
+        Action<IEntityUpdateSet<TEntity>> set,
+        IFindOptions<TEntity> options = null,
+        CancellationToken cancellationToken = default)
+    {
+        return await this.Inner.UpdateSetAsync(specification, set, options, cancellationToken).AnyContext();
+    }
+
+    /// <inheritdoc />
+    public async Task<long> UpdateSetAsync(
+        IEnumerable<ISpecification<TEntity>> specifications,
+        Action<IEntityUpdateSet<TEntity>> set,
+        IFindOptions<TEntity> options = null,
+        CancellationToken cancellationToken = default)
+    {
+        return await this.Inner.UpdateSetAsync(specifications, set, options, cancellationToken).AnyContext();
+    }
+
     public async Task<RepositoryActionResult> DeleteAsync(object id, CancellationToken cancellationToken = default)
     {
         if (id != default && this.options.SoftDeleteEnabled)
@@ -83,6 +112,32 @@ public async Task<RepositoryActionResult> DeleteAsync(TEntity entity, Cancellati
         return await this.Inner.DeleteAsync(entity, cancellationToken).AnyContext();
     }
 
+    /// <inheritdoc />
+    public async Task<long> DeleteSetAsync(
+        IFindOptions<TEntity> options = null,
+        CancellationToken cancellationToken = default)
+    {
+        return await this.Inner.DeleteSetAsync(options, cancellationToken).AnyContext();
+    }
+
+    /// <inheritdoc />
+    public async Task<long> DeleteSetAsync(
+        ISpecification<TEntity> specification,
+        IFindOptions<TEntity> options = null,
+        CancellationToken cancellationToken = default)
+    {
+        return await this.Inner.DeleteSetAsync(specification, options, cancellationToken).AnyContext();
+    }
+
+    /// <inheritdoc />
+    public async Task<long> DeleteSetAsync(
+        IEnumerable<ISpecification<TEntity>> specifications,
+        IFindOptions<TEntity> options = null,
+        CancellationToken cancellationToken = default)
+    {
+        return await this.Inner.DeleteSetAsync(specifications, options, cancellationToken).AnyContext();
+    }
+
     public async Task<bool> ExistsAsync(object id, CancellationToken cancellationToken = default)
     {
         var entity = await this.Inner.FindOneAsync(id, cancellationToken: cancellationToken).AnyContext();
@@ -273,4 +328,4 @@ public enum AuditStateByType
     ByUserId = 0,
     ByUserName = 1,
     ByEmail = 2
-}
+}