複数のドキュメントに参加するには？

Question

MongoDBで複数の文書に参加したい。私は次のコードを使用していますが、動作しません。私は何か間違って考えましたか？ Idを含む基本エンティティモデルを追加しました。

var products = _productRepository.GetCollection(_dbContext); 
var prodWarhoseMapping = _productWarehouseMapRepository.GetCollection(_dbContext); 
var warhouses = _warehouseRepository.GetCollection(_dbContext); 

public class Product:BaseEntity 
{ 
    public string product_code { get; set; } 
    public decimal fat_tax { get; set; } 
} 

public class ProductWarehouseMap :BaseEntity 
{ 
    public ObjectId product_id { get; set; } 
    public ObjectId warehouse_id { get; set; } 
    public int qty { get; set; } 
    public decimal price { get; set; } 
} 
public class Warehouse :BaseEntity 
{ 
    public ObjectId supplier_id { get; set; } 
    public string warehouse_code { get; set; } 
    public string name { get; set; } 
    public string email { get; set; } 
    public string phone { get; set; } 
    public string street_address { get; set; } 
    public string city { get; set; } 
    public string postal_code { get; set; } 
    public string region { get; set; } 
    public string country { get; set; } 
    public string manager_name { get; set; } 
    public string fax { get; set; } 
} 

//works proper 
var query1 = (from p in products 
      join pm in prodWarhoseMapping on p._id equals pm.product_id 
         select new 
         { 
          Products = p, 
          ProductMapping = pm, 
         }).ToList(); 

//Getting error 
var query = (from p in products 
    join pm in prodWarhoseMapping on p._id equals pm.product_id 
    join wh in warhouses on pm.warehouse_id equals wh._id 
    select new 
    { 
     Products = p, 
     ProductMapping = pm, 
     Warehouse = wh 
    }).ToList(); 

ベローは、私はベローはエラーメッセージタイプの

式「ですSystem.Collections.Generic.IEnumerable

public class BaseEntity 
{ 
    [BsonIgnoreIfDefault] 
    public ObjectId _id { get; set; } 

} 

ベースのエンティティモデルを追加するのを忘れ基本エンティティ です1[Project.Communication.EntityModels.ProductWarehouseMap]' cannot be used for parameter of type 'System.Linq.IQueryable 1メソッド[System.Linq.IQueryableの[Project.Communication.EntityModels.ProductWarehouseMap] '1[Project.Communication.EntityModels.ProductWarehouseMap] Where[ProductWarehouseMap](System.Linq.IQueryable 1 [Projec t.Communication.EntityModels.ProductWarehouseMap]、System.Linq.Expressions.Expression 1[System.Func 2 [Project.Communication.EntityModels.ProductWarehouseMap、可能System.Boolean]]）は、」 パラメータ名：arg0に

Answer 1

あなたのエラーメッセージは、それがWhere思われてしまいますが使用されますが、表示されているコードがまさにコンパイルを試みたものであると仮定していません。それにもかかわらず、あなたは、IEnumerableを使用して、このような

メモリに（）を選択し実行するなど、いくつかのバリエーションを試すことができます。

var query = (from p in products 
    join pm in prodWarhoseMapping on p._id equals pm.product_id 
    join wh in warhouses on pm.warehouse_id equals wh._id) 
    .AsEnumerable() 
    .Select(s => new 
    { 
     Products = p, 
     ProductMapping = pm, 
     Warehouse = wh 
    }).ToList(); 

かをAsQueryable()

var query = (from p in products.AsQueryable() 
    join pm in prodWarhoseMapping.AsQueryable() on p._id equals pm.product_id 
    join wh in warhouses.AsQueryable() on pm.warehouse_id equals wh._id 
    select new 
    { 
     Products = p, 
     ProductMapping = pm, 
     Warehouse = wh 
    }).ToList(); 

EDITを使用して：上記のアプローチは非常に長く、使用かかりますデータセットが巨大な場合は、多くのメモリが必要です。

根本的な原因を見つけるために、このクエリを試してみて、私はそれが返すものを知ってみましょうことができます：

var query2 = (from pm in prodWarhoseMapping 
     join wh in warhouses on pm.warehouse_id equals wh._id 
        select new 
        { 
         ProductMapping = pm, 
         Warehouse = wh,        
        }).ToList();