Sails js 批量上传并插入 MongoDB

Question

你好在我的 Sailsjs 应用程序中有批量上传功能，管理员可以上传 csv 文件。我正在使用 csv-parse 来解析 csv 内容。

现在我想将数据插入 Mongo 数据库，其中每一行都有车辆信息和测试信息。这两个模型是一对多的关系。我不知道如何将它们插入数据库。下面是我插入车辆的代码。

下面是我想在创建 Vehicle 模型后创建 VehicleTest 模型的代码示例，但我无权访问 vehicle 以获取 vechileTest 模型的信息

车辆型号

attributes: {
  make: {
    type: "string",
    required: true

  },


  tests :{
    collection: 'VehicleTest',
    via : 'vehicleTested'
  },

车辆测试模型

 attributes: {


vehicleTested :{
  modal :'Vehicle',
  required:true
},

函数的以下代码行读取文件并解析它

 var parse = require('csv-parse');
var fs = require("fs")
var createdVehicle =[];
var stream = files[0].fd;

fs.readFile(stream, 'utf8', function (err, data) {
  // Print the contents of the file as a string here
  // and do whatever other string processing you want

  parse(data, {columns: true,delimiter:'|'}, function(err, output){


    if(output.length>0)
    {
      for (var i = 0, len = output.length; i < len; i++) {

        var vehicle_TestInfo  = output[i];
        //console.log(vehicle_TestInfo);
        //
        Vehicle.create({make : vehicle_TestInfo.make,model:vehicle_TestInfo.model,year:vehicle_TestInfo.year ,engineFuel:vehicle_TestInfo.engineFuel,obdZone:vehicle_TestInfo.obdZone,generation:vehicle_TestInfo.generation,protocol:vehicle_TestInfo.protocol,onStar:vehicle_TestInfo.onStar}).exec(function(err,vehCreated){

          console.log(vehCreated);
          //VehicleTest.Create({vehicleTested:vehCreated._id,overAllComp:vehicle_TestInfo.overAllComp,deviceGeneration:vehicle_TestInfo.deviceGeneration}).exec(function(err,testCreated){
          //
          //  console.log(testCreated);
          //
          //})


      });
    }
    }

Answer 1

我就是这样实现的

 for (var i = 0, len = output.length; i < len; i++) {

        var vehicle_TestInfo  = output[i];
        //console.log(vehicle_TestInfo);
        //
       Vehicle.create({make : vehicle_TestInfo.make,model:vehicle_TestInfo.model,year:vehicle_TestInfo.year ,trim:vehicle_TestInfo.trim ,engineFuel:vehicle_TestInfo.engineFuel,obdZone:vehicle_TestInfo.obdZone,generation:vehicle_TestInfo.generation,protocol:vehicle_TestInfo.protocol,onStar:vehicle_TestInfo.onStar,
       tests : {deviceGeneration:vehicle_TestInfo.deviceGeneration,overAllComp:vehicle_TestInfo.overAllComp,isTested:vehicle_TestInfo.isTested,testingInferred:vehicle_TestInfo.testingInferred,vinRead:vehicle_TestInfo.vinRead,
         odoRead:vehicle_TestInfo.odoRead,pidRead:vehicle_TestInfo.pidRead,doorLocked:vehicle_TestInfo.doorLocked,SeatBelt:vehicle_TestInfo.seatBelt,fuelLevel:vehicle_TestInfo.fuelLevel,issueType:vehicle_TestInfo.issueType,degreeOfERGIntr:vehicle_TestInfo.degreeOfERGIntr,dataLoggerModel:vehicle_TestInfo.dataLoggerModel,
         numberOfVehicle:vehicle_TestInfo.numberOfVehicle,remarks:vehicle_TestInfo.remarks}}).exec(function(err,vehCreated){

          if(err && err.originalError && err.originalError.code===50)
          {
              Vehicle.update({id:vehCreated.id})

          }
         /// console.log(vehCreated);
         // vehCreated.tests.add({})
          createdVehicle.push(vehCreated);



      });

Sails js 批量上传并插入 MongoDB

Sails js bulk upload and insert into MongoDB

mongodb

sails.js

waterline