将nodejs MongoDB连接代码移动到另一个文件

Question

移动数据库连接代码另一个nodejs文件，不返回任何连接对象。

我可以在nodejs中将数据写入MongoDB。所有数据库连接代码都写入单个.js文件中。

现在我尝试将 db 连接代码分离到另一个 .js 文件，现在似乎无法成功建立连接。

这是 1 个.js文件中的工作代码：

const mongoDBIP = '192.168.1.71';
const mongoDBPort = 27017;
const mongo= require('mongodb').MongoClient;
const mongoURL = 'mongodb://<mongo admin>:<password>@'+`${mongoDBIP}`+':'+`${mongoDBPort}`;
...
mongo.connect(mongoURL, { useNewUrlParser: true, useUnifiedTopology: true }, (err, db) => {
if (err) {}
var dbo = db.db(<databaseName>);
var collection = dbo.collection('messages');
collection.insertOne(message, (err, result) => {
if (err) {}
})
...

现在我将其分解为 2 个.js文件：

var _mongo = require('./mongodb.js');
var mongoDBO = _mongo.mongoDBO;
...
var dbo = mongoDBO('feathers');
console.log('DBO:' + dbo);   <-- here, dbo is NULL
var collection = dbo.collection('messages');
collection.insertOne(message, (err, result) => {
if (err) {}
})
...

以下是mongodb的内容.js：

// mongodb.js
const mongoDBIP = '192.168.1.71';
const mongoDBPort = 27017;
const mongoClient = require('mongodb').MongoClient;
const mongoURL = 'mongodb://<mongo admin>:<password>@'+`${mongoDBIP}`+':'+`${mongoDBPort}`;

function mongoDBO(database) {
var dbo;
mongoClient.connect(mongoURL, { useNewUrlParser: true, useUnifiedTopology: true }, (err, dbase) => {
if (err) {}
dbo = dbase.db(database);   <-- here, dbo is NULL
});
return dbo;
}
module.exports = Object.freeze({
mongoDBO
});

我希望mongodb中的对象"dbo"不会为空.js但它确实如此。这在 nodejs v10.x 和 v12.x 下都发生。

Answer 1

这是 Tom 解释的实现，以防您需要。

蒙戈德布.js

const mongoClient = require('mongodb').MongoClient;
const mongoDBIP = '192.168.1.71';
const mongoDBPort = 27017;
const mongoURL = 'mongodb://<mongo admin>:<password>@'+`${mongoDBIP}`+':'+`${mongoDBPort}`;
let _db;
const initDb = callback => {
if (_db) {
console.log('Db is already initialized!');
return callback(null, _db);
}
mongoClient .connect(mongoURL)
.then(client => {
_db = client;
callback(null, _db);
})
.catch(err => {
callback(err);
});
};
const getDb = () => {
if (!_db) {
throw Error('Db not initialized');
}
return _db;
};
module.exports = {
initDb,
getDb
};

在主文件(索引、应用程序或服务器.js(中初始化它

const mongodb = require('./mongodb');

mongodb.initDb((err, mongodb ) => {
if (err) {
console.log(err);
} else {
app.listen(3000);
}
});

并在您的路线中使用它：

const mongodb = require('./mongodb');

mongodb.getDb()
.db()
.collection('your_collection_name')....

Answer 2

您正在尝试返回一个尚不存在的值。 在调用回调函数之前，不会设置 DBO。此时，原始函数已返回。

您必须更改 mongodb.js 文件以导出一个接受回调的函数，并在准备就绪时将 dbo 传递给该回调。

我建议阅读回调和异步编程。

Answer 3

像这样尝试

const mongoDBIP = "192.168.1.71";
const mongoDBPort = 27017;
const mongoClient = require("mongodb").MongoClient;
const mongoURL =
"mongodb://<mongo admin>:<password>@" +
`${mongoDBIP}` +
":" +
`${mongoDBPort}`;
var mongoDBO = database =>
new Promise((resolve, reject) => {
mongoClient.connect(
mongoURL,
{ useNewUrlParser: true, useUnifiedTopology: true },
(err, dbase) => {
if (err) {
reject(err);
}
resolve(dbase);
}
);
});
module.exports = Object.freeze({
mongoDBO
});

&

var _mongo = require('./mongodb.js');
var mongoDBO = _mongo.mongoDBO;
...
try {
let dbo = mongoDBO('feathers');
console.log('DBO:' + dbo);   <-- here, dbo is NULL
var collection = dbo.collection('messages');
collection.insertOne(message, (err, result) => {
if (err) {}
})
} catch (error) {
console.log(connection failed)
}

...