在流星中使用MongoDB聚合時無法獲得正確的結果

Question

我在流星中使用MongoDB聚合。

在數據庫中的項目是這樣的：

//物品1

{ 
    products: { 
    aaa: 100, 
    bbb: 200 
    } 
} 

// ITEM2

{ 
    products: { 
    aaa: 300, 
    bbb: 400 
    } 
} 

我管線看起來像這樣

let pipeline = [{ 
    $limit: 10 
    }, { 
    $group: { 
     _id: { 
     // … 
     }, 
     total: { 
     $sum: "$products.aaa" 
     } 
    } 
    }]; 

它正在完美工作克拉。但是，當我改變我的數據庫結構，這

//物品1

{ 
    products: [ 
    {code: "aaa", num: 100}, 
    {code: "bbb", num: 200} 
    ] 
} 

// ITEM2

{ 
    products: [ 
    {code: "aaa", num: 300}, 
    {code: "bbb", num: 400} 
    ] 
} 

我得到了total結果總是0，我想我的管道是錯誤的。請參閱裏面的評論：

let pipeline = [{ 
    $limit: 10 
    }, { 
    $group: { 
     _id: { 
     // … 
     }, 
     total: { 
     $sum: "$products.0.num" // Neither this nor "$products[0].num" works 
     } 
    } 
    }]; 

那麼我該如何正確書寫它？由於

Answer 1

隨着MongoDB的3.2（這將不與流星捆綁的服務器，但指出使用一個單獨的服務器實例阻止你而實際上將被推薦。）您可以使用$arrayElemAt與$map：

let pipeline = [ 
    { "$limit": 10 }, 
    { "$group": { 
     "_id": { 
     // … 
     }, 
     "total": { 
     "$sum": { "$arrayElemAt": [ 
      { "$map": { 
       "input": "$products", 
       "as": "product", 
       "in": "$$product.num" 
      }}, 
      0 
     ]} 
     } 
    }} 
]; 

對於舊版本，在使用$unwind進行處理後，使用「two」$group階段和$first運營商。而這僅僅是爲「第一」指標值：

let pipeline = [ 
    { "$limit": 10 }, 
    { "$unwind": "$products" }, 
    { "$group": { 
     "_id": "$_id",  // The document _id 
     "otherField": { "$first": "$eachOtherFieldForGroupingId" }, 
     "productNum": { "$first": "$products.num" } 
    }}, 
    { "$group": { 
     "_id": { 
     // … 
     }, 
     "total": { 
     "$sum": "$productNum" 
     } 
    }} 
]; 

因此，在後一種情況下，你$unwind後，你只是想用$first從數組中獲得了「第一」的指標，並且它也將使用從原始文檔中獲取想要用作分組鍵的一部分的每個字段。在$unwind之後，將爲每個陣列成員複製所有元素。

在前一種情況下，$map只是爲每個陣列成員提取"num"值，然後$arrayElemAt只是檢索想要的索引位置。

自然，MongoDB 3.2的更新方法更好。如果你想要另一個數組索引，那麼你需要反覆從數組中獲取$first元素，並保持從數組結果中過濾出來，直到達到所需的索引。

因此儘管在早期版本中可能，但要實現這一目標還有很多工作要做。