我有一组代表一些工作项的文档:
public class WorkItem
{
public string Id {get;set;
public string DocumentId { get; set; }
public string FieldId { get; set; }
public bool IsValidated { get; set; }
}
public class ExtractionUser
{
public string Id {get;set;}
public string Name {get;set;}
public string[] AssignedFields {get;set;}
}
用户有权访问一组 FieldId。我需要根据这组字段查询 WorkItems 并获取每个文档的状态:
public class UserWorkItems
{
public string DocumentId { get; set; }
public int Validated { get; set; }
public int Total { get; set; }
}
我的查询是这样的:
using (var session = RavenDb.OpenSession())
{
string[] userFields = session.Load<User>("users/1").Fields;
session.Query<WorkItem>()
.Where(w => w.FieldId.In(userFields))
.GroupBy(w => w.DocumentId)
.Select(g => new
{
DocumentId = g.Key,
Validated = g.Where(w => w.IsValidated).Count(),
Total = g.Count()
}).Skip(page * perPage).Take(perPage)
.ToArray();
}
我曾尝试创建一个 Map/Reduce 索引,但主要问题是我需要能够对未包含在 Reduce 输出中的 FieldId 应用过滤器,因为它是被计算的属性。
我还尝试在查询部分的 FieldId 和 TransformResults 上做一个简单的 Map 索引来执行 GroupBy - 但由于分页是在 TransformResults 之前应用的,所以页面和总计反映了分组之前的文档,这是不好的。
然后我尝试使用 Multi Map 索引来映射用户及其字段集合,并映射工作项和字段,然后尝试将结果减少到我想要的。我用索引定义创建了一个要点。减少部分涉及按字段分组,然后是多个 SelectMany 和最后一个 GroupBy 和 Select。该索引已被 raven 接受,但 i 不返回任何结果。我有点卡在 Multi Map 索引上,因为我不知道如何实际调试它。
我想最后我的问题可能会减少(双关语)如何查询“减少”字段?
有什么想法可以实现这样的功能吗?除了 Map/MultiMap/Reduce/TransformResults 之外,我还有其他选择吗?
更新:在阅读Ayende 的 Map Reduce 帖子时,我意识到我正在接近 mapreduce 错误。仍在寻找解决方案...
更新 2:经过更多研究,我最终得到了这个索引,它看起来像我想要做的,但不返回任何数据(索引直接在工作室中定义):
地图:
from user in docs
where user["@metadata"]["Raven-Entity-Name"] == "ExtractionUsers"
from field in user.AssignedFields
from item in docs
where item["@metadata"]["Raven-Entity-Name"] == "WorkItems" && item.FieldId == field
select new {
UserId = user.Id,
DocumentId = item.DocumentId,
Validated = item.Status=="Validated"? 1: 0,
Count = 1
}
减少:
from r in results
group r by new { r.UserId , r.DocumentId } into g
select new {
UserId = g.Key.UserId,
DocumentId = g.Key.DocumentId,
Validated = g.Sum(d => d.Validated),
Count = g.Sum(d => d.Count),
}
这个想法是尝试在索引中映射所有文档,并从用户链接到字段和工作项。