nodejs操作mongodb的增删改查功能实例

下面我为您详细讲解一下“nodejs操作mongodb的增删改查功能实例”的完整攻略。

1. 环境准备

首先，我们需要安装 MongoDB 数据库和 Node.js 运行时环境。具体安装步骤不再赘述，在这里略去。

在安装完毕之后，我们需要安装 MongoDB 驱动程序 mongoose。

npm install mongoose --save

2. 连接 MongoDB 数据库

创建一个新的 Node.js 模块，取名称为 db.js，然后在该模块中编写连接 MongoDB 数据库的代码。

const mongoose = require('mongoose');
mongoose.connect('mongodb://localhost:27017/test');
const db = mongoose.connection;
db.on('error', console.error.bind(console, 'connection error:'));
db.once('open', function() {
  console.log('MongoDB connected');
});

以上代码中，我们使用 mongoose.connect() 方法来连接 MongoDB 数据库。如果连接成功，消息 “MongoDB connected” 将打印到控制台。

3. 定义模型

在 Node.js 中，要使用 MongoDB，我们需要在代码中定义一个模型，表示数据库中的集合。在示例中，我们定义了一个 Person 模型，表示一个文档（即数据库中的一条记录）。

const mongoose = require('mongoose');
const Schema = mongoose.Schema;

const personSchema = new Schema({
  name: String,
  age: Number,
  gender: String
});

const Person = mongoose.model('Person', personSchema);

module.exports = Person;

例如，上述代码中定义了一个 Person 模型，并将其导出，以便其他模块中的代码可以使用它。

4. 实现增删改查功能

下面我们将讲解如何在 Node.js 中实现 MongoDB 数据库的增删改查功能。

4.1 插入数据

首先，我们需要在 Node.js 中编写插入数据的代码。在此之前，我们需要先定义一个 Person 模型，如上文所述。

const Person = require('./db');

const person = new Person({
    name: 'Tom',
    age: 20,
    gender: 'male'
});

person.save((err, res) => {
    if (err) {
        console.log('Error:' + err);
    } else {
        console.log('Success');
    }
});

以上代码中，我们首先导入了我们之前定义的 Person 模型。之后，我们使用该模型的构造方法创建了一个新的 person 对象，并设置其属性值。最后，我们调用 person.save() 方法将该对象保存到数据库中。如果保存成功，我们将在控制台中输出一个 Success 消息。

4.2 查询数据

接下来，我们将讲解如何在 Node.js 中编写查询数据的代码。

Person.find((err, res) => {
    if (err) {
        console.log('Error:' + err);
    } else {
        console.log(res);
    }
});

以上代码中，我们调用了 Person.find() 方法来查询 Person 集合中的所有文档。如果查询成功，我们将在控制台中输出一个包含所有文档的数组。

4.3 更新数据

现在我们来看一下如何在 Node.js 中编写更新数据的代码。

Person.findByIdAndUpdate('person_id', { age: 30 }, (err, res) => {
    if (err) {
        console.log('Error:' + err);
    } else {
        console.log('Success');
    }
});

以上代码中，我们使用 Person.findByIdAndUpdate() 方法来更新数据库中的文档。该方法接受三个参数：文档的 ID、要更新的属性及其新值、回调函数。如果更新成功，我们将在控制台中输出一个 Success 消息。

4.4 删除数据

最后，我们将演示如何在 Node.js 中实现删除数据的功能。

Person.findByIdAndDelete('person_id', (err, res) => {
    if (err) {
        console.log('Error:' + err);
    } else {
        console.log('Success');
    }
});

以上代码中，我们使用 Person.findByIdAndDelete() 方法来删除数据库中的文档。该方法接受两个参数：文档的 ID、回调函数。如果删除成功，我们将在控制台中输出一个 Success 消息。

示例说明

下面是两个对以上示例的说明：

示例一：插入一条文档

首先，我们定义一个 Person 模型，如上文所述。之后，我们在项目目录下创建一个名为 add.js 的文件，包含以下代码：

const Person = require('./db');

const person = new Person({
    name: 'Tom',
    age: 20,
    gender: 'male'
});

person.save((err, res) => {
    if (err) {
        console.log('Error:' + err);
    } else {
        console.log('Success');
    }
});

之后在终端中运行该文件，命令如下：

node add.js

如果插入成功，控制台将输出一个 Success 消息。

示例二：查询所有文档

首先，我们定义一个 Person 模型，如上文所述。之后，我们在项目目录下创建一个名为 query.js 的文件，包含以下代码：

const Person = require('./db');

Person.find((err, res) => {
    if (err) {
        console.log('Error:' + err);
    } else {
        console.log(res);
    }
});

之后在终端中运行该文件，命令如下：

node query.js

如果查询成功，控制台将输出一个包含所有文档的数组。