3

正如您可能已经从标题中猜到的那样，我正在尝试这样做：

    #region check new nations
    private void checknewnations()
    {
        addtolog("server","Checking for new nations");
        string sql = "SELECT * FROM " + variables.tbl_nations + " WHERE nations_new=0";
        MySqlCommand cmd = new MySqlCommand(sql, connection);
        MySqlDataReader reader = cmd.ExecuteReader();

        while (reader.Read())
        {
            addtolog("mysql",reader["nations_name"].ToString());

            int nation_ID = int.Parse(reader["nations_ID"].ToString());
            string nation_name = reader["nations_name"].ToString();
            string user_ID = reader["nations_user"].ToString();


            addnation(nation_ID, nation_name, user_ID);
        }
        addtolog("server","Finished checking for new nations.");
        //connection.Close();
        reader.Dispose();
    }
    #endregion

在 while 循环中调用它：

    #region addnation
    private void addnation(int nationIDnot, string nationName, string userID)
    {
        string nationID = makesixdigits(nationIDnot);
        string userName = "";

        string sql = "SELECT * FROM " + variables.tbl_users + " WHERE users_ID=" + userID;
        MySqlCommand cmd = new MySqlCommand(sql, connection);
        MySqlDataReader reader = cmd.ExecuteReader();


        while (reader.Read())
        {
            userName = reader["users_name"].ToString();
        }
        reader.Dispose();
        addtolog("add", "[" + nationID.ToString() + "] " + nationName + " [" + userID + "] " + userName);
    }
    #endregion

这在第二个代码块（在 while 循环中调用的代码块）中给我一个错误，说已经有一个与连接关联的数据读取器。我该如何让它发挥作用，因为我确信有办法。

4

3 回答 3

5

DataReader 保持连接，直到它遍历其所有记录。尝试这个

using(reader)
{
   System.Data.DataTable dt = new System.Data.DataTable();
   dt.Load(reader);

   foreach(DataRow row in dt.Rows)
   {
        addtolog("mysql",row["nations_name"].ToString());

        int nation_ID = int.Parse(row["nations_ID"].ToString());
        string nation_name = row["nations_name"].ToString();
        string user_ID = row["nations_user"].ToString();


        addnation(nation_ID, nation_name, user_ID);
   }
}

这样两个阅读器不共享相同的连接

于 2012-08-14T22:36:03.807 回答
1

在 2008 年的连接字符串中，您可以通过MultipleActiveResultSets=true;我没有使用过 mySQL 来获得多个活动结果集，所以我不确定，但如果您使用的是 ADO 提供程序，也许可以。

否则，只需建立另一个连接——不要重复使用同一个连接。

于 2012-08-14T22:31:46.507 回答
1

在循环中打开另一个连接，并使用它来获取第二个阅读器。由于循环很紧凑，您可能更愿意在第一个方法中打开两个连接，将第二个传递给被调用的方法，然后在第一个（“外部”）方法结束时关闭它们。通话之间的时间应该足够短，尽快关闭连接的正常规则无关紧要。

于 2012-08-14T22:38:01.953 回答