如何正确链接所有涉及 mongo 数据库的承诺 [重复]

Question

我是 Node 和 Mongo 的初学者，所以我需要一些帮助。我正在练习链接承诺和 MongoDB。我想将 2 个插入操作链接在一起。但是，当我运行此代码文件时，出现错误：“TypeError: Cannot read property 'db' of undefined 在 /Users/jenniferzhou/Documents/2018 - 2019/MEAN Practice/Guru99/E8/mongopractice5.js:12:22 在 process.internalTickCallback (internal/process/next_tick.js:77:7) " 该错误表明问题出在这行代码上：“var db = client1.db('EmployeeDB')”。但是，我不确定为什么这条线会返回错误。我知道 MongoClient.connect(url, { useNewUrlParser: true }) 返回一个承诺，但是这个承诺在某种程度上与第一个 .then(...) 返回的承诺不同吗？

var Promise = require('promise')
var MongoClient = require('mongodb').MongoClient
var url = 'mongodb://localhost:27017'
MongoClient.connect(url, { useNewUrlParser: true        }).then(function(client) {
     var db = client.db('EmployeeDB')
     db.collection('Employee').insertOne({
         Employeeid: 4,
         EmployeeName: "NewEmployee"
     })
    client.close()
}).then(function(client1) {
    var db = client1.db('EmployeeDB')
    db.collection('Employee').insertOne({
        Employeeid: 5,
        EmployeeName: "NewEmployee1"
    })
    client1.close()
}).catch(function(err) {
    console.log(err)
}) 

Answer 1

连接和插入返回承诺。这些与then 方法链接。 IMO 也希望构建执行离散任务并返回承诺的函数，所以...

const MongoClient = require('mongodb').MongoClient

function mongoConnect(url) {
    return MongoClient.connect(url, { useNewUrlParser: true });
}

function mongoClose(db) {
    return db.close();
}

function insertEmployee(db, employee) {
    return db.collection('Employee').insertOne(employee);
}

function insertSomeEmployees() {
    let db;
    return mongoConnect('mongodb://localhost:27017').then(result => {
        db = result;
        return insertEmployee(db, { Employeeid: 4, EmployeeName: "NewEmployee" });
    }).then(() => {
        return insertEmployee(db, { Employeeid: 5, EmployeeName: "NewEmployee1" });
    }).then(() => {
        return mongoClose(db);
    }).catch(function(err) {
        console.log(err)
    }); 
}

Answer 2

var Promise = require('promise')
var MongoClient = require('mongodb').MongoClient
var url = 'mongodb://localhost:27017';

MongoClient.connect(url, { useNewUrlParser: true}).then(function(client) {
   var db = client.db('EmployeeDB');
   db.collection("Employee").insertOne({
       Employeeid: 4,
       EmployeeName: "NewEmployee"
      }).then(function(res) {
         console.log('Document inserted');
    });

    db.collection("Employee").insertOne({
        Employeeid: 5,
        EmployeeName: "NewEmployee1"
      }).then(function(res) {
        console.log('Document inserted');
     });
 }).catch(function (err) {
    console.log(err);
 })

---

您应该在每个请求结束后关闭。

而且你没有使用你导入的承诺库。