Quando utilizzare SqlConnection.ClearAllPools() in C#

Question

Ho notato che i miei errori di codice su sqlWrite.ExecuteNonQuery(); dopo l'esecuzione di 200 inseriscono query in un paio di secondi. Ho sempre pensato che lo using assicurasse che le risorse vengano riutilizzate correttamente e non ci sarà bisogno di fare nulla. Questa è la prima volta che ottengo questo errore e ho avuto a che fare con sql/C# per quasi 3 anni facendo cose diverse.

using (SqlConnection varConnection = Locale.sqlConnectOneTime(Locale.sqlDataConnectionDetails)) 
{ 
    using (var sqlWrite = new SqlCommand(preparedCommand, varConnection)) 
    { 
     sqlWrite.Parameters.AddWithValue("@var_agr_fname", var_agr_fname == "" ? (object) DBNull.Value : var_agr_fname); 
     sqlWrite.ExecuteNonQuery(); 
    } 
} 


public static SqlConnection sqlConnectOneTime(string varSqlConnectionDetails) 
{ 
    var sqlConnection = new SqlConnection(varSqlConnectionDetails); 
    try 
    { 
     sqlConnection.Open(); 
    } 
    catch 
    { 
     DialogResult result = MessageBox.Show(new Form {TopMost = true}, 
               "Błąd połączenia z bazą danych. Czy chcesz spróbować nawiązac połączenie ponownie?", 
               "Błąd połączenia (000001)", 
               MessageBoxButtons.YesNo, 
               MessageBoxIcon.Stop); 
     if (result == DialogResult.No) 
     { 
      if (Application.MessageLoop) 
      { 
       Application.Exit(); // Use this since we are a WinForms app 
      } 
      else 
      { 
       Environment.Exit(1); // Use this since we are a console app 
      } 
     } 
     else 
     { 
      sqlConnection = sqlConnectOneTime(varSqlConnectionDetails); 
     } 
    } 
    return sqlConnection; 
} 

Messaggio di errore: A transport-level error has occurred when sending the request to the server. (provider: Shared Memory Provider, error: 0 - No process is on the other end of the pipe.)

Considerando consiglio per this error dovrei usare SqlConnection.ClearAllPools(); per assicurarsi che i collegamenti siano reset o scartati in modo corretto. Quindi posso usarlo ma la domanda è dove usarlo e quando? Come sapere se il limite si sta rompendo? Dov'è il limite? a 50/150/200? o dovrei usarlo ogni volta in un ciclo?

Answer 1

Quei 2 errori:

A transport-level error has occurred when sending the request to the server. (provider: TCP Provider, error: 0 - An existing connection was forcibly closed by the remote host.)

A transport-level error has occurred when sending the request to the server. (provider: Shared Memory Provider, error: 0 - No process is on the other end of the pipe.)

hanno riguardato valore DateTime essere inseriti in SQL con la data prima del 1900 anno. La regola Microsoft qui è .. non memorizzare il valore DateTime meno di 1900 anni nel valore DateTime in SQL. Utilizzare invece una stringa ...

Answer 2

"Ho un metodo che riuso usandolo una o più volte. Fa tutto da stabilire una connessione (o usando quella già connessa) per restituire la connessione al pool. Ho avuto modo di riutilizzare sempre la connessione se è aperta e se è chiusa la apro sempre ".

Sembra che tu abbia reinventato il Connection-Pool. Riutilizza sempre le connessioni se sono chiuse e non può riutilizzarle se sono aperte.

Quindi chiudere la connessione nel blocco catch:

public static SqlConnection sqlConnectOneTime(string varSqlConnectionDetails) { 
    var sqlConnection = new SqlConnection(varSqlConnectionDetails); 
    try { 
     sqlConnection.Open(); 
    } catch { 
     //log and 
     sqlConnection.Close(); 
     throw 
    } 
    return sqlConnection; 
} 

Modifica: Per essere onesti non vorrei utilizzare tali metodi factory a tutti. Sono solo una fonte di errori non riproducibili. Quanto tempo richiede per creare e aprire la connessione in cui lo stai utilizzando?

using(SqlConnection varConnection = new SqlConnection(Locale.sqlDataConnectionDetails)) { 
    using (var sqlWrite = new SqlCommand(preparedCommand, varConnection)) { 
     sqlWrite.Parameters.AddWithValue("@varSecus_agr_fname", varSecus_agr_fname == "" ? (object) DBNull.Value : varSecus_agr_fname); 
     varConnection.Open(); 
     sqlWrite.ExecuteNonQuery(); 
    } 
} 

I primi due collegamenti sono dalla tua domanda legata (non la risposta accettata), potrebbero anche essere utili:

• http://social.msdn.microsoft.com/Forums/en-US/sqldataaccess/thread/9609559d-f7ce-4bd8-97d0-0003ff7c9c98/
• http://blogs.msdn.com/b/spike/archive/2009/04/16/a-transport-level-error-has-occurred-when-sending-the-request-to-the-server-provider-tcp-provider-error-0-an-existing-connection-was-forcibly-closed-by-the-remote-host.aspx
• ExecuteReader requires an open and available Connection. The connection's current state is Connecting (non lo stesso soggetto, ma apparentemente uno sfondo simile)

Answer 3

In primo luogo, lasciami sono sicuro che questo codice sia orribile. Stai mescolando l'interfaccia utente con la creazione della connessione dati. Inoltre, si mostra una finestra di dialogo all'interno di una sezione catch e si effettua una chiamata ricorsiva! Questo è molto caotico e di per sé può portare a errori e comportamenti imprevedibili. E la formattazione (originale) rende difficile la lettura. Ci scusiamo per l'aspro commento ma dovresti davvero ridisegnare questo codice.

A parte questo il tuo codice dovrebbe funzionare bene, ma se stai ricevendo l'errore No process is on the other end of the pipe. significa che c'è qualcosa di sbagliato nel tuo database e/o SQL Server. Sembra che si ostruisca e non accetta più connessioni. Se esegui batch di inserimenti in un breve periodo, eseguili su una connessione, se possibile. ClearAllPools è un modo per recuperare quando succede qualcosa di sbagliato e sarebbe meglio scoprire di cosa si tratta invece di coprirlo. È come prendere il paracetamolo quando il dente fa male e non va mai dal dentista.

Un'altra cosa è che l'utilizzo di più SqlConnections crea una transazione separata per ciascuna connessione. Ciò aggiunge carico su SQL Server anche se può sicuramente fare più di centinaia di transazioni al secondo.

Inoltre, è possibile modificare il trasporto su named pipe e TCP per vedere se cambia qualcosa.