using语句内SqlConnection意外关闭的技术问题排查

我来帮你分析下这个问题——你遇到的System.InvalidOperationException（提示连接关闭），核心原因其实是并发操作共享同一个SqlConnection实例，哪怕你开了MARS也没用，这是因为SqlConnection本身不是线程安全的，并发调用它的方法会导致状态混乱。

先回顾下你的核心场景和代码：
你构建了一个SQL连接服务，核心流程是读取文件数据后，在using块里打开连接，然后通过Task.WhenAll并行执行多个查询操作：

var data = await GetDataFromFlatFilesAsync(dir).ConfigureAwait(false);
using (var conn = new SqlConnection(MyConnectionString)) {
    try {
        conn.Open();
        var rw = new SqlReaderWriter(conn);
        await DoStuffWithSqlAsync(rw, data).ConfigureAwait(false);
    } catch (Exception ex) {
        // 处理异常
    }
}

// DoStuffWithSqlAsync实现
private async Task DoStuffWithSqlAsync(SqlReaderWriter rw, IEnumerable<Thing> data) {
    await Task.WhenAll(data.Select(rw.RunQueryAsync)).ConfigureAwait(false);
}

// RunQueryAsync实现
public async Task RunQueryAsync<T>(T content) {
    // _conn在构造函数中赋值为传入的conn
    try {
        var dataQuery = _conn.CreateCommand();
        dataQuery.CommandText = TranslateContentToQuery(content);
        await dataQuery.ExecuteNonQueryAsync().ConfigureAwait(false);
    } catch (Exception ex) {
        // 处理异常
    }
}

你提到已经修复了连接未开启的问题，且_conn.State显示为Open，但错误依然存在——这就是并发操作共享连接导致的问题：MARS允许同一个连接上同时存在多个结果集，但不允许多个SqlCommand并发执行。当你用Task.WhenAll同时启动多个ExecuteNonQueryAsync时，这些操作会争抢同一个连接的资源，导致连接状态出现异常，哪怕表面上看连接是打开的。

给你几个可行的解决方案： #

方案1：为每个查询创建独立连接（推荐）

利用SQL连接池的特性，每个异步任务使用自己的连接，完全避免并发冲突。修改RunQueryAsync如下：

public async Task RunQueryAsync<T>(T content) {
    using (var conn = new SqlConnection(MyConnectionString)) {
        try {
            await conn.OpenAsync().ConfigureAwait(false);
            var dataQuery = conn.CreateCommand();
            dataQuery.CommandText = TranslateContentToQuery(content);
            await dataQuery.ExecuteNonQueryAsync().ConfigureAwait(false);
        } catch (Exception ex) {
            // 处理异常
        }
    }
}

连接池会自动复用空闲连接，不用担心频繁创建连接的性能问题，这是最安全的做法。

方案2：改为串行执行

如果必须共享连接，就放弃并行，改为逐个执行查询，确保同一时间只有一个操作使用连接：

private async Task DoStuffWithSqlAsync(SqlReaderWriter rw, IEnumerable<Thing> data) {
    foreach (var item in data) {
        await rw.RunQueryAsync(item).ConfigureAwait(false);
    }
}

这个方法简单，但执行效率会比并行低，适合数据量不大的场景。

方案3：用SqlBulkCopy做批量操作（如果是插入场景）

如果你的操作是批量插入数据，强烈推荐使用SqlBulkCopy，它专门针对批量数据优化，性能远高于逐个执行插入语句，而且可以安全地使用单个连接：

private async Task DoBulkInsertAsync(SqlConnection conn, IEnumerable<Thing> data) {
    using (var bulkCopy = new SqlBulkCopy(conn)) {
        bulkCopy.DestinationTableName = "YourTargetTableName";
        // 配置列映射，根据你的实体和数据库表调整
        bulkCopy.ColumnMappings.Add("ThingId", "Id");
        bulkCopy.ColumnMappings.Add("ThingName", "Name");
        
        // 将IEnumerable<Thing>转换为DataTable（或实现IDataReader）
        var dataTable = ConvertThingsToDataTable(data);
        await bulkCopy.WriteToServerAsync(dataTable).ConfigureAwait(false);
    }
}

补充关于OpenAsync的小说明 #

你之前提到用await conn.OpenAsync().ConfigureAwait(false)导致执行未阻塞——其实在控制台应用里使用OpenAsync是完全没问题的，错误原因应该是你在OpenAsync还没完成就开始执行查询了，和ConfigureAwait(false)无关。同步的conn.Open()虽然能解决这个问题，但异步版本在高并发场景下性能更好，只要确保在使用连接前等待OpenAsync完成就可以。

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