ASP.NET Core中MySQL查询：如何用do/while循环读取全表数据

嘿，你其实已经在代码里用上while循环来遍历MySQL查询结果啦！不过你的代码里有几个需要调整的地方，尤其是安全和逻辑细节问题，我来帮你理顺并修正：

核心问题梳理 #

1. 严重的SQL注入风险：直接拼接字符串生成SQL语句是非常危险的操作，恶意用户可以通过构造特殊输入篡改查询逻辑，甚至破坏你的数据库。
2. 变量覆盖逻辑混乱：你在循环里直接覆盖了方法传入的phone、message参数，而且传入的send_to参数完全没用到，这大概率不是你想要的业务逻辑。
3. 资源释放不够可靠：虽然你用finally关闭了连接，但MySqlDataReader和MySqlCommand最好用using语句自动释放资源，避免内存泄漏。

修正后的完整代码 #

[HttpPost]
public IActionResult SendMessage(string send_to, string message, string phone)
{
    var email = HttpContext.Session.GetString("email");
    
    // 使用using语句自动释放数据库连接，无需手动Close
    using (var conMySQL = new MySqlConnection("你的数据库连接字符串"))
    {
        conMySQL.Open();
        // 用参数化查询彻底避免SQL注入
        string query = "SELECT * FROM tbl_mensagens WHERE enviado = @enviado AND email_usuario = @email";
        using (var cmdMySQL = new MySqlCommand(query, conMySQL))
        {
            // 添加参数，替代字符串拼接
            cmdMySQL.Parameters.AddWithValue("@enviado", 0);
            cmdMySQL.Parameters.AddWithValue("@email", email);
            
            // 用using包裹DataReader，自动释放资源
            using (var reader = cmdMySQL.ExecuteReader())
            {
                // while循环遍历所有查询到的数据行
                while (reader.Read())
                {
                    var codmsgx = reader[0].ToString();
                    // 建议用字段名读取（比如reader["phone_col"]）替代索引，避免表结构变动导致错误
                    var dbPhone = reader[4].ToString();
                    var dbMessage = reader[5].ToString();
                    
                    // 调用业务方法时，使用数据库读取到的内容，避免覆盖传入参数
                    EnviarMensagem(send_to, dbMessage, dbPhone, email, codmsgx);
                    AtualizarBd(send_to, dbMessage, dbPhone, email, codmsgx);
                }
            }
        }
    }
    
    return View();
}

关键优化点说明 #

• 参数化查询：用@参数名的方式替代字符串拼接，再通过Parameters.AddWithValue传递参数，彻底杜绝SQL注入风险。
• using自动资源释放：MySqlConnection、MySqlCommand、MySqlDataReader都实现了IDisposable接口，用using包裹后，代码块结束时会自动释放资源，比手动调用Close更可靠。
• 变量逻辑清晰化：把从数据库读取的phone和message重命名为dbPhone、dbMessage，避免覆盖方法传入的参数，让业务逻辑更清晰。
• 字段读取建议：尽量用字段名（比如reader["codmsg"]）代替索引（reader[0]），这样即使表结构调整字段顺序，代码也不会出错。

关于do-while循环的补充 #

如果你确实想使用do-while循环，逻辑如下（不过一般while循环更直观，适合遍历结果集）：

using (var reader = cmdMySQL.ExecuteReader())
{
    // 先判断是否有数据，避免空结果集时执行无效逻辑
    if (reader.HasRows)
    {
        do
        {
            // 读取数据的业务逻辑
            var codmsgx = reader[0].ToString();
            var dbPhone = reader[4].ToString();
            var dbMessage = reader[5].ToString();
            
            EnviarMensagem(send_to, dbMessage, dbPhone, email, codmsgx);
            AtualizarBd(send_to, dbMessage, dbPhone, email, codmsgx);
        } while (reader.Read());
    }
}

do-while会先执行一次循环体再判断条件，所以需要先检查reader.HasRows，避免空结果集时执行不必要的操作。

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