Entwickler-Ecke :: Thema anzeigen - Wie ExecuteReader in einer Schleife nutzen?

DeadlyAppearance - Do 20.08.09 16:54
Titel: Wie ExecuteReader in einer Schleife nutzen?

Abend zusammen.

Ich bin neu bei C# und habe folgendes Problem.
Mein Mainthread erstellt eine Datenbankverbindung und soll so lange immer wieder ein Select auf eine Tabelle machen, bis dort eine Abbruchdatensatz vorhanden ist.
Jetzt habe ich jedoch das Problem, dass sich nach dem connection.Open(); nur einmal command.ExecuteReader(); aufrufen kann, ohne erneut die Verbindung zu Beenden und erneut eine aufzubauen. Macht in meinen Augen natürlich keinen Sin, in einer Whileschleife alle Sekunde ne neue Verbindung aufzubauen, nur um den Inhalt einer Tabelle zu prüfen.
Wie also kann ich mein Command immer wieder ausführen und mit dem neuen Inhalt arbeiten, ohne ständing eine neue Verbindung aufbauen zu müssen?

C#-Quelltext

1:
2:
3:
4:
5:
6:
7:
8:
9:
10:
11:
12:
13:
14:
15:
16:
17:
18:
19:
20:
21:
22:
23:
24:
25:

            //connection.Open();

            while (!stoped)
            {
                connection.Open();
                Reader = command.ExecuteReader();

                while (Reader.Read())
                {
                    if (Reader.GetUInt32(1) == 1)
                    {
                        Console.WriteLine(Reader.GetValue(0).ToString());
                    }
                    if (Reader.GetUInt32(1) == 255)
                    {
                        stoped = true;
                    }                    
                }

                connection.Close();

                Thread.Sleep(1000);
            }

            //connection.Close();

JüTho - Do 20.08.09 18:02

Hallo,

es hängt vom DBMS (einschl. Version) und dem DbProvider ab, ob und wie es überhaupt möglich ist. Unter OleDbCommand.ExecuteReader heißt es beispielsweise als Hinweis in der SDK-Doku/MSDN:

Zitat:

Während der OleDbDataReader verwendet wird, ist die zugeordnete OleDbConnection durch den Informationsfluss für den OleDbDataReader belegt. In diesem Zustand können an der OleDbConnection keine anderen Operationen ausgeführt werden, außer diese zu schließen. Dies gilt solange, bis die Close-Methode von OleDbDataReader aufgerufen wird.

Aber das, was du vorhast, belastet sowieso die DB-Anbindung enorm; du solltest dir ein anderes Verfahren ausdenken.

Vor allem musst du beachten, dass unter NET eine DbConnection immer nur kurzfristig aktiv ist und so schnell wie möglich wieder geschlossen wird. Empfohlenes Vorgehen ist deshalb der using-Block um die Connection:

C#-Quelltext

1:
2:
3:
4:
5:
6:
7:
8:
9:
10:
11:
12:

using( DbConnection conn = new DbConnection(connString) ) {
   using( DbCommand cmd = new DbCommand(cmdString, conn) ) {
      conn.Open();
      DbDataReader reader = cmd.ExecuteReader();

      while (reader.Read())
      {
           // tu etwas
      }
      reader.Close();
   }
}

Bei diesem Verfahren wird die DbConnection immer korrekt aufgelöst.

Gruß Jürgen

JüTho - Do 20.08.09 19:08

Zur Lebensdauer von Connections siehe [Artikel] Ressourcen schonen - Datenbanken richtig öffnen und schließen [http://www.mycsharp.de/wbb2/thread.php?threadid=22354]

Zum using-Block siehe u.a. Die »using«-Anweisung zur Zerstörung von Objekten [http://openbook.galileocomputing.de/visual_csharp/visual_csharp_03_009.htm#mjdaf85346b58c184d567467c0cfae29ae]. Der letzte Absatz dort lautet:

Zitat:

Die Klasse, die im Ausdruck instanziiert wird, muss eine Bedingung erfüllen: Sie muss die Schnittstelle IDisposable implementieren.

Dies kann sogar umgekehrt formuliert werden: Jede Klasse, die IDisposable enthält, sollte auf diese Weise mit using-Block benutzt werden.

Jürgen

DeadlyAppearance - Fr 21.08.09 14:50

Wow, das rennt ja nun richtig.
Aus welchem Grund ist das denn nun so rasend schnell zu meiner vorherigen Ausführung?

Kann man das jetzt so lassen?

C#-Quelltext

1:
2:
3:
4:
5:
6:
7:
8:
9:
10:
11:
12:
13:
14:
15:
16:
17:
18:
19:
20:
21:
22:
23:
24:
25:
26:
27:
28:
29:
30:
31:
32:
33:
34:
35:
36:
37:
38:
39:
40:
41:
42:
43:
44:

static void Main(string[] args)
        {
            Console.WriteLine("{0:T} | Server gestartet", DateTime.Now);
            
            //Wird in die Datenbank als Type 255 eingetragen, führt dies zum Beenden des Servers
            bool stoped = false;

            string myConnectionString = "SERVER=localhost;" +
                            "DATABASE=xxx;" +
                            "UID=xxx;" +
                            "PASSWORD=xxx;";

            while (!stoped)
            {
                using (MySqlConnection connection = new MySqlConnection(myConnectionString))
                {
                    using (MySqlCommand command = new MySqlCommand("SELECT * FROM xxx", connection))
                    {
                        connection.Open();

                        MySqlDataReader Reader = command.ExecuteReader();
                        while (Reader.Read())
                        {
                            //Neuen Account anlegen
                            if (Reader.GetUInt32(1) == 1)
                            {
                                Thread TNewAccount = new Thread(new ParameterizedThreadStart(CreateAccount.MyProcedure));
                                TNewAccount.Start(Reader.GetUInt32(0));
                            }
                            //Server stoppen
                            if (Reader.GetUInt32(1) == 255)
                            {
                                stoped = true;
                            }
                        }
                        Reader.Close();
                    }
                }
            }

            Console.WriteLine("{0:T} | Server gestoppt", DateTime.Now);
            Console.ReadLine(); 
        }
    }

Entwickler-Ecke.de based on phpBB
Copyright 2002 - 2011 by Tino Teuber, Copyright 2011 - 2026 by Christian Stelzmann Alle Rechte vorbehalten.
Alle Beiträge stammen von dritten Personen und dürfen geltendes Recht nicht verletzen.
Entwickler-Ecke und die zugehörigen Webseiten distanzieren sich ausdrücklich von Fremdinhalten jeglicher Art!