慢查询实体框架

Question

我注意到我对实体框架的一个查询太慢了。我认为问题是我使用的是包含，但我没有得到“任何”的速度差异。我正在执行这个查询的表有大约4k个条目，所以我不明白为什么要花20秒才能做到这一点。我正在使用mysql与最新的.net连接器。

var errorMessages = msgs.Where(m => m.Type == 1 && 
            (m.StatusCode == (int)ErrorCode.AbsentSubscriber || 
             m.StatusCode == (int)ErrorCode.AbsentSubscriber || 
             m.StatusCode == (int)ErrorCode.Deleted ||
             m.StatusCode == (int)ErrorCode.Error ||
             m.StatusCode == (int)ErrorCode.Expired ||
             m.StatusCode == (int)ErrorCode.InvalidDestination ||
             m.StatusCode == (int)ErrorCode.Rejected ||
             m.StatusCode == (int)ErrorCode.SubscriberError ||
             m.StatusCode == (int)ErrorCode.Undeliverable ||
             m.StatusCode == (int)ErrorCode.UnknownSubscriber))
            .GroupBy(m => m.StatusCode);

foreach (var error in errorMessages)
{
    var eSum =
            db.ErrorSumMessages.SingleOrDefault(
                m => m.ErrorCode == error.Key 
                && m.MessagesId == oldHourlyMessage.MessagesId);

    if (eSum != null)
    {
        //This gets called
        eSum.Count += error.Sum(m => m.MessageCount);
        db.Entry(eSum).Property(m => m.Count).IsModified = true;
    }
    else
    {
        db.ErrorSumMessages.Add(new ErrorSumMessage
            {
                Count = error.Sum(m => m.MessageCount),
                ErrorCode = error.Key,
                ErrorText = error.First().StatusText,
                MessagesId = oldHourlyMessage.MessagesId
            });
    } 
}

Answer 1

在您的代码中，在每一次称为db查询- db.ErrorSumMessages.SingleOrDefault的迭代中。如果errorMessages包含4K记录，您将得到4K查询！

若要减少db查询的数目，请在foreach语句之前选择必需(或全部) db.ErrorSumMessages：

var localErrorSumMessages = db.ErrorSumMessages.ToList();
foreach (var error in errorMessages)
{
   var eSum = localErrorSumMessages.SingleOrDefault(....); // selecting from collection in memory

Answer 2

请确保您还在主查询中查询ErrorSumMessages：

var errorMessages = msgs.Where(...)
            .GroupBy(m => m.StatusCode)
            .Select(g => new 
                 { 
                   StatusCode = g.Key,
                   eSum = db.ErrorSumMessages
                            .FirstOrDefault(
                            m => m.ErrorCode == g.Key 
                              && m.MessagesId == oldHourlyMessage.MessagesId),
                   Messages = g
                 })

foreach(var row in errorMessages)
{
    var eSum = row.eSum;
    var error = row.Messages;
    // rest should work unaltered, except error.Key => row.StatusCode
    ...

}

您必须使用FirstOrDefault，否则EF将抛出“方法‘单’和'SingleOrDefault‘只能用作最后的查询操作”。