0

我已经在 mongodb shell 上测试了以下聚合，它工作正常，但是它似乎不适用于 mongoose。我搜索了类似的主题和问题，但他们的解决方案不能解决我的问题。

文件结构是这样的

{
  name,
  id,

  contacts:[{
    contactId, //I need an array of this field
    dateAdded
  }, {
    contactId,
    dateAdded
  },
  {}..]
}

猫鼬模式是： 

 var AccountSchema = new mongoose.Schema({
    email:     { type: String, unique: true },
    password:  { type: String },
    name: {
      first:   { type: String },
      last:    { type: String },
      full:    { type: String }
    },
    contacts:  [Contact]
  });

这是聚合：

 Account.aggregate({
   $match: { _id: accountId }
 }, {
   $unwind:"$contacts"
 },
 {
   $group: {
     _id: '$_id',
     list: { $push:'$contacts.accountId' }
   }
 }, {
   $project: {
     _id: 0,
     contacts: 1
   }
 }, function(err, doc) {
   // var l=doc.result[0].list;
   callback(doc);  
 });

在 Mongodb shell 上，聚合返回一个如下所示的contactID 数组，但在 Mongoose 上返回一个空数组

{
  "result" : [
    {
      "_id" : null,
      "list" : [
         ObjectId("xxxbnbnb2013-06-23T16:24:03.785Z"),
         ObjectId("mnmnmnmui2013-06-23T16:24:04.688Z")
      ]
    }
  ],
  "ok" : 1
}
4

1 回答 1

4

您的查询似乎格式正确，我认为您只是在应该投影“列表”时投影了“联系人”。我尝试像您一样格式化我的数据，以下查询对我有用。在外壳中：

db.accounts.aggregate( 
{ $unwind:"$contacts" },
{ $group: {
     _id: '$_id',
     list: { $push:'$contacts.contactId' }
   }
 }, 
{ $project: { _id: 0, list: 1 }} )

或者，使用猫鼬框架，

Account.aggregate(
     { $unwind:"$contacts" },
     { $group: {
          _id: '$_id',
          list: { $push:'$contacts.contactId' }}},
     { $project: { 
          _id: 0, 
          list: 1 }},
     function (err, res) {
          if (err) //handle error;
          console.log(res);
          }
);

由于您试图在聚合查询的最终输出中抑制“_id”字段，我假设您真的只是对获取所有帐户中所有contactIds的列表感兴趣，而不是对链接它们感兴趣到特定帐户。如果您想留下一个长长的联系人 ID 列表（而不是每个原始帐户一个列表的小文档），您可以运行此聚合查询：

db.accounts.aggregate( 
{ $unwind:"$contacts" },
{ $group: {
     _id: "allcontacts",
     list: { $push:'$contacts.contactId' }
   }}
 )

或者，使用猫鼬框架，

Account.aggregate(
     { $unwind:"$contacts" },
     { $group: {
          _id: "allcontacts",
          list: { $push:'$contacts.contactId' }}},
     function (err, res) {
          if (err) ;
          console.log(res);
          }
     );
于 2013-09-17T15:35:17.827 回答