Aggiunto DbContext generico e relativi metodi

Author: Angelo Pirola

src/NET6CustomLibrary/EFCore/Core/Command.cs

@@ -0,0 +1,36 @@
+namespace NET6CustomLibrary.EFCore.Core;
+
+public class Command<TEntity, TKey> : ICommand<TEntity, TKey> where TEntity : class, IEntity<TKey>, new()
+{
+    public DbContext DbContext { get; }
+
+    public Command(DbContext dbContext)
+    {
+        DbContext = dbContext ?? throw new ArgumentNullException(nameof(dbContext));
+    }
+
+    public async Task CreateAsync(TEntity entity)
+    {
+        DbContext.Set<TEntity>().Add(entity);
+
+        await DbContext.SaveChangesAsync();
+
+        DbContext.Entry(entity).State = EntityState.Detached;
+    }
+
+    public async Task UpdateAsync(TEntity entity)
+    {
+        DbContext.Set<TEntity>().Update(entity);
+
+        await DbContext.SaveChangesAsync();
+
+        DbContext.Entry(entity).State = EntityState.Detached;
+    }
+
+    public async Task DeleteAsync(TEntity entity)
+    {
+        DbContext.Set<TEntity>().Remove(entity);
+
+        await DbContext.SaveChangesAsync();
+    }
+}

src/NET6CustomLibrary/EFCore/Core/Database.cs

@@ -0,0 +1,33 @@
+namespace NET6CustomLibrary.EFCore.Core;
+
+public class Database<TEntity, TKey> : IDatabase<TEntity, TKey> where TEntity : class, IEntity<TKey>, new()
+{
+    public DbContext DbContext { get; }
+
+    public Database(DbContext dbContext)
+    {
+        DbContext = dbContext ?? throw new ArgumentNullException(nameof(dbContext));
+    }
+
+    public async Task<List<TEntity>> GetAllAsync()
+    {
+        return await DbContext.Set<TEntity>()
+            .AsNoTracking()
+            .ToListAsync();
+    }
+
+    public async Task<TEntity> GetByIdAsync(TKey id)
+    {
+        var entity = await DbContext.Set<TEntity>()
+            .FindAsync(id);
+
+        if (entity == null)
+        {
+            return null;
+        }
+
+        DbContext.Entry(entity).State = EntityState.Detached;
+
+        return entity;
+    }
+}

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

@@ -0,0 +1,25 @@
+namespace NET6CustomLibrary.EFCore.Core.Interfaces;
+
+public interface ICommand<TEntity, TKey> where TEntity : class, IEntity<TKey>, new()
+{
+    /// <summary>
+    /// Create an item.
+    /// </summary>
+    /// <param name="entity"></param>
+    /// <returns></returns>
+    Task CreateAsync(TEntity entity);
+
+    /// <summary>
+    /// Update an item.
+    /// </summary>
+    /// <param name="entity"></param>
+    /// <returns></returns>
+    Task UpdateAsync(TEntity entity);
+
+    /// <summary>
+    /// Delete an item.
+    /// </summary>
+    /// <param name="entity"></param>
+    /// <returns></returns>
+    Task DeleteAsync(TEntity entity);
+}

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

@@ -0,0 +1,17 @@
+namespace NET6CustomLibrary.EFCore.Core.Interfaces;
+
+public interface IDatabase<TEntity, TKey> where TEntity : class, IEntity<TKey>, new()
+{
+    /// <summary>
+    /// Get the list of items.
+    /// </summary>
+    /// <returns></returns>
+    Task<List<TEntity>> GetAllAsync();
+
+    /// <summary>
+    /// Gets the item with the specified identifier.
+    /// </summary>
+    /// <param name="id"></param>
+    /// <returns></returns>
+    Task<TEntity> GetByIdAsync(TKey id);
+}

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

@@ -0,0 +1,9 @@
+namespace NET6CustomLibrary.EFCore.Core.Interfaces;
+
+public interface IEntity<TKey>
+{
+    /// <summary>
+    /// Defines the type of the ID field
+    /// </summary>
+    TKey Id { get; set; }
+}

src/NET6CustomLibrary/EFCore/Infrastructure/Interfaces/ICommandRepository.cs

@@ -0,0 +1,5 @@
+namespace NET6CustomLibrary.EFCore.Infrastructure.Interfaces;
+
+public interface ICommandRepository<TEntity, TKey> : ICommand<TEntity, TKey> where TEntity : class, IEntity<TKey>, new()
+{
+}

src/NET6CustomLibrary/EFCore/Infrastructure/Interfaces/IDatabaseRepository.cs

@@ -0,0 +1,5 @@
+namespace EFCoreGeneric.Infrastructure.Interfaces;
+
+public interface IDatabaseRepository<TEntity, TKey> : IDatabase<TEntity, TKey> where TEntity : class, IEntity<TKey>, new()
+{
+}

src/NET6CustomLibrary/EFCore/Infrastructure/Interfaces/IUnitOfWork.cs

@@ -0,0 +1,7 @@
+namespace NET6CustomLibrary.EFCore.Infrastructure.Interfaces;
+
+public interface IUnitOfWork<TEntity, TKey> : IDisposable where TEntity : class, IEntity<TKey>, new()
+{
+    IDatabaseRepository<TEntity, TKey> ReadOnly { get; }
+    ICommandRepository<TEntity, TKey> Command { get; }
+}

src/NET6CustomLibrary/EFCore/Infrastructure/Repository/CommandRepository.cs

@@ -0,0 +1,8 @@
+namespace NET6CustomLibrary.EFCore.Infrastructure.Repository;
+
+public class CommandRepository<TEntity, TKey> : Command<TEntity, TKey>, ICommandRepository<TEntity, TKey> where TEntity : class, IEntity<TKey>, new()
+{
+    public CommandRepository(DbContext dbContext) : base(dbContext)
+    {
+    }
+}

src/NET6CustomLibrary/EFCore/Infrastructure/Repository/DatabaseRepository.cs

@@ -0,0 +1,8 @@
+namespace NET6CustomLibrary.EFCore.Infrastructure.Repository;
+
+public class DatabaseRepository<TEntity, TKey> : Database<TEntity, TKey>, IDatabaseRepository<TEntity, TKey> where TEntity : class, IEntity<TKey>, new()
+{
+    public DatabaseRepository(DbContext dbContext) : base(dbContext)
+    {
+    }
+}