我正在使用StructureMap将LINQ数据上下文(DB
类)注入到我的存储库中,以便在基于HTTP上下文的基础上进行读取查询,这些查询通过服务层进行查询。一切正常工作几个小时,直到我得到一个“断开”连接ExecuteReader错误(请参阅下面的完整转储)。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语句中手动包装每个查询。
啊!这就说得通了。我完全错过了lambda表达式的需要。自从我在存储库上实现IDisposable后,我一直没有遇到任何问题。我会等待错误再次发生,并尝试使用它。 – 2011-03-10 12:34:53