Asynchrone SQLCommand und CCR

Question

Ich habe mit dem Demo-Code aus diesem MSDN-Artikel gespielt von Jeffrey Richter .

Ich habe eine neue Funktion zu seinem ApmToCcrAdapters hinzugefügt, um die SqlCommand.BeginExecuteReader zu handhaben. Nur ist es, die Leser zu schließen, bevor ich es lesen kann.

Der folgende Code wird verwendet, um eine FromIteratorHandler zu bieten:

    private static IEnumerator<ITask> AsyncReaderDemoHandler()
    {
       SqlDataReader reader = null;
       SqlConnection connection = new SqlConnection(@"Data Source=.\SQLEXPRESS;Initial Catalog=BizData;Integrated Security=True;Async=True;");
       string query = "SELECT * FROM Account;";
       SqlCommand command = new SqlCommand(query,connection);

       connection.Open();
       yield return Arbiter.Choice(ApmToCcrAdapters.GetReader(command),
          delegate(SqlDataReader r) { Msg("Got SQL data"); reader = r; },
          delegate(Exception e) { Msg("Failed to get SQL data"); });

       connection.Close();

       if (reader == null) yield break;

       //This is where the code fails: Reader is Closed!
       while (reader.Read())
       {
           Console.WriteLine(reader["Account"]);
       }
   }

Was wiederum ruft den folgenden Code:

   /// <summary>
   /// Gets the Reader, requires connection to be managed
   /// </summary>
   public static PortSet<SqlDataReader, Exception> GetReader(SqlCommand sqlCommand)
   {
       Port<SqlDataReader> portResponse = null;
       Port<Exception> portException = null;
       GetReaderResponse(sqlCommand, ref portResponse, ref portException);
       return new PortSet<SqlDataReader, Exception>(portResponse, portException);
   }

   // Wrapper for SqlCommand's GetResponse
   public static void GetReaderResponse(SqlCommand sqlCom,
      ref Port<SqlDataReader> portResponse, ref Port<Exception> portException)
   {
       EnsurePortsExist(ref portResponse, ref portException);
       sqlCom.BeginExecuteReader(ApmResultToCcrResultFactory.Create(
          portResponse, portException,
          delegate(IAsyncResult ar) { return sqlCom.EndExecuteReader(ar); }), null);
   }

Answer 1

Die Verbindung muss offen bleiben für die Leser zu arbeiten. Ich glaube, dass die Verbindung geschlossen ist Ihr Problem. Lassen Sie die Verbindung offen und fordern den Leser verfügen, wenn Sie fertig und ich denke, dass die Verbindung aufzuräumen sollte.