安装koa的以及koa-router及全局的glob(可使用*号遍历所有文件)
npm install koa --save npm install glob --save npm install koa-router --save
npm install koa2-cors --save
引入koa
const Koa = require('koa')
const app = new Koa()
const Router=require('koa-router')
const mongoose = require("mongoose")
const {connect,initSchemas} = require("./database/init")
const cors=require("koa2-cors")//跨域需求
app.use(cors())//注意位置
let entry = require("./appApi/entry.js")
let router = new Router();
router.use('/entry',entry.routes())//路由配置项
app.use(router.routes()) //注意
app.use(router.allowedMethods())//注意
;(async()=>{
await connect()//连接
initSchemas()//初始化Schemas
})()
app.use(async(ctx)=>{
ctx.body='<h1>hello world</h1>'
})
app.listen(3000,()=>{
console.log("3000 start")
})
数据导入
const Koa=require("koa")
const app =new Koa()
const Router = require("koa-router")
let router = new Router()
const mongoose=require('mongoose')
const fs=require('fs')
router.get('/entryInfo',async(ctx)=>{
fs.readFile("./JSON/entry.json",'utf8',(err,data)=>{
data=JSON.parse(data)
let saveCount=0
const Entry=mongoose.model('Entry')
data.map((value,index)=>{
console.log(value)
let newEntry=new Entry(value)
newEntry.save().then(()=>{
saveCount++
console.log("成功"+saveCount)
}).catch(err=>{
console.log("失败"+err)
})
})
})
ctx.body='开始导入数据'
})
数据导出
router.get('/getentryInfo',async(ctx)=>{
try{
const Entry=mongoose.model('Entry')
let result=await Entry.find().exec()
ctx.body={code:200,message:result}
}catch(error){
ctx.body={code:500,message:error}
}
})