4.处理数据
处理数据使用koa-better-body中间件
处理get数据：ctx.request.query
处理post数据：ctx.request.fields
const Koa = require('koa');
const body = require('koa-better-body');
const convert = require('koa-convert'); //转换旧的中间件，其实就是将generator函数转换为Promise对象
let server = new Koa();
server.use(convert(body({
uploadDir: './upload', //指定上传路径
keepExtensions: 'true' //文件是否需要扩展名
})));
server.listen(3000);
server.use(async ctx=>{
//console.log("body",ctx.request.body);//post数据
//console.log('files',ctx.request.files);//文件
console.log("fields",ctx.request.fields);//照单全收，常用
});
5.cookie
koa自带cookie
const Koa = require('koa');
let server = new Koa();
server.listen(3000);
server.keys = ['dassdswdf','d89whfoa7fjaoo','sdadiaiuwj887e']
server.use(async ctx=>{
ctx.cookies.set('user', 'zcox',{maxAge: 24*3600*1000,signed: true}); //设置cookie并且签名
console.log(ctx.cookies.get('user',{signed: true}));// 获取cookie
});
6.session
使用koa-session中间件，用法和cookie比较类似
const Koa = require('koa');
const session = require('koa-session');
let server = new Koa();
server.listen(3000);
server.keys = ['daewr2345234wfd','54twefsgyd','ererfwefsggh44','sdadetrgree453'];
server.use(session({maxAge: 20*60*1000},server));
server.use(async ctx=>{
if(!ctx.session['n']){
ctx.session['n'] = 1;
}else{
ctx.session['n']++;
}
console.log(ctx.session);
ctx.response.body = `你是第${ctx.session['n']}次访问`;
});
7.数据库操作
koa中使用koa-mysql中间件操作数据库，但它对应的是老版本的koa,在新版本的koa中不能直接使用，这就需要自己动手处理koa-mysql.
query函数返回的是一个普通的回调函数，而await后面跟的是Promise,因此要进行处理。
let db = mysql.createPool({host: 'localhost',user: 'root',password: '',port: 3306,database: '20171116'});
server.use(async ctx=>{
let p = new Promise((resolve,reject)=>{
let fn = db.query('SELECT * FROM user_table');
fn(function(err,data){
if(err){
reject(err);
}else{
resolve(data);
}
});
});
let datas = await p;
ctx.response.body = datas;
});
为了方便以后使用，对其进行封装，下面是自己封装的组件koa-better-mysql
const mysql = require('koa-mysql');
module.exports = {
createPool(json){
const db = mysql.createPool(json);
let _query = db.query.bind(db);
db.query = function(sql){
return new Promise((resolve,reject)=>{
_query(sql)((err,data)=>{
if(err){
reject(err);
}else{
resolve(data);
};
});
});
};
return db;
}
};
8.ejs模板引擎
const Koa = require('koa');
const ejs = require('koa-ejs');
const mysql = require('./libs/koa-better-mysql');
let server = new Koa();
server.listen(8080);
let db = mysql.createPool({host: 'localhost',user: 'root',password: '',database: '20171116',port: 3306});
ejs(server,{
root: './template',
layout: false,
viewExt: 'ejs',
cache: false,
debug: true
});
server.use(async ctx=>{
await ctx.render('index',{arr: await db.query('SELECT * FROM user_table')}); //渲染 render index文件名，{}要渲染数据
})
使用中间件koa-ejs
配置：
ejs(server,{
root: './template', //模板文件路径
layout: false, //用不着，我也不知道是干啥的，false就行
viewExt: 'ejs', //指定文件后缀
cache: false, //不需要缓存
debug: true //开启调试
});
