blocks|key|374036|text|Mongoose还没有实现批量插入(参见issue+#723)。|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|374037|由于您知道要保存的文档数，因此可以编写如下代码：|374038|var+total+=+docArray.length
++,+result+=+[]
;

function+saveAll(){
++var+doc+=+docArray.pop();

++doc.save(function(err,+saved){
++++if+(err)+throw+err;//handle+error

++++result.push(saved[0]);

++++if+(--total)+saveAll();
++++else+//+all+saved+here
++})
}

saveAll();|code-block|syntax|javascript|374039|当然，这是一个权宜之计，我推荐使用某种流量控制库(我使用的是q，它非常棒)。|374040|entityMap|0|LINK|mutability|MUTABLE|url|https://github.com/LearnBoost/mongoose/issues/723|1|https://github.com/kriskowal/q^0|K|A|0|0|0|0|U|1|1|0^^$0|@$1|2|3|4|5|6|7|W|8|@]|9|@$A|X|B|Y|1|Z]]|C|$]]|$1|D|3|E|5|6|7|10|8|@]|9|@]|C|$]]|$1|F|3|G|5|H|7|11|8|@]|9|@]|C|$I|J]]|$1|K|3|L|5|6|7|12|8|@]|9|@$A|13|B|14|1|15]]|C|$]]|$1|M|3|-4|5|6|7|16|8|@]|9|@]|C|$]]]|N|$O|$5|P|Q|R|C|$S|T]]|U|$5|P|Q|R|C|$S|V]]]]

Mongoose doesn't have bulk inserts implemented yet (see <a href="https://github.com/LearnBoost/mongoose/issues/723">issue #723</a>).

Since you know the number of documents you're saving, you could write something like this:

<pre><code>var total = docArray.length
 , result = []
;

function saveAll(){
 var doc = docArray.pop();

 doc.save(function(err, saved){
 if (err) throw err;//handle error

 result.push(saved[0]);

 if (--total) saveAll();
 else // all saved here
 })
}

saveAll();
</code></pre>

This, of course, is a stop-gap solution and I would recommend using some kind of flow-control library (I use <a href="https://github.com/kriskowal/q">q</a> and it's awesome).

blocks|key|590014|text|除非您需要访问中间件，否则可以使用.insert()在Mongoose中进行批量插入。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|590015|Model.collection.insert(docs,+options,+callback)|offset|length|style|CODE|590016|https://github.com/christkv/node-mongodb-native/blob/master/lib/mongodb/collection.js#L71-91|590017|entityMap|0|LINK|mutability|MUTABLE|url^0|0|0|1C|0|0|2K|0|0^^$0|@$1|2|3|4|5|6|7|Q|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|R|8|@$D|S|E|T|F|G]]|9|@]|A|$]]|$1|H|3|I|5|6|7|U|8|@]|9|@$D|V|E|W|1|X]]|A|$]]|$1|J|3|-4|5|6|7|Y|8|@]|9|@]|A|$]]]|K|$L|$5|M|N|O|A|$P|I]]]]

Bulk inserts in Mongoose can be done with .insert() unless you need to access middleware.

<code>Model.collection.insert(docs, options, callback)</code>

<a href="https://github.com/christkv/node-mongodb-native/blob/master/lib/mongodb/collection.js#L71-91">https://github.com/christkv/node-mongodb-native/blob/master/lib/mongodb/collection.js#L71-91</a>

blocks|key|374224|text|使用async+parallel，您的代码将如下所示：|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|374225|++async.parallel([obj1.save,+obj2.save,+obj3.save],+callback);|code-block|syntax|javascript|374226|由于Mongoose中的约定与async+(err，callback)中的约定相同，因此您不需要将它们包装在您自己的回调中，只需将您的save调用添加到一个数组中，当所有操作完成时，您将获得一个回调。|374227|如果您使用mapLimit，您可以控制要并行保存的文档数量。在本例中，我们并行保存10个文档，直到所有项目都成功保存。|374228|async.mapLimit(myArray,+10,+function(document,+next){
++document.save(next);
},+done);|374229|entityMap|0|LINK|mutability|MUTABLE|url|https://github.com/caolan/async#paralleltasks-callback^0|2|E|0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|W|8|@]|9|@$A|X|B|Y|1|Z]]|C|$]]|$1|D|3|E|5|F|7|10|8|@]|9|@]|C|$G|H]]|$1|I|3|J|5|6|7|11|8|@]|9|@]|C|$]]|$1|K|3|L|5|6|7|12|8|@]|9|@]|C|$]]|$1|M|3|N|5|F|7|13|8|@]|9|@]|C|$G|H]]|$1|O|3|-4|5|6|7|14|8|@]|9|@]|C|$]]]|P|$Q|$5|R|S|T|C|$U|V]]]]

Use <a href="https://github.com/caolan/async#paralleltasks-callback">async parallel</a> and your code will look like this:

<pre><code> async.parallel([obj1.save, obj2.save, obj3.save], callback);
</code></pre>

Since the convention is the same in Mongoose as in async (err, callback) you don't need to wrap them in your own callbacks, just add your save calls in an array and you will get a callback when all is finished.

If you use mapLimit you can control how many documents you want to save in parallel. In this example we save 10 documents in parallell until all items are successfully saved.

<pre><code>async.mapLimit(myArray, 10, function(document, next){
 document.save(next);
}, done);
</code></pre>

blocks|key|589985|text|我知道这是一个古老的问题，但它让我担心的是，这里没有正确的答案。大多数答案只是讨论迭代所有文档并逐个保存它们，如果您有多个文档，这是一个糟糕的主意，并且即使在许多请求中有一个请求也会重复该过程。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|589986|MongoDB特别有一个用于插入多个文档的batchInsert()调用，应该在原生mongodb驱动程序中使用。Mongoose是建立在这个驱动程序之上的，它不支持批量插入。它可能是有意义的，因为它被认为是MongoDB的对象文档建模工具。|offset|length|style|CODE|589987|解决方案:+Mongoose自带原生MongoDB驱动程序。您可以通过要求mongodb+npm+require('mongoose/node_modules/mongodb')来使用它(这一点不太确定，但是如果mongodb+npm不工作，您总是可以重新安装它，但我认为它应该如此)，然后执行适当的batchInsert|589988|entityMap^0|0|L|D|0|1D|14|46|B|0^^$0|@$1|2|3|4|5|6|7|L|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|M|8|@$D|N|E|O|F|G]]|9|@]|A|$]]|$1|H|3|I|5|6|7|P|8|@$D|Q|E|R|F|G]|$D|S|E|T|F|G]]|9|@]|A|$]]|$1|J|3|-4|5|6|7|U|8|@]|9|@]|A|$]]]|K|$]]

