因此,当我第一次打开与数据库的连接时,一切正常,但是当我关闭它并尝试重新打开它时,db对象没有给出错误,但返回了未定义的信息。

这是我打开连接的方法:

let conn = null;
let db = null;

async function validateLoginForm(payload, res) {
    const errors = {};
    let isFormValid = true;
    let message = '';

    if (!payload || typeof payload.email !== 'string' || payload.email.trim().length === 0) {
        if (payload.email !== 'anonymous') {
            isFormValid = false;
            errors.email = 'Please provide your email address.';
        }
    }

    if (!payload || typeof payload.password !== 'string' || payload.password.trim().length === 0) {
        if (payload.email !== 'anonymous') {
            isFormValid = false;
            errors.password = 'Please provide your password.';
        }
    }

    let stringConnection = payload.email === 'anonymous' ? 'mongodb://ds133221.mlab.com:33221/sandbox-te' : 'mongodb://' + payload.email + ':' +
        payload.password + '@ds133221.mlab.com:33221/sandbox-te';

    conn = await MongoClient.connect(stringConnection, await function(err, dbase) {
        if (err)
        {
            isFormValid = false;
            let errorMessage = 'Error connecting to DB';
            return res.status(400).json({
                success: false,
                message: errorMessage,
                errors: errors
            });
        }
        else
        {
            db = dbase;
            if (payload.email !== 'anonymous')
            {
                let roles = dbase.command({usersInfo: {user: payload.email, db: 'sandbox-te'}, showCredentials: true}, (err, result) => {
                    if (result.users[0] && result.users[0].roles[0] &&
                        (result.users[0].roles[0].role === 'dbOwner' || result.users[0].roles[0].role === 'readWrite'))
                    {
                        dbase.close();
                        return res.status(200).json({
                            success: true,
                            hasWriteRole: true
                        })
                    }
                });
            }
            else
            {
                return res.status(200).json({
                    success: true,
                    hasWriteRole: false
                })
            }
        }
    });
}


该文件的第一部分验证登录表单,第二部分使用电子邮件和密码来尝试打开与数据库的连接。

整个功能运行良好,但是当我尝试在另一个文件中将其重新打开时,它将无法正常工作:

router.post('/search', (req, res) => {

    db.open((err, dbase) => {
        let test = dbase.collection('test');
        console.log(test);
        let promiseOfFind = test.find({}).toArray((err, docs) => {
            console.log(docs);  // RETURNS UNDEFINED ONLY IF DB WAS CLOSED EARLIER
        })
    });
});


如果我没有在validateLoginForm函数中关闭数据库,则可以检索文档而不必再次打开它,但是我只是想实现这一点。

我的代码有什么问题?我对Java语言还很陌生,而针对Node.js的官方MongoDB驱动程序的API参考并没有太大帮助。

我正在使用最新版本的React,Express,MongoDB Node.JS官方驱动程序,当然还有Node.JS

提前致谢 !

最佳答案

使用MongoDB,您应该打开一个连接并通过您的应用程序重新使用它。您不需要那时的诺言。

因此在启动时:

const connection = MongoClient.connect(stringConnection, function(err, dbase) {
  // Start web server
});

07-24 09:44
查看更多