1 構建專案

1.1 安裝koa-generator

$ npm install -g koa-generator

1.2 使用koa-generator生成koa2專案

$ koa2  -e project(專案名稱)   （-e 代表使用模板引擎ejs）

1.3 進入專案

$ cd project 
$ npm install

1.4 啟動專案，預設埠號是3000

$  DEBUG=koa2-learn:* npm start        (該方法在修改檔案時需要重新啟動服務。不建議使用)
$  npm  run dev  （該方法可以直接重新整理服務）

1.5 專案目錄

其中：dbs為後來建立的操作mongo的檔案目錄；middleware為後來建立的自定義中介軟體目錄

2. 中介軟體

koa是從第一個中介軟體開始執行，遇到 await next() 進入下一個中介軟體，一直執行到最後一箇中間件，在逆序，執行上一個中介軟體，一直到第一個中介軟體執行結束才發出響應。

2.1 自定義中介軟體

建立資料夾middleware存放各種自定義中介軟體；
建立檔案 koa-pv.js:

// 自定義中介軟體 koa-pv

function pv (ctx) {
    global.console.log('當前路由', ctx.path) // 列印當前路由，node中全域性不能用window，需要用global代替
}

module.exports = function () {
    return async function(ctx, next) {
        pv(ctx)
        await next() // 每個中介軟體都必須有這一句，用以執行下一個中介軟體
    }
}
 

然後，在app.js中引入中介軟體

const pv = require('./middleware/koa-pv')

app.use(pv())

3. mongoose的使用

3.1 判斷是否安裝了mongo:

$ which mongod

3.2 執行 MongoDB

$ sudo mongod  

<!--

首先建立一個數據庫儲存目錄 /data/db：

sudo mkdir -p /data/db

啟動 mongodb，預設資料庫目錄即為 /data/db

參考：http://www.runoob.com/mongodb/mongodb-osx-install.html

如果已經有程序27017，需要先停止：

停止程序：
    lsof -i :27017
    kill  -9 3243
-->
 

3.3 配置mongoose

在資料夾dbs中建立檔案 config.js:

// 配置mongo 地址
module.exports =  {
    dbs: 'mongodb://127.0.0.1:27017/dbs'
}

3.4 建立資料表

在檔案dbs 中建立資料夾models 用來存放不同的資料表。
建立檔案person.js, 檔名person即為資料表名稱。

person.js:

const mongoose = require('mongoose')

// 建立資料表模型，該檔案的名字，即person，就是資料表的名字
// 下面給 person 表宣告兩個欄位name和age

let personSchema = new mongoose.Schema({
    name: String,
    age: Number
})

// 通過建 model 給 person 賦予增刪改查等讀寫的功能
module.exports = mongoose.model('Person', personSchema)

3.5 連線koa2和mongoose

// 一、引入mongoose
const mongoose = require('mongoose')
const dbConfig = require('./dbs/config')


// 二、 連線資料庫的服務
mongoose.connect(dbConfig.dbs, {
  useNewUrlParser: true
})

3.6 通過mongoose進行資料的增刪改查

進入檔案 routes/uses.js:

const router = require('koa-router')()
// 引入mongo模型
const Person = require('../dbs/models/person')

router.prefix('/users')

router.get('/', function (ctx, next) {
  ctx.body = 'this is a users response!'
})

router.get('/bar', function (ctx, next) {
  ctx.body = 'this is a users/bar response'
})


/**
 *  一、 增加 內容 向person資料模型中
 *
 *     可以通過命令列執行：curl -d 'name=cck&age=27' http://localhost:3000/users/addPerson
 *     若返回: {
                "code": 0
              }
       證明新增資料成功。

       注意： save()方法是model自帶的寫入資料的方法, 通過例項 person 寫入
 */

router.post('/addPerson', async function (ctx) {
  // 建立例項
  const person = new Person({
    name: ctx.request.body.name,
    age: ctx.request.body.age
  })

  let code = 0 // 狀態碼

  try {
    await person.save()
    code = 0
  } catch(e) {
    code = -1
  }

  // 返回狀態（成功為0， 錯誤為-1）
  ctx.body = {
    code
  }
})

/**
 *  二、 讀取 內容 從person資料模型中
 *      命令列中輸入：curl -d 'name=cck' http://localhost:3000/users/getPerson
 *      返回：{
                "code": 0,
                "result": {
                  "_id": "5beb91bcd6e7060ffcca6a46",
                  "name": "cck",
                  "age": 27,
                  "__v": 0
                },
                "results": [
                  {
                    "_id": "5beb91bcd6e7060ffcca6a46",
                    "name": "cck",
                    "age": 27,
                    "__v": 0
                  }
                ]
              }
 *
 *    注意： findOne()和find()方法是model自帶的讀取資料的方法, 注意：這裡直接通過模型 Person 寫入 ！！！
 *          findOne() 只是找到一條符合條件的內容
 *          find() 可以找到整個符合條件的集合(陣列)
 */

router.post('/getPerson', async function (ctx) {
  const result = await Person.findOne({
    name: ctx.request.body.name
  })

  const results = await Person.find({
    name: ctx.request.body.name
  })

  // 這裡沒有考慮異常，直接返回了結果
  ctx.body = {
    code: 0,
    result,
    results
  }
})

/**
 *  三、 修改 內容 從person資料模型中
 *      命令列中輸入：curl -d 'name=wy&age=19' http://localhost:3000/users/updatePerson
 *      返回：{
                "code": 0,
              }
 *
 *    注意： where()和update()方法是model自帶的讀取資料的方法, 注意：這裡直接通過模型 Person 寫入 ！！！
 *          where() 找到符合條件的內容
 *          update() 修改該內容
 */

router.post('/updatePerson', async function (ctx) {
  // 找到符合條件的name,並修改其age
  const result = await Person.where({
    name: ctx.request.body.name
  }).update({
    age: ctx.request.body.age
  })

  // 這裡沒有考慮異常，直接返回了結果
  ctx.body = {
    code: 0
  }
})

/**
 *  四、 刪除 內容 從person資料模型中
 *
 *    注意： where()和update()方法是model自帶的讀取資料的方法, 注意：這裡直接通過模型 Person 寫入 ！！！
 *          where() 找到符合條件的內容
 *          remove() 刪除該內容
 */

router.post('/removePerson', async function (ctx) {
  // 找到符合條件的name,並修改其age
  const result = await Person.where({
    name: ctx.request.body.name
  }).remove()

  // 這裡沒有考慮異常，直接返回了結果
  ctx.body = {
    code: 0
  }
})

module.exports = router