Kerangka Entitas: Sudah ada DataReader terbuka yang terkait dengan Perintah ini

Saya menggunakan Entity Framework dan kadang-kadang saya akan mendapatkan kesalahan ini.

EntityCommandExecutionException
{"There is already an open DataReader associated with this Command which must be closed first."}
   at System.Data.EntityClient.EntityCommandDefinition.ExecuteStoreCommands...

Meskipun saya tidak melakukan manajemen koneksi manual.

kesalahan ini terjadi sesekali.

kode yang memicu kesalahan (disingkat agar mudah dibaca):

        if (critera.FromDate > x) {
            t= _tEntitites.T.Where(predicate).ToList();
        }
        else {
            t= new List<T>(_tEntitites.TA.Where(historicPredicate).ToList());
        }

menggunakan pola Buang untuk membuka koneksi baru setiap kali.

using (_tEntitites = new TEntities(GetEntityConnection())) {

    if (critera.FromDate > x) {
        t= _tEntitites.T.Where(predicate).ToList();
    }
    else {
        t= new List<T>(_tEntitites.TA.Where(historicPredicate).ToList());
    }

}

masih bermasalah

mengapa EF tidak akan menggunakan kembali koneksi jika sudah terbuka.

Ini bukan tentang menutup koneksi. EF mengelola koneksi dengan benar. Pemahaman saya tentang masalah ini adalah bahwa ada beberapa perintah pengambilan data yang dieksekusi pada koneksi tunggal (atau perintah tunggal dengan banyak pilihan) sementara DataReader berikutnya dieksekusi sebelum yang pertama menyelesaikan pembacaan. Satu-satunya cara untuk menghindari pengecualian adalah untuk memungkinkan multiple DataReaders bersarang = nyalakan MultipleActiveResultSets. Skenario lain ketika ini selalu terjadi adalah ketika Anda beralih melalui hasil kueri (IQueryable) dan Anda akan memicu pemuatan malas untuk entitas yang dimuat di dalam iterasi.

Atau dengan menggunakan MARS (MultipleActiveResultSets) Anda dapat menulis kode Anda sehingga Anda tidak membuka beberapa set hasil.

Yang dapat Anda lakukan adalah mengambil data ke memori, sehingga pembaca tidak akan terbuka. Ini sering disebabkan oleh iterasi melalui resultset ketika mencoba untuk membuka set hasil lainnya.

Kode sampel:

public class MyContext : DbContext
{
    public DbSet<Blog> Blogs { get; set; }
    public DbSet<Post> Posts { get; set; }
}

public class Blog
{
    public int BlogID { get; set; }
    public virtual ICollection<Post> Posts { get; set; }
}

public class Post
{
    public int PostID { get; set; }
    public virtual Blog Blog { get; set; }
    public string Text { get; set; }
}

Katakanlah Anda sedang melakukan pencarian di database Anda yang berisi ini:

var context = new MyContext();

//here we have one resultset
var largeBlogs = context.Blogs.Where(b => b.Posts.Count > 5); 

foreach (var blog in largeBlogs) //we use the result set here
{
     //here we try to get another result set while we are still reading the above set.
    var postsWithImportantText = blog.Posts.Where(p=>p.Text.Contains("Important Text"));
}

Kita dapat melakukan solusi sederhana untuk ini dengan menambahkan .ToList () seperti ini:

var largeBlogs = context.Blogs.Where(b => b.Posts.Count > 5).ToList();

Ini memaksa entitas untuk memuat daftar ke dalam memori, jadi ketika kita mengulanginya meskipun dalam loop foreach itu tidak lagi menggunakan pembaca data untuk membuka daftar, itu malah dalam memori.

Saya menyadari bahwa ini mungkin tidak diinginkan jika Anda ingin malas memuat beberapa properti misalnya. Ini sebagian besar adalah contoh yang diharapkan menjelaskan bagaimana / mengapa Anda mungkin mendapatkan masalah ini, sehingga Anda dapat membuat keputusan yang sesuai

Ada cara lain untuk mengatasi masalah ini. Apakah itu cara yang lebih baik tergantung pada situasi Anda.

Masalahnya adalah hasil dari pemuatan malas, jadi salah satu cara untuk menghindarinya adalah tidak memiliki pemuatan malas, melalui penggunaan Sertakan:

var results = myContext.Customers
    .Include(x => x.Orders)
    .Include(x => x.Addresses)
    .Include(x => x.PaymentMethods);

