基于asp.net内核的Mysql数据库查询

Question

我需要查询数据库。这个查询工作正常，但我需要循环读取表中的所有数据。我不知道如何在这个查询中放入"do“或"while”

[HttpPost]
public IActionResult SendMessage(string send_to, string message, string phone)
{
    var email = HttpContext.Session.GetString("email");
    MySqlDataReader reader;           
    try
    {
        cmdMySQL.Connection = conMySQL;
        conMySQL.Open();
        cmdMySQL.CommandText = "SELECT * FROM tbl_mensagens WHERE enviado = '" + 0 + "' AND email_usuario = '" + email + "' ";
        reader = cmdMySQL.ExecuteReader();       
        while (reader.Read())
        {
            var codmsgx ="";
            phone = "";
            message = "";        
            codmsgx = reader[0].ToString();
            phone = reader[4].ToString();
            message = reader[5].ToString();
            EnviarMensagem(send_to, message, phone, email, codmsgx);
            AtualizarBd(send_to, message, phone, email, codmsgx);
        }
        reader.Close();           
        return View();
    }
    catch (Exception ex) { Debug.WriteLine(ex); return View(); }
    finally
    {
        conMySQL.Close();
    }
}

Answer 1

您只得到一行，因为您调用的是reader.Read()。每次调用Read()时，读取器前进到下一行并返回true；或者，当读取器前进到最后一行时，它返回false。

假设您有一个视图模型：

public class MensagensViewModel
{
    public string Codmsgx { get; set; }
    public string Phone { get; set; }
    public string Message { get; set; }
}

要从tbl_mensagens表中获取List<MensagensViewModel>数据，需要手动将访问的数据保存到mensagens中，代码如下：

try
    {
        cmdMySQL.Connection = conMySQL;             
        cmdMySQL.CommandText = "SELECT * FROM tbl_mensagens WHERE enviado = '" + 0 + "' AND email_usuario = '" + email + "' ";
        conMySQL.Open();
        reader = cmdMySQL.ExecuteReader();

        List<MensagensViewModel> mensagens = new List<MensagensViewModel>();//To save all retrieved data
        while (reader.Read())
        {
            var mensagen = new MensagensViewModel()
                {
                    Codmsgx = reader[0].ToString(),
                    Phone = reader[4].ToString(),
                    Message = reader[5].ToString()
                };

            mensagens.Add(mensagen);
            //other logic                 

        }
        reader.Close();
        return View();
    }
    catch (Exception ex) { Debug.WriteLine(ex); return View(); }
    finally
    {
        conMySQL.Close();
    }