【后端开发实习】用MongoDB实现仓库管理的出库入库实战

🕗 发布于 2024-07-11 07:20 mongodb 数据库

用MongoDB实现仓库管理的出库入库

MongoDB
项目部署
- 在数据库中创建一张商品信息表
- 提供信息表的增删改查操作接口

MongoDB

什么是MongoDB

Mongodb是一种比较常见的NoSQL类型数据库，所谓NoSQL就是Not only SQL，非关系型数据库，数据在MongoDB中的存储相比MySQL而言比较松散，并没有特定的数据结构，存储方式类似JSON，采用了一种二进制的BSON来进行数据存储。但是MongoDB由于以下的几个优势在互联网需要处理海量数据场景下有独特的优势，比较经典的应用场景有微信和Twitter每天数以TB甚至PB级别的数据量。

高性能
高可用
高扩展
丰富的查询支持

MongoDB安装以及开始运行

在这里插入图片描述
安装成功运行会看到上面这张结果图。

配置启动以及mongosh

在命令行中输入如下命令：

 sudo vim /etc/systemd/system/mongodb.service

在打开的mongodb.service文件中填入以下内容：

[Unit]
Description=High-performance, schema-free document-oriented database
After=network.target

[Service]
User=mongodb
ExecStart=/usr/bin/mongod --quiet --config /etc/mongod.conf

[Install]
WantedBy=multi-user.target

在这里插入图片描述
配置成功以后输入mongo就可以与数据库连接上并进行相关操作。

mongodb的基础使用命令

启动和使用MongoDB服务

# 重新加载配置，并启动mongodb
sudo systemctl daemon-reload
sudo systemctl start mongod

# 查看运行状态
sudo systemctl status mongod
# 如果mongodb状态为stop，则运行 sudo systemctl enable mongod

# 停止mongodb
sudo systemctl stop mongod

# 重启mongodb
sudo systemctl restart mongod

数据库操作

# 创建和切换数据库，命名规范：全部小写
use dbname
# 删除数据库,主要是用来删除已经从内存持久化到磁盘中的数据库
db.dropDatabse()
# 显示已经创建的数据库
show dbs

集合操作

# 创建集合
db.createCollection("collectionname")
# 删除集合
db.collectionname.drop()
# 显示已经创建的数据库
show dbs

！注：这里还有一个是集合的隐式创建，通过在文档操作的时候insert操作如果没有匹配到现有数据库，就创建一个。

文档操作

# 创建文档
db.collectionname.insert({BSON格式数据})
# 文档数据查询
db.collectionname.find()
# 文档数据更新，直接使用是覆盖更新
db.collectionname.update(query, update, options)
# 局部更新，使用$set修改器
db.collectionname.update({userId:"1001"},{$set:{username="张三"}})
# 批量更新，在option选项中增加multi:true
db.collectionname.update({userId:"1001"},{$set:{username="张三"}})
# 文档删除,如果没有带条件就是“删库跑路”
db.collectionname.remove(query)

! 注：mongodb中默认的是浮点类型的数据，因此想使用整型变量的时候需要用NumberInt函数进行转换。

项目部署

在数据库中创建一张商品信息表

在这里插入图片描述
由于已经有MongoCampass这个图形化的工具，在创建的时候可以使用这个提高效率而不用一行一行输入数据。

创建好集合以后就可以向集合中插入文档数据，编辑好一行以后按加号继续编辑下一行。

提供信息表的增删改查操作接口

这个部分的内容有一位大佬总结的很好了，这里贴出他的博客，非常建议学习，他总结的关于Schema和Collection还有Document之间的关系使我茅塞顿开。

//引入mongodb数据库 => MongoClient mongo =>客户端
const {MongoClient} = require("mongodb");
  
// mongo连接网址
const url = 'mongodb://127.0.0.1:27017';
  
//mongo连接 数据库名称
const dbName = 'Shop';
  
async function connect() {
// 注意点：由于 MongoClient.connect() 返回的是一个promise对象 因此可以使用async 和 await
// console.log(MongoClient.connect(url)); //（MongoClient.connect(url) 返回一个Promise对象）
const client = await MongoClient.connect(url); //链接数据库

const db = client.db(dbName); //匹配数据库
return {
client,
db
}
}
  
