批量插入MongoDB中和的NodeJS

我工作的MongoDB 2.6.9和的NodeJS 0.10.37，并根据我刚才的问题MongoDB calculating score from an existing fields and put it in a new field in the same collection和我有一个结构化的答案做这件事从chridam就像这样：批量插入MongoDB中和的NodeJS

var bulkUpdateOps = db.collection1.initializeUnorderedBulkOp(), 
    cursor = db.collection1.find(), // cursor 
    counter = 0; 

cursor.forEach(function(doc) { 
    // computations 
    var c1, c2, c3, c4, Field8; 
    c1 = 10 + (0.03*doc.Field3); 
    c2 = (doc.Field2 == 1) ? 1: 0.03; 
    c3 = 7 - (doc.Field5.match(new RegExp(".", "g")) || []).length; 
    c4 = (doc.Field2 == 1) ? Math.pow(doc.Field, -0.6) : 1; 
    Field8 = c1*c2*c3*c4; 

    bulkUpdateOps.find({ "_id": doc._id }).updateOne({ 
     "$set": { "Field8": Field8 } 
    }); 

    if (counter % 500 == 0) { 
     bulkUpdateOps.execute(); 
     bulkUpdateOps = db.collection1.initializeUnorderedBulkOp(); 
    } 
}) 

if (counter % 500 != 0) { bulkUpdateOps.execute(); }

但我仍然不知道从哪里开始实现上述，我应该创建一个js文件，它将为我做这个批量插入。从猫鼬连接到这个批量插入。

来源

2016-05-02 Jean Dupont

我试图创建一个包含此代码的js文件batch.js： //连接到DB VAR猫鼬=要求（ '猫鼬'）; var db = mongoose.connect（'mongodb：//127.0.0.1/mydb'）; 以及上述解决方案中给出的代码; 但是，当我尝试编译它，我得到这些错误，请帮助！ SyntaxError：意外的标记。（module.js：359：25） at Module._compile（module.js：439：25） at Object.Module._extensions..js（module.js：474：10） at Module.load（module.js：356：32） at Function .Module._load（module.js：312：12） at node.js：906：3在Function.Module.runMain（module.js：497：10）启动时（node.js：119：16） –

为了在Mongoose中使用基础的批量操作API，您应该可以通过mongoose模型中的.collection属性来访问它。在使用API之前，等待mongoose成功连接到数据库，因为Mongoose当前不支持“initializeOrderedBulkOp（）”，因为它不适用于其内部缓冲系统。因此，像下面的执行（未测试）应该给你一个想法：

var mongoose = require('mongoose'), 
    express = require('express'), 
    Schema = mongoose.Schema; 

mongoose.connect('mongodb://localhost/mydb'); 
var collection1Schema = new Schema({},{ strict: false, collection: 'Collection1' }),  
    MyModel = mongoose.model("MyModel", collection1Schema); 

mongoose.set('debug', true); 

mongoose.connection.on("open", function (err) { 
    if (err) throw err; 
    var bulkUpdateOps = MyModel.collection.initializeUnorderedBulkOp(), 
     counter = 0; 

    MyModel.find({}).lean().exec(function (err, docs) { 
     if (err) throw err; 

     docs.forEach(function (doc){ 
      // computations 
      var c1, c2, c3, c4, Field8; 
      c1 = 10 + (0.03*doc.Field3); 
      c2 = (doc.Field2 == 1) ? 1: 0.03; 
      c3 = 7 - (doc.Field5.match(new RegExp(".", "g")) || []).length; 
      c4 = (doc.Field2 == 1) ? Math.pow(doc.Field, -0.6) : 1; 
      Field8 = c1*c2*c3*c4; 

      counter++; 

      bulkUpdateOps.find({ "_id": doc._id }).updateOne({ 
       "$set": { "Field8": Field8 } 
      }); 

      if (counter % 500 == 0) { 
       bulkUpdateOps.execute(function(err, result) { 
        if (err) throw err; 
        bulkUpdateOps = MyModel.collection.initializeUnorderedBulkOp(); 
        console.log(result); 
       }); 
      } 

     });  

     if (counter % 500 != 0) {    
      bulkUpdateOps.execute(function(err, result) { 
       if (err) throw err; 
       console.log(result); 
      });   
     }  
    }); 

    var app = express(); 
    app.listen(3000, function() { 
     console.log('now listening on http://localhost:3000'); 
    }); 
});

来源

2016-05-03 10:05:41 chridam

它工作干净（y）非常感谢你 –

批量插入MongoDB中和的NodeJS

回答

相关问题