Repository Design

Tahsin020 · Tahsin020 · commit 0c1943a26f5b · 2022-12-25T17:46:49.000+03:00
diff --git a/Core/ETicaretAPI.Application/ETicaretAPI.Application.csproj b/Core/ETicaretAPI.Application/ETicaretAPI.Application.csproj
@@ -6,6 +6,10 @@
     <Nullable>enable</Nullable>
   </PropertyGroup>
 
+  <ItemGroup>
+    <PackageReference Include="Microsoft.EntityFrameworkCore" Version="7.0.1" />
+  </ItemGroup>
+
   <ItemGroup>
     <ProjectReference Include="..\ETicaretAPI.Domain\ETicaretAPI.Domain.csproj" />
   </ItemGroup>
diff --git a/Core/ETicaretAPI.Application/Repositories/Customer/ICustomerReadRepository.cs b/Core/ETicaretAPI.Application/Repositories/Customer/ICustomerReadRepository.cs
@@ -0,0 +1,14 @@
+﻿using ETicaretAPI.Domain.Entities;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ETicaretAPI.Application.Repositories
+{
+    public interface ICustomerReadRepository : IReadRepository<Customer>
+    {
+
+    }
+}
diff --git a/Core/ETicaretAPI.Application/Repositories/Customer/ICustomerWriteRepository.cs b/Core/ETicaretAPI.Application/Repositories/Customer/ICustomerWriteRepository.cs
@@ -0,0 +1,13 @@
+﻿using ETicaretAPI.Domain.Entities;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ETicaretAPI.Application.Repositories
+{
+    public interface ICustomerWriteRepository : IWriteRepository<Customer>
+    {
+    }
+}
diff --git a/Core/ETicaretAPI.Application/Repositories/IReadRepository.cs b/Core/ETicaretAPI.Application/Repositories/IReadRepository.cs
@@ -0,0 +1,18 @@
+﻿using ETicaretAPI.Domain.Entities.Common;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Linq.Expressions;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ETicaretAPI.Application.Repositories
+{
+    public interface IReadRepository<T> : IRepository<T> where T : BaseEntity
+    {
+        IQueryable<T> GetAll();
+        IQueryable<T> GetWhere(Expression<Func<T,bool>> method);
+        Task<T> GetSingleAsync(Expression<Func<T, bool>> method);
+        Task<T> GetByIdAsync(string id);
+    }
+}
diff --git a/Core/ETicaretAPI.Application/Repositories/IRepository.cs b/Core/ETicaretAPI.Application/Repositories/IRepository.cs
@@ -0,0 +1,15 @@
+﻿using ETicaretAPI.Domain.Entities.Common;
+using Microsoft.EntityFrameworkCore;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ETicaretAPI.Application.Repositories
+{
+    public interface IRepository<T> where T : BaseEntity
+    {
+        DbSet<T> Table { get; }
+    }
+}
diff --git a/Core/ETicaretAPI.Application/Repositories/IWriteRepository.cs b/Core/ETicaretAPI.Application/Repositories/IWriteRepository.cs
@@ -0,0 +1,21 @@
+﻿using ETicaretAPI.Domain.Entities.Common;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ETicaretAPI.Application.Repositories
+{
+    public interface IWriteRepository<T> : IRepository<T> where T : BaseEntity
+    {
+        Task<bool> AddAsync(T model);
+        Task<bool> AddRangeAsync(List<T> datas);
+        bool Update(T model);
+        bool Remove(T model);
+        bool RemoveRange(List<T> datas);
+        Task<bool> RemoveAsync(string id);
+
+        Task<int> SaveAsync();
+    }
+}
diff --git a/Core/ETicaretAPI.Application/Repositories/Order/IOrderReadRepository.cs b/Core/ETicaretAPI.Application/Repositories/Order/IOrderReadRepository.cs
@@ -0,0 +1,14 @@
+﻿using ETicaretAPI.Domain.Entities;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ETicaretAPI.Application.Repositories
+{
+    public interface IOrderReadRepository : IReadRepository<Order>
+    {
+
+    }
+}
diff --git a/Core/ETicaretAPI.Application/Repositories/Order/IOrderWriteRepository.cs b/Core/ETicaretAPI.Application/Repositories/Order/IOrderWriteRepository.cs
@@ -0,0 +1,13 @@
+﻿using ETicaretAPI.Domain.Entities;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ETicaretAPI.Application.Repositories
+{
+    public interface IOrderWriteRepository:IWriteRepository<Order>
+    {
+    }
+}
diff --git a/Core/ETicaretAPI.Application/Repositories/Product/IProductReadRepository.cs b/Core/ETicaretAPI.Application/Repositories/Product/IProductReadRepository.cs
@@ -0,0 +1,14 @@
+﻿using ETicaretAPI.Domain.Entities;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ETicaretAPI.Application.Repositories
+{
+    public interface IProductReadRepository:IReadRepository<Product>
+    {
+
+    }
+}
diff --git a/Core/ETicaretAPI.Application/Repositories/Product/IProductWriteRepository.cs b/Core/ETicaretAPI.Application/Repositories/Product/IProductWriteRepository.cs
@@ -0,0 +1,14 @@
+﻿using ETicaretAPI.Domain.Entities;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ETicaretAPI.Application.Repositories
+{
+    public interface IProductWriteRepository:IWriteRepository<Product>
+    {
+
+    }
+}
diff --git a/Infrastructure/ETicaretAPI.Persistence/Repositories/Customer/CustomerReadRepository.cs b/Infrastructure/ETicaretAPI.Persistence/Repositories/Customer/CustomerReadRepository.cs
@@ -0,0 +1,18 @@
+﻿using ETicaretAPI.Application.Repositories;
+using ETicaretAPI.Domain.Entities;
+using ETicaretAPI.Persistence.Contexts;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ETicaretAPI.Persistence.Repositories
+{
+    public class CustomerReadRepository : ReadRepository<Customer>, ICustomerReadRepository
+    {
+        public CustomerReadRepository(ETicaretAPIDbContext context) : base(context)
+        {
+        }
+    }
+}
diff --git a/Infrastructure/ETicaretAPI.Persistence/Repositories/Customer/CustomerWriteRepository.cs b/Infrastructure/ETicaretAPI.Persistence/Repositories/Customer/CustomerWriteRepository.cs
@@ -0,0 +1,18 @@
+﻿using ETicaretAPI.Application.Repositories;
+using ETicaretAPI.Domain.Entities;
+using ETicaretAPI.Persistence.Contexts;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ETicaretAPI.Persistence.Repositories
+{
+    public class CustomerWriteRepository : WriteRepository<Customer>, ICustomerWriteRepository
+    {
+        public CustomerWriteRepository(ETicaretAPIDbContext context) : base(context)
+        {
+        }
+    }
+}
diff --git a/Infrastructure/ETicaretAPI.Persistence/Repositories/Order/OrderReadRepository.cs b/Infrastructure/ETicaretAPI.Persistence/Repositories/Order/OrderReadRepository.cs
@@ -0,0 +1,18 @@
+﻿using ETicaretAPI.Application.Repositories;
+using ETicaretAPI.Domain.Entities;
+using ETicaretAPI.Persistence.Contexts;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ETicaretAPI.Persistence.Repositories
+{
+    public class OrderReadRepository : ReadRepository<Order>, IOrderReadRepository
+    {
+        public OrderReadRepository(ETicaretAPIDbContext context) : base(context)
+        {
+        }
+    }
+}
diff --git a/Infrastructure/ETicaretAPI.Persistence/Repositories/Order/OrderWriteRepository.cs b/Infrastructure/ETicaretAPI.Persistence/Repositories/Order/OrderWriteRepository.cs
@@ -0,0 +1,18 @@
+﻿using ETicaretAPI.Application.Repositories;
+using ETicaretAPI.Domain.Entities;
+using ETicaretAPI.Persistence.Contexts;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ETicaretAPI.Persistence.Repositories
+{
+    public class OrderWriteRepository : WriteRepository<Order>, IOrderWriteRepository
+    {
+        public OrderWriteRepository(ETicaretAPIDbContext context) : base(context)
+        {
+        }
+    }
+}
diff --git a/Infrastructure/ETicaretAPI.Persistence/Repositories/Product/ProductReadRepository.cs b/Infrastructure/ETicaretAPI.Persistence/Repositories/Product/ProductReadRepository.cs
@@ -0,0 +1,18 @@
+﻿using ETicaretAPI.Application.Repositories;
+using ETicaretAPI.Domain.Entities;
+using ETicaretAPI.Persistence.Contexts;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ETicaretAPI.Persistence.Repositories
+{
+    public class ProductReadRepository : ReadRepository<Product>, IProductReadRepository
+    {
+        public ProductReadRepository(ETicaretAPIDbContext context) : base(context)
+        {
+        }
+    }
+}
diff --git a/Infrastructure/ETicaretAPI.Persistence/Repositories/Product/ProductWriteRepository.cs b/Infrastructure/ETicaretAPI.Persistence/Repositories/Product/ProductWriteRepository.cs
@@ -0,0 +1,18 @@
+﻿using ETicaretAPI.Application.Repositories;
+using ETicaretAPI.Domain.Entities;
+using ETicaretAPI.Persistence.Contexts;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ETicaretAPI.Persistence.Repositories
+{
+    public class ProductWriteRepository : WriteRepository<Product>, IProductWriteRepository
+    {
+        public ProductWriteRepository(ETicaretAPIDbContext context) : base(context)
+        {
+        }
+    }
+}
diff --git a/Infrastructure/ETicaretAPI.Persistence/Repositories/ReadRepository.cs b/Infrastructure/ETicaretAPI.Persistence/Repositories/ReadRepository.cs
@@ -0,0 +1,38 @@
+﻿using ETicaretAPI.Application.Repositories;
+using ETicaretAPI.Domain.Entities.Common;
+using ETicaretAPI.Persistence.Contexts;
+using Microsoft.EntityFrameworkCore;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Linq.Expressions;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ETicaretAPI.Persistence.Repositories
+{
+    public class ReadRepository<T> : IReadRepository<T> where T : BaseEntity
+    {
+        private readonly ETicaretAPIDbContext _context;
+
+        public ReadRepository(ETicaretAPIDbContext context)
+        {
+            _context = context;
+        }
+
+        public DbSet<T> Table => _context.Set<T>();
+
+        public IQueryable<T> GetAll() => Table;
+
+        public IQueryable<T> GetWhere(Expression<Func<T, bool>> method)
+            => Table.Where(method);
+
+        public async Task<T> GetSingleAsync(Expression<Func<T, bool>> method)
+            => await Table.FirstOrDefaultAsync(method);
+
+        public async Task<T> GetByIdAsync(string id)
+            => await Table.FirstOrDefaultAsync(data => data.Id == Guid.Parse(id));
+
+
+    }
+}
diff --git a/Infrastructure/ETicaretAPI.Persistence/Repositories/WriteRepository.cs b/Infrastructure/ETicaretAPI.Persistence/Repositories/WriteRepository.cs
@@ -0,0 +1,60 @@
+﻿using ETicaretAPI.Application.Repositories;
+using ETicaretAPI.Domain.Entities.Common;
+using ETicaretAPI.Persistence.Contexts;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.ChangeTracking;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ETicaretAPI.Persistence.Repositories
+{
+    public class WriteRepository<T> : IWriteRepository<T> where T : BaseEntity
+    {
+        private readonly ETicaretAPIDbContext _context;
+
+        public WriteRepository(ETicaretAPIDbContext context)
+        {
+            _context = context;
+        }
+
+        public DbSet<T> Table => _context.Set<T>();
+
+        public async Task<bool> AddAsync(T model)
+        {
+            EntityEntry<T> entityEntry = await Table.AddAsync(model);
+            return entityEntry.State == EntityState.Added;
+        }
+        public async Task<bool> AddRangeAsync(List<T> datas)
+        {
+            await Table.AddRangeAsync(datas);
+            return true;
+        }
+        public bool Remove(T model)
+        {
+            EntityEntry entityEntry = Table.Remove(model);
+            return entityEntry.State == EntityState.Deleted;
+        }
+        public async Task<bool> RemoveAsync(string id)
+        {
+            T model = await Table.FirstOrDefaultAsync(data => data.Id == Guid.Parse(id));
+            return Remove(model);
+        }
+
+        public bool RemoveRange(List<T> datas)
+        {
+            Table.RemoveRange(datas);
+            return true;
+        }
+
+        public async Task<int> SaveAsync() => await _context.SaveChangesAsync();
+
+        public bool Update(T model)
+        {
+            EntityEntry entityEntry = Table.Update(model);
+            return entityEntry.State == EntityState.Modified;
+        }
+    }
+}
diff --git a/Infrastructure/ETicaretAPI.Persistence/ServiceRegistration.cs b/Infrastructure/ETicaretAPI.Persistence/ServiceRegistration.cs
@@ -1,4 +1,6 @@
-﻿using ETicaretAPI.Persistence.Contexts;
+﻿using ETicaretAPI.Application.Repositories;
+using ETicaretAPI.Persistence.Contexts;
+using ETicaretAPI.Persistence.Repositories;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.DependencyInjection;
 using System;
@@ -13,7 +15,15 @@ public static class ServiceRegistration
     {
         public static void AddPersistenceServices(this IServiceCollection services)
         {
-            services.AddDbContext<ETicaretAPIDbContext>(options => options.UseNpgsql(Configuration.ConnectionString));
+            services.AddDbContext<ETicaretAPIDbContext>(options => options.UseNpgsql(Configuration.ConnectionString),ServiceLifetime.Singleton);
+            services.AddSingleton<ICustomerReadRepository,CustomerReadRepository>();
+            services.AddSingleton<ICustomerWriteRepository, CustomerWriteRepository>();
+            services.AddSingleton<IOrderReadRepository, OrderReadRepository>();
+            services.AddSingleton<IOrderWriteRepository, OrderWriteRepository>();
+            services.AddSingleton<IProductReadRepository,  ProductReadRepository>();
+            services.AddSingleton<IProductWriteRepository, ProductWriteRepository>();
+            
+
         }
     }
 }
diff --git a/Presentation/ETicaretAPI.API/Controllers/ProductsController.cs b/Presentation/ETicaretAPI.API/Controllers/ProductsController.cs
