node.js使用mongoose操作数据库实现购物车的增、删、改、查功能示例

本文实例讲述了node.js使用mongoose操作数据库实现购物车的增、删、改、查功能。分享给大家供大家参考，具体如下：

1、数据库操作语句

mongoose通过model实现对每个集合的操作，在使用前需要先定义model:goods。

①、增加数据：从集合中查询一条记录，并返回doc，对doc操作之后通过save()保存到集合

goods.findone({productid},(err,goodsdoc)=>{
   goodsdoc.productnum=1;
   goodsdoc.save(err,doc);
});

②、删除数据：

model.remove(conditions,callback(){})

③、修改数据：

model.update(conditions,updates,callback(){})

④、查询数据：

model.find(conditions,callback(){})

2、添加购物车

在mongodb中新建用户user集合，user中有cartlist数组，用户点击添加购物车时在前端发出post请求包括用户、商品的id。然后在后端查询到对应的用户，将其cartlist中的商品id进行比对，如果在其中，则把商品数量+1，否则从商品集合中查询商品信息，插入到cartlist数组中。

前端添加购物车请求：

  addcart(productid){//加入购物车
   axios.post('./users/addcart',{
    userid:"100000077",
    productid:productid
   }).then((response)=>{
    let res=response.data;
    console.log(res.msg);
   });
  }

后端处理：

var express = require('express');
var router = express.router();
const mongoose=require('mongoose');
var user=require('../models/usermodel');
var goods=require('../models/productmodel');
//连接数据库
mongoose.connect('mongodb://localhost:27017/mall');
mongoose.connection.on('connected',()=>{
 console.log("mongodb连接成功");
});
//处理添加购物车请求
router.post('/addcart',(req,res,next)=>{
 let userid=req.body.userid;
 let productid=req.body.productid;
 let params={
  userid
 };
 user.findone(params,(err,userdoc)=>{//查询对应用户信息
  if (err){
   res.json({
    status:1,
    msg:err.message
   });
  }else{
   if(userdoc){
    let incart=false;
    userdoc.cartlist.foreach(function(item){//遍历cartlist比对商品id
     if (item.productid==productid){    //若商品在购物车内，数量增加
      incart=true;
      item.productnum++;
      savedoc(userdoc,res);
     }
    });
    //所选商品不在购物车内，则从商品列表内查找并添加到购物车
    if(!incart){
     goods.findone({productid},(err,goodsdoc)=>{
      if(err){
       res.json({
        status:1,
        msg:err.message
       })
      }else{
       goodsdoc.checked=true;
       goodsdoc.productnum=1;
       userdoc.cartlist.push(goodsdoc);//将商品插入到用户cartlist数组内
       console.log(userdoc.cartlist);
       savedoc(userdoc,res);
      }
     });
    }
   }
  }
 })
});

利用doc.save将修改后的文档保存到数据库

function savedoc(doc,res) {
 //保存操作
 doc.save((err,doc)=>{
  if (err){
   res.json({
    status:1,
    msg:err.message
   })
  }else {
   res.json({
    status:0,
    msg:"添加购物车成功",
    result:'success'
   })
  }
 })
}

3、从购物车删除数据

前端点击删除按钮，调用deletecart()发出post请求，删除成功重新加载购物车列表

   deletecart(){
    axios.post('users/deletecart',{
     productid:this.productid
    }).then((response,err)=>{
     let res=response.data;
     if(res.status===0){
      this.getcart();
      this.modalshow=false;
     }
    })
   },

后端获取到删除商品的id、用户的id，删除数据库中指定条目

router.post('/deletecart',(req,res)=>{
 "use strict";
 let productid=req.body.productid;
 let userid=req.cookies.userid;
 user.update({userid:userid},{
  $pull:{
   cartlist:{productid:productid}
  }
 },(err,doc)=>{
  if(err){
   res.json({
    status:1,
    msg:'数据库删除失败'
   })
  }else{
   if(doc){
    res.json({
     status:0,
     msg:'购物车删除成功'
    })
   }
  }
 })
});

4、修改购物车

前端对不同的按钮点击，实现购物车数量的增、减、选中的改变，调用editcart(opt,item)，然后将修改的数据以post发送

editcart(flag,item){
    if(flag==='check'){
     item.checked=!item.checked;
    }else if(flag==='add'){
     item.productnum++;
    }else if(flag==='sub'){
     item.productnum<=0 ? item.productnum=0 : item.productnum++ ;
    }
    axios.post('users/editcart',{
     productid:item.productid,
     checked:item.checked,
     productnum:item.productnum
    }).then((response,err)=>{
     let res=response.data;
     if(res.status===0){
      this.getcart();
     }else{
      console.log(res.msg);
     }
    })
}

后端接收要修改的数据，并对数据库进行更新：

router.post('/editcart',(req,res)=>{
 "use strict";
 let productid=req.body.productid;
 let checked=req.body.checked;
 let productnum=req.body.productnum;
 let userid=req.cookies.userid;
 user.update({userid:userid,'cartlist.productid':productid},{
  $set:{"cartlist.$.checked":checked,"cartlist.$.productnum":productnum}
 },(err,doc)=>{
  if(err){
   res.json({
    status:1,
    msg:err.message
   })
  }else {
   res.json({
    status:0,
    msg:'购物车更新成功'
   })
  }
 })
});

5、查询购物车

前端发送查询购物车get请求，将结果数据赋予catlist，页面遍历cartlist渲染数据

   getcart(){
    axios.get('users/getcart').then((response,err)=>{
     let res=response.data;
     if(res.status===0){
      this.cartlist=res.result.list;
     }else{
      console.log(res.msg);
     }
    })
   },

后端根据用户的cookie，查询指定的用户的购物车

router.get('/getcart',(req,res)=>{
 "use strict";
 user.findone({userid:req.cookies.userid},(err,doc)=>{
  if(doc){
   res.json({
    status:0,
    msg:'',
    result:{
     list:doc.cartlist
    }
   })
  }else{
   res.json({
    status:1,
    msg:"购物车列表查询失败"
   })
  }
 })
});

6、购物车的总价与全选

利用vue的计算属性可以实现属性的随时变化，计算属性只有在相关数据发送改变时才会随之改变，计算属性的实现像函数，但使用类似于一般属性，例如总价totalprice与判断是否全部选中allselected：

  computed:{
   totalprice(){
    let total=0;
    this.cartlist.foreach((item)=>{
     if(item.checked)
      total+=parsefloat(item.saleprice)*parseint(item.productnum);
    });
    return total;
   },
   allselected(){
    let selected=true;
    this.cartlist.foreach((item)=>{
     selected=selected&&item.checked;
    });
    console.log(selected);
    return selected;
   }
  },

计算属性totalprice由每个商品单价*数量而来，当其中有一个改变时，总价会立即改变，显示在页面中。

allselected由每个商品是否选中作‘与'运算而来，当有其中一个的选中状态发送改变，allselected也会改变，并改变购物车的全选标志。

希望本文所述对大家node.js程序设计有所帮助。