如何使用 Node.js 和 MongoDB 进行 CRUD？）下载系统适用的MongoDB后

2024-06-30 19:56:43 [百科] 来源：避面尹邢网

如何使用 Node.js 和 MongoDB 进行 CRUD？

译文作者：黄显东 2021-06-15 15:03:21开发开发工具 MongoDB Node.js和MongoDB提供了非常快速和灵活的何使s和开发体验。看看我们在MongoDB中使用Node创建、何使s和读取、何使s和更新和删除文档是何使s和多么的快速和容易。

[[405702]]

【51CTO.com快译】MongoDB是何使s和最早的NoSQL数据存储之一，也是何使s和目前流行的NoSQL数据存储。Node.js的何使s和JavaScript运行时继续在后端开发中占据主导地位。它们共同构成了一个高度灵活和动态的何使s和技术堆栈。

如何使用 Node.js 和 MongoDB 进行 CRUD？）下载系统适用的MongoDB后

Node.js和MongoDB允许快速实现基本的何使s和应用程序功能，如CRUD(创建、何使s和读取、何使s和更新和删除)操作。何使s和在本文中，何使s和我们将使用最新的何使s和 Node.js MongoDB 驱动程序（版本 3.6+）来了解 CRUD 基础知识。

如何使用 Node.js 和 MongoDB 进行 CRUD？）下载系统适用的MongoDB后

Node.js 和 MongoDB 设置

