RavenDB中Product与Snapshot的1:n关系索引查询问题求助

方法一：创建Map-Reduce索引（推荐用于直接查询组合结果） #

RavenDB的多Map-Reduce索引可同时处理两种文档类型，按Asin分组聚合出你需要的结构。

1. 定义Map-Reduce索引 #

public class ProductWithSnapshotsIndex : AbstractMultiMapIndexCreationTask<ProductWithSnapshots>
{
    public ProductWithSnapshotsIndex()
    {
        // 映射Product文档
        AddMap<Product>(products => 
            from product in products
            select new ProductWithSnapshots
            {
                P = product,
                S = new List<Snapshot>(),
                Asin = product.Asin
            });

        // 映射Snapshot文档
        AddMap<Snapshot>(snapshots => 
            from snapshot in snapshots
            select new ProductWithSnapshots
            {
                P = null,
                S = new List<Snapshot> { snapshot },
                Asin = snapshot.Asin
            });

        // Reduce阶段：按Asin分组合并数据
        Reduce = results => 
            from result in results
            group result by result.Asin into g
            select new ProductWithSnapshots
            {
                // 提取分组中唯一的Product
                P = g.Where(x => x.P != null).Select(x => x.P).FirstOrDefault(),
                // 合并所有Snapshot并按时间排序（按需调整）
                S = g.SelectMany(x => x.S).OrderByDescending(s => s.Timestamp).ToList()
            };

        // 为Asin创建索引，加速查询
        Index(x => x.Asin, FieldIndexing.Search);
    }

    // 辅助分组字段，无需暴露给查询结果
    public string Asin { get; set; }
}

2. 注册索引 #

在应用启动时初始化索引：

store.ExecuteIndex(new ProductWithSnapshotsIndex());

3. 查询索引 #

直接查询即可获得目标结构：

using (var session = store.OpenSession())
{
    // 查询所有带快照的商品
    var allProducts = session.Query<ProductWithSnapshots, ProductWithSnapshotsIndex>().ToList();

    // 按指定Asin查询单个商品的快照
    var target = session.Query<ProductWithSnapshots, ProductWithSnapshotsIndex>()
        .Where(x => x.Asin == "你的目标Asin")
        .FirstOrDefault();
}

方法二：查询时用Include+客户端关联（适合小型数据集） #

若不想创建索引，可先查询Product并预加载关联Snapshot，再在客户端组合数据：

using (var session = store.OpenSession())
{
    // 查询所有Product，同时预加载匹配Asin的Snapshot（避免N+1查询）
    var products = session.Query<Product>()
        .Include<Product, Snapshot>(p => p.Asin, s => s.Asin)
        .ToList();

    // 客户端组合数据
    var result = new List<ProductWithSnapshots>();
    foreach (var product in products)
    {
        var snapshots = session.Query<Snapshot>()
            .Where(s => s.Asin == product.Asin)
            .OrderByDescending(s => s.Timestamp)
            .ToList();

        result.Add(new ProductWithSnapshots
        {
            P = product,
            S = snapshots
        });
    }
}

关键注意事项 #

• 文档ID规范：建议给Product的ID添加前缀（如"products/" + Asin），Snapshot的ID设为"snapshots/{Asin}-{Timestamp:yyyyMMddHHmmss}"，避免不同类型文档ID冲突。
• 索引更新逻辑：RavenDB索引为增量更新，新增/修改Product或Snapshot后会自动同步索引数据。
• 性能选择：大数据量场景优先用Map-Reduce索引（预计算聚合结果，查询更快）；小型数据集可选用客户端关联方式。

内容的提问来源于stack exchange，提问作者Max E