added dapper and category get and get all methods

src/Application/Abstractions/Data/IDbConnectionFactory.cs

@@ -1,8 +1,8 @@
-using System.Data;
+using System.Data.Common;
 
 namespace Application.Abstractions.Data;
 
 public interface IDbConnectionFactory
 {
- IDbConnection GetOpenConnection();
+ ValueTask<DbConnection> OpenConnectionAsync();
 }

src/Application/Abstractions/Models/PaginatedList.cs

@@ -0,0 +1,32 @@
+using Microsoft.EntityFrameworkCore;
+
+namespace Application.Abstractions.Models;
+public class PaginatedList<T>
+{
+ public IReadOnlyCollection<T> Items { get; }
+ public int PageNumber { get; }
+ public int TotalPages { get; }
+ public int TotalCount { get; }
+
+ public PaginatedList(IReadOnlyCollection<T> items, int count, int pageNumber, int pageSize)
+ {
+ PageNumber = pageNumber;
+ TotalPages = (int)Math.Ceiling(count / (double)pageSize);
+ TotalCount = count;
+ Items = items;
+ }
+
+ public bool HasPreviousPage => PageNumber > 1;
+
+ public bool HasNextPage => PageNumber < TotalPages;
+
+ public static async Task<PaginatedList<T>> CreateAsync(IQueryable<T> source, int pageNumber, int pageSize)
+ {
+#pragma warning disable IDE0008 // Use explicit type
+ var count = await source.CountAsync();
+ var items = await source.Skip((pageNumber - 1) * pageSize).Take(pageSize).ToListAsync();
+#pragma warning restore IDE0008 // Use explicit type
+
+ return new PaginatedList<T>(items, count, pageNumber, pageSize);
+ }
+}

src/Application/Application.csproj

@@ -10,6 +10,7 @@
  <PackageReference Include="Dapper" Version="2.1.35" />
  <PackageReference Include="FluentValidation.DependencyInjectionExtensions" Version="11.9.1" />
  <PackageReference Include="MediatR" Version="12.3.0" />
+ <PackageReference Include="Microsoft.EntityFrameworkCore" Version="8.0.6" />
  <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="8.0.1" />
  <PackageReference Include="Serilog" Version="4.0.0" />
  </ItemGroup>

src/Application/Categories/Get/CategoryResponse.cs

@@ -0,0 +1,2 @@
+namespace Application.Categories.Get;
+public sealed record CategoryResponse(Guid Id, string Name);

src/Application/Categories/Get/GetCategoryQuery.cs

@@ -0,0 +1,4 @@
+using Application.Abstractions.Messaging;
+
+namespace Application.Categories.Get;
+public sealed record GetCategoryQuery(Guid CategoryId) : IQuery<CategoryResponse>;

src/Application/Categories/Get/GetCategoryQueryHandler.cs

@@ -0,0 +1,34 @@
+using System.Data.Common;
+using Application.Abstractions.Data;
+using Application.Abstractions.Messaging;
+using Dapper;
+using Domain.Categories;
+using SharedKernel;
+
+namespace Application.Categories.Get;
+internal sealed class GetCategoryQueryHandler(IDbConnectionFactory dbConnectionFactory)
+ : IQueryHandler<GetCategoryQuery, CategoryResponse>
+{
+ public async Task<Result<CategoryResponse>> Handle(GetCategoryQuery request, CancellationToken cancellationToken)
+ {
+ await using DbConnection connection = await dbConnectionFactory.OpenConnectionAsync();
+
+ const string sql =
+ $"""
+ SELECT
+ id AS {nameof(CategoryResponse.Id)},
+ name AS {nameof(CategoryResponse.Name)}
+ FROM categories
+ WHERE id = @CategoryId
+ """;
+
+ CategoryResponse? category = await connection.QuerySingleOrDefaultAsync<CategoryResponse>(sql, request);
+
+ if (category is null)
+ {
+ return Result.Failure<CategoryResponse>(CategoryErrors.NotFound(request.CategoryId));
+ }
+
+ return category;
+ }
+}

src/Application/Categories/GetAll/GetCategoriesQuery.cs

@@ -0,0 +1,6 @@
+using Application.Abstractions.Messaging;
+using Application.Abstractions.Models;
+using Application.Categories.Get;
+
+namespace Application.Categories.GetAll;
+public sealed record GetCategoriesQuery(int PageNumber, int PageSize) : IQuery<PaginatedList<CategoryResponse>>;

src/Application/Categories/GetAll/GetCategoriesQueryHandler.cs

