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

更新日期: 2019-02-01阅读: 2.7k标签: Koa

想使用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一些查询参数,并在使用传入的参数取对应数据。


链接: https://www.fly63.com/article/detial/1930

KOA2框架原理解析和实现

koa是一个基于node实现的一个新的web框架,它是由express框架的原班人马打造的。它的特点是优雅、简洁、表达力强、自由度高。它更express相比,它是一个更轻量的node框架

koa-easywechat_一个基于koa2的微信开发中间件

koa-easywechat注意:koa-easywechat中间件要写在最前面,也就是要第一个use,因为我在ctx上挂载了一个wechat对象,这个对象实现了大部分的微信接口,这样才能保证开发者在自己的写路由里,获取到ctx.wechat进行自己的业务开发

koa2中间件_深入理解 Koa2 中间件机制

我们知道,Koa 中间件是以级联代码(Cascading) 的方式来执行的。类似于回形针的方式,今天这篇文章就来分析 Koa 的中间件是如何实现级联执行的。在 koa 中,要应用一个中间件,我们使用 app.use()

koajs--基于node.js的下一代web开发框架

Koa 是一个新的 web 框架,由 Express 幕后的原班人马打造, 致力于成为 web 应用和 API 开发领域中的一个更小、更富有表现力、更健壮的基石。 通过利用 async 函数,Koa 帮你丢弃回调函数,并有力地增强错误处理。

node.js中 koa 框架的基本使用方法

安装 koa、简单使用、级联中间件的概念、获取get请求参数、获取post表单数据和文件上传、路由中间件 koa-router

Koa日志中间件封装开发详解

对于一个服务器应用来说,日志的记录是必不可少的,我们需要使用其记录项目程序每天都做了什么,什么时候发生过错误,发生过什么错误等等,便于日后回顾、实时掌握服务器的运行状态,还原问题场景

Koa中间件

Koa 应用程序是一个包含一组中间件函数的对象,它是按照类似堆栈的方式组织和执行的。当一个中间件调用 next() 则该函数暂停并将控制传递给定义的下一个中间件。当在下游没有更多的中间件执行后,堆栈将展开并且每个中间件恢复执行其上游行为

Koa使用koa-multer上传文件(上传限制、错误处理)

上传文件在开发中是很常见的操作,今天我选择使用koa-multer中间件来实现这一功能,除了上传文件外,我还会对文件上传进行限制,以及发生上传错误时的处理。由于原来的 koa-multer 已经停止维护,我们要使用最新的 @koa/multer

从零实现TypeScript版Koa

这篇文章会讲些什么?如何从零开始完成一个涵盖Koa核心功能的Node.js类库,从代码层面解释Koa一些代码写法的原因:如中间件为什么必须调用next函数、ctx是怎么来的和一个请求是什么关系

读 koa2 源码后的一些思考与实践

Nodejs官方api支持的都是callback形式的异步编程模型。问题:callback嵌套问题,koa2 是由 Express原班人马打造的,是现在比较流行的基于Node.js平台的web开发框架,Koa 把 Express 中内置的 router、view 等功能都移除了

点击更多...

内容以共享、参考、研究为目的,不存在任何商业目的。其版权属原作者所有,如有侵权或违规,请与小编联系!情况属实本人将予以删除!