异步调用MySQL时DataReader已打开异常的原因及解决方法

为什么会抛出这个异常？ #

这个问题我之前也碰到过，核心原因是你两个并行执行的Task共享了同一个数据库连接实例conn，而MySQL的数据库连接默认不允许同时存在多个活跃的命令/数据读取器操作。

• 同步运行时，GetUrlsCount()和GetImagesCount()是串行执行的：第一个方法执行完，连接已经被关闭/释放，第二个方法再使用连接，自然不会有冲突。
• 异步并行时，两个Task同时启动，第一个方法里的ExecuteScalar()还在执行（或者连接还没来得及关闭），第二个方法就尝试用同一个连接执行新的命令，这就触发了MySQL连接的限制——一个连接同一时间只能处理一个请求，所以抛出了"There is already an open DataReader associated with this Connection which must be closed first."的异常。

另外还要提一句：你手动调用conn.Close()和comm.Dispose()的方式也不够安全，如果代码在ExecuteScalar()之后抛出异常，连接可能无法被正确关闭，这也会加剧连接占用的问题。

如何修改代码使其支持异步？ #

我推荐以下几种循序渐进的优化方案：

1. 每个数据库操作使用独立的连接（最优先推荐） #

ADO.NET自带连接池机制，创建新的连接实例并不会真的每次都建立物理连接，连接池会自动复用空闲连接，所以完全不用担心性能问题。修改你的数据库方法，让它们各自创建并管理自己的连接，用using语句自动释放资源：

public static int GetImagesCount()
{
    // 建议从配置文件读取连接字符串，不要硬编码
    string connectionString = "你的MySQL连接字符串";
    
    // using语句会自动释放连接，无需手动Close/Dispose
    using (var conn = new MySqlConnection(connectionString))
    {
        conn.Open();
        string cmdString = "SELECT COUNT(*) FROM damocles.imagestoassess;";
        using (var comm = new MySqlCommand(cmdString, conn))
        {
            object result = comm.ExecuteScalar();
            // COUNT(*)不会返回null，这里处理DBNull是更严谨的写法
            return result == DBNull.Value ? 0 : Convert.ToInt32(result);
        }
    }
}

GetUrlsCount()方法做同样的修改，这样两个并行任务使用各自的连接，就不会再出现连接冲突的问题。

2. 使用真正的异步数据库操作（替代伪异步） #

你当前用Task.Factory.StartNew()包装同步方法的方式属于伪异步——它只是把同步操作放到线程池线程里执行，并没有真正利用IO异步的优势。更好的做法是使用MySQL驱动提供的异步方法：

public static async Task<int> GetImagesCountAsync()
{
    string connectionString = "你的MySQL连接字符串";
    
    using (var conn = new MySqlConnection(connectionString))
    {
        // 使用OpenAsync替代同步Open
        await conn.OpenAsync();
        string cmdString = "SELECT COUNT(*) FROM damocles.imagestoassess;";
        using (var comm = new MySqlCommand(cmdString, conn))
        {
            // 使用ExecuteScalarAsync替代同步ExecuteScalar
            object result = await comm.ExecuteScalarAsync();
            return result == DBNull.Value ? 0 : Convert.ToInt32(result);
        }
    }
}

调用的时候用Task.WhenAll()等待两个异步任务完成：

// 启动两个异步任务
var linksCountTask = DatabaseIn.GetUrlsCountAsync();
var imagesCountTask = DatabaseIn.GetImagesCountAsync();

// 等待两个任务都完成
await Task.WhenAll(linksCountTask, imagesCountTask);

// 获取结果
int linksCount = linksCountTask.Result;
int imagesCount = imagesCountTask.Result;

这种方式不会占用额外的线程池线程，能更高效地利用系统资源，是异步编程的最佳实践。

3. 避免手动管理连接的生命周期 #

你之前手动调用comm.Dispose()和conn.Close()的方式很容易出错——如果代码在中间抛出异常，这些资源可能无法被正确释放。using语句会自动在代码块结束时释放资源（无论是否发生异常），是更安全、更简洁的写法。

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