Node.js对MongoDB进行增删改查操作的实例代码

下面为你详细讲解“Node.js对MongoDB进行增删改查操作的实例代码”的完整攻略。

前置要求

在进行操作之前，需要保证你已经安装好了 Node.js 和 MongoDB 数据库，并成功启动了 MongoDB 数据库服务。

安装 MongoDB 驱动

首先，需要在 Node.js 项目中安装 MongoDB 驱动，可以通过 npm 安装

npm install mongodb --save

连接 MongoDB

在进行操作之前，需要先连接到 MongoDB 数据库。可以通过如下代码连接到 MongoDB ，创建一个 MongoClient 实例

const MongoClient = require('mongodb').MongoClient;
const uri = "mongodb+srv://<username>:<password>@<your-cluster-url>/test?retryWrites=true&w=majority";
const client = new MongoClient(uri, { useNewUrlParser: true });
client.connect(err => {
  const collection = client.db("test").collection("devices");
  // perform actions on the collection object
  client.close();
});

MongoClient 是 MongoDB 驱动的核心类，用于连接数据库、创建集合、查询集合等操作。在使用 MongoClient 连接 MongoDB 时，需要提供 MongoDB 数据库的连接字符串。连接字符串可以通过 MongoDB 的 Atlas 服务进行查看和修改。

插入数据

使用 MongoClient 插入数据的方法是 insertOne() 和 insertMany()，下面以 insertOne() 方法为例，插入一条数据：

const MongoClient = require('mongodb').MongoClient;
const uri = "mongodb+srv://<username>:<password>@<your-cluster-url>/test?retryWrites=true&w=majority";
const client = new MongoClient(uri, { useNewUrlParser: true });
client.connect(err => {
  const collection = client.db("test").collection("devices");
  // 插入一条数据
  collection.insertOne({ name: 'iPhone', price: 6999 }, function(err, result) {
    if (err) throw err;
    console.log("插入成功, 其中id为：" + result.insertedId);
    client.close(); // 关闭连接
  });
});

查询数据

MongoDB 的查询操作在驱动库中通过 find() 方法实现，查询操作支持多种查询条件和排序方式，下面是一个简单的示例代码：

const MongoClient = require('mongodb').MongoClient;
const uri = "mongodb+srv://<username>:<password>@<your-cluster-url>/test?retryWrites=true&w=majority";
const client = new MongoClient(uri, { useNewUrlParser: true });
client.connect(err => {
  const collection = client.db("test").collection("devices");

  // 查询所有
  collection.find({}).toArray(function (err, result) {
      if (err) throw err;
      console.log(result);
  });

  // 查询名为 iPhone 的数据
  collection.find({ "name": "iPhone" }).toArray(function (err, result) {
      if (err) throw err;
      console.log(result);
  });

  client.close();
});

更新数据

使用 updateOne() 和 updateMany() 方法更新数据，下面以 updateOne() 为例：

const MongoClient = require('mongodb').MongoClient;
const uri = "mongodb+srv://<username>:<password>@<your-cluster-url>/test?retryWrites=true&w=majority";
const client = new MongoClient(uri, { useNewUrlParser: true });
client.connect(err => {
  const collection = client.db("test").collection("devices");
  // 更新单条数据
  collection.updateOne({name: "iPhone"}, {$set: {price: 5999}}, function (err, result) {
    if (err) throw err;
    console.log("更新成功");
    client.close();
  });
});

删除数据

使用 deleteOne() 或 deleteMany() 方法删除数据，下面以 deleteOne() 方法为例：

const MongoClient = require('mongodb').MongoClient;
const uri = "mongodb+srv://<username>:<password>@<your-cluster-url>/test?retryWrites=true&w=majority";
const client = new MongoClient(uri, { useNewUrlParser: true });
client.connect(err => {
  const collection = client.db("test").collection("devices");
  // 删除单条数据
  collection.deleteOne({name: "iPhone"}, function (err, result) {
    if (err) throw err;
    console.log("删除成功");
    client.close();
  });
});

以上是基础的增删改查操作示例。具体实现还需要根据业务需求添加相应的查询条件、排序、限制数量等操作。