2

我的 C# WinForms 应用程序出现以下错误：

读取数据时遇到致命错误

我正在使用mysql.data V4.0.30319.

这是我的代码：

int catCount = 1;     
while (catCount < 13)
{
    MySqlConnection con = new MySqlConnection("server=server;user id=user;password=password;database=db;");
    con.Open();
    MySqlDataReader Rd;
    string query = "SELECT oc_newsletter_old_system.email FROM oc_newsletter_old_system WHERE oc_newsletter_old_system.cat_uid = "  + catCount;
    MySqlCommand mC = new MySqlCommand(query, con);
    Rd = mC.ExecuteReader();
    try
    {      
        while (Rd.Read())
        {
            string email = Rd.GetString(0);
            Boolean insert = true;
            int realCat = 0;
            switch (catCount)
            {
                case '1':
                    fileBrian += email + "\r\n";
                    break;
                case '2':
                    fileDunamis += email + "\r\n";
                    break;
                case '3':
                    fileFrohlich += email + "\r\n";
                    break;
                case '4':
                    fileGaithers += email + "\r\n";
                    break;
                case '5':
                    fileGospel7 += email + "\r\n";
                    break;
                case '6':
                    fileLifeshop += email + "\r\n";
                    realCat = 1;
                    break;
                case '7':
                    fileMeyer += email + "\r\n";
                    break;
                case '8':
                    fileOpwekking += email + "\r\n";
                    break;
                case '9':
                    filePelgrimKerken += email + "\r\n";
                    realCat = 2;
                    break;
                case 10:
                    filePelgrimKlanten += email + "\r\n";
                    realCat = 2;
                    break;
                case 11:
                    filePelgrimPers += email + "\r\n";
                    insert = false;
                    break;
                case 12:
                    filePelgrimScholen += email + "\r\n";
                    insert = false;
                    break;
            }

            if (insert == true)
            {    
                string salt = "h1bsqnp6wyxjxhf29ziuwsihg8nixe05";
                byte[] asciiBytes = ASCIIEncoding.ASCII.GetBytes(salt + email);
                byte[] hashedBytes = MD5CryptoServiceProvider.Create().ComputeHash(asciiBytes);
                string hashedString = BitConverter.ToString(hashedBytes).Replace("-", "").ToLower();
                string query2 = "INSERT IGNORE INTO `oc_ne_marketing` (`email`,`code`, `subscribed`, `store_id`) VALUES ('" + email + "', '" + hashedString + "', '1', '" + realCat + "')";
                MySqlConnection connection = new MySqlConnection("server=server;user id=user;password=password;database=db;");
                connection.Open();
                try
                {
                    MySqlCommand cmd1 = new MySqlCommand(query2, connection);
                    cmd1.CommandText = query2;
                    cmd1.ExecuteNonQuery();
                    cmd1.Dispose();
                }
                finally
                {
                    connection.Close();
                }
            }
            Application.DoEvents();
        }
    }
    finally
    {
        Rd.Close();
        con.Close();
    }

    catCount++;
    progressBar1.PerformStep();
    progressBar1.Refresh();
    Application.DoEvents();
}

我在这一行收到错误：

while (Rd.Read())

到目前为止我发现的唯一一件事是关闭阅读器和连接的问题，但据我所知，所有设置都正确......

所以大家知道是怎么回事吗？？？

4

2 回答 2

2

虽然不能直接回答您的问题，但根据您的要求，这里有一些信息和代码示例using。

using将语句与实现的对象一起使用是公认的最佳实践IDisposable——它本质上与 try/finally 块做同样的事情。

一旦退出 using 语句的范围（操作完成或抛出异常），Dispose将在对象上调用。有关更多详细信息，请参阅使用语句。

这是基于您的代码的简短示例：

int catCount = 1;     
string connectionString = "server=server;user id=user;password=password;database=db;"
string query = "SELECT email FROM oc_newsletter_old_system WHERE cat_uid=@cat_uid";

while (catCount < 13)
{

    using (MySqlConnection con = new MySqlConnection(connectionString))
    {

        con.Open();

        MySqlCommand mC = new MySqlCommand(query, con);
        mC.Parameters.AddWithValue("@cat_uid", catCount);

        using (MySqlDataReader Rd = mC.ExecuteReader())
        {

            while (Rd.Read())
            {

                 // rest of your code here
            }
        }
    }    
}

请注意，以上是基于 .NET SqlConnection、SqlCommand 和 SqlDataReader 类的，但对于 MySql 应该相同（或非常相似）。

我将连接字符串和查询字符串移到了它们自己的变量中（但这是个人喜好）。我还举了一个如何进行参数化查询的示例（这mCParameters.AddWithValue行 - 养成使用参数化查询的习惯是（IMO）一件好事，特别是如果您从 WinForms 迁移到基于 Web 的应用程序，因为它可以防止 SQL 注入攻击。

于 2013-07-31T23:07:12.733 回答
2

A2A，为了完整起见。

从这里：

解决方法是自定义 net_xxx_timeout 设置。例如，在打开连接之后和执行数据读取器之前发出以下命令：

var c = new MySqlCommand("set net_write_timeout=99999; set net_read_timeout=99999", con);
c.ExecuteNonQuery();

这是来自MySql.Data连接类的来源：

protected override void Dispose(bool disposing)
{
  if (State == ConnectionState.Open)
    Close();
  base.Dispose(disposing);
}

这基本上意味着处置足以关闭它（否则它很奇怪）。也一样SqlConnection。。

于 2013-07-31T23:26:58.157 回答