已经有一个打开的 DataReader 与此命令关联，必须先将其关闭

Question

我有这个查询，我在这个函数中收到错误：

var accounts = from account in context.Accounts
               from guranteer in account.Gurantors
               select new AccountsReport
               {
                   CreditRegistryId = account.CreditRegistryId,
                   AccountNumber = account.AccountNo,
                   DateOpened = account.DateOpened,
               };

 return accounts.AsEnumerable()
                .Select((account, index) => new AccountsReport()
                    {
                        RecordNumber = FormattedRowNumber(account, index + 1),
                        CreditRegistryId = account.CreditRegistryId,
                        DateLastUpdated = DateLastUpdated(account.CreditRegistryId, account.AccountNumber),
                        AccountNumber = FormattedAccountNumber(account.AccountType, account.AccountNumber)
                    })
                .OrderBy(c=>c.FormattedRecordNumber)
                .ThenByDescending(c => c.StateChangeDate);


public DateTime DateLastUpdated(long creditorRegistryId, string accountNo)
{
    return (from h in context.AccountHistory
            where h.CreditorRegistryId == creditorRegistryId && h.AccountNo == accountNo
            select h.LastUpdated).Max();
}

错误是：

已经有一个与此命令关联的打开的 DataReader，必须先将其关闭。

更新：

添加了堆栈跟踪：

InvalidOperationException: There is already an open DataReader associated with this Command which must be closed first.]
   System.Data.SqlClient.SqlInternalConnectionTds.ValidateConnectionForExecute(SqlCommand command) +5008639
   System.Data.SqlClient.SqlConnection.ValidateConnectionForExecute(String method, SqlCommand command) +23
   System.Data.SqlClient.SqlCommand.ValidateCommand(String method, Boolean async) +144
   System.Data.SqlClient.SqlCommand.RunExecuteReader(CommandBehavior cmdBehavior, RunBehavior runBehavior, Boolean returnStream, String method, DbAsyncResult result) +87
   System.Data.SqlClient.SqlCommand.RunExecuteReader(CommandBehavior cmdBehavior, RunBehavior runBehavior, Boolean returnStream, String method) +32
   System.Data.SqlClient.SqlCommand.ExecuteReader(CommandBehavior behavior, String method) +141
   System.Data.SqlClient.SqlCommand.ExecuteDbDataReader(CommandBehavior behavior) +12
   System.Data.Common.DbCommand.ExecuteReader(CommandBehavior behavior) +10
   System.Data.EntityClient.EntityCommandDefinition.ExecuteStoreCommands(EntityCommand entityCommand, CommandBehavior behavior) +443

[EntityCommandExecutionException: An error occurred while executing the command definition. See the inner exception for details.]
   System.Data.EntityClient.EntityCommandDefinition.ExecuteStoreCommands(EntityCommand entityCommand, CommandBehavior behavior) +479
   System.Data.Objects.Internal.ObjectQueryExecutionPlan.Execute(ObjectContext context, ObjectParameterCollection parameterValues) +683
   System.Data.Objects.ObjectQuery`1.GetResults(Nullable`1 forMergeOption) +119
   System.Data.Objects.ObjectQuery`1.System.Collections.Generic.IEnumerable<T>.GetEnumerator() +38
   System.Linq.Enumerable.Single(IEnumerable`1 source) +114
   System.Data.Objects.ELinq.ObjectQueryProvider.<GetElementFunction>b__3(IEnumerable`1 sequence) +4
   System.Data.Objects.ELinq.ObjectQueryProvider.ExecuteSingle(IEnumerable`1 query, Expression queryRoot) +29
   System.Data.Objects.ELinq.ObjectQueryProvider.System.Linq.IQueryProvider.Execute(Expression expression) +91
   System.Data.Entity.Internal.Linq.DbQueryProvider.Execute(Expression expression) +69
   System.Linq.Queryable.Max(IQueryable`1 source) +216
   CreditRegistry.Repositories.CreditRegistryRepository.DateLastUpdated(Int64 creditorRegistryId, String accountNo) in D:\Freelance Work\SuperExpert\CreditRegistry\CreditRegistry\Repositories\CreditRegistryRepository.cs:1497
   CreditRegistry.Repositories.CreditRegistryRepository.<AccountDetails>b__88(AccountsReport account, Int32 index) in D:\Freelance Work\SuperExpert\CreditRegistry\CreditRegistry\Repositories\CreditRegistryRepository.cs:1250
   System.Linq.<SelectIterator>d__7`2.MoveNext() +198
   System.Linq.Buffer`1..ctor(IEnumerable`1 source) +217
   System.Linq.<GetEnumerator>d__0.MoveNext() +96

