构建项目
npm install -g koa-generator
koa2 -e projectname
npm install mongoose
说明：我们用mongoose来操作mongodb，需要安装mongoose。生成项目后，在项目里新建一个文件夹dbs，用来存放和数据库相关的配置文件，配置文件config.js声明数据库的配置选项，里面再创建一个models文件夹，存放模型文件，目录结构如下
config.js
module.exports = {
dbs:'mongodb://127.0.0.1:27017/dbs'
}
说明：在mongodb中创建一个数据库，为dbs
person.js
const mongoose = require('mongoose')
let personSchma = new mongoose.Schema({
name:String,
age:Number
})
module.exports = mongoose.model('Person',personSchma)
说明：利用mongoose操作mongodb，需要引入这个模块。首先我们要用mongoose提供的schema方法声明一个模式，也就是描述存放的数据的字段和字段类型，接着再通过这个模式创建一个模型，这个模型封装了一些操作数据库的方法，我们需要把模型导出来供我们使用。
app.js
const Koa = require('koa')
const app = new Koa()
const views = require('koa-views')
const json = require('koa-json')
const onerror = require('koa-onerror')
const bodyparser = require('koa-bodyparser')
const logger = require('koa-logger')
//操作数据库我们需要这样，引入这两个模块哦
const mongoose = require('mongoose')
const dbConfig = require('./dbs/config')
const index = require('./routes/index')
const users = require('./routes/users')
// error handler
onerror(app)
// middlewares
app.use(bodyparser({
enableTypes:['json', 'form', 'text']
}))
app.use(json())
app.use(logger())
app.use(require('koa-static')(__dirname + '/public'))
app.use(views(__dirname + '/views', {
extension: 'ejs'
}))
// logger
app.use(async (ctx, next) => {
const start = new Date()
await next()
const ms = new Date() - start
console.log(`${ctx.method} ${ctx.url} - ${ms}ms`)
})
// routes
app.use(index.routes(), index.allowedMethods())
app.use(users.routes(), users.allowedMethods())
//mongoose
mongoose.connect(dbConfig.dbs,{
useNewUrlParser:true
})
// error-handling
app.on('error', (err, ctx) => {
console.error('server error', err, ctx)
});
module.exports = app
添加的代码是
const mongoose = require('mongoose')
const dbConfig = require('./dbs/config')
//mongoose
mongoose.connect(dbConfig.dbs,{
useNewUrlParser:true
})
说明：在app.js中引入mongoose和数据库的配置文件config.js,然后连接dbs数据库，传递进去的参数就是config.js文件里的dbs的值。
到这里，我们就连接上数据库了，接下来，就编写接口操作数据库。
编写增删改查数据的接口
在router文件夹下的user.js中编写接口
const router = require('koa-router')()
//要操作数据库了，之前我们在models里面根据描述创建了模型
//现在根据模型我们实例化一个表出来
//那我们需要在这个接口文件中，引进我们创建的模型,就是person文件啦
//再说一遍，schema描述表的字段，moudle里面有增删改查的操作
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'
})
//新建一个用来操作数据库的接口
router.post('/addPerson',async function(ctx){
//创建这个模型的实例啦
const person = new Person({
//通过post请求得到的body里的数据，添加到数据库
name: ctx.request.body.name,
age: ctx.request.body.age
})
// //保存这条数据哦
// await person.save()
// //返回这个操作的状态看看，不能总是0
// ctx.body = {
// code:0
// }
//换一种写法，我们需要捕获一下异常
let code
try {
//save方法是模型封装好的，实例可以调用这个方法
await person.save()
code = 0
} catch (error) {
code = -1
}
ctx.body = {
code:code
}
})
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
}
})
router.post('/updatePerson',async function(ctx) {
const result = await Person.where({
name:ctx.request.body.name
}).update({
age:ctx.request.body.age
})
ctx.body = {
code:0
}
})
router.post('/removePerson',async function(ctx) {
const result = await Person.where({
name:ctx.request.body.name
}).remove()
ctx.body = {
code:0
}
})
module.exports = router
测试方法：安装postman，填写我们接口的地址，根据情况选择请求方式，这里是post，还要注意的一点是，user.js里的接口还有一个前缀，也就是文件中的router.prefix('/users')，它的前缀就是/users。
测试getPerson的接口如下
数据库如下
总结：
mudels下的person.js对应的就是我们建的表，我们是通过mongoose操作数据库的，并不是mongodb原生的api，因此我们要引入这个mongoose。接着，通过mongodb提供的schema创建一个描述，是描述这个数据表的，这样，数据表就有字段了。但还不能操作它，现在我们需要通过这个描述，创建一个模型，模型里面有封装好的操作数据库的一些方法。model在这里就相当于一个桥梁，它既关联着数据表的描述，又关联着数据库。最终要完成实际操作的，还是要由实例来完成。因此，在我们编写接口的文件中，引入mongoose和模型，并且通过模型创建一个实例出来，就可以在接口操作数据啦。
