const Koa = require('koa');
const Router = require('koa-router');
const bodyparser = require('koa-bodyparser');
var mongoose = require('mongoose');
var Schema = mongoose.Schema;
let _url = "mongodb://127.0.0.1:27017/people"
let app = new Koa();
let router = new Router();
var People = new Schema({
name: String,
address: String,
})
var Model = mongoose.model('person',People)
//解决跨域
app.use(async (ctx,next) => {
ctx.set('Access-Control-Allow-Origin',"*");//允许所有路径的访问。
ctx.set('Access-Control-Allow-Methods',"OPTIONS, GET, PUT, POST, DELETE");//允许访问的方法
ctx.set('Access-Control-Allow-Headers',"x-requested-with, accept, origin, content-type");//允许访问的headers
ctx.set('Content-type',"application/json");//接受的类型
await next();//转移给下一个中间件。
})
app.use(bodyparser())
router.post('/test',async (ctx) => {
let postData= ctx.request.body;
await mongoose.connect(_url,{ useNewUrlParser: true },function(err) {
if(err){
console.log(err,'连接失败');
}
else{
console.log('连接成功');
var doc1 = new Model(postData);
doc1.save(); //这一步骤是必须的！save函数中可以使用cb
ctx.body = {
status:200,
msg:'success'
}
}
});
})
router.get('/test/:name',async (ctx) => {
const parms = ctx.params
await mongoose.connect(_url,{ useNewUrlParser: true },function(err) {
if(err){
console.log(err,'连接失败');
}
else{
let res = Model.find(parms);
console.log(res)
// console.log('连接成功');
// var doc1 = new Model(postData);
// doc1.save(); //这一步骤是必须的！save函数中可以使用cb
// ctx.body = {
// status:200,
// msg:'success'
// }
}
});
})
app.use(router.routes()).use(router.allowedMethods())
app.listen(27017,()=>{
console.log('[demo] server is starting at port 27017');
})