Answer 1

如果您在迭代另一个查询的结果时执行查询，则可能会发生这种情况。从您的示例中不清楚发生这种情况的位置，因为该示例不完整。

可能导致这种情况的一件事是迭代某些查询的结果时触发延迟加载。

通过在连接字符串中允许 MARS 可以轻松解决此问题。将 MultipleActiveResultSets=true 添加到连接字符串的提供程序部分（其中指定了数据源、初始目录等）。

Answer 2

您可以在 return 语句之前使用 ToList() 方法。

var accounts =
from account in context.Accounts
from guranteer in account.Gurantors

select new AccountsReport
{
    CreditRegistryId = account.CreditRegistryId,
    AccountNumber = account.AccountNo,
    DateOpened = account.DateOpened,
};

return accounts.AsEnumerable()
       .Select((account, index) => new AccountsReport()
       {
           RecordNumber = FormattedRowNumber(account, index + 1),
           CreditRegistryId = account.CreditRegistryId,
           DateLastUpdated = DateLastUpdated(account.CreditRegistryId, account.AccountNumber),
            AccountNumber = FormattedAccountNumber(account.AccountType, account.AccountNumber)
       })
       .OrderBy(c=>c.FormattedRecordNumber)
       .ThenByDescending(c => c.StateChangeDate)
       .ToList();


public DateTime DateLastUpdated(long creditorRegistryId, string accountNo)
{
    var dateReported = (from h in context.AccountHistory
                        where h.CreditorRegistryId == creditorRegistryId && h.AccountNo == accountNo
                        select h.LastUpdated).Max();
    return dateReported;
}

Answer 3

使用语法 .ToList() 将从数据库读取的对象转换为列表，以避免再次重新读取。

Answer 4

这是一个工作连接字符串，供需要参考的人使用。

<connectionStrings>
  <add name="IdentityConnection" connectionString="Data Source=(LocalDb)\v11.0;AttachDbFilename=|DataDirectory|\IdentityDb.mdf;Integrated Security=True;MultipleActiveResultSets=true;" providerName="System.Data.SqlClient" />
</connectionStrings>

Answer 5

就我而言，使用 Include() 解决了此错误，并且根据具体情况，当可以通过连接一次查询所有查询时，比发出多个查询要高效得多。

IEnumerable<User> users = db.Users.Include("Projects.Tasks.Messages");

foreach (User user in users)
{
    Console.WriteLine(user.Name);
    foreach (Project project in user.Projects)
    {
        Console.WriteLine("\t"+project.Name);
        foreach (Task task in project.Tasks)
        {
            Console.WriteLine("\t\t" + task.Subject);
            foreach (Message message in task.Messages)
            {
                Console.WriteLine("\t\t\t" + message.Text);
            }
        }
    }
}

Answer 6

我不知道这是否是重复的答案。如果是的话我很抱歉。我只是想让有需要的人知道我如何使用 ToList() 解决我的问题。

就我而言，我对以下查询遇到了相同的异常。

int id = adjustmentContext.InformationRequestOrderLinks.Where(
             item => item.OrderNumber == irOrderLinkVO.OrderNumber 
                  && item.InformationRequestId == irOrderLinkVO.InformationRequestId)
             .Max(item => item.Id);

我解决如下

List<Entities.InformationRequestOrderLink> links = 
      adjustmentContext.InformationRequestOrderLinks
           .Where(item => item.OrderNumber == irOrderLinkVO.OrderNumber 
                       && item.InformationRequestId == irOrderLinkVO.InformationRequestId)
           .ToList();

int id = 0;

