我的项目中有很多数据库,一个是masterDb,其他都是基于masterDb的数据库连接。例如,在验证页面中,用户可以输入“公司 ID”,可以使用 masterDb 检查该“公司 ID”,如果 ID 存在,则返回特定公司的数据库名称。使用数据库名称我想连接到特定的公司数据库。
现在我可以成功登录并获得数据库名称。使用这个数据库名称(req.headers['x-key-db'])我可以连接到特定的数据库。但在这里我将数据库连接代码放置在每个 api 调用中。有没有其他方法可以创建一次并在每个 api 调用中动态使用它。
app.get('/api/student-limited/:_pageNumber/:_pageSize', function(req, res) {
var db = mongoose.createConnection();
db.open('mongodb://localhost:27017/'+req.headers['x-key-db']);
var ClassSection = db.model('ClassSections', SectionSchema);
var Student = db.model('Students', StudentSchema);
var _pageNumber = parseInt(req.params._pageNumber), _pageSize = parseInt(req.params._pageSize);
Student.find({}, function (err, _docs) {
if(_docs){
Student.find({}, null, {sort: { Name: 1} }).skip(_pageNumber > 0 ? ((_pageNumber-1)*_pageSize) : 0).limit(_pageSize).populate('_idClass').exec(function (err, docs) {
if(err)
res.json(err);
else
res.json({ "TotalCount" : _docs.length, "_Array" : docs});
});
}
});
});
您可以创建一个如下所示的模块,它将检查您需要的数据库的数据库连接是否已经存在。如果存在,它将返回连接对象,否则它将创建一个并返回它。
var mongoose = require('mongoose');
//Object holding all your connection strings
var connections = {};
exports.getDatabaseConnection = function(dbName) {
if(connections[dbName]) {
//database connection already exist. Return connection object
return connections[dbName];
} else {
connections[dbName] = mongoose.createConnection('mongodb://localhost:27017/' + dbName);
return connections[dbName];
}
}
假设您将上述文件命名为data.js
。您只需在包含 API 代码的文件中引用此模块即可。您的 API 代码将更改为:
app.get('/api/student-limited/:_pageNumber/:_pageSize', function(req, res) {
//Call getDatabaseConnection function we created
var db = data.getDatabaseConnection(req.headers['x-key-db']);
var ClassSection = db.model('ClassSections', SectionSchema);
var Student = db.model('Students', StudentSchema);
var _pageNumber = parseInt(req.params._pageNumber), _pageSize = parseInt(req.params._pageSize);
Student.find({}, function (err, _docs) {
if(_docs){
Student.find({}, null, {sort: { Name: 1} }).skip(_pageNumber > 0 ? ((_pageNumber-1)*_pageSize) : 0).limit(_pageSize).populate('_idClass').exec(function (err, docs) {
if(err)
res.json(err);
else
res.json({ "TotalCount" : _docs.length, "_Array" : docs});
});
}
});
});
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)