共计 3101 个字符，预计需要花费 8 分钟才能阅读完成。
想使用 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 一些查询参数，并在使用传入的参数取对应数据。