实体框架：已经有一个打开的 DataReader 与此命令关联

Question

我正在使用实体框架，有时我会收到此错误。

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

即使我没有进行任何手动连接管理。

此错误间歇性发生。

触发错误的代码（为便于阅读而缩短）：

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

使用 Dispose 模式以每次打开新连接。

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());
    }

}

还是有问题

如果连接已经打开，为什么 EF 不重用它。

Answer 1

这不是关闭连接。 EF 正确管理连接。我对这个问题的理解是，在单个连接（或具有多个选择的单个命令）上执行了多个数据检索命令，而下一个 DataReader 在第一个完成读取之前执行。避免该异常的唯一方法是允许多个嵌套的 DataReaders = 打开 MultipleActiveResultSets。经常发生这种情况的另一种情况是，当您迭代查询结果 (IQueryable) 时，您将触发迭代内加载实体的延迟加载。

Answer 2

还有另一种方法可以解决这个问题。这是否更好取决于您的情况。

问题是由延迟加载引起的，因此避免它的一种方法是不延迟加载，通过使用 Include：

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

如果您使用适当的Includes，则可以避免启用 MARS。但是如果你错过了一个，你就会得到错误，因此启用 MARS 可能是修复它的最简单方法。

Answer 3

除了使用 MARS (MultipleActiveResultSets)，您还可以编写代码，这样您就不会打开多个结果集。

您可以做的是将数据检索到内存中，这样您就不会打开阅读器。 这通常是由于在尝试打开另一个结果集时迭代结果集造成的。

示例代码：

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; }
}

假设您正在查找包含以下内容的数据库：

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

我们可以通过像这样添加 .ToList() 来解决这个问题：

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

这迫使实体框架将列表加载到内存中，因此当我们在 foreach 循环中迭代它时，它不再使用数据读取器打开列表，而是在内存中。

我意识到，如果您想延迟加载某些属性，这可能不是您所希望的。 这主要是一个示例，希望能解释您如何/为什么会遇到此问题，以便您可以做出相应的决定

Answer 4

我通过向构造函数添加选项轻松（实用）解决了这个问题。因此，我只在需要时使用它。

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

Answer 5

当您尝试迭代的集合是一种延迟加载 (IQueriable) 时，您会收到此错误。

foreach (var user in _dbContext.Users)
{    
}

将 IQueriable 集合转换为其他可枚举集合将解决此问题。 例子

_dbContext.Users.ToList()

注意：.ToList() 每次都会创建一个新集合，如果您正在处理大数据，它可能会导致性能问题。

Answer 6

我在第二次查询之前使用以下代码部分解决了这个问题：

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

您可以以毫秒为单位更改睡眠时间

P.D.使用线程时很有用

Answer 7

我最初决定在我的 API 类中使用静态字段来引用 MyDataContext 对象的实例（其中 MyDataContext 是 EF5 上下文对象），但这似乎是造成问题的原因。我在我的每个 API 方法中添加了类似以下的代码，从而解决了问题。

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

正如其他人所说，EF 数据上下文对象不是线程安全的。因此将它们放在静态对象中最终会在适当的条件下导致“数据读取器”错误。

我最初的假设是只创建对象的一个​​实例会更有效，并且可以提供更好的内存管理。从我收集到的研究这个问题的资料来看，情况并非如此。事实上，将对 API 的每次调用视为一个独立的、线程安全的事件似乎更有效。确保在对象超出范围时正确释放所有资源。

这很有意义，特别是如果您将 API 带到下一个自然进程，即将其公开为 WebService 或 REST API。

披露

• 操作系统：Windows Server 2012
• .NET：安装 4.5，项目使用 4.0
• 数据来源：MySQL
• 应用程序框架：MVC3
• 身份验证：表单

Answer 8

我注意到当我将 IQueriable 发送到视图并在双 foreach 中使用它时会发生此错误，其中内部 foreach 也需要使用连接。简单示例（ViewBag.parents 可以是 IQueriable 或 DbSet）：

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

    }
}

简单的解决方案是在使用之前在集合上使用.ToList()。另请注意，MARS 不适用于 MySQL。

Answer 9

在启用 MARS 和将整个结果集检索到内存之间的一个很好的中间立场是，在初始查询中仅检索 ID，然后在执行过程中遍历实现每个实体的 ID。

例如（使用 this answer 中的“博客和帖子”示例实体）：

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();
    }
}

这样做意味着您只需将几千个整数拉入内存，而不是数千个整个对象图，这样可以最大限度地减少内存使用量，同时使您能够在不启用 MARS 的情况下逐项工作。

如示例中所示，这样做的另一个好处是，您可以在遍历每个项目时保存更改，而不必等到循环结束（或其他类似的解决方法）即使启用了 MARS 也需要（请参阅 here 和 here）。

Answer 10

尝试在您的连接字符串中设置MultipleActiveResultSets=true。 这允许对数据库进行多任务处理。

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

这对我有用...无论是您在 app.config 中的连接还是以编程方式设置它... 希望这有帮助

Answer 11

我发现我有同样的错误，当我使用 Func<TEntity, bool> 而不是 Expression<Func<TEntity, bool>> 为您的 predicate 时发生了。

一旦我将所有Func's 更改为Expression's，异常就会停止抛出。

我相信EntityFramwork 对Expression's 做了一些聪明的事情，而Func's 根本没有这样做

Answer 12

如果我们尝试将部分条件分组到 Func 或扩展方法中，我们会得到这个错误，假设我们有这样的代码：

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) { .... }

如果我们尝试在 Where() 中使用它会抛出异常，我们应该做的是像这样构建一个 Predicate：

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

更多内容可以阅读：http://www.albahari.com/nutshell/predicatebuilder.aspx

Answer 13

这个问题只要把数据转换成列表就可以解决

 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;
            }

Answer 14

在我的情况下，由于依赖注入注册而出现问题。我将使用 dbcontext 的每个请求范围服务注入到单例注册服务中。因此，在多个请求中使用了 dbcontext，因此出现了错误。

Answer 15

缓解此问题的两种解决方案：

1. 使用.ToList() 强制内存缓存保持延迟加载 查询，因此您可以通过它打开一个新的 DataReader 进行迭代。
2. .Include（/您要在查询中加载的其他实体/）这个 被称为急切加载，它允许您（确实）包括 在执行查询期间关联的对象（实体） 数据读取器。

Answer 16

就我而言，我发现在 myContext.SaveChangesAsync() 调用之前缺少“等待”语句。在这些异步调用之前添加等待解决了我的数据读取器问题。

Answer 17

在我的情况下，这个问题与 MARS 连接字符串无关，而是与 json 序列化有关。 将我的项目从 NetCore2 升级到 3 后，出现此错误。

更多信息可以找到here