rm-ventas/backend/src/Ventas.Infrastructure/Repositories/CatalogoRepository.cs

using Dapper;
using Npgsql;
using Ventas.Core.Interfaces;

namespace Ventas.Infrastructure.Repositories;

public class CatalogoRepository : ICatalogoRepository
{
    private readonly string _connectionString;

    public CatalogoRepository(string connectionString)
    {
        _connectionString = connectionString;
    }

    public async Task<IEnumerable<Dictionary<string, object>>> QuerySpAsync(string sp, object parameters)
    {
        using var connection = new NpgsqlConnection(_connectionString);
        var rows = await connection.QueryAsync(sp, parameters, commandType: System.Data.CommandType.StoredProcedure);
        return rows.Select(r => (Dictionary<string, object>)(IDictionary<string, object>)r!);
    }

    public async Task<string> ExecuteSpAsync(string sp, object parameters)
    {
        using var connection = new NpgsqlConnection(_connectionString);
        await connection.ExecuteAsync(sp, parameters, commandType: System.Data.CommandType.StoredProcedure);
        return "ok";
    }

    public async Task<string?> QuerySingleSpAsync(string sp, object parameters)
    {
        using var connection = new NpgsqlConnection(_connectionString);
        return await connection.QuerySingleOrDefaultAsync<string>(sp, parameters,
            commandType: System.Data.CommandType.StoredProcedure);
    }
}