- Koa.js 教程
- Koa.js - 主页
- Koa.js - 概述
- Koa.js - 环境
- Koa.js - 你好世界
- Koa.js - 生成器
- Koa.js - 路由
- Koa.js - URL 构建
- Koa.js - HTTP 方法
- Koa.js - 请求对象
- Koa.js - 响应对象
- Koa.js - 重定向
- Koa.js - 错误处理
- Koa.js - 级联
- Koa.js - 模板
- Koa.js - 表单数据
- Koa.js - 文件上传
- Koa.js - 静态文件
- Koa.js - Cookie
- Koa.js - 会话
- Koa.js - 身份验证
- Koa.js - 压缩
- Koa.js - 缓存
- Koa.js - 数据库
- Koa.js - RESTful API
- Koa.js - 日志记录
- Koa.js - 脚手架
- Koa.js - 资源
- Koa.js 有用资源
- Koa.js - 快速指南
- Koa.js - 有用的资源
- Koa.js - 讨论
Koa.js - 数据库
我们正在收到请求,但不会将它们存储在任何地方。我们需要一个数据库来存储数据。我们将使用一个名为MongoDB的著名 NoSQL 数据库。要安装并阅读有关 Mongo 的信息,请访问此链接。
为了将 Mongo 与 Koa 结合使用,我们需要一个节点的客户端 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”数据库,您必须使用与上面相同的命令更改为数据库。
要使用 mongoose,我们将在 app.js 文件中需要它,然后连接到在 mongodb://localhost 上运行的 mongod 服务
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);
上面的代码定义了一个人的模式,并用于创建一个 mongoose 模型Person。
保存文档
现在我们将创建一个新的 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()函数将其保存到我们的数据库中。这是在 mongoose 中定义的,并接受回调作为参数。此回调有两个参数:error和response。这将呈现 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 函数一样,它们的参数是错误和响应。
这三个功能是 -
Model.find(条件,回调)
该函数查找与条件对象中的字段匹配的所有文档。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.findOne(条件,回调)
此函数始终获取单个最相关的文档。它具有与 Model.find() 完全相同的参数。
Model.findById(id, 回调)
该函数接受_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 提供了三个更新文档的函数。
Model.update(条件、更新、回调)
此函数采用条件和更新对象作为输入,并将更改应用于与集合中的条件匹配的所有文档。例如,以下代码将更新所有个人文档以具有“美国”国籍。
Person.update({age: 25}, {nationality: "American"}, function(err, response){ console.log(response); });
Model.findOneAndUpdate(条件、更新、回调)
它确实如所说的那样。根据查询查找一个文档并根据第二个参数更新该文档。它还采用回调作为最后一个参数。例如,
Person.findOneAndUpdate({name: "Ayush"}, {age: 40}, function(err, response){ console.log(response); });
Model.findByIdAndUpdate(id, 更新, 回调)
此函数更新由其 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 关联的文档。
删除文档
我们已经介绍了创建、读取和更新,现在我们将了解如何使用 mongoose 删除文档。这里有3个函数,和update一模一样。
Model.remove(条件, [回调])
该函数将条件对象作为输入,并删除所有符合条件的文档。例如,如果我们需要删除所有20岁的人,
Person.remove({age:20});
Model.findOneAndRemove(条件, [回调])
此函数根据条件对象删除单个最相关的文档。例如,
Person.findOneAndRemove({name: "Ayush"});
Model.findByIdAndRemove(id, [回调])
此函数删除由其 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 应用程序。要进一步探索 mongoose,请阅读API 文档。