I know this is an old question, but it worries me that there are no properly correct answers here. Most answers just talk about iterating through all the documents and saving each of them individually, which is a BAD idea if you have more than a few documents, and the process gets repeated for even one in many requests. 

MongoDB specifically has a <code>batchInsert()</code> call for inserting multiple documents, and this should be used from the native mongodb driver. Mongoose is built on this driver, and it doesn't have support for batch inserts. It probably makes sense as it is supposed to be a Object document modelling tool for MongoDB. 

Solution: Mongoose comes with the native MongoDB driver. You can use that driver by requiring it <code>require('mongoose/node_modules/mongodb')</code> (not too sure about this, but you can always install the mongodb npm again if it doesn't work, but I think it should) and then do a proper <code>batchInsert</code>

blocks|key|590058|text|较新版本的MongoDB支持批量操作：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|590059|var+col+=+db.collection('people');
var+batch+=+col.initializeUnorderedBulkOp();

batch.insert({name:+"John"});
batch.insert({name:+"Jane"});
batch.insert({name:+"Jason"});
batch.insert({name:+"Joanne"});

batch.execute(function(err,+result)+{
++++if+(err)+console.error(err);
++++console.log('Inserted+'+%2B+result.nInserted+%2B+'+row(s).');
}|code-block|syntax|javascript|590060|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

Newer versions of MongoDB support bulk operations:

<pre class="lang-js prettyprint-override"><code>var col = db.collection('people');
var batch = col.initializeUnorderedBulkOp();

batch.insert({name: "John"});
batch.insert({name: "Jane"});
batch.insert({name: "Jason"});
batch.insert({name: "Joanne"});

batch.execute(function(err, result) {
 if (err) console.error(err);
 console.log('Inserted ' + result.nInserted + ' row(s).');
}
</code></pre>

blocks|key|374075|text|这是另一种不使用附加库的方法(不包含错误检查)。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|374076|function+saveAll(+callback+){
++var+count+=+0;
++docs.forEach(function(doc){
++++++doc.save(function(err){
++++++++++count%2B%2B;
++++++++++if(+count+==+docs.length+){
+++++++++++++callback();
++++++++++}
++++++});
++});
}|code-block|syntax|javascript|374077|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

Here is another way without using additional libraries (no error checking included)

<pre><code>function saveAll( callback ){
 var count = 0;
 docs.forEach(function(doc){
 doc.save(function(err){
 count++;
 if( count == docs.length ){
 callback();
 }
 });
 });
}
</code></pre>

blocks|key|590105|text|您可以使用mongoose+save返回的promise，mongoose中的Promise没有全部，但是您可以使用此模块添加该功能。|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|590106|创建一个与所有人一起增强mongoose承诺的模块。|590107|var+Promise+=+require("mongoose").Promise;

Promise.all+=+function(promises)+{
++var+mainPromise+=+new+Promise();
++if+(promises.length+==+0)+{
++++mainPromise.resolve(null,+promises);
++}

++var+pending+=+0;
++promises.forEach(function(p,+i)+{
++++pending%2B%2B;
++++p.then(function(val)+{
++++++promises[i]+=+val;
++++++if+(--pending+===+0)+{
++++++++mainPromise.resolve(null,+promises);
++++++}
++++},+function(err)+{
++++++mainPromise.reject(err);
++++});
++});

++return+mainPromise;
}

module.exports+=+Promise;|code-block|syntax|javascript|590108|然后在mongoose中使用它：|590109|var+Promise+=+require('./promise')

...

var+tasks+=+[];

for+(var+i=0;+i+<+docs.length;+i%2B%2B)+{
++tasks.push(docs[i].save());
}

Promise.all(tasks)
++.then(function(results)+{
++++console.log(results);
++},+function+(err)+{
++++console.log(err);
++})|590110|entityMap^0|E|4|13|7|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|S|8|@$9|T|A|U|B|C]|$9|V|A|W|B|C]]|D|@]|E|$]]|$1|F|3|G|5|6|7|X|8|@]|D|@]|E|$]]|$1|H|3|I|5|J|7|Y|8|@]|D|@]|E|$K|L]]|$1|M|3|N|5|6|7|Z|8|@]|D|@]|E|$]]|$1|O|3|P|5|J|7|10|8|@]|D|@]|E|$K|L]]|$1|Q|3|-4|5|6|7|11|8|@]|D|@]|E|$]]]|R|$]]

