HTML CSS JAVASCRIPT PYTHON PYTHON2 JAVA C C++ C# SQL Excel Linux AI BOOTSTRAP PHP 教程库 参考手册 技术文章 测验 练习 HOWTO FAQ
❮ 上一节 下一节 ❯

Koa.js - 数据库

我们接收请求，但并未将它们存储在任何地方。我们需要一个数据库来存储数据。我们将使用一个著名的 NoSQL 数据库 MongoDB。要安装并了解 Mongo，请访问此链接。

为了将 Mongo 与 Koa 结合使用，我们需要一个节点的客户端 API。我们有多种选择，但在本教程中，我们将坚持使用 mongoose。Mongoose 用于 Node 中 MongoDB 的文档建模。文档建模意味着，我们将创建一个模型(非常类似于面向文档编程中的类)，然后我们将使用此模型生成文档(就像我们在 OOP 中创建类的文档一样)。我们所有的处理都将在这些"文档"上完成，最后，我们将这些文档写入我们的数据库。

设置 Mongoose

现在我们已经安装了 Mongo，让我们安装 mongoose，就像我们安装其他节点包一样。

$ npm install --save mongoose

在开始使用 mongoose 之前，我们必须使用 Mongo shell 创建一个数据库。要创建新数据库，请打开终端并输入"mongo"。 Mongo shell 将启动，输入以下内容。

use my_db

将为您创建一个新数据库。每当您打开 Mongo shell 时，它都会默认为"test"db，您必须使用与上述相同的命令更改为您的数据库。

要使用 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 中添加一个新的 get 路由来呈现此文档。

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，尚未运行。我们的表单如下所示。

Mongoose Create

我们现在将在"/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; //获取解析后的信息
   
   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 Response

我们现在有一个创建人员的界面!

检索文档

Mongoose 提供了很多用于检索文档的函数，我们将重点介绍其中的三个。所有这些函数也将回调作为最后一个参数，并且与 save 函数一样，它们的参数是 error 和 response。

这三个函数是 −

Model.find(conditions, callback)

此函数查找与条件对象中的字段匹配的所有文档。Mongo 中使用的相同运算符也适用于 mongoose。例如，这将从人员集合中获取所有文档。

Person.find(function(err, response){
    console.log(response);
});

这将获取字段名称为"Ayush"且年龄为 20 的所有文档。

Person.find({name: "Ayush", age: 20}, 
   function(err, response){
      console.log(response);
   });

我们还可以提供所需的投影，即所需的字段。例如，如果我们只想要国籍为"Indian"的人的姓名，我们使用 −

Person.find({nationality: "Indian"}, 
   "name", function(err, response) {
      console.log(response);
   });

Model.findOne(conditions, callback)

此函数始终获取单个最相关的文档。它具有与 Model.find() 完全相同的参数。

Model.findById(id, callback)

此函数将 _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(condition, updates, callback)

此函数以条件和更新对象作为输入，并将更改应用于集合中符合条件的所有文档。例如，以下代码将更新所有 Person 文档，使其国籍为"美国"。

Person.update({age: 25},
   {nationality: "American"}, 
   function(err, response){
      console.log(response);
   });

Model.findOneAndUpdate(condition, updates, callback)

它的作用正如其名称所示。根据查询查找一个文档，并根据第二个参数更新该文档。它还将回调作为最后一个参数。例如，

Person.findOneAndUpdate({name: "Ayush"}, 
   {age: 40}, 
   function(err, response){
      console.log(response);
   });

Model.findByIdAndUpdate(id, updates, callback)

此函数更新由其 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 关联的文档。

删除文档

我们已经介绍了Create、Read 和Update，现在我们将了解如何使用 mongoose 删除文档。这里有三个函数，与更新完全相同。

Model.remove(condition, [callback])

此函数以条件对象作为输入，并删除所有符合条件的文档。例如，如果我们需要删除所有 20 岁的人，

Person.remove({age:20});

Model.findOneAndRemove(condition, [callback])

此函数根据条件对象删除单个最相关的文档。例如，

Person.findOneAndRemove({name: "Ayush"});

Model.findByIdAndRemove(id, [callback])

此函数删除由其 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 文档。

❮ 上一节 下一节 ❯