EF Core操作PostgreSQL用流式查询报Connection is busy错误如何解决？

1. 报错原因 #

你触发Connection is busy异常的核心原因是同一个数据库上下文实例占用的连接同时处理两个互斥的活跃操作：

• 同步遍历IQueryable类型的query时，EF Core会持续占用数据库连接逐行拉取查询结果，在整个遍历结束前，连接一直处于被占用状态
• 遍历过程中调用的SaveChangesAsync需要复用同一个上下文的连接执行写入操作，但此时连接还被未结束的读操作持有，因此驱动抛出连接繁忙的异常
  另外你直接用同步foreach遍历IQueryable属于同步查询操作，本身在异步场景下使用也不符合最佳实践。

2. 是否需要用两个独立上下文 #

是的，你需要拆分独立的读上下文和写上下文：

• 读上下文专门负责流式拉取数据，不需要开启变更跟踪，全程只处理读请求
• 写上下文专门负责批量写入，和读上下文的连接完全隔离，不会出现连接抢占问题
  生产环境推荐通过注入IDbContextFactory<你的上下文类型>来创建独立的上下文实例，避免手动管理上下文生命周期的问题。

3. 该场景的支持性说明 #

EF Core本身完全支持流式查询同时写入的场景，这个报错既不是EF Core的问题，也不是Npgsql驱动特有的问题：
所有关系数据库的ADO.NET驱动默认都不允许同一个数据库连接同时处理两个活跃的请求，只是不同驱动的报错提示不同。只要拆分读写上下文隔离连接，就能正常实现该场景。

// 从注入的IDbContextFactory创建独立的读写上下文
using var readContext = await _dbContextFactory.CreateDbContextAsync(cancellationToken);
using var writeContext = await _dbContextFactory.CreateDbContextAsync(cancellationToken);

var query =
    from foo in readContext.Foos.AsNoTracking()
    where !readContext.Bars.Any(bar => bar.FooId == foo.Id)
    select foo;

var buffer = new List<Bar>(BUFFERSIZE);
// 用异步流式遍历，不会加载全量数据到内存
await foreach (var foo in query.AsAsyncEnumerable().WithCancellation(cancellationToken))
{
    buffer.Add(new Bar(foo)
    {
        // 额外初始化逻辑
    });
    
    if (buffer.Count == BUFFERSIZE)
    {
        writeContext.Bars.AddRange(buffer);
        await writeContext.SaveChangesAsync(cancellationToken);
        writeContext.ChangeTracker.Clear();
        buffer.Clear(); // 复用List实例，减少内存分配
    }
}

// 写入最后一批不足阈值的数据
if (buffer.Count > 0)
{
    writeContext.Bars.AddRange(buffer);
    await writeContext.SaveChangesAsync(cancellationToken);
}

• 如果数据量超过千万级别，推荐将全量流式查询改为按主键分页查询，避免长时间持有读库连接影响其他业务
• BUFFERSIZE建议设置为1000~5000的范围，过小会导致写入次数过多性能下降，过大则会增加单次写入的内存占用

内容的提问来源于stack exchange，提问作者Sebastian Widz