using System;

using Microsoft.Extensions.Configuration;

using Npgsql;

using System.Threading.Tasks;

using Dapper;

​

public class UserRepository 

{

    private readonly string connectionString;

​

    public UserRepository(IConfiguration configuration) 

    {

        connectionString = configuration.GetConnectionString("DefaultConnection");

    }

​

    public string GetUserByEmail(string searchInput)

    {

        var connection = GetOpenConnectionAsync(connectionString).Result;

        var sql = "SELECT FROM users WHERE user_email = '" + searchInput + "'";

​

        return connection.QueryFirstOrDefault(sql);

    }

​

    private async Task<NpgsqlConnection> GetOpenConnectionAsync(string connectionString) 

    {

        var connStr = connectionString;

​

        using var connection = new NpgsqlConnection(connStr);

        await connection.OpenAsync();

​

        return connection;

    }

}