我们正在接收请求，但不会将它们存储在任何地方.我们需要一个数据库来存储数据.我们将使用一个名为 MongoDB 的着名NoSQL数据库.要安装和阅读有关Mongo的信息.
为了使用使用Koa的Mongo，我们需要一个客户端API用于节点.我们有多种选择，但是对于本教程，我们将坚持 mongoose . Mongoose用于Node for MongoDB中的文档建模.文档建模意味着，我们将创建一个模型(很像在面向文档的编程中的类)，然后我们将生成文档这个模型(就像我们在OOP中创建类的文档).我们所有的处理都将在这些"文件"上完成，最后，我们将在我们的数据库中写下这些文件.
现在我们安装了Mongo，让我们安装mongoose，就像我们安装其他节点包一样.
$ npm install --save mongoose
在我们开始使用mongoose之前，我们必须使用Mongo shell创建一个数据库.要创建新数据库，请打开终端并输入"mongo". Mongo shell将启动，输入以下内容.
use my_db
将为您创建一个新数据库.每当你打开Mongo shell时，它都默认为"test"db，你必须使用与上面相同的命令更改到你的数据库.
要使用mongoose，我们将在我们的app.js文件中需要它，然后连接到在mongodb上运行的mongod服务://localhost
var koa = require('koa');
var _ = require('koa-router')();
var app = koa();
var mongoose = require('mongoose');
mongoose.connect('mongodb://localhost/my_db');
app.use(_.routes());
app.listen(3000);现在我们的应用已连接到我们的数据库，让我们创建一个新模型.该模型将作为我们数据库中的集合.要创建新模型，请在定义任何路径之前使用以下代码.
var koa = require('koa');
var _ = require('koa-router')();
var app = koa();
var mongoose = require('mongoose');
mongoose.connect('mongodb://localhost/my_db');
var personSchema = mongoose.Schema({
name: String,
age: Number,
nationality: String
});
var Person = mongoose.model("Person", personSchema);
app.use(_.routes());
app.listen(3000);上面的代码定义了一个人的模式，用于创建猫鼬模型人.
现在我们将创建一个新的html表单，它将获取一个人的详细信息并将其保存到我们的数据库中.要创建表单，请在views目录中创建一个名为person.pug的新视图文件，其中包含以下内容.
html head title Person body form(action = "/person", method = "POST") div label(for = "name") Name: input(name = "name") br div label(for = "age") Age: input(name = "age") br div label(for = "nationality") Nationality: input(name = "nationality") br button(type = "submit") Create new person
还在index.js中添加新的获取路线以呈现此文档.
var koa = require('koa');
var _ = require('koa-router')();
var app = koa();
var mongoose = require('mongoose');
mongoose.connect('mongodb://localhost/my_db');
var personSchema = mongoose.Schema({
name: String,
age: Number,
nationality: String
});
var Person = mongoose.model("Person", personSchema);
_.get('/person', getPerson);
function *getPerson(next){
this.render('person');
yield next;
}
app.use(_.routes());
app.listen(3000);转到localhost:3000/person查看我们的表单是否显示正确.请注意，这只是UI，它还没有工作.这就是我们表单的外观.
我们将会现在在'/person'定义一个邮政处理程序，它将处理这个请求.
var koa = require('koa');
var _ = require('koa-router')();
var app = koa();
var mongoose = require('mongoose');
mongoose.connect('mongodb://localhost/my_db');
var personSchema = mongoose.Schema({
name: String,
age: Number,
nationality: String
});
var Person = mongoose.model("Person", personSchema);
_.post('/person', createPerson);
function *createPerson(next){
var self = this;
var personInfo = self.request.body; //Get the parsed information
if(!personInfo.name || !personInfo.age || !personInfo.nationality){
self.render(
'show_message', {message: "Sorry, you provided wrong info", type: "error"});
} else {
var newPerson = new Person({
name: personInfo.name,
age: personInfo.age,
nationality: personInfo.nationality
});
yield newPerson.save(function(err, res) {
if(err)
self.render('show_message',
{message: "Database error", type: "error"});
else
self.render('show_message',
{message: "New person added", type: "success", person: personInfo});
});
}
}
app.use(_.routes());
app.listen(3000);在上面的代码中，如果我们收到任何空字段或者没有收到任何字段，我们将发送错误响应.但是，如果我们收到格式正确的文档，那么我们将从Person模型创建一个newPerson文档，并使用 newPerson.save()函数将其保存到我们的DB中.这是在mongoose中定义的，并接受回调作为参数.此回调有两个参数，错误和响应.这将呈现show_message视图，因此我们也需要创建它.
要显示此路线的响应，我们还需要创建 show_message 视图.使用以下代码创建一个新视图.
html
head
title Person
body
if(type = "error")
h3(style = "color:red") #{message}
else
h3 New person, name:
#{person.name}, age:
#{person.age} and nationality:
#{person.nationality} added!以下是我们在成功提交表格时收到的回复(show_message.pug).
我们现在有一个创建人员的界面！
Mongoose提供了很多检索文档的功能，我们将重点关注其中的三个.所有这些函数也将回调作为最后一个参数，就像save函数一样，它们的参数是错误和响应.
这三个函数是 :
此函数查找与条件对象中的字段匹配的所有文档. Mongo中使用的相同运算符也适用于mongoose.例如，这将从人员集合中获取所有文档.
Person.find(function(err, response){
console.log(response);
});这将获取字段名称为"Ayush"且年龄为20的所有文档.
Person.find({name: "Ayush", age: 20},
function(err, response){
console.log(response);
});我们还可以提供我们需要的预测，即我们需要的字段.例如，如果我们只想要国籍 "印度"的人的名称，我们使用 :
Person.find({nationality: "Indian"},
"name", function(err, response) {
console.log(response);
});此函数始终提取单个最相关的文档.它与Model.find()具有完全相同的参数.
此函数接受 _id (由mongo定义)作为第一个参数，一个可选的投影字符串和一个处理响应的回调.例如，
Person.findById("507f1f77bcf86cd799439011",
function(err, response){
console.log(response);
});让我们创建一条路线来查看所有人的记录.
var koa = require('koa');
var _ = require('koa-router')();
var app = koa();
var mongoose = require('mongoose');
mongoose.connect('mongodb://localhost/my_db');
var personSchema = mongoose.Schema({
name: String,
age: Number,
nationality: String
});
var Person = mongoose.model("Person", personSchema);
_.get('/people', getPeople);
function *getPeople(next){
var self = this;
yield Person.find(function(err, response){
self.body = response;
});
}
app.use(_.routes());
app.listen(3000);Mongoose提供三种更新文件的功能.
此函数接受一个条件并将对象更新为输入，并将更改应用于与集合中的条件匹配的所有文档.例如，以下代码将更新所有Person文档以具有"American"国籍.
Person.update({age: 25},
{nationality: "American"},
function(err, response){
console.log(response);
});它完全符合所说.根据查询查找一个文档，并根据第二个参数进行更新.它还将回调作为最后一个参数.例如，
Person.findOneAndUpdate({name: "Ayush"},
{age: 40},
function(err, response){
console.log(response);
});此函数更新由其id标识的单个文档.例如，
Person.findByIdAndUpdate("507f1f77bcf86cd799439011",
{name: "James"},
function(err, response){
console.log(response);
});让我们创建一条更新人的路线.这将是一个PUT路由，其中id为参数，有效载荷中包含详细信息.
var koa = require('koa');
var _ = require('koa-router')();
var app = koa();
var mongoose = require('mongoose');
mongoose.connect('mongodb://localhost/my_db');
var personSchema = mongoose.Schema({
name: String,
age: Number,
nationality: String
});
var Person = mongoose.model("Person", personSchema);
_.put('/people/:id', updatePerson);
function *updatePerson() {
var self = this;
yield Person.findByIdAndUpdate(self.params.id,
{$set: {self.request.body}}, function(err, response){
if(err) {
self.body = {
message: "Error in updating person with id " + self.params.id};
} else {
self.body = response;
}
});
}
app.use(_.routes());
app.listen(3000);要测试此路线，请在终端中输入以下内容(将ID替换为您创建的人员的ID).
curl -X PUT --data "name = James&age = 20&nationality = American" https://localhost:3000/people/507f1f77bcf86cd799439011
这将使用上述详细信息更新与路径中提供的ID相关联的文档.
我们已经涵盖了 C reate， R ead和 U pdate，现在我们将看到如何使用mongoose来删除文档.这里有三个函数，就像更新一样.
此函数将条件对象作为输入并删除符合条件的所有文档.例如，如果我们需要移除所有20岁的人，
Person.remove({age:20});此函数删除单，最相关的文件根据条件对象.例如，
Person.remove({age:20});此函数删除由其id标识的单个文档.例如，
Person.findByIdAndRemove("507f1f77bcf86cd799439011");现在让我们创建一条删除数据库中人员的路线.
var koa = require('koa');
var _ = require('koa-router')();
var app = koa();
var mongoose = require('mongoose');
mongoose.connect('mongodb://localhost/my_db');
var personSchema = mongoose.Schema({
name: String,
age: Number,
nationality: String
});
var Person = mongoose.model("Person", personSchema);
_.delete('/people/:id', deletePerson);
function *deletePerson(next){
var self = this;
yield Person.findByIdAndRemove(self.params.id, function(err, response){
if(err) {
self.body = {message: "Error in deleting record id " + self.params.id};
} else {
self.body = {message: "Person with id " + self.params.id + " removed."};
}
});
}
app.use(_.routes());
app.listen(3000);要测试这个，请使用以下curl命令 :
curl -X DELETE https://localhost:3000/people/507f1f77bcf86cd799439011
这将删除具有给定id的人，产生以下消息. :
{message: "Person with id 507f1f77bcf86cd799439011 removed."}这包含了我们如何使用MongoDB，mongoose和Koa创建简单的CRUD应用程序.要进一步探索猫鼬，请阅读 API文档.