//数据库操作之 增函数 参数1：集合 参数2：data数据（增的数据）
async function insert(colName, data) {
//1:链接数据库 并且把db 和 client在链接数据库中导出 
let {
db,
client
} = await connect()

//2：匹配数据库集合
const collection = db.collection(colName);
//3：需要判断传入的数据 是一条还是多条 一条就是insertOne 多条就是insertMany 在集合之中插入数据 
const result = await collection[Array.isArray(data) ? "insertMany" : "insertOne"](data);
//3：关闭数据库连接
client.close();
return result;
}
  //数据库之 改
// `db.集合的名称.updateOne( {name:"ppp",age:10 } , { $set : { name:"嘿嘿",age:20} } );`
//根据id来修改 数据库中的data
async function update(colName, query, newData) { //newData{$set:{price:200,qty:2},$inc:{view:1}}
let {
  db,
  client
} = await connect();
let collection = db.collection(colName);
  
//根据id删除 数据
if (query._id && typeof query._id === 'string') {
  query._id = ObjectId(query._id);
}
  
let result = await collection.updateOne(query, newData);
console.log("result" + result);
return result;
  }
  //数据库之 删 
// `db.集合的名称.deleteMany({name:"ppp"})`
async function remove(colName, query) {
//1：链接数据库
let {
  db,
  client
} = await connect()
//根据id删除 数据
if (query._id && typeof query._id === 'string') {
  query._id = ObjectId(query._id);
}
  
//2：匹配集合
let collection = db.collection(colName);
  
//判断是删除一条还是多条
let result = await collection.deleteMany(query);
client.close();
return result;
  }
// //查 函数
// 操作数据库的前提是：引入数据库，还有连接网址，连接数据库名称，数据库的链接
// 方法里面：数据库的链接（里面有着：链接数据库 匹配数据库集合，最后根据所选的集合 操作数据库） 最后关闭数据库！
async function find(colName, query = {}, options = {}) { //参数1：数据库中的集合（表） 参数2：操作的数据库语句 参数3：配置参数 
//1:链接数据库
let {
  db,
  client
} = await connect();
//2:匹配数据库集合 
let collection = db.collection(colName);
//3：最后根据所选的集合 操作数据库 查询操作
let result = collection.find(query);
  
//分页功能 需要的参数：页数 限制显示的多少页 跳过的数据条数 eg: 1页-0~5-0条 2页-5~10条-5条 3页-10~15-10条
//01：查询跳过的记录
if (options.skip) {
  result = result.skip(options.skip) //result.skip()方法 设置跳过记录 
}
//02：设置显示的条数
if (options.limit) {
  result = result.limit(options.limit)
}
//排序的功能
if (options.sort) { //前端传来的之 ["price"] 或者["price","1"] 第一种为默认的降序 第二种为升序
  let key, val;
  key = options.sort[0]; //拿到key值 
  if (options.sort.length > 1) {
val = options.sort[1] * 1;
  } else {
val = -1;
  }
  result = result.sort({ //对象[字符串] 
[key]: val
  })
}
  
result = await result.toArray(); //返回的是一个数组的形式！给与前端！
//最后 客户端关闭数据库  
client.close();
return result; //返回查询结果 一个promise对象
  }
  //把增删改查 到出  在引入这个工具函数时候 调用！
  module.exports = {
insert,
find,
update,
remove
  }

调用接口：

const express = require("express");
const router = express.Router();

const mongo = require("./mongo");
const { ObjectId } = require("mongodb");

const colc_name = "goods"
//post 方式 增加数据 
router.post("/insert", async (req, res) => {
  // `db.集合的名称.insertMany([{name:"名称",age:11},{name:"www",age:20}])`

  // insert() 参数1：数据库集合 参数2：插入的数据 插入一条数据的话 直接一个对象 插入多条数据的话 [{},{}] 对象里面书写插入的参数！
  // let result = await mongo.insert("goods2", {
  //   "name": "ppp",
  //   "purchase": "1件起购",
  //   "oldprice": 12345.00,
  // });
  let result = await mongo.insert(colc_name, [{
    "name": "ppp",
    "purchase": "1件起购",
    "oldprice": 222,
  }, {
    "name": "lll",
    "purchase": "1件起购",
    "oldprice": 111,
  }]);
  res.send("插入成功"+result);
})
//查询
router.get("/search", async (req, res) => {
//分页效果！
//设置默认显示的条数还有第几页 并且获取到前端发来的请求参数！
let {
  //page 第一页 size为显示条数大小为10 sort默认的排序（降） 根据nowPrice排序 注意点：nowPrice一定是数值型！ 不带""
  page = 1, size = 10, sort = "oldprice"
} = req.query;
//设置skip跳过的记录 还有限制显示的那些数据条数
let skip = (page - 1) * size;
let limit = size * 1;
  
//排序的参数处理
sort = sort.split(","); //参数传递：price,1等等！  ['price'],['price','-1']
  
//find()参数：参数1：数据库中的集合（表） 参数2：操作的数据库语句 参数3：配置参数 
let result = await mongo.find(colc_name, {}, {
  skip,
  limit,
  sort
});
res.send(result);
})
//删除数据
router.delete('/:id', async (req, res) => {
// router.delete('/:name', async (req, res) => {
const {
  id
  // name
} = req.params;
// console.log("name" + name);
    var objectId = new ObjectId(id)
try {
  const result = await mongo.remove(colc_name, {
_id: id
  })
  // const result = await mongo.remove('goods2', {
  //   name: name
  // })
  res.send('success')
  return result;
} catch (err) {
  res.send(err);
}
  
  })
