在BAE中使用mongoose操作mongodb
获取中...
几乎网上所有的使用mongoose的例子都是长连接的方式，因为nodejs本身机制的关系，使用长连接一定程度上会提高性能，但是bae的免费mongodb不支持长链接，之前也有很多人做了尝试，比如断开后捕捉错误，然后自动重连的方式,现在来看都不太成功，于是还是中规中矩的使用短链接的方式来做吧，这里实现了一个连接打开和关闭的托管。
mongoosekeeper.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
| 'use strict';
var mongoose = require('mongoose');
var util = require("util");
function MongooseKeeper() {
this.db = mongoose.createConnection();
this.open_count = 0;
}
MongooseKeeper.prototype.config = function(conf) {
var options = {
db: { native_parser: true },
server: {
poolSize:4
}
};
var constr = "";
if(process.env.MONGO_DB_STR){
constr = process.env.MONGO_DB_STR ;
}
else{
constr = util.format('mongodb://%s:%s@%s:%d/%s', conf.userid,conf.password,conf.host,conf.port,conf.database);
}
this.dbUri = constr;
this.options = options;
}
MongooseKeeper.prototype.open =function() {
this.open_count++;
if(this.open_count ==1 && this.db.readyState == 0)
{
this.db.open(this.dbUri,this.options,function() {
console.log("db opened");
});
}
}
MongooseKeeper.prototype.close =function() {
this.open_count--;
if(this.open_count == 0 )
{
this.db.close(function(){
console.log("db closed");
});
}
}
MongooseKeeper.prototype.use = function(action,callback) {
var self = this;
self.open();
action.call(null,function() {
console.log("正在访问的数据库请求量"+self.open_count);
self.close();
callback.apply(null, arguments);
self =null;
})
};
exports = module.exports = new MongooseKeeper();
|
首先在应用启动的时候，比如在app.js中，配置数据连接的等信息
1
2
| // 引用mongoosekeeper
var mongoosekeeper = require('./lib/mongoosekeeper');
|
1
2
3
4
5
6
7
8
| // 调用更新配置，这里的配置可以去读某个json
mongoosekeeper.config({
"host": "192.168.57.186",
"database": "dbname",
"userid":"userid",
"password":"123456",
"port":27017
});
|
定义Model
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
| 'use strict';
var mongoose = require('mongoose');
var Schema = mongoose.Schema;
var mongokeeper = require('../lib/mongoosekeeper');
var articleModel = function () {
var articleSchema = new Schema({
content : String, // 发布内容
type : Number, //
pictures : [{url:String,width:Number,height:Number}], // 配图
thumbnails : [{url:String,width:Number,height:Number}], // 缩略图
tags : [String], // 标签
author : String, // 发布人账号
author_name : String, // 发布人名称
create_date : { type: Date, default: Date.now }, //创建时间
meta : {
votes : Number, //顶
favs : Number //收藏
}
});
//因为使用了createConnection 这里要使用mongokeeper.db.model
//而不是mongoose.model
return mongokeeper.db.model('article', articleSchema);
};
module.exports = new articleModel();
|
在调用model的时候，使用 mongoosekeeper.use 方法包装实际的调用即可
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
| var express = require('express'),
router = express.Router(),
mongoosekeeper = require('../lib/mongoosekeeper'),
articleModel = require('../models/articleModel');
/* GET home page. */
router.get('/', function(req, res) {
mongoosekeeper.use(queryArticle,function(err,list){
if(err){
throw err;
}
else{
res.render('index',{data:list});
}
});
});
//proxy 参数即为mongoosekeeper.use的第二个参数
function queryArticle(proxy){
var search = {} ; //获取所有文章
var query = articleModel.find(search).limit(25);
query.sort('-create_date');
query.exec(proxy);
}
module.exports = router;
|
完整代码
本文由 Xuanye 创作，采用 知识共享署名 4.0 国际许可协议。
本站文章除注明转载/出处外，均为本站原创或翻译，转载请务必署名。
