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

Question

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

在 C# 中将这些文档推送到 raven 数据库(最好是批处理)的最有效方法是什么，而不必单独查询 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

您的 session 代码似乎无法使用 RavenDB api 进行跟踪(我们没有Add 或Commit)。以下是您如何在 RavenDB 中执行此操作

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