Aggiunte implementazioni EFCore Transaction

Author: AngeloDotNet

src/NET6CustomLibrary/EFCoreTransaction/Core/Interfaces/IRepository.cs

@@ -0,0 +1,16 @@
+namespace NET6CustomLibrary.EFCoreTransaction.Core.Interfaces;
+
+public interface IRepository<TEntity, TKey> where TEntity : class, ITEntity<TKey>, new()
+{
+    //GET
+    Task<List<TEntity>> GetAllTAsync();
+    Task<TEntity> GetByIdTAsync(TKey id);
+    Task<List<TEntity>> GetOrderByIdAscendingTAsync();
+    Task<List<TEntity>> GetOrderByIdDescendingTAsync();
+    Task<int> GetCountTAsync();
+
+    // SET
+    Task CreateTAsync(TEntity entity);
+    Task UpdateTAsync(TEntity entity);
+    Task DeleteTAsync(TEntity entity);
+}

src/NET6CustomLibrary/EFCoreTransaction/Core/Interfaces/ITEntity.cs

@@ -0,0 +1,6 @@
+namespace NET6CustomLibrary.EFCoreTransaction.Core.Interfaces;
+
+public interface ITEntity<TKey>
+{
+    TKey Id { get; set; }
+}

src/NET6CustomLibrary/EFCoreTransaction/Core/Repository.cs

@@ -0,0 +1,90 @@
+namespace NET6CustomLibrary.EFCoreTransaction.Core;
+
+public class Repository<TEntity, TKey> : IRepository<TEntity, TKey> where TEntity : class, ITEntity<TKey>, new()
+{
+    public DbContext DbContext { get; }
+
+    public Repository(DbContext dbContext) => DbContext = dbContext ?? throw new ArgumentNullException(nameof(dbContext));
+
+    public async Task CreateTAsync(TEntity entity)
+    {
+        using var transaction = await DbContext.Database.BeginTransactionAsync();
+
+        try
+        {
+            DbContext.Set<TEntity>().Add(entity);
+            await DbContext.SaveChangesAsync();
+            DbContext.Entry(entity).State = EntityState.Detached;
+
+            await transaction.CommitAsync();
+        }
+        catch (Exception)
+        {
+            await transaction.RollbackAsync();
+            throw;
+        }
+    }
+
+    public async Task UpdateTAsync(TEntity entity)
+    {
+        using var transaction = await DbContext.Database.BeginTransactionAsync();
+
+        try
+        {
+            DbContext.Set<TEntity>().Update(entity);
+            await DbContext.SaveChangesAsync();
+            DbContext.Entry(entity).State = EntityState.Detached;
+
+            transaction.Commit();
+        }
+        catch (Exception)
+        {
+            await transaction.RollbackAsync();
+            throw;
+        }
+    }
+
+    public async Task DeleteTAsync(TEntity entity)
+    {
+        using var transaction = await DbContext.Database.BeginTransactionAsync();
+
+        try
+        {
+            DbContext.Set<TEntity>().Remove(entity);
+            await DbContext.SaveChangesAsync();
+
+            transaction.Commit();
+        }
+        catch (Exception)
+        {
+            await transaction.RollbackAsync();
+            throw;
+        }
+    }
+
+    public async Task<List<TEntity>> GetAllTAsync() => await DbContext.Set<TEntity>()
+        .AsNoTracking().ToListAsync();
+
+    public async Task<TEntity> GetByIdTAsync(TKey id)
+    {
+        var entity = await DbContext.Set<TEntity>()
+            .FindAsync(id);
+
+        if (entity == null)
+        {
+            return null;
+        }
+
+        DbContext.Entry(entity).State = EntityState.Detached;
+
+        return entity;
+    }
+
+    public async Task<List<TEntity>> GetOrderByIdAscendingTAsync() => await DbContext.Set<TEntity>()
+        .OrderBy(x => x.Id).AsNoTracking().ToListAsync();
+
+    public async Task<List<TEntity>> GetOrderByIdDescendingTAsync() => await DbContext.Set<TEntity>()
+        .OrderByDescending(x => x.Id).AsNoTracking().ToListAsync();
+
+    public async Task<int> GetCountTAsync() => await DbContext.Set<TEntity>().CountAsync();
+}

