Npgsql/EFCore.PG项目中DbContext并发查询异常解析

在使用Npgsql.EntityFrameworkCore.PostgreSQL进行数据库操作时，开发者可能会遇到一个常见的并发问题：当多个请求同时访问数据库时，系统抛出NpgsqlOperationInProgressException异常，提示"命令已在执行中"。本文将深入分析这一问题的根源，并提供正确的解决方案。

问题现象

在ASP.NET Core 8应用程序中，当多个GET请求并行执行时，系统会抛出以下异常：

Npgsql.NpgsqlOperationInProgressException: A command is already in progress: SELECT c."Id", [所有其他列] FROM "数据库表" AS c

这种情况通常出现在看似合理的代码结构中，例如：

[HttpGet]
public async Task<IActionResult> GetAsync(CancellationToken cancellationToken)
{
    return Ok(await dbContext.SomeDbSet.ToListAsync(cancellationToken));
}

问题根源

经过深入分析，发现问题的根本原因在于数据库连接的管理方式。在原始实现中，开发者将NpgsqlConnection实例以单例(Singleton)模式注册到依赖注入容器中，并在多个DbContext实例间共享同一个物理连接。

这种设计存在严重问题，因为：

1. 一个DbConnection代表一个实际的物理数据库连接
2. 物理连接无法被多个线程同时使用
3. 当多个DbContext实例尝试通过同一个连接执行命令时，就会产生冲突

解决方案

正确的做法是避免共享数据库连接实例。以下是推荐的两种解决方案：

方案一：直接传递连接字符串

// 注册服务
services.AddSingleton<ConnectionStringProvider>();
services.AddDbContext<MyDbContext>((sp, options) => 
    options.UseNpgsql(sp.GetRequiredService<ConnectionStringProvider>().GetConnectionString()));

方案二：使用NpgsqlDataSource

Npgsql提供了更现代的连接管理方式：

// 注册服务
services.AddNpgsqlDataSource(Configuration.GetConnectionString("Default"));
services.AddDbContext<MyDbContext>((sp, options) => 
    options.UseNpgsql(sp.GetRequiredService<NpgsqlDataSource>()));

最佳实践

1. DbContext生命周期：始终将DbContext注册为Scoped或Transient生命周期
2. 连接管理：让EF Core和Npgsql自行管理连接池
3. 并发控制：确保每个DbContext实例使用独立的物理连接
4. 性能考虑：连接池会自动管理物理连接的创建和复用，无需手动优化

总结

在Npgsql和EF Core的集成使用中，正确的连接管理方式至关重要。避免手动管理DbConnection实例，转而使用连接字符串或NpgsqlDataSource，可以有效地避免并发操作导致的异常问题。理解底层连接管理机制，有助于开发者构建更稳定、高效的数据库访问层。