koa2 入門（1）koa-generator 腳手架和 mongoose 使用

項目地址：https://github.com/caochangkui/demo/tree/koa2-learn

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

---

參考

• koa文檔： https://koa.bootcss.com/#
• koa參考資料：https://www.jianshu.com/p/6b816c609669
• mongoDB教程： http://www.runoob.com/mongodb/mongodb-tutorial.html
• mongosse中文文檔： https://mongoose.shujuwajue.com/