src/NET6CustomLibrary/EFCoreTransaction/Infrastructure/Interfaces/ITUnitOfWork.cs

@@ -0,0 +1,6 @@
+namespace NET6CustomLibrary.EFCoreTransaction.Infrastructure.Interfaces;
+
+public interface ITUnitOfWork<TEntity, TKey> : IDisposable where TEntity : class, ITEntity<TKey>, new()
+{
+    IRepository<TEntity, TKey> Repository { get; }
+}

src/NET6CustomLibrary/EFCoreTransaction/Infrastructure/TUnitOfWork.cs

@@ -0,0 +1,27 @@
+namespace NET6CustomLibrary.EFCoreTransaction.Infrastructure;
+
+public class TUnitOfWork<TEntity, TKey> : ITUnitOfWork<TEntity, TKey> where TEntity : class, ITEntity<TKey>, new()
+{
+    public DbContext DbContext { get; }
+    public IRepository<TEntity, TKey> Repository { get; }
+
+    public TUnitOfWork(DbContext dbContext, IRepository<TEntity, TKey> repository)
+    {
+        DbContext = dbContext;
+        Repository = repository;
+    }
+
+    public void Dispose()
+    {
+        Dispose(true);
+        GC.SuppressFinalize(this);
+    }
+
+    protected virtual void Dispose(bool disposing)
+    {
+        if (disposing)
+        {
+            DbContext.Dispose();
+        }
+    }
+}

src/NET6CustomLibrary/Extensions/DependencyInjection.cs

@@ -110,6 +110,15 @@ public static IServiceCollection AddDbContextGenericsMethods<TDbContext>(this IS
         return services;
     }
 
+    public static IServiceCollection AddDbContextTransactionMethods<TDbContext>(this IServiceCollection services) where TDbContext : DbContext
+    {
+        services.AddScoped<DbContext, TDbContext>();
+        services.AddScoped(typeof(ITUnitOfWork<,>), typeof(TUnitOfWork<,>));
+        services.AddScoped(typeof(IRepository<,>), typeof(Repository<,>));
+
+        return services;
+    }
+
     /// <summary>
     /// Extension method per aggiungere un DbContext di tipo TDbContext con il provider MySQL / MariaDB
     /// </summary>
@@ -296,7 +305,7 @@ public static IEndpointRouteBuilder AddDatabaseHealthChecks(this IEndpointRouteB
             {
                 ResponseWriter = async (context, report) =>
                 {
-                    var result = System.Text.Json.JsonSerializer.Serialize(new
+                    var result = JsonSerializer.Serialize(new
                     {
                         status = report.Status.ToString(),
                         details = report.Entries.Select(e => new
@@ -318,7 +327,7 @@ public static IEndpointRouteBuilder AddDatabaseHealthChecks(this IEndpointRouteB
             {
                 ResponseWriter = async (context, report) =>
                 {
-                    var result = System.Text.Json.JsonSerializer.Serialize(new
+                    var result = JsonSerializer.Serialize(new
                     {
                         status = report.Status.ToString(),
                         details = report.Entries.Select(e => new

src/NET6CustomLibrary/GlobalUsings.cs

@@ -41,6 +41,10 @@
 global using NET6CustomLibrary.EFCore.Core.Interfaces;
 global using NET6CustomLibrary.EFCore.Infrastructure.Interfaces;
 global using NET6CustomLibrary.EFCore.Infrastructure.Repository;
+global using NET6CustomLibrary.EFCoreTransaction.Core;
+global using NET6CustomLibrary.EFCoreTransaction.Core.Interfaces;
+global using NET6CustomLibrary.EFCoreTransaction.Infrastructure;
+global using NET6CustomLibrary.EFCoreTransaction.Infrastructure.Interfaces;
 global using NET6CustomLibrary.MailKit.Options;
 global using NET6CustomLibrary.MailKit.Services;
 global using NET6CustomLibrary.MultiLanguage;