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

我有这个查询，我得到了这个函数的错误:

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

当前回答

对于那些通过谷歌找到这个的人; 我得到这个错误是因为，正如错误所建议的那样，我未能在相同的SqlCommand上创建另一个SqlDataReader之前关闭一个SqlDataReader，错误地假设它将在离开创建它的方法时被垃圾收集。

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

2017-07-21 18:01:22

其他回答

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

2017-07-26 14:56:42

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

例如……

我创建了一个SQL标量函数，意外返回一个VARCHAR…然后……使用它在VIEW中生成一个列。视图被正确映射到DbContext…所以Linq说的很好。然而，实体期望DateTime?VIEW返回String。

奇怪的是……

"已经有一个与此命令相关联的开放数据阅读器必须先关闭"

很难弄明白……但在我修正了返回参数后…一切顺利

2018-10-23 17:55:07

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

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

在已接受的回答中提出的解决方案将允许执行这些查询，实际上整个请求将成功。

但是，如果检查发送到数据库的请求，您将注意到多个请求—每个缺失(惰性加载)数据的附加请求。这可能是性能杀手。

更好的方法是告诉EF在初始查询期间预加载所有需要的惰性加载数据。这可以使用"Include"语句完成:

using System.Data.Entity;

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

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

2018-03-31 10:45:43

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

2022-06-15 08:19:17

在我的例子中，使用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);
            }
        }
    }
}

2013-04-15 07:05:08

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

推荐文章

最新文章

标签