Apakah koneksi Database akan ditutup jika kami menghasilkan baris datareader dan tidak membaca semua catatan?

Sementara memahami cara yieldkerja kata kunci, saya menemukan link1 dan link2 di StackOverflow yang menganjurkan penggunaan yield returnsementara iterasi DataReader dan sesuai dengan kebutuhan saya juga. Tapi itu membuat saya bertanya-tanya seperti apa yang terjadi, jika saya menggunakan yield returnseperti yang ditunjukkan di bawah ini dan jika saya tidak mengulangi seluruh DataReader, akankah koneksi DB tetap terbuka selamanya?

IEnumerable<IDataRecord> GetRecords()
{
    SqlConnection myConnection = new SqlConnection(@"...");
    SqlCommand myCommand = new SqlCommand(@"...", myConnection);
    myCommand.CommandType = System.Data.CommandType.Text;
    myConnection.Open();
    myReader = myCommand.ExecuteReader(CommandBehavior.CloseConnection);
    try
       {               
          while (myReader.Read())
          {
            yield return myReader;          
          }
        }
    finally
        {
            myReader.Close();
        }
}


void AnotherMethod()
{
    foreach(var rec in GetRecords())
    {
       i++;
       System.Console.WriteLine(rec.GetString(1));
       if (i == 5)
         break;
  }
}

Saya mencoba contoh yang sama dalam contoh Aplikasi Konsol dan memperhatikan saat debugging bahwa blok akhirnya GetRecords()tidak dijalankan. Bagaimana saya memastikan penutupan Koneksi DB? Apakah ada cara yang lebih baik daripada menggunakan yieldkata kunci? Saya mencoba merancang kelas khusus yang akan bertanggung jawab untuk mengeksekusi SQL pilihan dan prosedur tersimpan pada DB dan akan mengembalikan hasilnya. Tapi saya tidak ingin mengembalikan DataReader ke pemanggil. Saya juga ingin memastikan bahwa koneksi akan ditutup di semua skenario.

Sunting Mengubah jawaban atas jawaban Ben karena tidak tepat mengharapkan penelepon metode menggunakan metode ini dengan benar dan sehubungan dengan koneksi DB akan lebih mahal jika metode ini dipanggil beberapa kali tanpa alasan.

Terima kasih Jakob dan Ben untuk penjelasan terperinci.

Ya, Anda akan menghadapi masalah yang Anda uraikan: sampai Anda selesai mengulangi hasilnya, Anda akan membuat koneksi tetap terbuka. Ada dua pendekatan umum yang bisa saya pikirkan untuk menghadapi ini:

Dorong, jangan tarik

Saat Anda kembali sebuah IEnumerable<IDataRecord>, struktur data Anda dapat menarik dari. Sebagai gantinya, Anda dapat mengganti metode Anda untuk mendorong hasilnya. Cara paling sederhana adalah dengan memasukkan sebuah Action<IDataRecord>yang dipanggil pada setiap iterasi:

void GetRecords(Action<IDataRecord> callback)
{
    // ...
      while (myReader.Read())
      {
        callback(myReader);
      }
}

Perhatikan bahwa mengingat Anda berurusan dengan koleksi item, IObservable/ IObservermungkin struktur data sedikit lebih tepat, tetapi kecuali jika Anda membutuhkannya, yang sederhana Actionjauh lebih mudah.

Mengevaluasi dengan bersemangat

Alternatif lain adalah memastikan iterasi sepenuhnya selesai sebelum kembali.

Anda biasanya dapat melakukan ini dengan hanya memasukkan hasilnya dalam daftar lalu mengembalikannya, tetapi dalam hal ini ada komplikasi tambahan dari setiap item yang menjadi referensi yang sama kepada pembaca. Jadi Anda perlu sesuatu untuk mengekstrak hasil yang Anda butuhkan dari pembaca:

IEnumerable<T> GetRecords<T>(Func<IDataRecord,T> extractor)
{
    // ...
     var result = new List<T>();
     try
     {
       while (myReader.Read())
       {
         result.Add(extractor(myReader));         
       }
     }
     finally
     {
         myReader.Close();
     }
     return result;
}

Anda finallyBlok akan selalu dieksekusi.

Saat Anda menggunakan yield return kompiler akan membuat kelas bersarang baru untuk mengimplementasikan mesin negara.

Kelas ini akan berisi semua kode dari finallyblok sebagai metode terpisah. Ini akan melacak finallyblok yang perlu dijalankan tergantung pada negara. Semua finallyblok yang diperlukan akan dieksekusi diDispose metode.

Menurut spesifikasi bahasa C #, foreach (V v in x) embedded-statementdiperluas ke

{
    E e = ((C)(x)).GetEnumerator();
    try
    {
        while (e.MoveNext())
        {
            V v = (V)(T)e.Current;
            embedded - statement
        }
    }
    finally {
        … // Dispose e
    }
}

sehingga enumerator akan dibuang meskipun Anda keluar dari loop dengan breakatau return.

Untuk mendapatkan informasi lebih lanjut tentang implementasi iterator Anda dapat membaca artikel ini oleh Jon Skeet

Edit

Masalah dengan pendekatan tersebut adalah bahwa Anda mengandalkan klien kelas Anda untuk menggunakan metode ini dengan benar. Misalnya mereka bisa mendapatkan enumerator secara langsung dan mengulanginya melalui awhile lingkaran tanpa membuangnya.

Anda harus mempertimbangkan salah satu solusi yang disarankan oleh @BenAaronson.

Terlepas dari yieldperilaku tertentu , kode Anda berisi jalur eksekusi yang tidak akan membuang sumber daya Anda dengan benar. Bagaimana jika baris kedua Anda melempar pengecualian atau yang ketiga? Atau bahkan keempat Anda? Anda membutuhkan rantai coba / akhirnya yang sangat kompleks, atau Anda dapat menggunakan usingblok.

IEnumerable<IDataRecord> GetRecords()
{
    using(var connection = new SqlConnection(@"..."))
    {
        connection.Open();

        using(var command = new SqlCommand(@"...", connection);
        {
            using(var reader = command.ExecuteReader())
            {
               while(reader.Read())
               {
                   // your code here.
                   yield return reader;
               }
            }
        }
    }
}

Orang-orang mengatakan bahwa ini tidak intuitif, bahwa orang yang memanggil metode Anda mungkin tidak tahu bahwa menghitung hasilnya dua kali akan memanggil metode dua kali. Yah, keberuntungan yang sulit. Begitulah cara kerjanya bahasa. Itu sinyal yang IEnumerable<T>mengirim. Ada alasan mengapa ini tidak kembali List<T>atau T[]. Orang yang tidak tahu ini perlu dididik, tidak bekerja.

Visual Studio memiliki fitur yang disebut analisis kode statis. Anda dapat menggunakannya untuk mengetahui apakah Anda telah membuang sumber daya dengan benar.

Apa yang Anda lakukan tampaknya salah, tetapi akan bekerja dengan baik.

Anda harus menggunakan IEnumerator <> , karena juga mewarisi IDisposable .

Tetapi karena Anda menggunakan foreach, kompiler masih menggunakan IDisposable untuk menghasilkan IEnumerator <> untuk foreach.

pada kenyataannya, pendahuluan melibatkan banyak hal internal.

Periksa /programming/13459447/do-i-need-to-consider-disposing-of-any-ienumerablet-i-use