mongoose（node.js）でバルクアップロードを実行する方法

Question

ノードjsで一括アップロードを実行しようとしています。mongodbは私のdbです。誰も私にこの最高の記事を教えてもらえますか？

Answer 1

Model.collection.insertまたはModel.insertManyは、collectionsが一括して項目の配列である場合、以下のように使用できます。

Model.collection.insert(collections, function (err, models) { 
    next(err, models); 
}); 

OR、

Model.insertMany(collections, function (err, models) { 
    next(err, models); 
}); 

マングース参照：http://mongoosejs.com/docs/api.html#model_Model.insertMany

モンゴ参照：https://docs.mongodb.com/v3.2/reference/method/db.collection.insert/

Answer 2

あなたはマングースでバッチ/一括挿入で複数のレコードを挿入することができます。

var arr = [{ name: 'Star Wars' }, { name: 'The Empire Strikes Back' }]; 
Movies.insertMany(arr, function(error, docs) {}); 

のは、私は次のようなデータでemployees.xlsxをエクセルファイルがあると私は、一括書き込みを行いたいとしましょう。

はそこにノードにJSONにExcelデータを変換するためのいくつかのライブラリがあり、私はxlsxを使用しますが、それはあなたのために便利であるものは何でも使用することができます個人的な好みです。

ここでは、 "/ public/employees.xlsx"ファイルを読むためのヘルパーを使用しています。ここからコンテンツが見つかりましたhere。

//** helper/excel-reader.js **// 

var excelReader = {}; 
excelReader.readExcel = function(filePath){  

    var XLSX = require('xlsx'); 
    var workbook = XLSX.readFile(filePath); 
    var sheet_name_list = workbook.SheetNames; 
    var data = []; 

    sheet_name_list.forEach(function(y) { 
    var worksheet = workbook.Sheets[y]; 
    var headers = {}; 

    for(z in worksheet) { 
     if(z[0] === '!') continue; 
     //parse out the column, row, and value 
     var tt = 0; 
     for (var i = 0; i < z.length; i++) { 
      if (!isNaN(z[i])) { 
       tt = i; 
       break; 
      } 
     }; 
     var col = z.substring(0,tt); 
     var row = parseInt(z.substring(tt)); 
     var value = worksheet[z].v; 

     //store header names 
     if(row == 1 && value) { 
      headers[col] = value; 
      continue; 
     } 

     if(!data[row]) data[row]={}; 
     data[row][headers[col]] = value; 
    } 
    //drop those first two rows which are empty 
    data.shift(); 
    data.shift();  
    }); 
return data; 
} 

module.exports = excelReader; 

ここで、従業員モデルはどういうわけかこのように見えます。

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

var employee = new Schema({ 
    name: String, 
    adderess: String, 
    phonenumber: String 
}); 

module.exports = mongoose.model('Employee', employee); 

今度はので、ここで上記のコードを使用してみましょう私は、「ローカルホスト：3000 /ユーザー」と入力するたびに、私のusers.jsルートである、それはデータベースにCSVコンテンツを書きます。

var express = require('express'); 
var router = express.Router(); 
var excelReader = require('../helpers/excel-reader'); 
var mongoose = require('mongoose'); 
var Employee = require('../models/employee'); 

/* GET users listing. */ 
router.get('/', function(req, res, next) { 
    var employeesJsonArray = excelReader.readExcel('./public/employees.xlsx') 
    Employee.insertMany(employeesJsonArray,function(error, docs) { 
    if(error){ 
     next(error) 
    } 
    else{ 
     res.json(docs);//just rendering the document i got 
    } 
    }); 
}); 
module.exports = router;