C/C++教程

EFCore启用数据库连接池

本文主要是介绍EFCore启用数据库连接池,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

本文环境为.Net5 + ASP.Net Core Web API + EFCore 5.0.12 + MySQL 5,介绍了如何使用EFCore开启数据库连接池。

在实现了自己的DbContext之后,需要在Startup.cs的ConfigureServices方法中注册DbContext。在ASP.Net Core Web API中,每次请求对应的Controller都会创建一次DbContext对象,而普通的注册会在每次创建DbContext对象时连接一次数据库,这样会频繁的连接数据库(然后关闭),很有可能会使数据库的连接资源耗尽。因此,需要使用连接池以便减少数据库的连接次数,使系统更加稳健。

EFCore提供了2种开启数据库连接池的方法,一种是使用IServiceCollection接口的扩展方法AddDbContextPool,该扩展方法注册了DbContext类,可以在Controller中注入DbContext对象;另一种方法是使用IServiceCollection接口的扩展方法AddPooledDbContextFactory,该扩展方法注册了IDbContextFactory接口,可以在Controller中注入IDbContextFactory类型的对象。

2种开启数据库连接池方法的区别是:前者(AddDbContextPool)直接注入DbContext对象,因此在请求建立连接时就进行数据库连接,尽管是使用池种的数据库连接;后者(AddPooledDbContextFactory)对IDbContextFactory进行了单例注册,在需要数据库连接的时候使用CreateDbContext方法建立数据库连接,可视为能够仅在需要请求数据库的时候动态建立数据库连接,灵活性比较大。

针对上述2种方法,AddDbContextPool方法适合在每个请求都需要连接数据库的Controller中使用,AddPooledDbContextFactory方法则没有使用限制,唯一需要注意的是处理好2个关联的需要使用DbContext对象的方法,防止频繁创建DbContext。鉴于此,更推荐使用AddPooledDbContextFactory方法启用数据库连接池。

需要注意的是,在启用数据库连接池的时候,自己实现的DbContext派生类中,构造函数不能有除了DbContextOptions以外的参数,这是因为连接池时DbContext对象会被连接池保存,这意味着DbContext对象是单例的,所以不能有其他注入的服务。参考stackoverflow。

此外,数据库连接字符串默认参数是pooling=true,如果改为pooling=false也会对启用数据库连接池造成影响。

1、默认不启用数据库连接池

//注册数据库上下文
services.AddDbContext<MySqlDbContext>();

2、使用AddDbContextPool启用数据库连接池

//注册数据库上下文(启用数据库连接池)
var connectionString = Configuration.GetConnectionString("MySQLConnection");
services.AddDbContextPool<MySqlDbContext>(optionsBuilder =>
        optionsBuilder.UseMySql(connectionString, ServerVersion.AutoDetect(connectionString)),
    64
);

3、使用AddPooledDbContextFactory启用数据库连接池

//注册数据库上下文(启用数据库连接池)
var connectionString = Configuration.GetConnectionString("MySQLConnection");
services.AddPooledDbContextFactory<MySqlDbContext>(optionsBuilder =>
        optionsBuilder.UseMySql(connectionString, ServerVersion.AutoDetect(connectionString)),
    64
);
[Route("api/[controller]")]
[ApiController]
public class ClientsController : ControllerBase
{
    private readonly ILogger<ClientsController> _logger;
    private readonly IDbContextFactory<MySqlDbContext> _dbContextFactory;

    public ClientsController(
        ILogger<ClientsController> logger,
        IDbContextFactory<MySqlDbContext> dbContextFactory
    )
    {
        _logger = logger;
        _dbContextFactory = dbContextFactory;
    }

    [HttpGet("count")]
    public async Task<IActionResult> GetCountAsync()
    {
        try
        {
            using (var dbContext = _dbContextFactory.CreateDbContext())
            {
                var count = await dbContext.Clients.CountAsync();
                return Ok(count);
            }
        }
        catch (Exception e)
        {
            var message = $@"GetCountAsync failed:{e.Message}.";
            _logger.LogError(message);
            return Problem(message);
        }
    }
}
这篇关于EFCore启用数据库连接池的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!