@@ -0,0 +1,44 @@
+using System.Data.Common;
+using Application.Abstractions.Data;
+using Application.Abstractions.Messaging;
+using Application.Abstractions.Models;
+using Application.Categories.Get;
+using Dapper;
+using SharedKernel;
+
+namespace Application.Categories.GetAll;
+internal sealed class GetCategoriesQueryHandler(IDbConnectionFactory dbConnectionFactory)
+ : IQueryHandler<GetCategoriesQuery, PaginatedList<CategoryResponse>>
+{
+ public async Task<Result<PaginatedList<CategoryResponse>>> Handle(GetCategoriesQuery request, CancellationToken cancellationToken)
+ {
+ await using DbConnection connection = await dbConnectionFactory.OpenConnectionAsync();
+
+ const string countSql = @"
+ SELECT COUNT(*)
+ FROM categories
+ ";
+
+ const string sql = @"
+ SELECT
+ id AS Id,
+ name AS Name
+ FROM categories
+ ORDER BY id
+ OFFSET @Offset ROWS
+ FETCH NEXT @PageSize ROWS ONLY
+ ";
+
+ int totalCount = await connection.ExecuteScalarAsync<int>(countSql);
+
+#pragma warning disable IDE0008 // Use explicit type
+#pragma warning disable IDE0037 // Use inferred member name
+ var categories = await connection.QueryAsync<CategoryResponse>(sql, new { Offset = (request.PageNumber - 1) * request.PageSize, PageSize = request.PageSize });
+#pragma warning restore IDE0037 // Use inferred member name
+#pragma warning restore IDE0008 // Use explicit type
+
+ var paginatedCategories = new PaginatedList<CategoryResponse>(categories.ToList(), totalCount, request.PageNumber, request.PageSize);
+
+ return Result.Success(paginatedCategories);
+ }
+}

src/Application/Users/GetByEmail/GetUserByEmailQueryHandler.cs

@@ -1,4 +1,4 @@
-using System.Data;
+using System.Data.Common;
 using Application.Abstractions.Data;
 using Application.Abstractions.Messaging;
 using Dapper;
@@ -23,7 +23,7 @@ FROM users u
  WHERE u.id = @Email
  """;
 
- using IDbConnection connection = factory.GetOpenConnection();
+ await using DbConnection connection = await factory.OpenConnectionAsync();
 
  UserResponse? user = await connection.QueryFirstOrDefaultAsync<UserResponse>(
  sql,

src/Application/Users/GetById/GetUserByIdQueryHandler.cs

@@ -1,4 +1,4 @@
-using System.Data;
+using System.Data.Common;
 using Application.Abstractions.Data;
 using Application.Abstractions.Messaging;
 using Dapper;
@@ -23,7 +23,7 @@ FROM users u
  WHERE u.id = @UserId
  """;
 
- using IDbConnection connection = factory.GetOpenConnection();
+ await using DbConnection connection = await factory.OpenConnectionAsync();
 
  UserResponse? user = await connection.QueryFirstOrDefaultAsync<UserResponse>(
  sql,

src/Infrastructure/Database/DbConnectionFactory.cs

@@ -1,15 +1,14 @@
-using System.Data;
+using System.Data.Common;
 using Application.Abstractions.Data;
 using Npgsql;
 
 namespace Infrastructure.Database;
 
 internal sealed class DbConnectionFactory(NpgsqlDataSource dataSource) : IDbConnectionFactory
 {
- public IDbConnection GetOpenConnection()
+ public async ValueTask<DbConnection> OpenConnectionAsync()
  {
- NpgsqlConnection connection = dataSource.OpenConnection();
-
- return connection;
+ return await dataSource.OpenConnectionAsync();
  }
 }
+

src/Infrastructure/DependencyInjection.cs

@@ -70,8 +70,8 @@ private static IServiceCollection AddDatabase(this IServiceCollection services,
  options => options
  .UseNpgsql(connectionString, npgsqlOptions =>
  npgsqlOptions.MigrationsHistoryTable(HistoryRepository.DefaultTableName, Schemas.Default))
- .UseSnakeCaseNamingConvention());
- //.UseQueryTrackingBehavior(QueryTrackingBehavior.NoTracking));
+ .UseSnakeCaseNamingConvention()
+ .UseQueryTrackingBehavior(QueryTrackingBehavior.NoTracking));
 
  services.AddScoped<IUnitOfWork>(sp => sp.GetRequiredService<ApplicationDbContext>());
 

src/Web.Api/Endpoints/Categories/Get.cs

@@ -1,4 +1,4 @@
-using Application.Categories.GetById;
+using Application.Categories.Get;
 using MediatR;
 using SharedKernel;
 using Web.Api.Extensions;
@@ -15,11 +15,11 @@ public void MapEndpoint(IEndpointRouteBuilder app)
  ISender sender,
  CancellationToken cancellationToken) =>
  {
- var query = new GetCategoryByIdQuery(categoryId);
+ var query = new GetCategoryQuery(categoryId);
 
- Result result = await sender.Send(query, cancellationToken);
+ Result<CategoryResponse> result = await sender.Send(query, cancellationToken);
 
- return result.Match(Results.NoContent, CustomResults.Problem);
+ return result.Match(Results.Ok, CustomResults.Problem);
  })
  .WithTags(Tags.Categories);
  }

src/Web.Api/Endpoints/Categories/GetAll.cs

@@ -0,0 +1,29 @@
+using Application.Abstractions.Models;
+using Application.Categories.Get;
+using Application.Categories.GetAll;
+using MediatR;
+using SharedKernel;
+using Web.Api.Extensions;
+using Web.Api.Infrastructure;
+
+namespace Web.Api.Endpoints.Categories;
+
+internal sealed class GetAll : IEndpoint
+{
+ public void MapEndpoint(IEndpointRouteBuilder app)
+ {
+ app.MapGet("categories", async (
+ int pageNumber,
+ int pageSize,
+ ISender sender,
+ CancellationToken cancellationToken) =>
+ {
+ var query = new GetCategoriesQuery(pageNumber, pageSize);
+
+ Result<PaginatedList<CategoryResponse>> result = await sender.Send(query, cancellationToken);
+
+ return result.Match(Results.Ok, CustomResults.Problem);
+ })
+ .WithTags(Tags.Categories);
+ }
+}