如何使用 Node.js 驱动程序在 mongoDB 中多次插入数组？答案

【问题标题】：How to insert an array multiple times in mongoDB using the Node.js driver?如何使用 Node.js 驱动程序在 mongoDB 中多次插入数组？
【发布时间】：2016-07-21 00:03:09
【问题描述】：

我正在尝试使用mongodb-node.js 驱动程序插入包含在任何给定数组中的多个对象。我的意图是修改每个对象的内容并立即将这些对象保存在数据库中。下面的代码说明了我想要做什么。

var MongoClient = require("mongodb").MongoClient;
var URL = "mongodb://localhost:27017/database";

MongoClient.connect(URL, function(err,db) {
  if(err) console.log(err);

  var array = []; // an array that serves as a data source

  for(var i=0; i<10; i++) {
    array.push({ key: i });
  };

  db.collection("collection_name", function(err,col) {
    if(err) console.log(err);

    // --- "document insertion" --- //
    array.forEach(function(doc) {
      col.insert(doc);
    });
    // --- "document insertion" --- //

  });
});

这完全没问题，因为数组中的每个对象都插入到数据库中。但是，我想多次执行此操作；换句话说，我试图在for循环或while循环中运行“文档插入”代码，其中数据在每次迭代中由某个函数修改，然后保存在mongoDB中，但这根本行不通。

我尝试了以下方法，但没有成功，因为好像 for 循环和 while 循环只执行了一次。

// --- "document insertion" --- //
for(var j=0; j<n; j++) { /* where n > 1 */
  /* someFunction() might be executed to alter the content of the objects */
  array.forEach(function(doc) {
    col.insert(doc);
  });
};
// --- "document insertion" --- //

这也不起作用。

// --- "document insertion" --- //
while(--n) { /* where n > 1 */
  /* someFunction() */
  array.forEach(function(doc) {
    col.insert(doc);
  });
};
// --- "document insertion" --- //

我想对包含更复杂架构设计的大型数组（大于 10k 个文档）执行此操作多次。 for 或 while 循环试图模拟时间的步伐，并且数组中的每个对象都应该随着时间的推移而变化。我的目标是保存数组中所有对象的每个时间步。鉴于“文档插入”一段代码似乎只执行一次，我怎么能做到这一点？我希望我已经清楚地表达了自己。

任何评论都会受到欢迎和赞赏。感谢您的帮助。

【问题讨论】：

标签： arrays node.js mongodb

【解决方案1】：

问题在于 mongoDB Node.js 驱动程序会在插入文档之前添加一个_id 属性（如简单提到的here），即您的数组元素在第一个循环之后将有一个_id 属性。在循环的第二次运行中，这将导致重复键异常，因此文档只插入一次。您可以在向insert 添加回调时自己查看问题并写出如下错误：

...
col.insert(doc, function(err) {
    if (err) {
        console.log(ErrorEvent);
    }
});
...

errmsg: 'E11000 重复键错误收集：...

对此的快速修复可能如下所示：

...
array.forEach(function (doc) {
    col.insert(doc);
    delete doc._id;
});
...

【讨论】：

【解决方案2】：

在操作数组后使用 isertMnay() 插入文档数组

https://docs.mongodb.com/manual/tutorial/insert-documents/#write-op-insertmany

db.collection("collection_name", function(err,col) {
if(err) console.log(err);

// --- "document insertion" --- //

  col.insertMany(doc);

// --- "document insertion" --- //

  });
  });

【讨论】：

【解决方案3】：

正如您提到的，对于 10k 文档，使用 for 循环或 while 循环并不是一个好主意。它会让你的节点在某个时候挂起。如果你使用异步模块，它可能会处理循环。

例子：

说一千遍

async.times(1000, function(n, next) {
    array.forEach(function (doc) {
        col.insert(doc);
        next(err, doc);
    });
}, function(err, docs) {
    // we should now have 1000 doc. If you want to use. :)
});

这将并行运行。如果你想让它系列使用 timesSeries 而不是 times

【讨论】：