资讯专栏INFORMATION COLUMN

基于Koa(nodejs框架)对json文件进行增删改查

imccl / 2573人阅读

摘要:本文介绍了基于的文件的增删改查。代码准备路由增删改查接口,可添加在下面装载所有子路由示例唐僧孙悟空猪八戒沙和尚新增和修改新增和修改可以分开,但是为了省代码就合并在一起了。

想使用nodejs(koa)搭建一个完整的前后端,完成数据的增删改查,又不想使用数据库,那使用json文件吧。
本文介绍了基于koa的json文件的增、删、改、查

代码准备

</>复制代码

  1. const Koa = require("koa")
  2. const bodyParser = require("koa-bodyparser")
  3. const Router = require("koa-router")
  4. const fs = require("fs")
  5. const path = require("path")
  6. const app = new Koa()
  7. const router = new Router()
  8. app.use(bodyParser())
  9. // 路由
  10. const deploy = new Router()
  11. // 增删改查接口,可添加在下面
  12. // 装载所有子路由
  13. router.use("/deploy", deploy.routes(), deploy.allowedMethods())
  14. app.use(router.routes()).use(router.allowedMethods())
  15. app.listen(3000);

json示例

</>复制代码

  1. [
  2. {"id": 1, "name": "唐僧"},
  3. {"id": 2, "name": "孙悟空"},
  4. {"id": 3, "name": "猪八戒"},
  5. {"id": 4, "name": "沙和尚"}
  6. ]
1.新增和修改

新增和修改可以分开,但是为了省代码就合并在一起了。

</>复制代码

  1. deploy.post("/add-modify", async (ctx) => {
  2. // 这里使用的bodyParser来解析post请求传来的数据,id是用来查找之前有的数据并进行修改,新增数据的在前台应该将id设置为空
  3. let id = ctx.request.body.id
  4. let params = ctx.request.body.params
  5. let writeJson = () => {
  6. return new Promise((resolve,reject)=>{
  7. // fs模块读取json文件 对fs、path模块不熟悉的可以去查下官方文档
  8. fs.readFile(path.join(__dirname, "/data/project.json"),function(err,data){
  9. if(err){
  10. // 报错返回
  11. resolve({code: -1, msg: "新增失败" + err})
  12. return console.error(err);
  13. }
  14. let jsonData = data.toString();//将二进制的数据转换为字符串
  15. jsonData = JSON.parse(jsonData);//将字符串转换为json对象
  16. // 有id值=>修改 无id值=>新增
  17. if (id) {
  18. jsonData.splice(jsonData.findIndex(item => item.id === id), 1, params)
  19. } else {
  20. // 有重复 => 返回-1 无重复 => 将params加到json数组末尾
  21. let hasRepeat = jsonData.filter((item) => item.id === params.id);
  22. hasRepeat ? resolve({code: -1, msg: "新增失败,有重复项目id"}) : jsonData.push(params);
  23. }
  24. //因为nodejs的写入文件只认识字符串或者二进制数,所以把json对象转换成字符串重新写入json文件中
  25. let str = JSON.stringify(jsonData);
  26. fs.writeFile(path.join(__dirname, "/data/project.json"),str,function(err){
  27. if(err){
  28. resolve({code: -1, msg: "新增失败" + err})
  29. }
  30. resolve({code: 0, msg: "新增成功"})
  31. })
  32. })
  33. })
  34. }
  35. // 返回给前端
  36. ctx.body = await writeJson()
  37. })
2.删除

删除,这里使用的get方法

