在Express中对MongoDB数据库进行增删改查

逃离我推掉我的手 2022-11-17 05:17 317阅读 0赞

这两天跟着B站的Johnny老师学习NodeJs+Express+MongoDB相关的知识点，前后跟着做了1小时搞定NodeJs(Express)的用户注册、登录和授权、Element UI + NodeJs(Express)全栈开发后台管理界面、Express-9-MongoDB删除产品和DELETE请求等系列视频。本篇博客主要是学习在Express中如何对MongoDB数据库进行增删改查。

编码前的准备工作  
首先要安装好NodeJs运行环境，配置好node和npm的环境变量，最好安装淘宝 NPM 镜像cnpm，安装配置好npm后，打开终端运行npm install -g cnpm --registry=https://registry.npm.taobao.org命令全局安装cnpm；然后在系统中安装好MongoDB，关于如何在Windows系统下安装MongoDB可以参考Windows 平台安装 MongoDB-菜鸟教程。我使用的系统是Windows10系统，采用的开发工具是Visual Studio Code，另外还需要在VSCode中安装REST Client插件，用于发送HTTP请求和查看服务端的响应信息，类似于PostMan，不过Rest-Client插件可以直接在VSCode中发送HTTP的GET、POST、PUT、DELETE请求，对于开发人员来说很方便，具体可以参考Johnny老师的B站视频VSCode中类似PostMan的API接口请求利器 - rest client，这篇视频快速的讲解了VSCode中Rest-Client的使用，具体的还可以看VSCode中Rest-Client的使用教程。  
建立好上述开发环境后，打开VSCode，在一个目录中新建一个EXPRESS-TEST的文件夹，用于存放项目文件，新建一个server.js文件用于存放代码，test.http存放rest-client编写的接口用于测试客户端的http请求。  
然后在VSCode中打开终端，使用cnpm命令安装express和MongoDB的数据库模块mongoose和cors(支持跨域)，命令如下：

cnpm install express  
cnpm install mongoose  
cnpm install cors  
  
使用Express启动http服务  
Express 是一个保持最小规模的灵活的 Node.js Web 应用程序开发框架，为 Web 和移动应用程序提供一组强大的功能，简单易用，下面的代码演示了如何使用Express在指定的4001端口上监听，开启一个http服务，当然端口可以随意指定，只要和系统中其他不冲突即可，感觉使用起来比Java SpringBoot简单不少。

const express = require('express')

const app = express()

// 在4001端口上监听  
app.listen(4001, () => \{  
  console.log('App is listening on port 4001!')  
\})  
  
在NodeJs中对MongoDB数据库进行增删改查  
连接MongoDB数据库  
新建一个MongoDB数据库模型，命名为express-test

const mongoose = require('mongoose')

mongoose.connect('mongodb://localhost:27017/express-test',  
  \{ useNewUrlParser: true,   
    useUnifiedTopology: true,  
    useCreateIndex: true,  
  \})  
// 创建产品Schema  
const Productschema = new mongoose.Schema(\{  
    title: \{ type: String, unique: true\}  
\})

// 定义MongoDB数据模型 (表=》集合)  
const Product = mongoose.model('Product',Productschema)  
  
新增产品  
// 新增产品  
app.post('/products', async function(req, res)\{  
  // 获取客户端请求的json数据  
  const data = req.body;  
  // 插入数据到产品表集合中  
  const product = await Product.create(data)  
  res.send(product)  
\})  
  
查询所有产品记录  
// 查询所有产品记录  
app.get('/products', async function(req, res)\{  
  // const data = await Product.find().skip(1).limit(2)  
  // const data = await Product.find().where(\{  
  //   title: '华为'  
  // \})  
  const data = await Product.find().sort(\{ \_id: -1 \})  
  res.send(data)  
\})  
  
根据title产品名称查询指定的产品信息  
// 根据title名称查询指定的产品信息  
app.get('/products/:titleName', async function(req,res)\{  
  const titleName = req.params.titleName;  
  Product.find(\{ "title": titleName \}, function(err, doc)\{  
    if(err) \{  
      console.log(err)  
    \} else \{  
      res.json(doc)  
      // res.send(res.json(doc))  
    \}  
  \})  
\})  
  
使用PUT请求修改产品信息  
// 修改产品和PUT请求  
// patch表示部分修改，put表示覆盖  
//app.patch();  
app.put('/products/:id', async function(req,res)\{  
  const product = await Product.findById(req.params.id);  
  // 将客户端传过来的title赋值给产品(赋值不需要异步，因为它只是javascript中的一个内存操作，而查询、保存数据都需要和MongoDB连接需要异步)  
  product.title = req.body.title;  
  // 保存产品  
  await product.save();  
  res.send(product);  
\})  
  
根据客户端传递的id号删除某个产品  
app.delete('/products/:id', async function(req, res)\{  
  // 根据客户端传递过来的id从MongoDB数据库中查询对应的产品  
  const product = await Product.findById(req.params.id);  
  // 删除查询到的产品  
  await product.remove();  
  // 向客户端发送删除成功的信息  
  res.send(\{  
    success: true,  
  \})  
\})  
  
使用Rest-Client编写http请求  
VScode中的Rest-Client有一个规定，就是http请求文件必须以http为后缀，比如说tets.http文件。  
本EXPREES-TEST项目中对应的test.http测试文件如下：

@url=http://localhost:4001  
@json=Content-Type: application/json

\#\#\# products page  
GET \{ \{url\}\}/products

