Subsonic ActiveRecord - Verbindungen hängen beim Hinzufügen von vielen Datensätzen

Question

Ich bekomme eine vertraute Timeout SqlException, wenn ich eine Menge neuer Datensätze schnell mit Subsonic ActiveRecord und Sql Server hinzufügen.

Timeout abgelaufen. Der Timeout-Zeitraum ist vor dem Erhalt einer Verbindung vom Pool verstrichen. Dies kann aufgetreten sein, weil alle gepoolten Verbindungen verwendet wurden und max Pool Größe erreicht wurde.

Ich habe es geschafft, diese Frage mit dem folgenden einfachen Code-Block zu replizieren:

for (int i = 0; i < 1000; i++) 
    { 
     var address = new Address(); 
     address.City = "TEST"; 
     address.Save(); 
    } 

Der Code wird Datensätze hinzufügen, bis es 100 (die Größe Max Pool, wahrscheinlich nicht zufällig) erreicht, an dem Punkt es scheitert mit der obigen Ausnahme. Danach werden die Verbindungen für ungefähr 5-10 Minuten gehalten, währenddessen alle Versuche, die Datenbank zu verwenden, die obige Ausnahme ergeben.

Interessanterweise habe ich festgestellt, dass das Ausführen auf meinem lokalen Computer in VS (gleiche Codebasis für genau die gleiche Datenbankinstanz) der Code erfolgreich alle 1000 Datensätze hinzufügen. Vielleicht verlangsamt die Latenz zwischen hier und meinem Host die Datenbankaufrufe genug?

Vorausgesetzt, dass es lokal funktioniert, nehme ich an, dies ist kein Subsonic Problem direkt, aber gibt es einen Fehler, den ich mache oder irgendeine Art und Weise kann ich meinen Code oder Konfiguration ändern, um das schnelle Öffnen und Schließen von Verbindungen zu behandeln viele Datensätze seriell hinzufügen?

Answer 1

Ich habe einen Perf-Test auf AR und SimpleRepo durchgeführt, der 100.000 Datensätze durchschlug und das Ding ziemlich hart schlug - Verbindungsprobleme sind wirklich der erste Stop beim Perf-Tuning.

Das sagte - wir hatten ein Problem in Pre-Release mit einem Leser offen gelassen werden :). Ich habe es vor ein paar Monaten repariert - kannst du bestätigen, dass du die neuesten Bits hast?

Auch - ja Latenz kann seltsam sein. Ich kenne die Details nicht, aber es sieht so aus.

Answer 2

Ich hatte das gleiche Problem mit MySQL. Durch das Instanziieren eines neuen aktiven Datensatzobjekts und den anschließenden Aufruf von save wurde eine Verbindung geöffnet, die nie geschlossen wurde.

Eine Lösung gefunden, die zu funktionieren scheint (Danke an kamsar http://github.com/subsonic/SubSonic-3.0/issues#issue/69) Offenbar liegt das Problem an einem nicht geschlossenen Reader ?!

Ändern der Linie 197 in SubSonicRepository.cs (3.0.0.3) zu "können (DbDataReader rdr = provider.ExecuteReader (Abfrage))" ( und Einwickeln der Verwendung in einem geeigneten Umfang auf etwa wie 218) scheint gelöst zu haben.

So sah der Code so aus und keine Verbindungsleck mehr !!!

  //var rdr = provider.ExecuteReader(query); 
      using (System.Data.Common.DbDataReader rdr = provider.ExecuteReader(query)) 
      { 
       if (rdr.Read()) 
        result = rdr[0]; 
       // repopulate primary key column with newly generated ID 
       if (result != null && result != DBNull.Value) 
       { 

        try 
        { 
         var tbl = provider.FindOrCreateTable(typeof(T)); 
         var prop = item.GetType().GetProperty(tbl.PrimaryKey.Name); 
         var settable = result.ChangeTypeTo(prop.PropertyType); 
         prop.SetValue(item, settable, null); 

        } 
        catch (Exception x) 
        { 
         //swallow it - I don't like this per se but this is a convenience and we 
         //don't want to throw the whole thing just because we can't auto-set the value 
        } 
       } 
      } 

Answer 3

InnerSphere hat die richtige Antwort. Ich konnte nicht abstimmen, weil ich den Rep-Score nicht habe und nicht herausfinden konnte, wie ich einfach auf seinen Post antworten/kommentieren sollte.

Die einzige Sache, die hinzuzufügen ist, wenn Sie den Code von GitHub ziehen, dieses Update ist bereits enthalten.

Keine Probleme nach dem Kompilieren und Verwenden der DLL aus dem Amtskode erstellt.

Answer 4

ich rdr.Close() direkt nach dem Ergebnis zu erhalten, d.h .:

if (rdr.Read()) 
    result = rdr[0]; 

rdr.Close();