//修改数据
  router.put("/:id", async (req, res) => {
let {
  id
} = req.params;
console.log("id" + id);
// let whereDate = {
//   name: "ooo"
// }
let whereDate = {
  _id: id
}
let updataDate = {
  $set: {
name: "zzz",
oldPrice: 200,
  },
  $inc: {
view: 1
  }
}
console.log(whereDate, updataDate); //ok
  
try {
  let result = await mongo.updata(colc_name, whereDate, updataDate);
  res.send("success");
} catch (err) {
  res.send("fail")
}
  })
module.exports = router;

在定义了所有的接口以后统一导出，然后就能通过router中的url来访问了。

原文地址：https://blog.csdn.net/weixin_73074012/article/details/140231570

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：VIM三种模式的操作
下一篇：SpringBoot防止重复提交 AOP+自定义注解+redis

MySQL数据库基础
在过去的mysql中主要是使用的utf8mb3，但是mysql显示的就是utf8，中mysql8中区分显示了。类似于不同的编译器，虽然C/C++的代码是一样的，但是预处理、编译、汇编、链接这些过程却不
阅读更多2024-09-30
Percona Monitoring and Management
Percona Monitoring and Management (PMM)是一款开源的专用于管理和监控MySQL、MongoDB、PostgreSQL。
阅读更多2024-09-30
鸿蒙开发（NEXT/API 12）【已连接穿戴设备查询】手机侧应用开发
Wear Engine提供查询用户已连接的穿戴设备列表（即支持Wear Engine能力且与手机侧运动健康App处于连接状态的穿戴设备）的接口。
阅读更多2024-09-30
Redis数据库
本篇文章介绍了redis的相关知识，并使用springboot集成redis，实现缓存和分布式锁，后续会对文章勘误及更新~~
阅读更多2024-09-30
旧版的存档
【代码】旧版的存档。
阅读更多2024-09-30
Spring Boot 封装统一返回结果及全局异常处理
为了更细致地控制异常处理，我们可以定义一些自定义异常。然后，在全局异常处理器中添加对自定义异常的处理。通过封装统一的返回结果和全局异常处理，我们可以让Spring Boot应用更加健壮和易于维护。这种
阅读更多2024-09-30
【C++】IO流
C++IO流，包含输入输出流、文件流、字符流
阅读更多2024-09-30
低至1元/小时：国庆七天，30元通关《黑神话：悟空》！
随着《黑神话：悟空》自8月20日全球同步上线，正式登陆PC、PS5平台以来，以其精湛的画面和流畅的战斗体验，在发售三天后，该作的全平台销量超过1000万套，打破中国游戏历史记录，被媒体称为“中国首款3
阅读更多2024-09-30
阿里巴巴国际站获取商品详情item_get接口技术分享
item_get API接口是阿里巴巴开放平台提供的一个重要接口，它允许商家通过API调用，获取阿里巴巴平台上的商品详细信息。这些信息包括商品标题、价格、库存、属性、描述等，为商家提供了全面、准确的商
阅读更多2024-09-30
软件测试谣言二三事，认真你就输了
软件测试的职业寿命，取决于互联网行业能存活多久，至少目前看来，这个职业没有消失的风险，至于你能在这个职业待多久，那取决于你自己的能力，我见过不少超过35岁的老员工还在测试的职位上兢兢业业。以广州为例，
阅读更多2024-09-30