```
### 模型
> 模型主要放在`models`文件夹
- 定义一个和数据库表对应的模型：`member.js`
```
module.exports = function(sequelize, DataTypes) {
return sequelize.define('member', {
id: {
type: DataTypes.INTEGER,
allowNull: false,
primaryKey: true
},
name: {
type: DataTypes.STRING,
allowNull: false
}
}, {
tableName: 'member',
timestamps: false,
freezeTableName: true
});
};
```
由于构建模型是非常耗时而且重复代码多，所以本框架提供了数据表模型生成工具，通过下面地址可以快速构建模型，无需手工操作
生成前需配置 `config/db.json`配置文件，通常只需配置数据库类型，数据库连接信息即可
```
http://localhost:3000/tools/generate/models
```
### 数据库CURD
数据库操作集成强大的ORM框架：Sequelize.js，支持目前所有主流数据库，[详细文档](http://docs.sequelizejs.com/en/v3/)
- 数据库配置信息，配置文件在`config/db.json`下面
```
{
// 开发环境
"development": {
"username": "sa", // 数据库用户名
"password": "000000", // 数据库密码
"database": "monk_node", // 数据库名称
"host": "MONKSOUL", // 服务器主机地址
"dialect": "mssql", // 数据库类型（'mysql'|'mariadb'|'sqlite'|'postgres'|'mssql'）
"output": "../models", // 生成实体模型(models)存放的目录
"additional": { // 其他参数
"timestamps": false,
"freezeTableName": true
}
},
// 测试环境
"test": {
"username": "sa",
"password": "000000",
"database": "monk_node",
"host": "MONKSOUL",
"dialect": "mssql",
"output": "../models",
"additional": {
"timestamps": false,
"freezeTableName": true
}
},
// 生产环境
"production": {
"username": "sa",
"password": "000000",
"database": "monk_node",
"host": "MONKSOUL",
"dialect": "mssql",
"output": "../models",
"additional": {
"timestamps": false,
"freezeTableName": true
}
}
}
```
- 引入核心ORM模块
```
var db = require("../../../core/db");
```
- CURD
```
var db = require("../../../core/db");
module.exports={
// 新增
post_create:function(req,res){
db.member.create({name:"百小僧"}).then(function(msg){
// 新增成功
console.log(msg);
});
},
// 删除操作
post_delete:function(req,res){
db.member.destroy().then(function(msg){
// 删除成功
console.log(msg);
});
},
// 根据条件删除
post_delete:function(req,res){
db.member.destroy({
where:{
id:10
}
}).then(function(msg){
// 删除成功
console.log(msg);
});
},
// 更新操作
post_delete:function(req,res){
db.member.update({name:'新生帝'},{
where:{
id:10
}
}).then(function(msg){
// 更新成功
console.log(msg);
});
},
// 根据主键查询一条
get_id:function(req,res){
db.member.findById(10).then(function(data){
// 查询成功
console.log(data);
});
},
// 根据条件查询一条
get_one:function(req,res){
db.member.findOne({
where:{
name:"百小僧"
}
}}).then(function(data){
// 查询成功
console.log(data);
});
},
// 查询所有
get_all:function(req,res){
db.member.findAll().then(function(data){
// 查询成功
console.log(data);
});
},
// 根据条件查询
get_all:function(req,res){
db.member.findAll({
where:{
id:{
$gt:2
}
}
}).then(function(data){
// 查询成功
console.log(data);
});
},
// 分页查询
get_all:function(req,res){
db.member.findAll({
offset: 10,
limit: 2,
where:{
isDel:false
}
}).then(function(data){
// 查询成功
console.log(data);
});
}
};
```
### Session，Cookies
> Session、Cookies主要用户存储客户端会话信息，通常用于登录判断
- Session 使用
```
module.exports={
get_index:function(req,res){
// 检查 session 中的 isVisit 字段
// 如果存在则增加一次，否则为 session 设置 isVisit 字段，并初始化为 1。
if(req.session.isVisit) {
req.session.isVisit++;
res.send('第 ' + req.session.isVisit + '次来此页面
'); } else { req.session.isVisit = 1; res.send("欢迎第一次来这里"); console.log(req.session); } } } ``` - Cookies 使用 ``` module.exports={ get_index:function(req,res){ // 如果请求中的 cookie 存在 isVisit, 则输出 cookie // 否则，设置 cookie 字段 isVisit, 并设置过期时间为1分钟 if (req.cookies.isVisit) { console.log(req.cookies); res.send("再次欢迎访问"); } else { res.cookie('isVisit', 1, {maxAge: 60 * 1000}); res.send("欢迎第一次访问"); } } } ``` ### 过滤器、中间件 > 过滤器，中间件主要对请求进行过滤的 - 在控制器中直接使用 ``` module.exports={ get_admin:[function(req,res,next){ if(未登录){ res.redirect("登录页面"); } else{ next(); } },function(req,res){ res.send("ok"); }] }; ``` - 全局过滤器，将过滤器定义到`filters`文件夹下，如创建一个`loginFilter.js` ``` module.exports = function (req, res, next) { if(未登录){ res.redirect("登录页面"); } else{ next(); } }; ``` 在控制器中使用 ``` var loginFilter = require("../../../filters/loginFilter"); module.exports={ get_admin:[loginFilter,function(req,res){ res.send("ok"); }] } ``` - 多个过滤器 ``` module.exports={ get_admin:[function(req,res,next){ console.log("日志记录"); next(); },function(req,res,next){ if(未登录){ res.redirect("登录页面"); } else{ next(); } },function(req,res){ res.send("ok"); }] }; ``` ### 文件上传 > 文件上传集成强大的`multer`组件，[详细文档](https://www.npmjs.com/package/multer) - 使用教程 ``` var multer = require('multer'); var upload = multer({ dest: 'uploads/' }) module.exports={ // 单文件上传 post_upload:[upload.single('file'), function (req, res, next) { // 上传成功。。。。 }], // 多文件上传 post_uploads:[upload.array('file',10), function (req, res, next) { // 上传成功。。。。 }] }; ``` ### Redis存储 > 集成了 `redis` 模块，[文档地址](https://www.npmjs.com/package/redis) - 基础使用 ``` var redis = require("redis"), client = redis.createClient(); // if you'd like to select database 3, instead of 0 (default), call // client.select(3, function() { /* ... */ }); client.on("error", function (err) { console.log("Error " + err); }); client.set("string key", "string val", redis.print); client.hset("hash key", "hashtest 1", "some value", redis.print); client.hset(["hash key", "hashtest 2", "some other value"], redis.print); client.hkeys("hash key", function (err, replies) { console.log(replies.length + " replies:"); replies.forEach(function (reply, i) { console.log(" " + i + ": " + reply); }); client.quit(); }); ``` ### WebSocket > 框架已经集成了socket.io ，可以开发实时通信，聊天等应用，[详细文档](http://socket.io/) - 服务端代码，`utils/socket.js` ``` var io = require('socket.io')(); // socket.io 基础使用，监听连接请求 io.on('connection', function (socket) { console.log("客户端连接成功~~"); // 监听来自客户端事件 socket.on('send', function (data) { // 调用客户端receive事件，并传递data io.emit('receive', data); }); // 这里就写各种监听事件就可以了， // 通过 socket.on("") 监听客户端事件，通过 io.emit("") 触发所有客户端事件，socket.emit("") 触发指定客户端 }); exports.listen = function (server) { return io.listen(server); }; ``` - 客户端代码 ``` ``` ## 友情捐赠 如果你觉得 Monk.Node 对你有价值，并且愿意让她继续成长下去，你可以资助这个项目的开发，为作者加油打气。  如果你喜欢Monk.Node，可以点击右上角的 `star`，想实时关注进度，可以点击右上角的 `watch`。 最后，感谢每一个提建议和使用或者捐赠的朋友！因为你们，我们才能坚持！也是因为你们，未来才会更美好！