依靠nodejs子进程导入导出mongodb数据库

import {ipcMain} from 'electron'

let jsonFileToTrainModel = require('../model/jsonFileToTrainModal')
const fs = require('fs');
const spawn = require('child_process').spawn
export default function () {
  // *****************以下是数据库相关*******************************
  // 导出本地数据库
  ipcMain.on('exportLocalData', (event, arg) => {
    let cmdPath = process.cwd() + "\\static\\mongodb"
    let spawnObj = spawn('.\\bin\\mongoexport.exe', ['-h', 'localhost:27017', '-d', 'nipDb', '-c', arg, '-o', `.\\mustTable\\${arg}.json`], {cwd: cmdPath})
    spawnObj.stdout.on('data', function (chunk) {
      event.returnValue = ""
    })
    spawnObj.on('close', function (code) {
      console.log("导出成功")
      event.returnValue = ""
    })
  });

  // 读取本地数据库文件再导入数据库
  ipcMain.on('importToLocalDataByDatabase', (event, arg) => {
    // G:\gs_books\8.0electron\electron_gyy\static\mongodb\exportData\1.json  arg{filePath,tableName}
    let cmdPath = process.cwd() + "\\static\\mongodb"
    let spawnObj = spawn('.\\bin\\mongoimport.exe', ['-h', 'localhost:27017', '-d', 'gs_db', '-c', arg.tableName, '--file', arg.filePath], {cwd: cmdPath})
    spawnObj.stdout.on('data', function (chunk) {
      console.log("没在成功打印,在子进程关闭那里打印的")
      event.returnValue = ""
    });
    // 失败
    spawnObj.stderr.on('data', (data) => {
      // console.log(data.toString());
    });
    // 子进程关闭
    spawnObj.on('close', function (code) {
      console.log("导入成功")
      event.returnValue = ""
    })
  });

  //dump并查询
  ipcMain.on('readDumpFile', (event) => {
    let cmdPath = process.cwd() + "\\static\\mongodb"
    let spawnObj = spawn('.\\bin\\mongodump.exe', ['-o', '.\\bin\\dump'], {cwd: cmdPath})
    // 成功
    spawnObj.stdout.on('data', function (chunk) {
      console.log(chunk)
    });
    // 失败
    spawnObj.stderr.on('data', (data) => {
      // console.log(data.toString());
    });
    // 子进程关闭
    spawnObj.on('close', function (code) {
      // 先dump成功再读
      let allFiles = readFileFunc(cmdPath + "\\bin\\dump")
      event.returnValue = allFiles
    })
  });

  // 读取本地json文件
  ipcMain.on('importToLocalDataByJsonFile', (event, arg) => {
    // G:\gs_books\8.0electron\electron_gyy\static\mongodb\exportData\1.json  arg{filePath,tableName}
    let filePath = arg.filePath
    fs.readFile(filePath, async function (err, data) {
      if (err) {
        return console.error(err)
      }
      let fileData = JSON.parse(data.toString())

      fileData.length > 0 && fileData.forEach(item => {
        if (item.trainingPlanEntity) {
          delete item.trainingPlanEntity
        }
        if (item.trainingDesignStateUpAndDowns) {
          delete item.trainingDesignStateUpAndDowns
        }
        item.trainingDesignRelevanceList.length > 0 && item.trainingDesignRelevanceList.forEach(ele => {
          ele.netList.forEach(uu => {
            uu.subject && delete uu.subject
            uu.subjects && delete uu.subjects
          })
        })
      })
      // insert会把数组里面的东西全部导入
      await jsonFileToTrainModel.collection.insert(fileData, (err, docs) => {
        if (err) {
          event.returnValue = {code:0}
        } else {
          event.returnValue = {code:1}
        }
      })
    })


  });


  // *****************以下是考核相关*******************************
  // 查询考核列表
  ipcMain.on('getInitExamData_', async (event) => {
    let trainModel = require('../model/trainModel')
    let findResult = await trainModel.find()
    // console.log(findResult)
    event.returnValue = findResult
  });

  // 查询考核详情
  ipcMain.on('getTrainInfo_', async (event, arg) => {
    // 需要联合查询 存在一张主表和两张附表
    let trainModel = require('../model/trainModel')
    let findResult = await trainModel.findOne({examDesignId: arg})
    // console.log(findResult)
    event.returnValue = findResult
  });


  // *****************以下是工具方法*******************************
  // 定义一个读dump文件夹里面读文件的方法
  let readFileFunc = (path) => {
    // 读出数据库dump里面的东西
    let folders = []
    let files = fs.readdirSync(path);
    // console.log(files)
    files.forEach(function (item, index) {
      if (item !== "gs_db") return
      let fileSons = fs.readdirSync(`${path}\\${item}`)
      let obj = {}
      obj[item] = fileSons
      folders.push(obj)
    })
    return folders;
  }
}