\#\#\# post 新增产品  
POST \{ \{url\}\}/products  
Content-Type: application/json

\{  
  "title": "我的手机"  
\}

\#\#\# put 修改产品  
PUT \{ \{url\}\}/products/5e48c999e12a60686cbad30b  
Content-Type: application/json

\{  
  "title": "Apple"  
\}

\#\#\# 删除某个产品  
DELETE \{ \{url\}\}/products/5e4aaa812d6048635c877fd1

\#\#\# 静态文件托管  
get \{ \{url\}\}/index.html

完整的示例代码  
/\* jshint esversion: 8 \*/   
// expess模块  
const express = require('express')

const app = express()

app.use(express.json())

// MongoDB模块  
const mongoose = require('mongoose')

mongoose.connect('mongodb://localhost:27017/express-test',  
  \{ useNewUrlParser: true,   
    useUnifiedTopology: true,  
    useCreateIndex: true,  
  \})

// 创建产品Schema  
const Productschema = new mongoose.Schema(\{  
    title: \{ type: String, unique: true\}  
\})

// 定义MongoDB数据模型 (表=》集合)  
const Product = mongoose.model('Product',Productschema)

// 往MongoDB数据库中插入数据  
// Product.insertMany(\[  
//   \{title: 'Apple'\},  
//   \{title: '华为'\},  
//   \{title: '三星'\},  
//   \{title: '小米'\},  
//   \{title: 'Oppo'\},  
//   \{title: 'Vivo'\},  
// \])

// 删除所有数据  
// Product.deleteMany(\{\}, function(err, doc) \{  
//   if(err) \{  
//     console.log(err)  
//   \} else \{  
//     console.log(doc)  
//   \}  
// \});

// 允许跨域  
app.use(require('cors')())

// 路由：express 静态文件托管  
// app.use('/static', express.static('public'))  
app.use('/', express.static('public'))

// 新增产品  
app.post('/products', async function(req, res)\{  
  // 获取客户端请求的json数据  
  const data = req.body;  
  // 插入数据到产品表集合中  
  const product = await Product.create(data)  
  res.send(product)  
\})

// 查询所有产品记录  
app.get('/products', async function(req, res)\{  
  // const data = await Product.find().skip(1).limit(2)  
  // const data = await Product.find().where(\{  
  //   title: '华为'  
  // \})  
  const data = await Product.find().sort(\{ \_id: -1 \})  
  res.send(data)  
\})

// 查询单个产品记录 产品详情页的接口    
// app.get('/products/:id', async (req,res) => \{  
//   const data = await Product.findById(req.params.id)  
//   res.send(data)  
// \})

// 根据title名称查询指定的产品信息  
app.get('/products/:titleName', async function(req,res)\{  
  const titleName = req.params.titleName;  
  Product.find(\{ "title": titleName \}, function(err, doc)\{  
    if(err) \{  
      console.log(err)  
    \} else \{  
      res.json(doc)  
      // res.send(res.json(doc))  
    \}  
  \})  
\})

// 修改产品和PUT请求  
// patch表示部分修改，put表示覆盖  
//app.patch();  
app.put('/products/:id', async function(req,res)\{  
  const product = await Product.findById(req.params.id);  
  // 将客户端传过来的title赋值给产品(赋值不需要异步，因为它只是javascript中的一个内存操作，而查询、保存数据都需要和MongoDB连接需要异步)  
  product.title = req.body.title;  
  // 保存产品  
  await product.save();  
  res.send(product);  
\})

// 修改产品信息  
app.get('/products/update/:titleName', async function(req,res)\{  
  const titleName = req.params.titleName;  
  Product.update(\{ title : titleName \}, \{"$set":\{title: "My Oppo A5"\}\}, function(err, doc)\{  
    if(err) \{  
      console.log(err)  
    \} else \{  
      res.json(doc)  
      // res.send(res.json(doc))  
    \}  
  \})  
\})

// 根据客户端传递的id号删除某个产品  
app.delete('/products/:id', async function(req, res)\{  
  // 根据客户端传递过来的id从MongoDB数据库中查询对应的产品  
  const product = await Product.findById(req.params.id);  
  // 删除查询到的产品  
  await product.remove();  
  // 向客户端发送删除成功的信息  
  res.send(\{  
    success: true,  
  \})  
\})

// 在4001端口上监听  
app.listen(4001, () => \{  
  console.log('App is listening on port 4001!')  
\})  
  
我在实际使用VSCode的过程中，当使用async集合await调用MongoDB实现异步调用时保存，需要在源代码文件server.js的顶部添加如下一行：

/\* jshint esversion: 8 \*/   
1  
这样就可以正常使用async集合await调用异步接口了。

参考资料  
Windows 平台安装 MongoDB  
MongoDB 教程-菜鸟教程  
Express  
【全栈之巅】Express-1-认识Express  
【全栈之巅】Express-2-快速上手路由  
【全栈之巅】Express-3-静态文件托管  
【全栈之巅】Express-4-CORS跨域请求  
【全栈之巅】Express-5-MongoDB基础  
【全栈之巅】Express-6-MongoDB查询  
【全栈之巅】Express-7-MongoDB新增产品和POST请求  
【全栈之巅】Express-8-MongoDB修改产品和PUT请求  
【全栈之巅】Express-9-MongoDB删除产品和DELETE请求  
【全栈之巅】VSCode中类似PostMan的API接口请求利器 - rest client