Node Mongo Examples使用Node对MongoDB进行查询和数据修改

在中，我们将深入探讨如何使用 Node.js 与 MongoDB 数据库进行交互，特别是在执行查询和数据修改操作方面。 MongoDB 是一个非常流行的文档型数据库系统，它使用 JSON 格式的文档存储数据，而 Node.js 则是一个轻量级、高性能的 JavaScript 运行环境，非常适合构建服务器端应用程序。当这两者结合时，我们可以构建高效且可扩展的 Web 服务。

要开始使用 Node.js 与 MongoDB，我们需要安装 mongodb 驱动程序，这可以通过 npm（Node.js 包管理器）来完成。在命令行中运行以下命令：

npm install mongodb --save

安装完成后，我们可以创建一个 Node.js 项目，并引入 mongodb 库：

const MongoClient = require('mongodb').MongoClient;

const uri = 'mongodb+srv://:@cluster0.mongodb.net/test?retryWrites=true&w=majority';

</password>sername>

这里的 uri 是你的 MongoDB 连接字符串，需要替换 和 为实际的 MongoDB 账户凭据。

接下来，我们使用 MongoClient.connect() 方法连接到 MongoDB 集群：

MongoClient.connect(uri, { useNewUrlParser: true, useUnifiedTopology: true }, (err, client) => {

  if (err) throw err;

  console.log(\"Connected to MongoDB\");

  const db = client.db('your_database_name');

  //在这里执行你的查询和修改操作

  client.close();

});

现在，让我们看看如何执行基本的查询操作。假设我们有一个名为 users 的集合，我们可以使用 db.collection() 获取集合引用，然后调用 find() 方法查询数据：

const usersCollection = db.collection('users');

usersCollection.find({}).toArray((err, docs) => {

  if (err) throw err;

  console.log(\"Users:\", docs);

});

这将返回集合中所有用户的列表。如果想根据特定条件查询，可以传入查询对象，例如找名字为 \"John\" 的用户：

usersCollection.find({ name: 'John' }).toArray((err, docs) => {

  if (err) throw err;

  console.log(\"Johns:\", docs);

});

对于数据修改操作，我们可以使用 updateOne()，updateMany()，或 findOneAndUpdate() 方法。例如，我们要更新名字为 \"John\" 的用户年龄：

usersCollection.findOneAndUpdate( {

  name: 'John' }, {

  $set: { age: 30 } }, {

  returnOriginal: false }

  , (err, result) => {

  if (err) throw err;

  console.log(\"Updated user:\", result.value);

});

returnOriginal: false 参数使得 findOneAndUpdate 返回更新后的文档，而不是更新前的版本。

除了 updateOne()，updateMany() 方法还可以批量更新多条匹配的记录。例如，将所有年龄小于 30 岁的用户年龄加 1：

usersCollection.updateMany( {

  age: { $lt: 30 } }, {

  $inc: { age: 1 } }

  , (err, res) => {

  if (err) throw err;

  console.log(`Updated ${res.modifiedCount} documents.`);

});

此外，MongoDB 还支持 deleteOne()，deleteMany() 方法用于删除数据。例如，删除名字为 \"John\" 的用户：

usersCollection.deleteOne({ name: 'John' }, (err, res) => {

  if (err) throw err;

  console.log(`Deleted ${res.deletedCount} document(s).`);

});