</>复制代码

  1. deploy.get("/delete", async (ctx) => {
  2. let id = ctx.request.query.id
  3. let deleteJson = () => {
  4. return new Promise((resolve,reject)=>{
  5. fs.readFile(path.join(__dirname, "/data/project.json"),function(err,data){
  6. if(err){
  7. resolve({code: -1, msg: "删除失败" + err})
  8. return console.error(err);
  9. }
  10. let jsonData = data.toString();//将二进制的数据转换为字符串
  11. jsonData = JSON.parse(jsonData);//将字符串转换为json对象
  12. // 过滤出所存item的id和前端传来id不等的 item ,下面提供了两种方法filter和splice
  13. jsonData = jsonData.filter((item) => item.id !== id);
  14. // jsonData.splice(jsonData.findIndex(item => item.id === id), 1)
  15. let str = JSON.stringify(jsonData);
  16. fs.writeFile(path.join(__dirname, "/data/project.json"),str,function(err){
  17. if(err){
  18. resolve({code: -1, msg: "删除失败" + err})
  19. }
  20. resolve({code: 0, msg: "删除成功"})
  21. })
  22. })
  23. })
  24. }
  25. ctx.body = await deleteJson()
  26. })
3.查询

</>复制代码

  1. deploy.get("/find", async (ctx) => {
  2. // 两种查询方式 1.id为空 => 查询全部 2.id有值 => 查询单个
  3. let id = ctx.request.query.id
  4. let findJson = () => {
  5. return new Promise((resolve,reject)=>{
  6. fs.readFile(path.join(__dirname, "/data/project.json"),function(err,data){
  7. if(err){
  8. resolve({code: -1, msg: "查询失败" + err})
  9. return console.error(err);
  10. }
  11. let jsonData = data.toString();//将二进制的数据转换为字符串
  12. jsonData = JSON.parse(jsonData);//将字符串转换为json对象
  13. // 有id值=>单个 无id值=>全部
  14. if (id) {
  15. jsonData = jsonData.filter((item) => item.id === id);
  16. resolve({code: 0, data: jsonData})
  17. } else {
  18. resolve({code: 0, data: jsonData})
  19. }
  20. })
  21. })
  22. }
  23. ctx.body = await findJson()
  24. })

当然,上面提供的还没有支持分页,想要实现分页,需求改变json格式,如下:

</>复制代码

  1. {
  2. "data": [{"id": 1, "name": "唐僧"},
  3. {"id": 2, "name": "孙悟空"},
  4. {"id": 3, "name": "猪八戒"},
  5. {"id": 4, "name": "沙和尚"}],
  6. "currentPage": 1,
  7. "pageSize": 4,
  8. "pageNum": 1,
  9. "total": 4
  10. }

新增page一些查询参数,并在使用传入的参数取对应数据。

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/101502.html

相关文章

  • 使用express+mongoosemongodb实现删改操作

    摘要:项目地址写在开头本文主要分享我如何使用对实现增删改查操作,感谢社区所有精品文章的帮助,以及的开源项目对我的启发。我们这个项目是建立一个班级学生管理系统,能够对学生的姓名及学号进行增删改查的操作。 项目地址:https://github.com/jrainlau/mongoose_cru... 写在开头 本文主要分享我如何使用express+mongoose对mongodb实现增删改查...

    Markxu 评论0 收藏0
  • 用js简单提供删改接口

    摘要:本周写实验,需要提供简单的后台接口对数据库进行增删改查,以前写后台只用过和因为比较容易,用写的也比较快,所以这次想用实现简单的增删改查接口。 本周写实验,需要提供简单的后台接口对数据库进行增删改查,以前写后台只用过php和java,因为比较容易,用js写的也比较快,所以这次想用js实现简单的增删改查接口。 初始化 需要工具:nodejs 依赖:express,mysql,body-p...

    shadowbook 评论0 收藏0
  • 基于nodejs将mongodb的数据实时同步到elasticsearch

    摘要:一前言因公司需要选用做全文检索,持久化存储选用的是,但是希望里面的数据发生改变可以实时同步到上,一开始主要使用的版本,可以搞定这个问题。或者修改中的某一条数据,也会实时同步到中。如何把的主文档和附件信息都同步到中利用的来实现。 一、前言 因公司需要选用elasticsearch做全文检索,持久化存储选用的是mongodb,但是希望mongodb里面的数据发生改变可以实时同步到elast...

    miya 评论0 收藏0

发表评论

0条评论

imccl

|高级讲师

TA的文章

阅读更多
最新活动
阅读需要支付1元查看
<