if (links.Any())
{
  id = links.Max(x => x.Id);
}
if (id == 0)
{
//do something here
}

Answer 7

您似乎正在使用相同的 EF 上下文从活动查询中调用 DateLastUpdated，并且 DateLastUpdate 向数据存储本身发出命令。实体框架一次仅支持每个上下文一个活动命令。

您可以将上述两个查询重构为一个这样的查询：

return accounts.AsEnumerable()
       .Select((account, index) => new AccountsReport()
       {
         RecordNumber = FormattedRowNumber(account, index + 1),
         CreditRegistryId = account.CreditRegistryId,
         DateLastUpdated = (
             from h in context.AccountHistory 
             where h.CreditorRegistryId == creditorRegistryId && h.AccountNo == accountNo 
             select h.LastUpdated
         ).Max(),
         AccountNumber = FormattedAccountNumber(account.AccountType, account.AccountNumber)
       })
       .OrderBy(c=>c.FormattedRecordNumber)
       .ThenByDescending(c => c.StateChangeDate);

我还注意到您在查询中调用 FormattedAccountNumber 和 FormattedRecordNumber 等函数。除非这些是您从数据库导入到实体数据模型中并正确映射的存储过程或函数，否则它们也会抛出异常，因为 EF 不知道如何将这些函数转换为可以发送到数据存储的语句。

另请注意，调用 AsEnumerable 不会强制执行查询。直到查询执行被推迟直到枚举出来。如果您愿意，可以使用 ToList 或 ToArray 强制枚举。

Answer 8

就我而言，我从数据上下文中打开了一个查询，例如

    Dim stores = DataContext.Stores _
        .Where(Function(d) filter.Contains(d.code)) _

...然后随后查询相同的...

    Dim stores = DataContext.Stores _
        .Where(Function(d) filter.Contains(d.code)).ToList

将 .ToList 添加到第一个解决了我的问题。我认为将其包装在如下属性中是有意义的：

Public ReadOnly Property Stores As List(Of Store)
    Get
        If _stores Is Nothing Then
            _stores = DataContext.Stores _
                .Where(Function(d) Filters.Contains(d.code)).ToList
        End If
        Return _stores
    End Get
End Property

其中 _stores 是私有变量，而 Filters 也是从 AppSettings 读取的只读属性。

Answer 9

顺便说一句……当 SQL 对象的（内部）数据映射出现问题时，也可能会发生这种情况。

例如...

我创建了一个SQL标量函数，不小心返回了一个VARCHAR...然后...用它生成了一个VIEW 中的列。 VIEW 已正确映射到 DbContext 中...因此 Linq 可以很好地调用它。但是，实体期望DateTime？，而VIEW返回字符串。

哪个奇怪地抛出...

“已经有一个与此命令关联的打开的 DataReader
必须先关闭它”

很难弄清楚...但是在我更正返回参数后...一切都很好

Answer 10

发生此问题很可能是因为实体框架的“延迟加载”功能。通常，除非在初始获取期间明确要求，否则仅在需要时才获取所有联接数据（存储在其他数据库表中的任何数据）。在许多情况下，这是一件好事，因为它可以防止获取不必要的数据，从而提高查询性能（无连接）并节省带宽。

在问题中描述的情况下，执行初始获取，并且在“选择”阶段请求缺少延迟加载数据，发出附加查询，然后 EF 抱怨“打开 DataReader”。

接受的答案中提出的解决方法将允许执行这些查询，并且实际上整个请求都会成功。

但是，如果您检查发送到数据库的请求，您会注意到多个请求 - 针对每个丢失（延迟加载）数据的附加请求。这可能是性能杀手。

更好的方法是告诉 EF 在初始查询期间预加载所有需要的延迟加载数据。这可以使用“Include”语句来完成：

using System.Data.Entity;

query = query.Include(a => a.LazyLoadedProperty);

这样，将执行所有需要的联接，并且所有需要的数据将作为单个查询返回。问题中描述的问题将得到解决。

Answer 11

除了Ladislav Mrnka的回答之外：

如果您要在设置选项卡上发布和覆盖容器，则可以将MultipleActiveResultSet设置为True。您可以通过单击高级...找到此选项，它将位于高级组下。

