因此,当我第一次打开与数据库的连接时,一切正常,但是当我关闭它并尝试重新打开它时,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
});