【发布时间】:2014-01-07 13:48:58
【问题描述】:
我有以下代码从 5 个不同的表中从 DB 获取特定的用户详细信息。
var userValues = usrRepository.AsQueryable()
.Where(user => user.UserType == (int)GlobalEnumeration.UserType.MDappUser && user.IsActive == true)
.Include(f => f.appusraddrs)
.Include(c => c.usrcalendar)
.Include(f => f.usrattributes)
.Include("usrAttributes.usrAttributeValues")
.Include("usrAttributes.usrAttributeValues.ApplicationAttributeValue")
.ToList();
但是,当我尝试使用最后一个包含 .Include("usrAttributes.usrAttributeValues.ApplicationAttributeValue") 来包含表 ApplicationAttributeValue 时,我总是会收到超时错误。
如果我不包含该表,我不会收到错误消息。
错误堆栈
MySql.Data.MySqlClient.MySqlException (0x80004005): Timeout expired. The timeout period elapsed prior to completion of the operation or the server is not responding. ---> System.TimeoutException: A connection attempt failed because the connected party did not properly respond after a period of time, or established connection failed because connected host has failed to respond ---> System.IO.IOException: Unable to read data from the transport connection: A connection attempt failed because the connected party did not properly respond after a period of time, or established connection failed because connected host has failed to respond. ---> System.Net.Sockets.SocketException: A connection attempt failed because the connected party did not properly respond after a period of time, or established connection failed because connected host has failed to respond
at System.Net.Sockets.NetworkStream.Read(Byte[] buffer, Int32 offset, Int32 size)
--- End of inner exception stack trace ---
at System.Net.Sockets.NetworkStream.Read(Byte[] buffer, Int32 offset, Int32 size)
at MySql.Data.Common.MyNetworkStream.Read(Byte[] buffer, Int32 offset, Int32 count)
--- End of inner exception stack trace ---
at MySql.Data.Common.MyNetworkStream.HandleOrRethrowException(Exception e)
at MySql.Data.Common.MyNetworkStream.Read(Byte[] buffer, Int32 offset, Int32 count)
at MySql.Data.MySqlClient.TimedStream.Read(Byte[] buffer, Int32 offset, Int32 count)
at System.IO.BufferedStream.Read(Byte[] array, Int32 offset, Int32 count)
at MySql.Data.MySqlClient.MySqlStream.ReadFully(Stream stream, Byte[] buffer, Int32 offset, Int32 count)
at MySql.Data.MySqlClient.MySqlStream.LoadPacket()
at MySql.Data.MySqlClient.MySqlStream.ReadPacket()
at MySql.Data.MySqlClient.NativeDriver.GetResult(Int32& affectedRow, Int64& insertedId)
at MySql.Data.MySqlClient.Driver.NextResult(Int32 statementId, Boolean force)
at MySql.Data.MySqlClient.MySqlDataReader.NextResult()
at MySql.Data.MySqlClient.MySqlCommand.ExecuteReader(CommandBehavior behavior)
at MySql.Data.MySqlClient.ExceptionInterceptor.Throw(Exception exception)
at MySql.Data.MySqlClient.MySqlConnection.HandleTimeoutOrThreadAbort(Exception ex)
at MySql.Data.MySqlClient.MySqlCommand.ExecuteReader(CommandBehavior behavior)
at MySql.Data.Entity.EFMySqlCommand.ExecuteDbDataReader(CommandBehavior behavior)
at System.Data.EntityClient.EntityCommandDefinition.ExecuteStoreCommands(EntityCommand entityCommand, CommandBehavior behavior)
和
at System.Data.EntityClient.EntityCommandDefinition.ExecuteStoreCommands(EntityCommand entityCommand, CommandBehavior behavior)
at System.Data.Objects.Internal.ObjectQueryExecutionPlan.Execute[TResultType](ObjectContext context, ObjectParameterCollection parameterValues)
at System.Data.Objects.ObjectQuery`1.GetResults(Nullable`1 forMergeOption)
at System.Data.Objects.ObjectQuery`1.System.Collections.Generic.IEnumerable<T>.GetEnumerator()
at System.Collections.Generic.List`1..ctor(IEnumerable`1 collection)
at System.Linq.Enumerable.ToList[TSource](IEnumerable`1 source)
at MyBusiness.Business.SearchIndexing.SearchIndexBC.GetMyBusinessDetails()
at MyBusiness.Framework.Indexing.Services.IndexingTaskExecutor.BatchIndex(String indexName, String settingsFilename, IndexSettings indexSettings)
at MyBusiness.Framework.Indexing.Services.IndexingTaskExecutor.UpdateIndexBatch(String indexName)
at MyBusiness.Business.ProfileManagement.ProfileManagementBC.UpdateOtherDetails(appuser user)
【问题讨论】:
-
什么确切地是
usrRepository?它的类型是什么?如果你需要AsQueryable,那让我很紧张……你看过生成的SQL了吗?你有多少数据? -
亲爱的 Jon 这是一个存储库,appuserRepository userRepository = new appuserRepository(unitOfWork);其中 appuserRepository 是 appuser 实体类型的存储库
-
那么它不是已经实现
IQueryable<T>了吗? -
那么为什么要打电话给
AsQueryable?我建议你删除它,除非你真的需要它...... -
对不起,我在没有 AsQueryable() 的情况下很难形成查询,因为我在 Linq 中不是那么好。我认为它应该从 var userValues = usrRepository.GetAll() 开始?不确定。
标签: c# mysql asp.net-mvc linq entity-framework