聚合后用猫鼬更新集合答案

【问题标题】：updating collection with mongoose after an aggregation聚合后用猫鼬更新集合
【发布时间】：2016-02-02 14:11:57
【问题描述】：

我目前在一家小公司实习，我正在研究 user 架构，如下所示：

var UserSchema = new Schema({
    name: String,
    email: {
        type: String,
        unique: true
    },
    username: {
        type: String,
        unique: true
    },
    hashed_password: String,
    provider: String,
    salt: String,

由于我使用的应用程序发生了变化，我更新了这个架构：

var UserSchema = new Schema({
    name: String,
    email: {
        type: String,
        unique: true
    },
    username: {
        type: String,
        unique: true
    },
    hashed_password: String,
    provider: String,
    salt: String,


    stats : {
        bricks: Number,// Number of bricks created by an user
        layers: Number,// --------- layers ------------------
        projects: Number,//-------- projects ----------------
        lastogin: Date
    },

});

当然，网上有一个旧版本的应用，我需要更新用户集合中存在的所有用户。

为此，我需要计算每个用户创建的每个砖块/层/项目。这是 brick 架构：

/**************
App fields
**************/

// False deletion field
field.deleted = function() {
  return field.bool();
};

// Creation date
field.created = function() {
  return field.date();
};

// Title Field
field.title = function() {
  return field.string();
};

// Desc Field
field.desc = function() {
  return field.string();
};

// Default short Id field
field.shortId = function(id) {
  return {
    type: ShortId,
    index: true,
    len: 7,     // Length 7 characters
    base: 64,   // Web-safe base 64 encoded string
    alphabet: "abcdefghijklmnopkrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890", // Use default alphabet for base
    retries: 4  // Four retries on collision
  };
};

// The author of the content
field.user = function() {
  return {
    user: field.ref('User'),
  }
};

field.favorites = function() {
  return [{
    type: Schema.ObjectId,
    ref: 'User'
  }];
};

field.contributors = function() {
  return [{
    type: Schema.ObjectId,
    ref: 'User'
  }];
};

field.comments = function() {
  return [{
    // user that have written the comment
    user: field.ref('User'),
    // comment text it-self
    comment: field.string()
  }];
};

经过一番研究，我决定使用 mongoose（和 mongodb）的聚合管道来按用户分组砖块，使用以下查询：

db.bricks.aggregate(
    [
        {
            $group : {
                _id : "$user",
                count : {  $sum : 1}
        }
    ]
)

以及以下与 mongoose 一起使用的方法：

var promise =Brick.aggregate()
        .group({ _id: "$user"})
        .exec(function (err, res) {
            if (err) return handleError(err);
            else {
                console.log(res);
            }
        });

我知道 exec() 方法返回 promise，我仍在学习如何正确使用它。

之后，我想对所有用户执行更新查询。由于他们没有创建相同数量的砖块，因此我无法进行多次更新，我需要使用如下所示的查询循环遍历结果：

User.update({id : user_id}, {$set : {"stats.bricks" : Brick.find({user : user_id}).count()}})

是否可以这样做，还是我需要以不同的方式重新考虑问题

【问题讨论】：

你很接近，但不幸的是.exec() 没有返回承诺。省略.exec()，您实际上有一个可以对结果采取行动的承诺。哦，最后一个代码示例显然是从 MongoDB shell 借来的，你“认为”正在发生的事情并不是真正发生的事情。作为“同步”过程，内部查询结果在执行外部查询之前得到评估。也可以是静态值
谢谢！但是在 mongoose API 的文档中，写着 .exec() 返回一个 promise（API 文档上的 promise redirect 一词的链接）。无论如何，我怀疑最后一个“查询”不会像这样工作，我在组中添加了一个“计数”字段（您可以在 mongoshell 查询中看到它）来获取用户创建的元素数量，然后使用它的更新。
嗯。谢谢你在这里的第一张海报真正关注谁给了你好的建议（不是！）。不，不是的。 .exec() 特别需要一个“回调”作为参数。

标签： node.js mongodb mongoose aggregation-framework

【解决方案1】：

我尝试了其他方法，成功得到了我想要的结果

exports.updatesUsersStats = function (req, res) {
  User.find().exec(function(err, users) {
    console.log(users.length);
    _.each(users, function(currentUser) {
      console.log("Count bricks user :" +currentUser._id);
      Brick.find({user : currentUser._id})
        .exec(function(err, bricks) {
          if(err) return handleError(err);
          console.log("Update user :"+ currentUser._id);
          User.update({_id : currentUser._id}, {$set : {"stats.bricks" : bricks.length}})
            .exec(function(err)
            {
              if(err) return handleError(err);
            });
        });
    });
    res.jsonp({
      updateType : "updateUserStats",
      operations : users.length
    });
  });
};

我把考虑到所有用户（没有创建内容的用户）的聚合放在一边。

【讨论】：