Jika Anda menggunakan yang sesuai Include, Anda dapat menghindari mengaktifkan MARS. Tetapi jika Anda melewatkannya, Anda akan mendapatkan kesalahan, jadi mengaktifkan MARS mungkin adalah cara termudah untuk memperbaikinya.

Anda mendapatkan kesalahan ini, ketika koleksi yang Anda coba untuk beralih adalah jenis pemuatan malas (IQueriable).

foreach (var user in _dbContext.Users)
{    
}

Mengubah koleksi IQueriable menjadi koleksi enumerable lainnya akan menyelesaikan masalah ini. contoh

_dbContext.Users.ToList()

Catatan: .ToList () membuat set baru setiap waktu dan itu dapat menyebabkan masalah kinerja jika Anda berurusan dengan data besar.

Saya memecahkan masalah dengan mudah (pragmatis) dengan menambahkan opsi ke konstruktor. Jadi, saya menggunakannya hanya saat dibutuhkan.

public class Something : DbContext
{
    public Something(bool MultipleActiveResultSets = false)
    {
        this.Database
            .Connection
            .ConnectionString = Shared.ConnectionString /* your connection string */
                              + (MultipleActiveResultSets ? ";MultipleActiveResultSets=true;" : "");
    }
...

Coba di string koneksi Anda untuk mengatur MultipleActiveResultSets=true. Ini memungkinkan multitasking pada basis data.

Server=yourserver ;AttachDbFilename=database;User Id=sa;Password=blah ;MultipleActiveResultSets=true;App=EntityFramework

Itu berfungsi untuk saya ... apakah koneksi Anda di app.config atau Anda mengaturnya secara terprogram ... semoga ini membantu

Saya awalnya memutuskan untuk menggunakan bidang statis di kelas API saya untuk referensi contoh objek MyDataContext (Di mana MyDataContext adalah objek Konteks EF5), tetapi itulah yang tampaknya menciptakan masalah. Saya menambahkan kode seperti berikut ke setiap metode API saya dan itu memperbaiki masalahnya.

using(MyDBContext db = new MyDBContext())
{
    //Do some linq queries
}

Seperti yang dinyatakan orang lain, objek Konteks Data EF TIDAK thread aman. Jadi menempatkan mereka di objek statis pada akhirnya akan menyebabkan kesalahan "pembaca data" di bawah kondisi yang tepat.

Asumsi awal saya adalah bahwa membuat hanya satu instance objek akan lebih efisien, dan memberikan manajemen memori yang lebih baik. Dari apa yang saya kumpulkan meneliti masalah ini, bukan itu masalahnya. Bahkan, tampaknya lebih efisien untuk memperlakukan setiap panggilan ke API Anda sebagai peristiwa aman yang terisolasi. Memastikan bahwa semua sumber daya dirilis dengan benar, karena objek keluar dari ruang lingkup.

Ini masuk akal terutama jika Anda membawa API Anda ke perkembangan alami berikutnya yang akan mengeksposnya sebagai WebService atau REST API.

Penyingkapan

• OS: Windows Server 2012
• .NET: Diinstal 4,5, Proyek menggunakan 4.0
• Sumber Data: MySQL
• Kerangka Aplikasi: MVC3
• Otentikasi: Formulir

Saya perhatikan bahwa kesalahan ini terjadi ketika saya mengirim IQueriable ke tampilan dan menggunakannya dalam double foreach, di mana foreach bagian dalam juga perlu menggunakan koneksi. Contoh sederhana (ViewBag.parents dapat IQueriable atau DbSet):

foreach (var parent in ViewBag.parents)
{
    foreach (var child in parent.childs)
    {

    }
}

Solusi sederhana adalah untuk digunakan .ToList()pada koleksi sebelum menggunakannya. Perhatikan juga bahwa MARS tidak berfungsi dengan MySQL.

Saya menemukan bahwa saya memiliki kesalahan yang sama, dan itu terjadi ketika saya menggunakan Func<TEntity, bool>bukan Expression<Func<TEntity, bool>>untuk Anda predicate.

Setelah saya berubah semua Func'suntuk Expression'spengecualian berhenti yang dilemparkan.

Saya percaya bahwa EntityFramworkmelakukan beberapa hal pintar Expression'syang tidak ada hubungannya dengan ituFunc's

2 solusi untuk mengatasi masalah ini:

1. Memaksa cache memori menjaga pemuatan malas dengan .ToList()setelah kueri Anda, sehingga Anda kemudian dapat mengulanginya dengan membuka DataReader baru.
2. .Include(/ entitas tambahan yang ingin Anda muat dalam query /) ini disebut eager loading, yang memungkinkan Anda untuk (memang) memasukkan objek terkait (entitas) selama ia mengeksekusi query dengan DataReader.

Jalan tengah yang baik antara mengaktifkan MARS dan mengambil seluruh hasil yang diatur ke dalam memori adalah untuk mengambil hanya ID di kueri awal, dan kemudian loop melalui ID mematerialisasi setiap entitas saat Anda pergi.

Misalnya (menggunakan entitas sampel "Blog dan Posting" seperti dalam jawaban ini ):

using (var context = new BlogContext())
{
    // Get the IDs of all the items to loop through. This is
    // materialized so that the data reader is closed by the
    // time we're looping through the list.
    var blogIds = context.Blogs.Select(blog => blog.Id).ToList();

    // This query represents all our items in their full glory,
    // but, items are only materialized one at a time as we
    // loop through them.
    var blogs =
        blogIds.Select(id => context.Blogs.First(blog => blog.Id == id));

    foreach (var blog in blogs)
    {
        this.DoSomethingWith(blog.Posts);

        context.SaveChanges();
    }
}

Melakukan ini berarti Anda hanya menarik beberapa ribu bilangan bulat ke dalam memori, berbeda dengan ribuan keseluruhan grafik objek, yang seharusnya meminimalkan penggunaan memori sambil memungkinkan Anda untuk mengerjakan item-per-item tanpa mengaktifkan MARS.

Manfaat lain yang bagus dari ini, seperti yang terlihat dalam sampel, adalah Anda dapat menyimpan perubahan saat Anda mengulangi setiap item, daripada harus menunggu sampai akhir loop (atau solusi lain seperti itu), seperti yang akan diperlukan bahkan dengan MARS diaktifkan (lihat di sini dan di sini ).

Dalam kasus saya, saya menemukan bahwa ada pernyataan "menunggu" yang hilang sebelum panggilan myContext.SaveChangesAsync (). Menambahkan menunggu sebelum panggilan async itu memperbaiki masalah pembaca data untuk saya.

Jika kita mencoba mengelompokkan sebagian kondisi kita menjadi Fungsi <> atau metode ekstensi, kita akan mendapatkan kesalahan ini, misalkan kita memiliki kode seperti ini:

public static Func<PriceList, bool> IsCurrent()
{
  return p => (p.ValidFrom == null || p.ValidFrom <= DateTime.Now) &&
              (p.ValidTo == null || p.ValidTo >= DateTime.Now);
}

Or

public static IEnumerable<PriceList> IsCurrent(this IEnumerable<PriceList> prices) { .... }

Ini akan membuang pengecualian jika kita mencoba menggunakannya di Where (), yang harus kita lakukan adalah membangun Predikat seperti ini:

public static Expression<Func<PriceList, bool>> IsCurrent()
{
    return p => (p.ValidFrom == null || p.ValidFrom <= DateTime.Now) &&
                (p.ValidTo == null || p.ValidTo >= DateTime.Now);
}

Selanjutnya dapat dibaca di: http://www.albahari.com/nutshell/predicatebuilder.aspx

Masalah ini dapat diatasi hanya dengan mengubah data menjadi daftar