You can use the promise returned by mongoose <code>save</code>, <code>Promise</code> in mongoose does not have all, but you can add the feature with this module.

Create a module that enhance mongoose promise with all.

<pre><code>var Promise = require("mongoose").Promise;

Promise.all = function(promises) {
 var mainPromise = new Promise();
 if (promises.length == 0) {
 mainPromise.resolve(null, promises);
 }

 var pending = 0;
 promises.forEach(function(p, i) {
 pending++;
 p.then(function(val) {
 promises[i] = val;
 if (--pending === 0) {
 mainPromise.resolve(null, promises);
 }
 }, function(err) {
 mainPromise.reject(err);
 });
 });

 return mainPromise;
}

module.exports = Promise;
</code></pre>

Then use it with mongoose:

<pre><code>var Promise = require('./promise')

...

var tasks = [];

for (var i=0; i &lt; docs.length; i++) {
 tasks.push(docs[i].save());
}

Promise.all(tasks)
 .then(function(results) {
 console.log(results);
 }, function (err) {
 console.log(err);
 })
</code></pre>

blocks|key|374143|text|添加一个名为mongoHelper.js的文件|type|unstyled|depth|inlineStyleRanges|entityRanges|data|374144|var+MongoClient+=+require('mongodb').MongoClient;

MongoClient.saveAny+=+function(data,+collection,+callback)
{
++++if(data+instanceof+Array)
++++{
++++++++saveRecords(data,collection,+callback);
++++}
++++else
++++{
++++++++saveRecord(data,collection,+callback);
++++}
}

function+saveRecord(data,+collection,+callback)
{
++++collection.save
++++(
++++++++data,
++++++++{w:1},
++++++++function(err,+result)
++++++++{
++++++++++++if(err)
++++++++++++++++throw+new+Error(err);
++++++++++++callback(result);
++++++++}
++++);
}
function+saveRecords(data,+collection,+callback)
{
++++save
++++(
++++++++data,+
++++++++collection,
++++++++callback
++++);
}
function+save(data,+collection,+callback)
{
++++collection.save
++++(
++++++++data.pop(),
++++++++{w:1},
++++++++function(err,+result)
++++++++{
++++++++++++if(err)
++++++++++++{+++++++++++++++
++++++++++++++++throw+new+Error(err);
++++++++++++}
++++++++++++if(data.length+>+0)
++++++++++++++++save(data,+collection,+callback);
++++++++++++else
++++++++++++++++callback(result);
++++++++}
++++);
}

