Node.js Express+Mongodb 项目实战
这是一个简单的商品管理系统的小项目，包含的功能还算挺全的，项目涵盖了登录、注册，图片上传以及对商品进行增、删、查、改等操作，对于新手来说是个很不错的练手项目，分享给大家。
GitHub源码：https://github.com/oceanMin/cms
项目前准备
- 安装node.js
- 安装express
- 安装mongoDB
章节目录
商品管理系统目录结构：
查询mongodb数据库登录功能
创建数据库
1.打开数据库
2.需要创建productmanage数据库
3.productmanage 数据库里面有user表
4.在user表中有数据 ,如果没有执行如下命令插入
db.user.insert({"username":"admin","password":"123456"})
如图：
连接数据库
继续在app.js文件中添加如下代码：
//安装body-parser中间件
//获取post
var bodyParser = require('body-parser');
// 设置body-parser中间件
app.use(bodyParser.urlencoded({ extended: false }));
app.use(bodyParser.json()); //数据库操作
var MongoClient=require('mongodb').MongoClient; var DbUrl='mongodb://localhost:27017/productmanage'; /*连接数据库*/ //登录
app.get('/login',function(req,res){
res.render('login');
}) //获取登录提交的数据
app.post('/doLogin',function(req,res){ //1.获取数据
//2.连接数据库查询数据
MongoClient.connect(DbUrl,function(err,db){
if(err){
console.log(err);
return;
} //查询数据 {"username":req.body.username,"password":req.body.password}
var result=db.collection('user').find(req.body); //遍历数据的方法
result.toArray(function(err,data){
console.log(data); if(data.length>0){
console.log('登录成功'); //保存用户信息
req.session.userinfo=data[0];
res.redirect('/product'); /*登录成功跳转到商品列表*/
}else{
//console.log('登录失败');
res.send("<script>alert('登录失败');location.href='/login'</script>");
}
db.close();
})
})
})
退出登录
退出登录很简单，下面一段代码搞定：
app.get('/loginOut',function(req,res){
//销毁session
req.session.destroy(function(err){
if(err){
console.log(err);
}else{
res.redirect('/login');
}
})
})
中间件权限判断
这里我们要添加一个中间件作为权限判断，首先要安装一个express-session中间件用来保存用户信息
cnpm install express-session --save-dev
在app.js文件中，我们自定义一个中间件用来判断登录状态
//保存用户信息
var session = require("express-session");
//配置中间件 固定格式
app.use(session({
secret: 'keyboard cat',
resave: false,
saveUninitialized: true,
cookie: {
maxAge:1000*60*30
},
rolling:true
})) //自定义中间件 判断登录状态
app.use(function(req,res,next){
//console.log(req.url);
//next();
if(req.url=='/login' || req.url=='/doLogin'){
next();
}else{
if(req.session.userinfo&&req.session.userinfo.username!=''){ /*判断有没有登录*/
app.locals['userinfo']=req.session.userinfo; /*配置全局变量 可以在任何模板里面使用*/
next();
}else{
res.redirect('/login')
}
}
})
密码加密存储
这里我们用到的是md5加密，用法很简单，还是一样 先安装依赖：
cnpm install md5-node --save-dev
在app.js文件中引入：
var md5=require('md5-node'); /*md5加密*/
//获取登录提交的数据
app.post('/doLogin',function(req,res){
var username=req.body.username;
var password=md5(req.body.password); /*要对用户输入的密码加密*/
//1.获取数据
//2.连接数据库查询数据
MongoClient.connect(DbUrl,function(err,db){
if(err){
console.log(err);
return;
}
//查询数据 {"username":req.body.username,"password":req.body.password}
var result=db.collection('user').find({
username:username,
password:password
});
//另一种遍历数据的方法
result.toArray(function(err,data){
if(data.length>0){
console.log('登录成功');
//保存用户信息
req.session.userinfo=data[0];
res.redirect('/product'); /*登录成功跳转到商品列表*/
}else{
//console.log('登录失败');
res.send("<script>alert('登录失败');location.href='/login'</script>");
}
db.close();
})
})
})
※ 注意：在使用md5加密登录系统时，要确保数据库中保存的密码是加密的，否则会因密码不一致而登录不上。
数据库商品列表显示
打开app.js文件，修改代码如下：
app.get('/product',function(req,res){
//连接数据库查询数据
MongoClient.connect(DbUrl,function(err,db){
if(err){
console.log(err);
console.log('数据库连接失败');
return;
}
var result=db.collection('product').find();
result.toArray(function(error,data){
if(error){
console.log(error);
return;
}
db.close();
//console.log(data);
res.render('product',{
list:data
});
})
})
})
DB数据库的封装
完善DB数据库封装。新建 modules/db.js ，添加如下代码：
var MongoClient = require('mongodb').MongoClient;
var DbUrl = 'mongodb://127.0.0.1:27017/productmanage'; //连接数据库
var ObjectID = require('mongodb').ObjectID;
function __connectDb(callback){
MongoClient.connect(DbUrl, function(err,db){
if(err){
console.log(err);
console.log('数据库连接失败');
return;
}
callback(db);
})
}
//暴露ObjectID
exports.ObjectID = ObjectID;
/**
* collectionname: 表名
* json：查询条件
* callback： 返回查询的数据
*/
// 查询数据
exports.find = function(collectionname,json,callback){
__connectDb(function(db){
var result = db.collection(collectionname).find(json);
result.toArray(function(error, data){
db.close(); /**关闭数据库连接 */
callback(error, data); /**拿到数据，执行回调函数 */
})
})
}
// 新增数据
exports.insert = function(collectionname,json,callback){
__connectDb(function(db){
db.collection(collectionname).insertOne(json,function(error,data){
callback(error,data);
})
})
}
// 修改数据
exports.update = function(collectionname,json1,json2,callback){
__connectDb(function(db){
db.collection(collectionname).updateOne(json1,{$set:json2},function(error,data){
callback(error,data);
})
})
}
// 删除数据
exports.delete = function(collectionname,json,callback){
__connectDb(function(db){
db.collection(collectionname).deleteOne(json,function(error,data){
callback(error,data);
})
})
}
然后在app.js文件中引入db.js文件
//数据库操作
var DB=require('./modules/db.js');
//获取登录提交的数据
app.post('/doLogin',function(req,res){
var username=req.body.username;
var password=md5(req.body.password); /*要对用户输入的密码加密*/ //1.获取数据
//2.连接数据库查询数据
DB.find('user',{
username:username,
password:password
},function(err,data){
if(data.length>0){
console.log('登录成功');
//保存用户信息
req.session.userinfo=data[0]; res.redirect('/product'); /*登录成功跳转到商品列表*/ }else{
//console.log('登录失败');
res.send("<script>alert('登录失败');location.href='/login'</script>");
}
})
}) //商品列表
app.get('/product',function(req,res){
DB.find('product',{},function(err,data){
res.render('product',{
list:data
});
})
})
图片上传
图片上传插件的使用
1. npm install multiparty
2. var multiparty = require('multiparty');
3.上传图片的地方
var form = new multiparty.Form();
form.uploadDir='upload' 上传图片保存的地址
form.parse(req, function(err, fields, files) {
//获取提交的数据以及图片上传成功返回的图片信息
});
4.html页面form 表单要加入 enctype="multipart/form-data"（这个很重要）
图片上传代码如下：
var multiparty = require('multiparty'); /*图片上传模块 即可以获取form表单的数据 也可以实现上传图片*/
//获取表单提交的数据 以及post过来的图片
app.post('/doProductAdd',function(req,res){
//获取表单的数据 以及post过来的图片
var form = new multiparty.Form();
form.uploadDir='upload' //上传图片保存的地址 目录必须存在
form.parse(req, function(err, fields, files) {
//获取提交的数据以及图片上传成功返回的图片信息
//console.log(fields); /*获取表单的数据*/
//console.log(files); /*图片上传成功返回的信息*/
var title=fields.title[0];
var price=fields.price[0];
var fee=fields.fee[0];
var description=fields.description[0];
var pic=files.pic[0].path;
//console.log(pic);
DB.insert('product',{
title:title,
price:price,
fee,
description,
pic
},function(err,data){
if(!err){
res.redirect('/product'); /*上传成功跳转到首页*/
}
})
});
})
修改商品
修改商品代码如下：
//执行修改的路由
app.post('/doProductEdit',function(req,res){
var form = new multiparty.Form(); form.uploadDir='upload' // 上传图片保存的地址 form.parse(req, function(err, fields, files) {
//获取提交的数据以及图片上传成功返回的图片信息
var _id=fields._id[0]; /*修改的条件*/
var title=fields.title[0];
var price=fields.price[0];
var fee=fields.fee[0];
var description=fields.description[0]; var originalFilename=files.pic[0].originalFilename;
var pic=files.pic[0].path; if(originalFilename){ /*修改了图片*/
var setData={
title,
price,
fee,
description,
pic
};
}else{ /*没有修改图片*/
var setData={
title,
price,
fee,
description
};
//删除生成的临时文件
fs.unlink(pic);
}
DB.update('product',{"_id":new DB.ObjectID(_id)},setData,function(err,data){
if(!err){
res.redirect('/product');
}
})
});
删除商品数据
app.js加入删除商品代码：
//删除商品
app.get('/productdelete',function(req,res){ //获取id
var id=req.query.id;
DB.deleteOne('product',{"_id":new DB.ObjectID(id)},function(err){
if(!err){ res.redirect('/product');
}
})
//res.send('productdelete');
})
路由模块化
基本功能完成的差不多，我们来改造下刚写的代码
首先，改造一下 app.js页面，修改如下：
var express=require('express');
//引入模块
var admin =require('./routes/admin.js');
var index =require('./routes/index.js')
var app=new express(); /*实例化*/
//admin
//admin/user
app.use('/',index);
app.use('/admin',admin);
app.listen(3000,'127.0.0.1');
……
完整代码请查看GitHub源码，如有问题请直接在 Issues 中提，或者您发现问题并有非常好的解决方案，欢迎 PR