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 //开启调试
});