Node使用Mongoose操作MongoDB数据库——增删改查的实现

  当初刚出社会时就规划了下自己的职业生涯:先成为一名优秀的前端工程师,再成为一名全栈工程师(精通前端开发、后台开发和客户端开发),最后成为一名优秀的系统架构师。转眼间已经工作*年,是时候迈出关键性的一步了,开始涉足后端领域。于是最近在研究Node和Express,并研究了如何使用Express这个基于Node的Web开发框架开发RESTful API,以及Node如何连接MongoDB数据库,先总结如下:

(一)安装Node和MongoDB

  1)到Node官网https://nodejs.org/下载最新版Node,或者直接点击这里下载。下载下来是一个后缀为msi的文件,直接双击运行即可。安装完在控制台输入:node -v,如果输出版本号则说明安装成功。

  2)到MongoDB官网https://www.mongodb.com/下载最新版MongoDB,或者直接点击这里下载。下载下来也是一个msi文件,直接双击运行即可。

(二)配置和开启MongoDB数据库

  1)在D盘新建一个mongodb文件夹,并新建两个子文件夹mongodb/bin和mongodb/db。

  2)在C盘找到MongoDB的安装目录,将C:\Program Files\MongoDB\Server\3.2\bin路径下的所有文件拷贝到D:/mongodb/bin下。

  3)打开控制台,切换到D:/mongodb/bin目录,输入:

D:\mongodb\bin>D:/mongodb/bin/mongod --dbpath=D:/mongodb/db

  

  4)另外再打开一个控制台窗口,切换到D:/mongodb/bin目录,输入:

D:\mongodb\bin>D:/mongodb/bin/mongo

  运行MongoDB。

  这时会进入MongoDB的交互模式,输入:

> use test
switched to db test

  新建了一个test数据库。

(三)一个CRUD的栗子

  为了简单起见,我就没有写那些表单、输入框什么的,数据直接在代码里改。

  1.目录结构

  Node使用Mongoose操作MongoDB数据库——增删改查的实现

  2.入口文件app.js

  1)我们需要安装一些外部模块:express、express3-handlebars、mongoose、body-parser、supervisor(非必需)

Administrator@kagolzeng-PC1 MINGW64 /d/Code/FullStack/mongoose
$ npm install --save express express3-handlebars mongoose body-parser
Administrator@kagolzeng-PC1 MINGW64 /d/Code/FullStack/mongoose
$ npm install -g supervisor

  

  2)引入express、body-parser和movie.js

 var express = require('express');
var bodyParser = require('body-parser');
//数据操作对象
var Movie = require('./public/server/js/movie');

  其中movie.js是为了方便数据操作,避免重复代码,抽出来的一个模块。

  3)定义express对象app和设置静态文件路径等

 var app = express();
app.use(express.static(__dirname + '/public'));//设置静态文件路径
app.use(bodyParser());//用来解析req.body参数的

  

  4)设置模板引擎

 //设置模板引擎,这里用的是handlebars模板
var handlebars = require('express3-handlebars').create({
defaultLayout: 'main'//默认布局(母版页),默认从views/layouts/main.handlebars中找文件
});
app.engine('handlebars', handlebars.engine);
app.set('view engine', 'handlebars');

  

  5)定义路由

 //定义路由
app.get('/', function(req, res){
Movie.find(function(err, docs){
res.render('home', {//渲染视图,默认从views/home.handlebars中找文件
movies: docs
});//向home页面传入了movies变量
});
});
app.get('/about', function(req, res){
res.render('about');
});

  

  6)定义API接口

 //定义API接口
//新增接口
app.post('/add', function(req, res){
var movie = new Movie({//定义一个模块实例
title: req.body.title,
doctor: req.body.doctor,
year: req.body.year,
country: req.body.country,
language: req.body.language,
summary: req.body.summary
});
movie.save(function(err){
if(err){
console.log('保存失败');
}
console.log('保存成功');
res.json({ ret: 0, msg: 'succeed' });
});
});
//更新接口
app.post('/update', function(req, res){
var id = req.body.id;
if(id){
Movie.update({
_id: id
}, {
$set: {
title: req.body.title,
doctor: req.body.doctor,
year: req.body.year,
country: req.body.country,
language: req.body.language,
summary: req.body.summary
}
}, function(err){
if(err){
console.log(err);
return;
}
console.log('更新成功');
res.json({ ret: 0, msg: 'succeed' });
});
}
});
//删除接口
app.post('/delete', function(req, res){
var id = req.body.id;
if(id){
Movie.remove({
_id: id
},function(err){
if(err){
console.log(err);
return;
}
console.log('删除成功');
res.json({ ret: 0, msg: 'succeed' });
});
}
});
//根据ID获取单条数据的接口
app.post('/getMovieById', function(req, res){
Movie.findById(req.body.id, function(err, doc){
res.json(doc);
});
});

  

  7)错误页

 //以下两个中间价是用来展示错误页的
