DbLinq - 缓存问题

Question

我在 ASP.NET MVC 网站中使用 linq to sql for MySql（使用 DbLinq）。 我有一个奇怪的缓存问题。 考虑我的 Repository 类中的以下方法：

public IEnumerable<Message> GetInbox(int userId)
{
  using(MyDataContext repo = new MyDataContext(new MySqlConnection("[Connectionstring]")))
  {
    return repo.Messages.Where(m => m.MessageTo == userId);
  }
}

public IEnumerable<Message> GetOutbox(int userId)
{
  using (MyDataContext repo = new MyDataContext(new MySqlConnection("[Connectionstring]")))
  {
    return repo.Messages.Where(m => m.MessageFrom == userId);
  }
}

“MyDataContext”是由 DbLinq 生成的到我的数据库的映射，它继承自 DataContext。 我在这里没有重用数据上下文（上面的代码看起来有点傻，但我想绝对确保这不是某些数据上下文/mysqlconnection 重用问题）。

发生的情况是，无论我使用什么 userId 调用这两个方法中的任何一个，结果都保持不变。 时期。 尽管我可以看到 repo.Messages 有超过 10 个结果，并且 MessageFrom 和 MessageTo 值不同，但我只得到第一个查询的结果结果返回。 因此，如果我调用 GetInbox(4374)，它会给我消息 A 和消息 B。之后调用 GetInbox(526) 仍然会给我消息 A 和 B，即使有 消息 C 和 D 的 userId 为 526。我必须重新启动应用程序才能看到任何更改。

这里发生了什么？ 我确信我正在做一些愚蠢的事情，以至于当有人向我指出这一点时我会感到羞愧。 如果我没有做一些非常愚蠢的事情，那么我会觉得这个问题很奇怪。 我读到过关于不重用 DataContext 的内容，但我没有。 为什么会出现这个缓存问题？ 下面是我的控制器代码，但我怀疑它是否重要：

[Authorize]
public ActionResult Inbox(int userId)
{
  Mailbox inbox = new Mailbox(userId, this.messageRepository.GetInbox(userId));
  return PartialView("Inbox", inbox);
}

虽然 SO 上有类似的问题，但我还没有找到这个确切问题的答案。 非常感谢！

更新： 将代码更改为： return repo.Messages.ToList().Where(m => m.MessageFrom == userId); 修复它，然后就可以正常工作了。 看起来像一些缓存问题。 但是，我当然不想那样解决它。 更改代码以便在查询后不释放数据上下文并不能解决问题。

Answer 1

我写了一些非常相似的代码，看起来效果很好。 唯一的区别是，正如 Marc 所建议的，我传入连接字符串并在Where 方法上调用ToList。 我的数据库不是自动生成的，而是派生自 DataContext。 代码如下。

class Program
{
    static void Main(string[] args)
    {
        List<Item> first = GetItems("F891778E-9C87-4620-8AC6-737F6482CECB").ToList();
        List<Item> second = GetItems("7CA18DD1-E23B-41AA-871B-8DEF6228F96C").ToList();
        Console.WriteLine(first.Count);
        Console.WriteLine(second.Count);
        Console.Read();
    }

    static IEnumerable<Item> GetItems(string vendorId)
    {
        using (Database repo = new Database(@"connection_string_here"))
        {
            return repo.GetTable<Item>().Where(i => i.VendorId.ToString() == vendorId).ToList(); ;
        }
    }
}

Answer 2

从编写测试开始。 这将告诉您 Linq2Sql 的行为是否正确。 类似于：

var inboxMessages = this.messageRepository.GetInbox(userId1);
Assert.That(inboxMessages.All(m => m.MessageTo == userId1);

inboxMessages = this.messageRepository.GetInbox(userid2);
Assert.That(inboxMessages.All(m => m.MessageTo = userid2);

如果成功，您应该真正检查是否是延迟执行导致了问题。 您应该立即枚举 inboxMessages。

另一件可能引起麻烦的事情是，当数据上下文已经被释放时，您就开始枚举。 解决这个问题的唯一方法是根本不丢弃它（并在它超出范围时依靠 GC 清理它），或者提出一个自定义的 IDisposable 对象，这样你就可以在它周围放置一个 using 。 就像是：

using(var inboxMessages = this.messageRepository.GetInbox(userId1))
{
    Assert.That(inboxMessages.All(m => m.MessageTo == userId1);
}

Answer 3

LINQ-to-SQL 中的缓存与 DataContext 相关联，并且主要限于身份缓存 - 在大多数情况下，即使您之前已经执行过查询，它也会重新运行查询。 有一些示例，例如 .Single(x=>x.Id == id) （具有特殊处理）。

由于您每次显然都会获得新的数据上下文，因此我认为这不是罪魁祸首。 然而，我也对代码的工作原理感到有点惊讶......你确定这具有代表性吗？

LINQ 的 Where 方法被延迟 - 这意味着它不会执行，直到您迭代数据（例如使用 foreach）。 但到那时你已经处理了数据上下文！ 您是否从示例中截取了一些内容？

另外 - 通过给它一个 SqlConnection （您随后不会 Dispose()），您可能会影响清理 - 最好只给它（数据上下文）连接字符串。

Answer 4

嗯，看来是DbLinq的问题。 我使用了 3 周前的源代码，QueryCache 中存在一个明显的错误（尽管它总是在那里）。 有一个完整的线程涵盖了这个这里。

我更新了 dblinq 源。 Querycache 现在被禁用（确实意味着性能下降），而且至少现在它可以工作了。 我得看看性能是否可以接受。 必须承认我有点困惑，因为我想做的是一个常见的 linq2sql 模式。 谢谢大家。

Answer 5

我会避免在生产代码中使用 DBLinq...Linq-To-SQL 的许多功能都未实现，并且浏览源代码显示成熟度较低...许多方法未实现或标记为“未终止”。

……你已被警告过！