如何使用 .net 核心中的依赖注入来处理与 dapper 的 postgresql db 连接？

Question

我在我的 asp.net 核心 Web API 项目中使用 Dapper ORM 进行数据库操作。现在我每次都打开新的数据库连接并在 using 块中使用它，这样它们就会在作用域结束时被释放。但我希望在不使用 using 块的情况下处理所有这些连接，并且还希望自动处理它们。我正在寻找一种使用依赖注入来实现此目的的方法，因为它们会自动处理实现 IDisposable 的对象。

这是我处理所有数据库连接的方式：

在我的基础存储库中创建了一个 GetConnection 属性：

private IDbConnection _connection;

public IDbConnection GetConnection
{
    get
    {
        _connection = new NpgsqlConnection("Connection String");
        return _connection;
    }
}

使用块访问属性：

public async Task<IEnumerable<T>> GetAllAsync()
{
    IEnumerable<T> records = null;

    using (IDbConnection connection = GetConnection)
    {
        //db operations
    }

    return records;
}

那么我怎样才能使用依赖注入来实现相同的效果，它会在需要时初始化 IDbconnection 并在请求结束时处理，而无需将 IDbconnection 封装在 using 块内？

简而言之，我想避免每次都使用 GetConnection 属性来创建数据库对象，并避免使用 using 块来处理相同的对象。

Answer 1

我是这样做的：

在startup.cs文件中添加Transient服务

services.AddTransient<IDbConnection>((sp) => new NpgsqlConnection("connectionString"));

在基本存储库构造函数中初始化 IDbconnection 对象，如：

class  RepositoryBase
{
    protected IDbConnection _connection;

    protected RepositoryBase(IDbConnection dbConnection)
    {
         _connection = dbConnection;
    }
}

并在我的存储库中执行数据库操作，例如

class XyzRepository : RepositoryBase
{
    public async Task<IEnumerable<T>> GetAllAsync()
    {
        IEnumerable<T> records = null;

        await _connection.ExecuteScalarAsync<object>("sqlQuery");

        return records;
    }

}

这将在请求结束时自动处理 IDbconnection 对象，而不使用 using 块。

来自答案的参考：How do I handle Database Connections with Dapper in .NET?

Answer 2

您不想只使用一个数据库连接来访问数据库。当一个数据库连接被释放时（在using 块的末尾），它会被返回给连接池，这比您自己想出的任何方案都更加高效和安全。

如果你想删除对NpgsqlConnection 的依赖，你应该创建一个连接工厂来创建IDbConnection 并将工厂插入到你的类中。 using 构造是好的和最佳实践，而不是您想要摆脱的东西。

还有更多关于连接池here。

编辑：查看您的代码，我发现您已经将连接创建抽象化了。您的代码实际上很好。