app.use(function(req, res, next){
res.status(404);
res.render('404');
});
app.use(function(err, req, res, next){
res.status(505);
res.render('505');
});

  

  8)监听端口

 //监听3000端口
app.listen(3000);
console.log('在浏览器中输入localhost:3000访问系统首页');

  

  3.movie.js数据操作模块

 var mongoose = require('mongoose');
mongoose.connect('mongodb://localhost/test');//连接到test数据库
var Schema = mongoose.Schema;
var movieSchema = new Schema({//定义框架
title: String,
doctor: String,
year: Number,
country: String,
language: String,
summary: String
});
var Movie = mongoose.model('Movie', movieSchema);//定义模块
module.exports = Movie;//导出模块,使外部可以调用

  这里要注意的是定义模块的第一个参数并不是数据库的名称,这里对应的数据库名称是:movies。

  4.布局(母版页)main.handlebars

 <!DOCTYPE html>
<html>
<head>
<meta charset="utf-8">
<title>Home</title>
<script src="http://code.jquery.com/jquery.min.js"></script>
<link rel="stylesheet" href="http://cdn.bootcss.com/bootstrap/3.3.5/css/bootstrap.min.css">
</head>
<body>
{{{body}}}
<script src="/client/js/index.js"></script>
</body>
</html>

  

  5.各个视图文件

  1)home.handlebars

 <h1>Welcome to Meadowlark Travel</h1>
<div><a href="javascript:;" id="btn_add" class="btn btn-primary">Add</a></div>
<div><a href="javascript:;" id="btn_update" class="btn btn-primary">Update</a></div>
<div><a href="javascript:;" id="btn_delete" class="btn btn-primary">Delete</a></div>
<table class="table">
<tr>
<th>ID</th>
<th>Title</th>
<th>Doctor</th>
<th>Year</th>
<th>Country</th>
<th>Language</th>
<th>Summary</th>
</tr>
{{#each movies}}
<tr>
<td>{{_id}}</td>
<td>{{title}}</td>
<td>{{doctor}}</td>
<td>{{year}}</td>
<td>{{country}}</td>
<td>{{language}}</td>
<td>{{summary}}</td>
</tr>
{{/each}}
</table>

  2)about.handlebars

<h1>About Meadowlark Travel</h1>

  3)404.handlebars

<h1>404 - Not Found</h1>

  4)505.handlebars

<h1>505 - Internal Error</h1>

  

  6.jQuery风格的Ajax请求文件index.js

 $('#btn_add').on('click', function(){
$.ajax({
url: '/add',
type: 'post',
data: {
title: 'Sudu7',
doctor: 'Jack',
year: '2015',
country: 'America',
language: 'English',
summary: 'Great'
},
success: function(data){
console.log(JSON.stringify(data));
}
});
});
$('#btn_update').on('click', function(){
$.ajax({
url: '/update',
type: 'post',
data: {
id: '5731af54a2b840a83f2f26d3 ',
title: '极盗者',
doctor: '罗杰斯',
year: '2015',
country: 'America',
language: 'English',
summary: '极限运动'
},
success: function(data){
console.log(JSON.stringify(data));
}
});
});
$('#btn_delete').on('click', function(){
$.ajax({
url: '/delete',
type: 'post',
data: {
id: '5731ad259ad2c8882ecb87c2'
},
success: function(data){
console.log(JSON.stringify(data));
}
});
});
$.ajax({
url: '/getMovieById',
type: 'post',
data: {
id: '57328a0101c4095818fb1724'
},
success: function(data){
console.log(JSON.stringify(data));
}
});

(四)总结

  至此,就实现了从数据库到后台,再到前端的整个编码过程。

上一篇:第二次作业#include int main() { int a,b,c,d,e; printf("请输入一个不多于五位的整数:\n"); scanf("%d",&a); if(a>=100000||a<=0) { printf("输入格式错误! \n"); } else { if(


下一篇:练习2 B题 - 求绝对值