Почему вылетает ошибка: An operation is already in progress?

Question

[beduin01]

Не могу разобраться, почему вылетает ошибка: System.InvalidOperationException: An operation is already in progress.

Кусок кода который который если выкинуть, все работает нормально я пометил.

List<UserData> uds = new List<UserData>();
        UserData ud;

        List<string> dblist = GetListDBsList();
        if (dblist.Contains(config.PGdbName))
        {
            Console.WriteLine("Data Base exists: {0}", config.PGdbName);
        }

        else
        {
            Console.WriteLine("Data Base DO NOT exists: {0}", config.PGdbName);
            return;
        }

        NpgsqlConnection conn = new NpgsqlConnection("Server=127.0.0.1;Port=5432;User Id=" + config.PGLogin + ";" +
           "Password=" + config.PGPass + ";Database=" + config.PGdbName + ";");

        //select datname from pg_database;

        try
        {
            conn.Open();

            Console.WriteLine("PG Connected");
        }

        catch(SocketException e)
        {
            Console.WriteLine(e.Message);

        }

        //NpgsqlTransaction tr = conn.BeginTransaction();
        // Где-то в этом блоке ошибка 
        string tablesListRequestSQL = @"SELECT table_name FROM information_schema.tables WHERE table_schema='public'";
        NpgsqlCommand commandGetDBTables = new NpgsqlCommand(tablesListRequestSQL, conn);
        NpgsqlDataReader drGetDBTables = commandGetDBTables.ExecuteReader();
        //tr.Commit();
        while (drGetDBTables.Read())
        {
            existsInDBTables.Add(drGetDBTables[0].ToString());
        }

        foreach (string table in requireTablesList) // 
        {
            if (!existsInDBTables.Contains(table)) // if element from requireTablesList do not found -> DB have not simmilar Tables!
            {
                notFoundedTables.Add(table);
            }

        }

        if (notFoundedTables.Count != 0) // if not empty
        {
            Console.WriteLine("Next tables are marked as reqired for Sync, but can't be found in DataBase: ");

            foreach (var table in notFoundedTables)
            {
                Console.WriteLine(table);
            }
        }
        // Конец блока где ошибка.


        Console.ReadKey();


         NpgsqlCommand command = new NpgsqlCommand("SELECT city, state FROM cities", conn);


        try
        {

            NpgsqlDataReader dr = command.ExecuteReader();
            while (dr.Read())
            {
               // UserData ud = new UserData();
                ud.id = Int32.Parse(dr[0].ToString());
                ud.guid = (dr[1].ToString());
                ud.name = (dr[2].ToString());
                ud.userblob = (byte[])dr[3];
                uds.Add(ud);
                //File.WriteAllBytes("outputimg.jpg", ud.userblob);
                //Console.ReadKey();

            }

        }

        finally
        {
            conn.Close();
        }

Что не так делаю?

Comments

[Дмитрий Ковальский]

А зачем вы делаете SELECT в рамках транзакции? Это же не изменение данных - какую цель преследуете?

[beduin01]

Дмитрий Ковальский: ну я же его закомментил -- он для экспериментов был. Или вы о чем?

[Maa-Kut]

в какой строке эксепшн-то вылетает?

[beduin01]

NpgsqlDataReader dr = command.ExecuteReader(); // вот тут
while (dr.Read())

Answer 1

[Александр Ананьев]

In general, An operation is already in progress is supposed to mean that you're trying to execute a new query on a connection that is still busy with an old one.

https://github.com/npgsql/npgsql/issues/826

Comments

[beduin01]

Вот полный код: https://github.com/bubnenkoff/DBSyncNET/blob/maste... где косяк то??

Answer 2

[Maa-Kut]

Как насчет того, чтобы ридеры в using забрать?

using(NpgsqlDataReader drGetDBTables = commandGetDBTables.ExecuteReader())
{
        //tr.Commit();
        while (drGetDBTables.Read())
        {
            existsInDBTables.Add(drGetDBTables[0].ToString());
        }
}
...
using(NpgsqlDataReader dr = command.ExecuteReader())
{
            while (dr.Read())
            {
               // UserData ud = new UserData();
                ud.id = Int32.Parse(dr[0].ToString());
                ud.guid = (dr[1].ToString());
                ud.name = (dr[2].ToString());
                ud.userblob = (byte[])dr[3];
                uds.Add(ud);
                //File.WriteAllBytes("outputimg.jpg", ud.userblob);
                //Console.ReadKey();

            }
}

Подозреваю, что второй ExecuteReader падает из-за того, что предыдущий ридер не закрыт - команда как бы еще выполняется. Кстати, сами команды тоже можно в using завернуть - они ж тоже IDisposable.

Comments

[beduin01]

Как закрыть текущий ридер?

[beduin01]

Using это типа организация скоупа, при выходе из которого сборщик мусора все чистит?

[Maa-Kut]

Именно. При выходе из using-блока автоматически будет вызван Dispose() у ридера. А его Dispose заодно и закрытие выполняет.

[beduin01]

Maa-Kut: спасибо, а коммиты в каких случаях делать? Тут как я понимаю автокоммит идет

[Maa-Kut]

Не вижу смысла делать коммит, если не делалось изменений в БД. В общем же случае сначала создаем транзакцию, потом выполняем-закрываем команды, потом делаем коммит или роллбэк (смотря что нужно). Еще можно использовать класс TransactionScope: https://msdn.microsoft.com/ru-ru/library/system.tr... По ссылке есть пример.