غير المتزامن SQLCommand وCCR

Question

ولقد لعب مع رمز العرض من هذه المادة MSDN بواسطة جيفري ريختر .

ولقد أضاف وظيفة جديدة لApmToCcrAdapters له للتعامل مع SqlCommand.BeginExecuteReader. فقط هو إغلاق القارئ قبل أن أتمكن من قراءتها.

ويتم استخدام التعليمات البرمجية التالية لتوفير FromIteratorHandler:

    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"]);
       }
   }

والذي بدوره يدعو التعليمات البرمجية التالية:

   /// <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

ويجب أن يبقى اتصال مفتوح للقارئ للعمل. أعتقد إغلاق الاتصال هو مشكلتك. ترك الاتصال مفتوحة، وندعو التصرف على القارئ عند القيام به، وأعتقد أنه ينبغي تنظيف الاتصال.