0

我正在使用 StructureMap 将 LINQ 数据上下文（DB类）注入到我的存储库中，用于基于 HTTP 上下文的读取查询，这些查询通过服务层进行查询。一切正常工作了几个小时，直到我收到“Broken” Connection ExecuteReader 错误（请参阅下面的完整转储）。

写查询（不是读查询）包含在一个using (var db = new DB()) {...}语句中，我认为这不会导致问题。

我已经添加MultipleActiveResultSets=true;到我的连接字符串，这似乎解决了一段时间的问题，但错误返回，直到我回收我的应用程序池，这暂时解决了问题。大概回收池会释放所有“损坏”的数据上下文。

StructureMap 配置为为每个 HTTP 上下文注入数据上下文和存储库：

For<DB>().HttpContextScoped().Use(new DB());
For<IUserRepository>().HttpContextScoped().Use<SqlUserRepository>();

数据上下文由我的用户存储库使用，如下所示：

private DB _db;
public SqlUserRepository(DB db)
{
    _db = db;
}

这反过来又方便地查询数据上下文，如下所示：

public IQueryable<User> GetUsers()
{
    var users = from u in _db.Users
                select u; // omitted the rest
}

几个小时后，最终出现了这个可怕的错误：

System.InvalidOperationException: ExecuteReader requires an open and available 
Connection. The connection's current state: Broken. at 
System.Data.SqlClient.SqlCommand.ValidateCommand(String method, Boolean async) at 
System.Data.SqlClient.SqlCommand.RunExecuteReader(CommandBehavior cmdBehavior, RunBehavior 
runBehavior, Boolean returnStream, String method, DbAsyncResult result) at 
System.Data.SqlClient.SqlCommand.RunExecuteReader(CommandBehavior cmdBehavior, RunBehavior 
runBehavior, Boolean returnStream, String method) at 
System.Data.SqlClient.SqlCommand.ExecuteReader(CommandBehavior behavior, String method) at 
System.Data.SqlClient.SqlCommand.ExecuteDbDataReader(CommandBehavior behavior) at 
System.Data.Common.DbCommand.ExecuteReader() at 
System.Data.Linq.SqlClient.SqlProvider.Execute(Expression query, QueryInfo queryInfo, 
IObjectReaderFactory factory, Object[] parentArgs, Object[] userArgs, ICompiledSubQuery[] 
subQueries, Object lastResult) at 
System.Data.Linq.SqlClient.SqlProvider.ExecuteAll(Expression query, QueryInfo[] queryInfos, 
IObjectReaderFactory factory, Object[] userArguments, ICompiledSubQuery[] subQueries) at 
System.Data.Linq.SqlClient.SqlProvider.System.Data.Linq.Provider.IProvider.Execute(Expressi
on query) at System.Data.Linq.DataQuery`1.System.Linq.IQueryProvider.Execute[S](Expression 
expression) at System.Linq.Queryable.FirstOrDefault[TSource](IQueryable`1 source) at 
MyApp.Data.SqlUserRepository.GetUser(String username) at 
MyApp.Services.BranchService.GetUser(String username) at 
MyApp.Controllers.BranchController.get_CurrentUser() at 
MyApp.Controllers.BranchController.OnActionExecuting(ActionExecutingContext filterContext) 
at 
System.Web.Mvc.Controller.System.Web.Mvc.IActionFilter.OnActionExecuting(ActionExecutingCon
text filterContext) at 
System.Web.Mvc.ControllerActionInvoker.InvokeActionMethodFilter(IActionFilter filter, 
ActionExecutingContext preContext, Func`1 continuation) at 
System.Web.Mvc.ControllerActionInvoker.<>c__DisplayClassd.<>c__DisplayClassf.b__c() at 
System.Web.Mvc.ControllerActionInvoker.InvokeActionMethodWithFilters(ControllerContext 
controllerContext, IList`1 filters, ActionDescriptor actionDescriptor, IDictionary`2 
parameters) at System.Web.Mvc.ControllerActionInvoker.InvokeAction(ControllerContext 
controllerContext, String actionName)

我该如何解决这个问题？我真的不想手动将每个查询包装在 using 语句中。

4

4 回答 4

3

看起来您无意中创建了一个单例上下文：

For<DB>().HttpContextScoped().Use(new DB());

为了为每个请求创建一个新的上下文，请改用它：

For<DB>().HttpContextScoped().Use(() => new DB());
于 2011-03-10T12:06:00.877 回答
1

我只会为每个存储库使用一个新的 DataContext ，除非由于某种原因你不能。看到这个问题：StructureMap / ASP.MVC / Visual Studio / LinqToSql 的奇怪行为

于 2011-03-09T17:01:37.077 回答
0

您的 GetUsers 方法正在返回一个 IQueryable，这意味着在对其进行迭代之前，不会从数据库中检索数据。如果返回 IQueryable，关闭数据读取器，然后尝试迭代数据，则会收到错误消息，因为连接已关闭。

于 2011-03-09T18:54:45.607 回答
0

造成这种情况的一个原因是您的连接根本无法打开。“SqlConnection.Open”语句中出现的任何异常都被抑制了。如果问题不在您的应用程序中，则可能是服务器无法授予您连接。可能是因为您的应用程序或同一服务器上托管的其他数据库中的连接泄漏。

于 2011-12-21T18:43:02.597 回答