 var details = _webcontext.products.ToList();


            if (details != null)
            {
                Parallel.ForEach(details, x =>
                {
                    Products obj = new Products();
                    obj.slno = x.slno;
                    obj.ProductName = x.ProductName;
                    obj.Price = Convert.ToInt32(x.Price);
                    li.Add(obj);

                });
                return li;
            }

Dalam situasi saya masalah terjadi karena registrasi injeksi ketergantungan. Saya menyuntikkan layanan per permintaan lingkup yang menggunakan dbcontext ke layanan tunggal terdaftar. Karenanya dbcontext digunakan dalam banyak permintaan dan karenanya kesalahan.

Dalam kasus saya masalah ini tidak ada hubungannya dengan string koneksi MARS tetapi dengan serialisasi json. Setelah memutakhirkan proyek saya dari NetCore2 ke 3 saya mendapatkan kesalahan ini.

Informasi lebih lanjut dapat ditemukan di sini

Saya memecahkan masalah ini menggunakan bagian kode berikut sebelum permintaan kedua:

 ...first query
 while (_dbContext.Connection.State != System.Data.ConnectionState.Closed)
 {
     System.Threading.Thread.Sleep(500);
 }
 ...second query

Anda dapat mengubah waktu tidur dalam milidetik

PD Berguna saat menggunakan utas