使用C# MySqlReader读取多请求时仅获首条数据的解决方法求助

咱们先拆解你遇到的两个核心问题：仅能获取第一条记录，以及包含多个请求的命令逻辑异常，一步步来排查解决：

一、仅读取第一条记录的核心原因及修复 #

最常见的问题就是你没有对MySqlDataReader做循环遍历，只执行了一次读取操作就停止了。先给你对比错误和正确的读取方式：

错误示例（仅取第一条） #

var model = new List<WorkPeriod1>();
using (MySqlCommand cmd2 = new MySqlCommand(yourSqlString, connection))
{
    using (MySqlDataReader reader = cmd2.ExecuteReader())
    {
        // 只执行一次Read()，自然只能拿到第一条记录
        if (reader.Read())
        {
            model.Add(new WorkPeriod1 { TargetDate = reader.GetDateTime("target_date") });
        }
    }
}

正确的循环读取方式 #

var model = new List<WorkPeriod1>();
// 用using包裹命令和读取器，确保资源自动释放
using (MySqlCommand cmd2 = new MySqlCommand("SELECT DISTINCT target_date FROM work_period w, aspnetusers u WHERE u.Id=w.id_manager AND u.UserType=0 AND u.Id_num<>0 AND u.IsActive = TRUE AND w.target_date >= DATE_SUB('2018-04-21',INTERVAL 7 DAY);", connection))
{
    using (MySqlDataReader reader = cmd2.ExecuteReader())
    {
        // 用while循环遍历所有返回的记录
        while (reader.Read())
        {
            var period = new WorkPeriod1();
            // 先判断字段是否为空，避免空值报错
            if (!reader.IsDBNull(reader.GetOrdinal("target_date")))
            {
                period.TargetDate = reader.GetDateTime("target_date");
            }
            model.Add(period);
        }
    }
}

这里要注意几个细节：

• 必须用while (reader.Read())替代if (reader.Read())，前者会持续读取直到没有更多记录
• 读取字段前先判断DBNull，防止数据库中空字段导致的运行时异常
• 始终用using包裹数据库相关对象，避免资源泄漏

二、处理包含多个请求的批处理命令 #

你提到“一个命令中包含3个请求”，也就是SQL语句用分号分隔了多个查询（比如SELECT ...; SELECT ...; SELECT ...;）。这种情况下，MySqlDataReader需要用NextResult()来切换到下一个结果集，否则只能拿到第一个查询的结果：

多结果集读取示例 #

假设你的批处理SQL是这样的：

SELECT DISTINCT target_date FROM work_period w, aspnetusers u WHERE ...;
SELECT COUNT(*) FROM work_period;
SELECT * FROM aspnetusers WHERE UserType=0;

对应的C#读取逻辑要这样写：

using (MySqlCommand cmd = new MySqlCommand(yourBatchSql, connection))
{
    using (MySqlDataReader reader = cmd.ExecuteReader())
    {
        // 处理第一个结果集（target_date列表）
        while (reader.Read())
        {
            model.Add(new WorkPeriod1 { TargetDate = reader.GetDateTime("target_date") });
        }

        // 切换到第二个结果集
        if (reader.NextResult())
        {
            while (reader.Read())
            {
                int totalCount = reader.GetInt32(0);
                // 处理第二个查询的结果
            }
        }

        // 切换到第三个结果集
        if (reader.NextResult())
        {
            while (reader.Read())
            {
                // 处理第三个查询的结果
            }
        }
    }
}

如果跳过NextResult()，就会一直停留在第一个结果集，自然拿不到后面查询的数据。

三、先验证你的SQL语句本身是否正确 #

最后别忘了先在MySQL客户端（比如MySQL Workbench、Navicat）里执行你的SQL，确认是否真的返回5条记录：

• 检查DISTINCT关键字：如果target_date有重复值，去重后记录数会减少
• 检查关联条件u.Id=w.id_manager：是否存在关联错误，过滤掉了部分记录
• 检查日期条件：DATE_SUB('2018-04-21',INTERVAL 7 DAY)计算后是2018-04-14，确认数据库中符合日期要求的记录数是否为5条

如果SQL本身返回的记录数就不对，那不管怎么读取都拿不到5条，这一步很关键！

内容的提问来源于stack exchange，提问作者Владислав Золоторёв