Закрытие соединения datareader для подключения к MySql

Question

Так что это немного похоже на код.

У меня есть функция, которая проверяет последний идентификатор в таблице, эта функция вызывается внутри другой функции. В конце этой функции у меня есть другая функция, открывающая другой datareader.

Ошибка:

There is already an open Datareader associated with this connection which must be closed first.

getLastIdfromDB()

public string getLastIdFromDB() 
{ 
    int lastIndex; 
    string lastID =""; 
    var dbCon = DB_connect.Instance(); 

    if (dbCon.IsConnect()) 
    { 
     MySqlCommand cmd2 = new MySqlCommand("SELECT ID FROM `competitor`", dbCon.Connection); 

     try 
     { 
      MySqlDataReader reader = cmd2.ExecuteReader(); 

      while (reader.Read()) 
      { 
        string item = reader2["ID"].ToString(); 
        lastIndex = int.Parse(item); 
        lastIndex++; 
        lastID = lastIndex.ToString(); 
       } 
     } 
     catch (Exception ex) 
     { 
       MessageBox.Show("Error:" + ex.Message); 
     } 
    } 

    return lastID; 
} 

Эта функция позже на используемый в этой функции:

private void addPlayerBtn_Click(object sender, EventArgs e) 
{ 
    ListViewItem lvi = new ListViewItem(getLastIdFromDB()); 
    .........................................^ 
    ...         HERE 
    ... 
    ... irrelevant code removed 
    ......................................... 

      var dbCon = DB_connect.Instance(); 

      if (dbCon.IsConnect()) 
      { 
       MySqlCommand cmd = new MySqlCommand("INSERT INTO `competitor`(`ID`, `Name`, `Age`) VALUES(@idSql,@NameSql,@AgeSql)", dbCon.Connection); 
       cmd.Parameters.AddWithValue("@idSql", getLastIdFromDB()); 
       cmd.Parameters.AddWithValue("@NameSql", playerName.Text); 
       cmd.Parameters.AddWithValue("@AgeSql", playerAge.Text); 

       try 
       { 
        cmd.ExecuteNonQuery(); 
        listView1.Items.Clear(); 
       } 
       catch (Exception ex) 
       { 
        MessageBox.Show("Error:" + ex.Message); 
        dbCon.Connection.Close(); 
       } 
       finally 
       { 
        updateListView(); 
       } 
     } 
} 

Что бы быть лучшим способом для мне решить эту проблему и в будущем обязательно закрыть m y соединений правильно?

UPDATE: (по запросу, включены DB_connect)

class DB_connect 
    { 
     private DB_connect() 
     { 
     } 

     private string databaseName = "simhopp"; 

     public string DatabaseName 
     { 
      get { return databaseName; } 
      set { databaseName = value; } 
     } 

     public string Password { get; set; } 
     private MySqlConnection connection = null; 

     public MySqlConnection Connection 
     { 
      get { return connection; } 
     } 

     private static DB_connect _instance = null; 

     public static DB_connect Instance() 
     { 
      if (_instance == null) 
       _instance = new DB_connect(); 
      return _instance; 
     } 

     public bool IsConnect() 
     { 
      bool result = true; 

      try 
      { 
       if (Connection == null) 
       { 
        if (String.IsNullOrEmpty(databaseName)) 
         result = false; 

        string connstring = string.Format("Server=localhost; database={0}; UID=root;", databaseName); 

        connection = new MySqlConnection(connstring); 
        connection.Open(); 

        result = true; 
       } 
      } 
      catch (Exception ex) 
      { 
       Console.Write("Error: " + ex.Message); 
      } 

      return result; 
     } 

     public void Close() 
     { 
      connection.Close(); 
     } 
    } 
} 

Answer 1

Как было предложено Pikoh в комментариях, использование предложения using действительно решило его для меня.

Рабочий код-фрагмент:

getLastIdFromDB

using (MySqlDataReader reader2 = cmd2.ExecuteReader()) { 

     while (reader2.Read()) 
     { 
     string item = reader2["ID"].ToString(); 
     lastIndex = int.Parse(item); 
     lastIndex++; 
     lastID = lastIndex.ToString(); 
     } 
} 

Answer 2

Вы пытаетесь иметь несколько открытых читателей на том же соединении. Обычно это называется «MARS» (несколько активных наборов результатов). MySql, похоже, не поддерживает его.

Вам придется либо ограничиться одним открытым читателем за один раз, либо использовать более одного соединения, чтобы вы могли иметь одно соединение для каждого читателя.

Мое предложение было бы выбрасывать эту однополюсную вещь и вместо этого использовать connection pooling и соответствующие using блоки.

Answer 3

Ваша обработка здесь соединение не хорошо. Вам нужно выровнять DB_connect. Нет необходимости поддерживать одно соединение - просто открывайте и закрывайте соединение каждый раз, когда вам это нужно. Под обложками ADO.NET «объединит» соединение для вас, так что вам не придется ждать, чтобы снова подключиться.

Для любого объекта, который реализует IDisposable вам необходимо либо позвонить .Dispose() на него в finally блоке, или обернуть его в using заявлении. Это гарантирует, что ваши ресурсы будут утилизированы надлежащим образом. Я рекомендую оператор using, потому что он помогает держать область видимой.

Ваши соглашения об именах должны соответствовать стандартам C#. Методы, возвращающие логическое значение, должны быть равны IsConnected, а не IsConnect. addPlayerBtn_Click должно быть AddPlayerButton_Click. getLastIdFromDB должно быть GetlastIdFromDb или getLastIdFromDatabase.

public string GetLastIdFromDatabase() 
{ 
    int lastIndex; 
    string lastID =""; 

    using (var connection = new MySqlConnection(Configuration.ConnectionString)) 
    using (var command = new MySqlCommand("query", connection)) 
    { 
     connection.Open(); 
     MySqlDataReader reader = cmd2.ExecuteReader(); 

     while (reader.Read()) 
     { 
       string item = reader2["ID"].ToString(); 
       lastIndex = int.Parse(item); 
       lastIndex++; 
       lastID = lastIndex.ToString(); 
     } 
    } 

    return lastID; 
} 

Обратите внимание, что ваш запрос тоже плох.Я подозреваю, что вы используете строковый тип данных вместо числа, хотя ваши идентификаторы основаны на цифрах. Вы должны переключить столбец на тип данных, а затем выбрать номер max(). Или используйте автоинкрементный столбец или последовательность, чтобы получить следующий идентификатор. Чтение каждой отдельной строки для определения следующего идентификатора и приращения счетчика не очень хорошо.