基于Koa(nodejs框架)对json文件进行增删改查的示例代码
程序员文章站
2022-05-14 09:18:02
想使用nodejs(koa)搭建一个完整的前后端,完成数据的增删改查,又不想使用数据库,那使用json文件吧。
本文介绍了基于koa的json文件的增、删、改、查。...
想使用nodejs(koa)搭建一个完整的前后端,完成数据的增删改查,又不想使用数据库,那使用json文件吧。
本文介绍了基于koa的json文件的增、删、改、查。
代码准备
const koa = require('koa') const bodyparser = require('koa-bodyparser') const router = require('koa-router') const fs = require('fs') const path = require('path') const app = new koa() const router = new router() app.use(bodyparser()) // 路由 const deploy = new router() // 增删改查接口,可添加在下面 // 装载所有子路由 router.use('/deploy', deploy.routes(), deploy.allowedmethods()) app.use(router.routes()).use(router.allowedmethods()) app.listen(3000);
json示例
[ {"id": 1, "name": "唐僧"}, {"id": 2, "name": "孙悟空"}, {"id": 3, "name": "猪八戒"}, {"id": 4, "name": "沙和尚"} ]
1.新增和修改
新增和修改可以分开,但是为了省代码就合并在一起了。
deploy.post('/add-modify', async (ctx) => { // 这里使用的bodyparser来解析post请求传来的数据,id是用来查找之前有的数据并进行修改,新增数据的在前台应该将id设置为空 let id = ctx.request.body.id let params = ctx.request.body.params let writejson = () => { return new promise((resolve,reject)=>{ // fs模块读取json文件 对fs、path模块不熟悉的可以去查下官方文档 fs.readfile(path.join(__dirname, '/data/project.json'),function(err,data){ if(err){ // 报错返回 resolve({code: -1, msg: '新增失败' + err}) return console.error(err); } let jsondata = data.tostring();//将二进制的数据转换为字符串 jsondata = json.parse(jsondata);//将字符串转换为json对象 // 有id值=>修改 无id值=>新增 if (id) { jsondata.splice(jsondata.findindex(item => item.id === id), 1, params) } else { // 有重复 => 返回-1 无重复 => 将params加到json数组末尾 let hasrepeat = jsondata.filter((item) => item.id === params.id); hasrepeat ? resolve({code: -1, msg: '新增失败,有重复项目id'}) : jsondata.push(params); } //因为nodejs的写入文件只认识字符串或者二进制数,所以把json对象转换成字符串重新写入json文件中 let str = json.stringify(jsondata); fs.writefile(path.join(__dirname, '/data/project.json'),str,function(err){ if(err){ resolve({code: -1, msg: '新增失败' + err}) } resolve({code: 0, msg: '新增成功'}) }) }) }) } // 返回给前端 ctx.body = await writejson() })
2.删除
删除,这里使用的get方法
deploy.get('/delete', async (ctx) => { let id = ctx.request.query.id let deletejson = () => { return new promise((resolve,reject)=>{ fs.readfile(path.join(__dirname, '/data/project.json'),function(err,data){ if(err){ resolve({code: -1, msg: '删除失败' + err}) return console.error(err); } let jsondata = data.tostring();//将二进制的数据转换为字符串 jsondata = json.parse(jsondata);//将字符串转换为json对象 // 过滤出所存item的id和前端传来id不等的 item ,下面提供了两种方法filter和splice jsondata = jsondata.filter((item) => item.id !== id); // jsondata.splice(jsondata.findindex(item => item.id === id), 1) let str = json.stringify(jsondata); fs.writefile(path.join(__dirname, '/data/project.json'),str,function(err){ if(err){ resolve({code: -1, msg: '删除失败' + err}) } resolve({code: 0, msg: '删除成功'}) }) }) }) } ctx.body = await deletejson() })
3.查询
deploy.get('/find', async (ctx) => { // 两种查询方式 1.id为空 => 查询全部 2.id有值 => 查询单个 let id = ctx.request.query.id let findjson = () => { return new promise((resolve,reject)=>{ fs.readfile(path.join(__dirname, '/data/project.json'),function(err,data){ if(err){ resolve({code: -1, msg: '查询失败' + err}) return console.error(err); } let jsondata = data.tostring();//将二进制的数据转换为字符串 jsondata = json.parse(jsondata);//将字符串转换为json对象 // 有id值=>单个 无id值=>全部 if (id) { jsondata = jsondata.filter((item) => item.id === id); resolve({code: 0, data: jsondata}) } else { resolve({code: 0, data: jsondata}) } }) }) } ctx.body = await findjson() })
当然,上面提供的还没有支持分页,想要实现分页,需求改变json格式,如下:
{ "data": [{"id": 1, "name": "唐僧"}, {"id": 2, "name": "孙悟空"}, {"id": 3, "name": "猪八戒"}, {"id": 4, "name": "沙和尚"}], "currentpage": 1, "pagesize": 4, "pagenum": 1, "total": 4 }
新增page一些查询参数,并在使用传入的参数取对应数据。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
上一篇: django 用户上传文件media的存储访问配置1
下一篇: JSON Web Token入门教程