module.exports+=+MongoClient;|code-block|syntax|javascript|374145|然后，在代码更改中，您需要|374146|var+MongoClient+=+require("./mongoHelper.js");|374147|然后，当需要保存调用时(连接并检索集合之后)|374148|MongoClient.saveAny(data,+collection,+function(){db.close();});|374149|你可以改变错误处理来满足你的需要，在回调中回传错误等等。|374150|entityMap^0|0|0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|S|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|T|8|@]|9|@]|A|$E|F]]|$1|G|3|H|5|6|7|U|8|@]|9|@]|A|$]]|$1|I|3|J|5|D|7|V|8|@]|9|@]|A|$E|F]]|$1|K|3|L|5|6|7|W|8|@]|9|@]|A|$]]|$1|M|3|N|5|D|7|X|8|@]|9|@]|A|$E|F]]|$1|O|3|P|5|6|7|Y|8|@]|9|@]|A|$]]|$1|Q|3|-4|5|6|7|Z|8|@]|9|@]|A|$]]]|R|$]]

Add a file called mongoHelper.js

<pre><code>var MongoClient = require('mongodb').MongoClient;

MongoClient.saveAny = function(data, collection, callback)
{
 if(data instanceof Array)
 {
 saveRecords(data,collection, callback);
 }
 else
 {
 saveRecord(data,collection, callback);
 }
}

function saveRecord(data, collection, callback)
{
 collection.save
 (
 data,
 {w:1},
 function(err, result)
 {
 if(err)
 throw new Error(err);
 callback(result);
 }
 );
}
function saveRecords(data, collection, callback)
{
 save
 (
 data, 
 collection,
 callback
 );
}
function save(data, collection, callback)
{
 collection.save
 (
 data.pop(),
 {w:1},
 function(err, result)
 {
 if(err)
 { 
 throw new Error(err);
 }
 if(data.length &gt; 0)
 save(data, collection, callback);
 else
 callback(result);
 }
 );
}

module.exports = MongoClient;
</code></pre>

Then in your code change you requires to

<pre><code>var MongoClient = require("./mongoHelper.js");
</code></pre>

Then when it is time to save call (after you have connected and retrieved the collection)

<pre><code>MongoClient.saveAny(data, collection, function(){db.close();});
</code></pre>

You can change the error handling to suit your needs, pass back the error in the callback etc.

blocks|key|590162|text|这是一个古老的问题，但我在搜索"mongoose+insert+array+of+document“时，首先在google搜索结果中出现了这个问题。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|590163|您可以使用两个选项model.create()+mongoose和model.collection.insert()+mongodb。在此处查看有关每个选项的优缺点的更全面的讨论：|590164|Mongoose+(mongodb)+batch+insert?|offset|length|590165|entityMap|0|LINK|mutability|MUTABLE|url|https://stackoverflow.com/questions/16726330/mongoose-mongodb-batch-insert^0|0|0|0|W|0|0^^$0|@$1|2|3|4|5|6|7|P|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|Q|8|@]|9|@]|A|$]]|$1|D|3|E|5|6|7|R|8|@]|9|@$F|S|G|T|1|U]]|A|$]]|$1|H|3|-4|5|6|7|V|8|@]|9|@]|A|$]]]|I|$J|$5|K|L|M|A|$N|O]]]]

This is an old question, but it came up first for me in google results when searching "mongoose insert array of documents".

There are two options model.create() [mongoose] and model.collection.insert() [mongodb] which you can use. View a more thorough discussion here of the pros/cons of each option:

<a href="https://stackoverflow.com/questions/16726330/mongoose-mongodb-batch-insert">Mongoose (mongodb) batch insert?</a>

At the moment I use save to add a single document. Suppose I have an array of documents that I wish to store as single objects. Is there a way of adding them all with a single function call and then getting a single callback when it is done? I could add all the documents individually but managing the callbacks to work out when everything is done would be problematic.

How can I save multiple documents concurrently in Mongoose/Node.js?

中间件

MongoDB

目前，我使用save来添加单个文档。假设我有一个文档数组，我希望将其存储为单个对象。有没有一种方法可以通过一个函数调用将它们全部添加到一起，然后在完成时获得一个回调？我可以单独添加所有文档，但管理回调以确定何时完成所有操作将是有问题的。

问如何在Mongoose/Node.js中同时保存多个文档？
EN

回答 9

Stack Overflow用户

Stack Overflow用户

Stack Overflow用户

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何在Mongoose/Node.js中同时保存多个文档？EN

回答 9

Stack Overflow用户

Stack Overflow用户

Stack Overflow用户

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何在Mongoose/Node.js中同时保存多个文档？
EN