WIP: Metodi CRUD con Transaction

Author: AngeloDotNet

src/NET6CustomLibrary/EFCore/Core/Command.cs

@@ -33,4 +33,60 @@ public async Task DeleteAsync(TEntity entity)
 
         await DbContext.SaveChangesAsync();
     }
+
+    //public async Task CreateTransactionAsync(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 UpdateTransactionAsync(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 DeleteTransactionAsync(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;
+    //    }
+    //}
 }

src/NET6CustomLibrary/EFCore/Core/Interfaces/ICommand.cs

@@ -22,4 +22,10 @@
     /// <param name="entity"></param>
     /// <returns></returns>
     Task DeleteAsync(TEntity entity);
+
+    //Task CreateTransactionAsync(TEntity entity);
+
+    //Task UpdateTransactionAsync(TEntity entity);
+
+    //Task DeleteTransactionAsync(TEntity entity);
 }