安装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} } })