如何用node.js和mongoose实现购物车数据库的增删操作？

本文共计1544个文字，预计阅读时间需要7分钟。

本示例介绍了使用node.js和mongoose操作数据库实现购物车的增删改查功能。以下是具体步骤：

1. 数据库操作语句： - 增加购物车：`db.Carts.insertOne(cartData)` - 删除购物车：`db.Carts.deleteOne({ _id: cartId })` - 修改购物车：`db.Carts.updateOne({ _id: cartId }, { $set: updatedCartData })` - 查询购物车：`db.Carts.find({ userId: userId })`

2. Mongoose通过model实现集合操作： - 在使用前，需引入Mongoose和数据库连接。 javascript const mongoose=require('mongoose'); const db=mongoose.connect('mongodb://localhost:27017/mydb');

3. 创建购物车model： javascript const CartSchema=new mongoose.Schema({ userId: { type: String, required: true }, products: [ { productId: { type: String, required: true }, quantity: { type: Number, required: true } } ] });

const Cart=mongoose.model('Cart', CartSchema);

4. 增加购物车： javascript const cartData={ userId: '123', products: [ { productId: '456', quantity: 2 } ] };

Cart.create(cartData, (err, cart)=> { if (err) { console.error(err); } else { console.log('Cart created:', cart); } });

5. 删除购物车： javascript const cartId='123';

Cart.deleteOne({ _id: cartId }, (err, result)=> { if (err) { console.error(err); } else { console.log('Cart deleted:', result); } });

6. 修改购物车： javascript const cartId='123'; const updatedCartData={ $set: { products: [ { productId: '456', quantity: 3 } ] } };

Cart.updateOne({ _id: cartId }, updatedCartData, (err, result)=> { if (err) { console.error(err); } else { console.log('Cart updated:', result); } });

7. 查询购物车： javascript const userId='123';

Cart.find({ userId: userId }, (err, carts)=> { if (err) { console.error(err); } else { console.log('Carts found:', carts); } });

本文实例讲述了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程序设计有所帮助。