You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

.NET使用MySQL提示MySqlConnection已被占用的问题求解

问题根因分析
  • 直接报错原因:你调用cmd.ExecuteReader()之后,当前MySQL连接已经被返回的MySqlDataReader独占,同一时间一个数据库连接只能处理一个活跃的操作,此时你又执行var data = cmd.ExecuteNonQuery()相当于在同一个连接上同时发起两个请求,就触发了连接被占用的报错。另外ExecuteNonQuery仅用于执行INSERT/UPDATE/DELETE这类不返回结果集的增删改语句,你的场景是查询数据,这行代码完全多余,可以直接删除。
  • 其余隐藏问题:
    1. 资源管理不规范:MySqlConnection、MySqlCommand、MySqlDataReader都实现了IDisposable接口,应该用using语句包裹自动释放资源,不需要手动调用Close方法,避免异常场景下出现资源泄漏
    2. 异步方法使用错误:你声明的是async Task类型的异步方法,但所有数据库操作都用的同步方法,还强制用Task.FromResult包装返回值,完全没有利用异步IO的优势,反而增加了不必要的开销
    3. 数据读取逻辑错误:当前代码只会返回结果集第一行的最后一个字段的值,遍历字段时会反复覆盖myString,读完第一行就直接返回,其余行和其余字段的数据都会被丢弃
    4. 错误提示不符合场景:查询失败的错误提示写的是"Faild to add data",和实际查询业务完全不符
修正后的参考代码
public async Task<object> GetFormListDetails()
{
    try
    {
        // 连接字符串建议放到配置文件中,不要硬编码在业务代码里
        using var con = new MySqlConnection(@"Server=Localhost;Database=HotelManagement;Uid=root;Pwd=Onkar@123;");
        await con.OpenAsync();
        using var cmd = new MySqlCommand("select * from HotelManagement.MealType", con);
        using var tableData = await cmd.ExecuteReaderAsync();
        
        var fieldCount = tableData.FieldCount;
        // 用列表存储所有行数据,按需调整返回结构
        var resultList = new List<Dictionary<string, object>>();
        while (await tableData.ReadAsync())
        {
            var rowData = new Dictionary<string, object>();
            for (int i = 0; i < fieldCount; i++)
            {
                rowData[tableData.GetName(i)] = tableData.GetValue(i);
            }
            resultList.Add(rowData);
        }

        return new ResponseModel(ResponseCode.OK, "查询成功", resultList);
    }
    catch (Exception ex)
    {
        return new ResponseModel(ResponseCode.Error, ex.Message, null);
    }
}
额外优化建议
  • 连接字符串不要硬编码在代码中,建议放到appsettings.json等配置文件中,方便多环境切换和敏感信息管理
  • 可以定义对应的MealType实体类来映射查询结果,比用字典或者字符串存储的可读性和可维护性更高
  • 尽量避免使用SELECT *查询全表字段,按需查询需要的字段,减少不必要的性能开销

内容的提问来源于stack exchange,提问作者Onkar Nirhali

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.09.27 04:24:08