根据对象的值更新 MongoDB 集合

Question

我有一个如下所示的 MongoDB 集合：

[
  {
    "stock": "GOOGLE",
    "price": 0
  },
  {
    "stock": "FACEBOOK",
    "price": 0
  }
]

我有一个像这样的Stock_Prices 对象：

{
  "GOOGLE": {
    "price": 31.35
  },
  "FACEBOOK": {
    "price": 10.75
  }
}

我需要使用 Node.js 从 Stock_Prices 对象更新集合中的每只股票。

我想到了以下方法：

• 遍历集合文档
• 对于每个文档，获取“stock”字段值（GOOGLE、FACEBOOK）
• 从Stock_Prices[document.stock].price中提取价格
• 更新文档

这是一种不可接受的方法，因为我有成千上万条记录，需要立即更新。

更新：没必要，它应该是更新操作 - 如果是查找，那么我相信也会完成工作

我该怎么做？

Answer 1

您必须获取您的 对象 并将其转换为数组并将其传递给聚合管道。

const stocksMap = {
  "GOOGLE": {
    "price": 31.35
  },
  "FACEBOOK": {
    "price": 10.75
  }
}

const stocks = Object.entries(stocksMap).map(([stock, price]) => ({ stock, price : price.price }))

/* You will get something like this
[{
  "stock": "GOOGLE",
  "price": 31.35
}, {
  "stock": "FACEBOOK",
  "price": 10.75
}]
*/

/* If you want to just read the data, without updating */

db.stocks.aggregate([
  {
    $set: {
      price: {
        $reduce: {
          input: stocks,
          initialValue: 0,
          in: {
            $cond: [
              { $eq: ["$$this.stock", "$stock"] },
              "$$this.price",
              "$$value"
            ]
          }
        }
      }
    }
  }
])

/* If you want to update the existing data, you can use the same pipeline in an aggregation (available from v4.2) */

db.stocks.update({}, [
  {
    $set: {
      price: {
        $reduce: {
          input: stocks,
          initialValue: 0,
          in: {
            $cond: [
              { $eq: ["$$this.stock", "$stock"] },
              "$$this.price",
              "$$value"
            ]
          }
        }
      }
    }
  }
])

如果您不想更新文档，可以将stocks 放在另一个集合中，然后改用$lookup。那应该更高效。

Answer 2

我将从帖子中取出一个库存对象并展示如何更新：

var stock_price =  { "GOOGLE": { "price": 31.35 } }  // this is the input

var stock_price_doc = Object.keys(stock_price).map (k => ( {field: k, value: stock_price[k] } ) )[0]

stock_price_doc 现在有这个值：{ "field" : "GOOGLE", "value" : { "price" : 31.35 } }

集合的文档（来自帖子）：

{
    "stock": "GOOGLE",
    "price": 0
}

更新操作：

db.stocks.update(
  { stock: stock_price_doc.field },
  { $set: { price: stock_price_doc.value.price } }
)

更新后的文档（结果）：

{ "stock" : "GOOGLE", "price" : 31.35 }

如果更新是增加股票价格，而不是设置值使用这个：

{ $inc: { price: stock_price_doc.value.price } }