先在系统上安装Node.js和MongoDB，何使s和以及一个包含`curl`可用命令的命令行。（如果你使用的是 2018 年以后的 Linux、MacOS 或 Windows 10 版本，则很可能使用[curl](https://curl.se/)。）

如何使用 Node.js 和 MongoDB 进行 CRUD？）下载系统适用的MongoDB后

下载系统适用的MongoDB后，可以将其安装为服务或将其作为可执行文件运行。无论哪种方式，请通过打开命令行并运行`mongo`命令来确保 MongoDB 正在运行。（如果没有作为服务安装，可能需要将该命令添加到路径中。）这使你可以访问系统上运行的 MongoDB 实例。

接下来，确保安装了 Node.js 和 npm。在命令行中，键入`node -v`。如果安装了 Node.js，将获得版本号。如果没有，则需要下载Node.js并安装到机器上。

Curl允许从命令行执行简单的HTTP请求。例如，运行`curl www.google.com`将收到来自 Google 主页的标记。

创建一个 Node.js 项目

在文件夹中创建一个npm init类型的新项目。项目名称可以使用node-mongo-intro。当然，你也可以接受其他缺省值。

添加所需的依赖项。在刚创建的项目目录中，键入`npm install mongodb polka --save`. 这将安装 MongoDB 的 Node.js 驱动程序（允许项目访问 MongoDB）和用于处理 HTTP 请求的Polka HTTP 服务器。

编辑 package.json 文件以包含启动脚本，如Listing 1 所示。

Listing 1. A start script

"scripts": { 
"test": "echo \"Error: no test specified\" && exit 1",
"start": "node src/index" // <-- add this line
},

接着创建一个 /node-mongo-intro/src/index.js 文件，并将Listing 2 的内容放入其中。

Listing 2. HTTP test in index.js

const polka = require('polka');

polka()
.get('/create', (req, res) => { 
res.end(`works`);
})
.listen(3000, err => { 
if (err) throw err;
console.log(`> Running on localhost:3000`);
});

现在用`npm run start`启动服务器。服务器将在端口3000上侦听。你可以使用curl http://localhost:3000/create进行测试。测试后应该会看到“works”的响应(以及一些curl请求信息)。

在 MongoDB 中插入一条记录

现在我们将执行一个简单的插入。这是 CRUD 中的 “C”。将`index.js`文件更新为如Listing 3 所示。

Listing 3. A simple insert

const polka = require('polka');
const {  MongoClient } = require("mongodb");

polka()
.get('/create', (req, res) => { 
const client = new MongoClient("mongodb://localhost:27017");
async function run() { 
try { 
await client.connect();
const database = client.db("intro");
const collection = database.collection("quotes");

const result = await collection.insertOne({ "quote":"Life is what happens to you while you're busy making other plans."});
res.end(JSON.stringify(result));
} catch (e) { 
console.log("Error: " + e);
} finally { 
await client.close();
}
}
run().catch(console.dir);
})
.listen(3000, err => { 
if (err) throw err;
console.log(`> Running on localhost:3000`);
});

Listing 3 中的代码打开到本地系统上 MongoDB 实例的连接，然后指定一个数据库 ( `"intro"`) 和集合 ( `"quotes"`)。集合类似于关系数据库中的表。

接下来，代码插入一个文档（类似于 SQL 记录）并在一个HTTP响应中发送结果。

运行插入

首先，按 Ctrl-C 停止并重新启动节点服务器。然后在命令行运行这个命令：

npm run startcurl http : //localhost:3000/create

验证插入

如果你掌握 SQL 技术，你会注意到的一件事是，我们在进行这项工作之前没有创建表和模式。我们甚至没有创建我们使用的数据库。因为 MongoDB 为我们完成了这些所需的工作，它可以接受任何类型的结构化键值文档到集合中。

使用mongo打开mongo shell，并输入命令use intro。这将切换到自动创建的intro数据库。现在输入db.quotes.find()命令，将看到该记录被插入。注意MongoDB会在“_id”字段上自动生成一个唯一的ID。你可以通过在文档上自己指定一个来覆盖它。

在MongoDB中检索文档

现在让我们把文件拿出来。添加如 Listing 4所示的.get()映射。这是CRUD中的“R”。

Listing 4. Retrieve a document

.get('/retrieve', (req, res) => { 
const client = new MongoClient("mongodb://localhost:27017");
async function run() { 

try { 
await client.connect();
const database = client.db("intro");
const collection = database.collection("quotes");

const cursor = collection.find({ }, { });

let items = [];
await cursor.forEach(function(doc){ 
items.push(doc);
});
res.end(JSON.stringify(items));
} catch (error){ 
console.warn("ERROR: " + error);
if (errCallback) errCallback(error);
} finally { 
await client.close();
}
}
run().catch(console.dir);
})

Listing 4 以与Listing 3 相同的方式连接，然后发出一个`find`命令，并带有一个空查询。这意味着它匹配所有文档。接下来，它接收响应并将其编组到一个数组中以发送回客户端。

注意，游标操作和集合是异步的。清单3中的collection.insertOne也是如此。我们使用await关键字来处理这些，而不使用嵌套的回调。

使用curl http://localhost:3000/retrieve测试新端点(在停止并再次启动服务器之后)，将看到返回的集合。

MongoDB中更新文档

现在是CRUD中的“U”。Listing 5处理了这一点。

Listing 5. Updating a document

.get('/update', (req, res) => { 
const client = new MongoClient("mongodb://localhost:27017");
async function run() { 
try { 
await client.connect();
const database = client.db("intro");
const collection = database.collection("quotes");

const updateDoc = { 
$set: { 
author:
"John Lennon",
},
};

const result = await collection.updateOne({ }, updateDoc, { }); // <-- empty filter matches all docs
res.end("Updated: " + result.modifiedCount);
} catch (e) { 
errCallback(e);
} finally { 
await client.close();
}
}
run().catch(console.dir);
})

Listing 5 再次连接到数据库，然后创建一个更新文档。本文档通过指定一个`$set`包含要更改的字段和值的对象的字段来告诉 MongoDB 要更改什么。在我们的例子中，我们将该`author`字段设置为`"John Lennon"`，即相关引用的引用者。

接下来，Listing 5 使用该`updateOne()`函数来执行更新文档。最后一个空对象参数是过滤器。在这种情况下，我们希望匹配所有文档，因此我们将其留空。

最后，我们发回我们更新的文档数量（一个）。

MongoDB中删除文档

CRUD的最后一个字母是“D”，表示删除。

删除操作的映射如Listing 6所示。

Listing 6. Deleting a document

.get('/delete', (req, res) => { 
const client = new MongoClient("mongodb://localhost:27017");
async function run() { 
try { 
await client.connect();
const database = client.db("intro");
const collection = database.collection("quotes");
const query = {  };
const result = await collection.deleteOne(query);
if (result.deletedCount === 1) { 
res.end("Successfully deleted one document.");
} else { 
res.end("Deleted 0 documents.");
}
} finally { 
await client.close();
}
}