MongoDB 使用 async/await 进行 NodeJS 连接

在本文中，我们将介绍如何使用 async/await 在 Node.js 中连接 MongoDB数据库。MongoDB是一个流行的开源数据库，它具有高性能、可伸缩性和灵活的数据模型。Node.js是一个基于事件驱动的JavaScript运行时，可用于构建高效且可扩展的网络应用程序。

阅读更多：MongoDB 教程

安装 MongoDB 驱动程序

在开始之前，我们首先需要安装 MongoDB 驱动程序。可以使用npm命令行工具来安装官方的MongoDB驱动程序mongodb。打开终端，并运行以下命令：

npm install mongodb

安装完成后，我们可以开始使用async/await在Node.js中连接到MongoDB数据库。

连接到 MongoDB 数据库

首先，我们需要在Node.js中导入MongoDB驱动程序。创建一个名为mongodb.js的文件，并添加以下代码：

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

const url = 'mongodb://localhost:27017';
const dbName = 'mydatabase';

const connectToMongoDB = async () => {
  try {
    const client = await MongoClient.connect(url);
    console.log('Connected to MongoDB');

    const db = client.db(dbName);

    // 在此处执行 MongoDB 操作

    client.close();
    console.log('Disconnected from MongoDB');
  } catch (error) {
    console.error('Failed to connect to MongoDB', error);
  }
};

connectToMongoDB();

在这个示例中，我们首先导入了MongoClient类，并定义了一个url变量，它存储了本地 MongoDB 数据库的连接URL。我们还定义了一个dbName变量，它表示要连接的数据库的名称。

然后，我们创建了一个名为connectToMongoDB的异步函数。在这个函数中，我们使用MongoClient.connect方法连接到 MongoDB 数据库。如果连接成功，我们将在控制台输出”Connected to MongoDB”。

接下来，我们使用client.db(dbName)方法获取与指定数据库名称相对应的数据库对象。在这个对象上，我们可以执行各种 MongoDB 操作，如插入、查询和更新。

最后，我们通过调用client.close方法关闭与 MongoDB 的连接，并在控制台输出”Disconnected from MongoDB”。

执行 MongoDB 操作

在上一节的代码中，有一个注释部分表示在连接成功时执行 MongoDB 操作。这里，我们将演示一些常见的 MongoDB 操作。

插入文档

要向 MongoDB 中的集合插入文档，我们可以使用insertOne或insertMany方法。以下是一些示例：

const insertDocuments = async (db) => {
  const collection = db.collection('documents');

  // 插入单个文档
  const document1 = { name: 'John', age: 30 };
  const result1 = await collection.insertOne(document1);
  console.log('Inserted document:', result1.insertedId);

  // 插入多个文档
  const document2 = { name: 'Jane', age: 25 };
  const document3 = { name: 'Sam', age: 35 };
  const result2 = await collection.insertMany([document2, document3]);
  console.log('Inserted documents:', result2.insertedIds);
};

insertDocuments(db);

在这个示例中，我们首先通过调用db.collection方法获取到了一个集合对象。然后，我们使用insertOne方法插入一个文档，并通过输出插入文档的insertedId来验证操作是否成功。

接下来，我们使用insertMany方法插入多个文档，并通过输出插入文档的insertedIds来验证操作是否成功。

查询文档

要查询 MongoDB 中的文档，我们可以使用find方法。以下是一个示例：

const findDocuments = async (db) => {
  const collection = db.collection('documents');

  // 查询所有文档
  const documents = await collection.find().toArray();
  console.log('Found documents:', documents);

  // 查询特定条件的文档
  const query = { age: { $gt: 30 } }; // 年龄大于30
  const filteredDocuments = await collection.find(query).toArray();
  console.log('Filtered documents:', filteredDocuments);
};

findDocuments(db);

在这个示例中，我们首先通过调用db.collection方法获取到了一个集合对象。然后，我们使用find方法查询所有文档，并通过调用toArray方法将结果转换为数组。最后，我们在控制台中输出查询结果。

此外，我们还可以通过在find方法中传入查询条件来查询特定条件的文档。在这个示例中，我们查询年龄大于30的文档，并输出结果。

更新文档

要更新 MongoDB 中的文档，我们可以使用updateOne或updateMany方法。以下是一个示例：

const updateDocuments = async (db) => {
  const collection = db.collection('documents');

  // 更新单个文档
  const filter = { name: 'John' };
  const update = {  $set: { age: 35 } }; // 设置年龄为35 const result1 = await collection.updateOne(filter, update); console.log('Updated document count:', result1.modifiedCount); // 更新多个文档 const query = { age: {$ lt: 30 } }; // 年龄小于30
  const update2 = { $inc: { age: 5 } }; // 增加年龄5岁
  const result2 = await collection.updateMany(query, update2);
  console.log('Updated documents count:', result2.modifiedCount);
};

updateDocuments(db);

在这个示例中，我们首先通过调用db.collection方法获取到了一个集合对象。然后，我们使用updateOne方法更新符合条件的单个文档，并通过输出modifiedCount来验证操作是否成功。

接下来，我们使用updateMany方法更新符合条件的多个文档，并通过输出modifiedCount来验证操作是否成功。

总结

在本文中，我们通过使用 async/await 在 Node.js 中连接 MongoDB 数据库。我们了解了如何安装 MongoDB 驱动程序，并使用示例代码演示了如何执行插入、查询和更新等常见的 MongoDB 操作。通过这种方法，我们可以以更简洁、直观的方式处理数据库操作，并且使我们的代码更易于维护和扩展。

如果您想深入了解 MongoDB 和 Node.js，请查阅官方文档和其他相关资源，继续提升您的技能。

希望本文对您有所帮助，谢谢阅读！