Answer 12

我通过改变解决了这个问题
等待 _accountSessionDataModel.SaveChangesAsync();
到
_accountSessionDataModel.SaveChanges();
在我的存储库课程中。

 public async Task<Session> CreateSession()
    {
        var session = new Session();

        _accountSessionDataModel.Sessions.Add(session);
        await _accountSessionDataModel.SaveChangesAsync();
     }

将其更改为：

 public Session CreateSession()
    {
        var session = new Session();

        _accountSessionDataModel.Sessions.Add(session);
        _accountSessionDataModel.SaveChanges();
     }

问题是我在创建会话（在代码中）后更新了前端中的会话，但由于 SaveChangesAsync 是异步发生的，因此获取会话会导致此错误，因为显然 SaveChangesAsync 操作尚未准备好。

Answer 13

对于那些通过 Google 找到此内容的人；
我收到此错误是因为，正如错误所建议的那样，我未能在同一 SqlCommand 上创建另一个 SqlDataReader 之前关闭 SqlDataReader，错误地认为在离开创建它的方法时它将被垃圾收集。

我通过以下方式解决了该问题在创建第二个读取器之前调用 sqlDataReader.Close();。

Answer 14

当我循环和更新数据时，同样的错误发生在我身上
IEnumerable
当我将循环集合更改为 List 并通过 .ToList() 转换来填充它时，它解决并更新了，没有任何错误。

Answer 15

当我尝试更新读取循环中的一些记录时，我遇到了同样的错误。
我尝试了投票最多的答案 MultipleActiveResultSets=true 并发现，这只是获取下一个错误的解决方法

不允许新事务，因为有其他线程正在运行
在会话中

，适用于大型结果集的最佳方法是使用块并为每个块打开单独的上下文，如中所述。
来自实体框架的 SqlException - 新不允许事务，因为会话中还有其他线程正在运行

Answer 16

对我来说，这是我自己的错误。当我应该使用 SqlCommand.ExecuteNonQuery() 时，我试图使用 SqlCommand.executeReader() 运行 INSERT。它被打开但从未关闭，导致了错误。请注意这种疏忽。

Answer 17

这是从现实场景中提取的：

• 代码在连接字符串中设置了 MultipleActiveResultSets 的阶段环境中运行良好
• 代码发布到生产环境而没有 MultipleActiveResultSets=true
• 如此多的页面/调用工作，而单个页面/调用失败
• 仔细观察调用，对数据库进行了不必要的调用，需要将其删除
• 在生产中设置 MultipleActiveResultSets=true 并发布清理后的代码，一切正常且高效

总之，不要忘记 MultipleActiveResultSets，代码可能已经运行了很长时间才发现冗余的数据库调用，这可能会非常昂贵，我建议不要完全依赖于设置 MultipleActiveResultSets 属性，但也要找出为什么代码在失败的地方需要它。

Answer 18

如果您使用启用了 TransactionScopeAsyncFlowOption 的 Transaction 范围，但忘记 await 某些存储库方法，也可能会发生这种情况。

Answer 19

我已经通过查询进行迭代。
我通过在 @foreach 语句中放置 .ToList() 解决了我的问题。

foreach (var user in report.myUsers.ToList())
{
}

Answer 20

我在我的工具中使用 Web 服务，这些服务在其中获取存储过程。当越来越多的客户端工具获取Web服务时，就会出现这个问题。我通过为那些获取存储过程的函数指定 Synchronized 属性来修复此问题。现在它工作正常，错误从未出现在我的工具中。

 [MethodImpl(MethodImplOptions.Synchronized)]
 public static List<t> MyDBFunction(string parameter1)
  {
  }

该属性允许一次处理一个请求。所以这解决了问题。

Answer 21

就我而言，我必须在连接字符串中将 MultipleActiveResultSets 设置为 True。
然后出现了另一个错误（真正的错误），即无法在同一数据上下文上同时运行 2 个（SQL）命令！ （EF Core，代码优先）
因此，我的解决方案是寻找任何其他异步命令执行并将其转换为同步，因为我只有一个用于这两个命令的 DbContext。

我希望它能帮助你