Неверная попытка прочитать - возможно ли действие?

Question

public void ExecuteAction(MySqlCommand query, Action<MySqlDataReader> action) 
    { 
     _connection.Open(); 
     query.Connection = _connection; 
     using(var reader = query.ExecuteReader()) 
     { 
      while (reader.Read()) 
      { 
       action(reader); 
      } 
      reader.Close(); 
     } 
     _connection.Close(); 
    } 

Можно ли сделать что-то подобное? Я получаю всегда ошибку «Неверная попытка чтения, когда читатель закрыт».

Это кусок кода, который я использую:

private void UpdateRecords() 
    { 
     var query = String.Format("SELECT * FROM {0}", _table); 
     var cmd = new MySqlCommand(query); 
     _db.ExecuteAction(cmd, reader => 
            { 
             var rows = new List<object>(); 
             for (var i = 0; i < reader.FieldCount; i++) 
             { 
              if (reader.IsDBNull(i)) continue; 
              var name = reader.GetName(i); 
              if (!_fields.Contains(name)) _fields.Add(name); 
              rows.Add(reader.GetValue(i)); 
             } 
             _records.Add(new Record(_fields, rows)); 
            }); 
    } 

Я пытаюсь хранить все записи таблиц баз данных по в динамические классы внутри программы. Когда я пытаюсь добавить динамические данные mysql в эти классы, я получаю эту ошибку.

Другой вопрос, который связан: есть ли библиотека, которая может сделать это для меня? Это много кода, который мне не нужно было бы записывать, но это мой первый подход к MySQL и C#, поэтому у меня нет каких-либо знаний. Спасибо за помощь.

UPDATE: теперь я получаю ошибку, что соединение уже открыт, MySQL делает меня проклятье (я привык к MongoDB ...)

Answer 1

Я решил проблему. Я не знал, что не могу использовать более одного раза одно и то же соединение для вызова разных читателей, поэтому мне приходилось создавать новый каждый раз, когда мне нужно было запросить db.

MySQL - Multiple result sets

Answer 2

ExecuteAction ли работа? Вы даже используете этот код? UpdateRecords имеет очевидные проблемы. Если вы посмотрите на ExecuteAction, он откроет соединение, затем объявит читателя в заявлении using. После этого он закрывает соединение. В UpdateRecords у вас нет кода для открытия/закрытия соединения, и вам также не хватает кода, чтобы избавиться от чтения. В результате ваш код может работать иногда (например, если соединение уже открыто в другом месте) и не будет работать в другое время (в случае, если соединение еще не было выполнено).