Node.js 中的 MongoDB CRUD 操作指南

2023-12-22 06:38:09

使用 Node.js 执行 MongoDB CRUD 操作的全面指南

摘要：

本文旨在提供一份全面且循序渐进的指南，指导开发者在 Node.js 环境中对 MongoDB 数据库执行创建 (C)、读取 (R)、更新 (U) 和删除 (D) 操作（简称 CRUD）。我们将使用 MongoDB 官方驱动包来执行这些操作，同时提供代码示例、最佳实践和故障排除技巧。

目录：

CRUD 操作概述
安装和设置
连接到 MongoDB
创建 (C) 操作
读取 (R) 操作
更新 (U) 操作
删除 (D) 操作
最佳实践
故障排除

正文：

CRUD 操作概述

CRUD（创建、读取、更新和删除）操作是与数据库交互的基本操作。对于 MongoDB 来说，这些操作可以通过使用驱动程序包（例如官方 MongoDB 驱动程序包）来实现。

安装和设置

首先，在你的项目中安装 MongoDB 驱动程序包：

npm install mongodb

连接到 MongoDB

在 Node.js 中，可以使用以下代码连接到 MongoDB：

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

const uri = "mongodb://localhost:27017";
const client = new MongoClient(uri, { useNewUrlParser: true, useUnifiedTopology: true });

client.connect(err => {
  if (err) {
    console.error(err);
    return;
  }
  console.log("Connected to MongoDB");
  
  // 执行 CRUD 操作
  
  client.close();
});

创建 (C) 操作

使用 insertOne() 或 insertMany() 方法插入一个或多个文档：

// 插入一个文档
db.collection('users').insertOne({ name: 'John Doe' }, (err, result) => {
  if (err) {
    console.error(err);
    return;
  }
  console.log(`Inserted document with id: ${result.insertedId}`);
});

// 插入多个文档
db.collection('users').insertMany([{ name: 'Jane Doe' }, { name: 'Peter Parker' }], (err, result) => {
  if (err) {
    console.error(err);
    return;
  }
  console.log(`Inserted ${result.insertedCount} documents`);
});

读取 (R) 操作

使用 find()、findOne() 和 aggregate() 方法检索文档：

// 查找所有文档
db.collection('users').find({}).toArray((err, docs) => {
  if (err) {
    console.error(err);
    return;
  }
  console.log(`Found ${docs.length} documents`);
  console.log(docs);
});

// 查找一个文档
db.collection('users').findOne({ name: 'John Doe' }, (err, doc) => {
  if (err) {
    console.error(err);
    return;
  }
  console.log(`Found document:`);
  console.log(doc);
});

// 使用聚合管道
db.collection('users').aggregate([{ $group: { _id: null, totalUsers: { $sum: 1 } } }]).toArray((err, result) => {
  if (err) {
    console.error(err);
    return;
  }
  console.log(`Total number of users: ${result[0].totalUsers}`);
});

更新 (U) 操作

使用 updateOne()、updateMany() 和 replaceOne() 方法更新文档：

// 更新一个文档
db.collection('users').updateOne({ name: 'John Doe' }, { $set: { email: 'john.doe@example.com' } }, (err, result) => {
  if (err) {
    console.error(err);
    return;
  }
  console.log(`Updated ${result.modifiedCount} document(s)`);
});

// 更新多个文档
db.collection('users').updateMany({ age: { $gt: 25 } }, { $inc: { age: 1 } }, (err, result) => {
  if (err) {
    console.error(err);
    return;
  }
  console.log(`Updated ${result.modifiedCount} document(s)`);
});

// 替换一个文档
db.collection('users').replaceOne({ name: 'Jane Doe' }, { name: 'Jane Smith', age: 30 }, (err, result) => {
  if (err) {
    console.error(err);
    return;
  }
  console.log(`Replaced ${result.modifiedCount} document(s)`);
});

删除 (D) 操作

使用 deleteOne() 和 deleteMany() 方法删除文档：

// 删除一个文档
db.collection('users').deleteOne({ name: 'Peter Parker' }, (err, result) => {
  if (err) {
    console.error(err);
    return;
  }
  console.log(`Deleted ${result.deletedCount} document(s)`);
});

// 删除多个文档
db.collection('users').deleteMany({ age: { $lt: 18 } }, (err, result) => {
  if (err) {
    console.error(err);
    return;
  }
  console.log(`Deleted ${result.deletedCount} document(s)`);
});