使用 C# 给定一个对象列表，将它们推送到 ravendb，而不知道哪些对象已经存在

Question

给定 1000 个具有复杂数据结构的文档。例如，一个 Car 类具有三个属性（Make 和 Model）以及一个 Id 属性。

C# 中将这些文档推送到 raven db（最好是批量）的最有效方法是什么，而无需单独查询 raven 集合来查找要更新的内容和要插入的内容。目前我必须像这样走。这是完全低效的。 注意：_session 是 IDocumentSession 上的一个包装器，其中 Commit 调用 SaveChanges 并 Add 调用 Store。

    private void PublishSalesToRaven(IEnumerable<Sale> sales)
    {
        var page = 0;
        const int total = 30;
        do
        {
            var paged = sales.Skip(page*total).Take(total);
            if (!paged.Any()) return;
            foreach (var sale in paged)
            {
                var current = sale;
                var existing = _session.Query<Sale>().FirstOrDefault(s => s.Id == current.Id);
                if (existing != null)
                    existing = current;
                else
                    _session.Add(current);
            }
            _session.Commit();
            page++;
        } while (true);
    }

Answer 1

您的会话代码似乎无法使用 RavenDB api 进行跟踪（我们没有 Add 或 Commit）。
以下是在 RavenDB 中执行此操作的方法

private void PublishSalesToRaven(IEnumerable<Sale> sales)
{
    sales.ForEach(session.Store);
    session.SaveChanges();
}

Answer 2

您的代码示例根本不起作用。主要问题是，您不能只是切换引用并期望 RavenDB 认识到这一点：

if (existing != null)
    existing = current;

相反，您必须一一更新每个属性：

existing.Model = current.Model;
existing.Make = current.Model;

这是您可以在 RavenDB 和许多其他框架中促进更改跟踪的方式（例如NHibernate）。如果您想避免编写这段无趣的代码，我建议使用 AutoMapper：

existing = Mapper.Map<Sale>(current, existing);

代码的另一个问题是您在应该使用 Session.Load 的地方使用了 Session.Query。 记住：如果您通过 ID 查询文档，您将始终需要使用 Load！
主要区别在于，一个使用本地缓存，另一个不使用（这同样适用于等效的 NHibernate 方法）。

好的，现在我可以回答你的问题了：
如果我理解正确，您希望将一堆销售实例保存到数据库中，如果它们不存在，则应添加它们，如果存在，则应更新它们。正确的？
一种方法是使用上面的提示更正示例代码并使其正常工作。但是，这将为每次迭代发出一个不必要的请求 (Session.Load(existingId))。如果您设置一个索引来选择 Sales 集合中所有文档的所有 Id，则可以轻松避免这种情况。在循环访问项目之前，您可以加载所有现有的 ID。

不过，我想知道你到底想做什么。您的领域/用例是什么？

Answer 3

这就是现在对我有用的方法。注意：InjectFrom方法来自Omu.ValueInjecter（nuget包）

    private void PublishSalesToRaven(IEnumerable<Sale> sales)
    {
        var ids = sales.Select(i => i.Id);
        var existingSales = _ravenSession.Load<Sale>(ids);
        existingSales.ForEach(s => s.InjectFrom(sales.Single(i => i.Id == s.Id)));

        var existingIds = existingSales.Select(i => i.Id);
        var nonExistingSales = sales.Where(i => !existingIds.Any(x => x == i.Id));
        nonExistingSales.ForEach(i => _ravenSession.Store(i));

        _ravenSession.SaveChanges();
    }