28 Node.js连接MongoDB

在本节中，我们将学习如何使用Node.js连接到MongoDB数据库。我们将通过简单的示例，逐步实现连接和基本操作。

环境准备

1. 安装Node.js：确保你的系统中安装了Node.js。可以通过命令 node -v 检查版本。
2. 安装MongoDB：确保你已经安装了MongoDB并运行在本地或使用云服务（如MongoDB Atlas）。
3. 创建项目：创建一个新目录并初始化一个Node.js项目。

   mkdir my-mongo-project
   cd my-mongo-project
   npm init -y

4. 安装MongoDB驱动：

   npm install mongodb

连接MongoDB

下面是连接MongoDB的基本代码示例。

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

// 替换为你的MongoDB连接字符串
const url = 'mongodb://localhost:27017';
const dbName = 'mydatabase';

async function main() {
    const client = new MongoClient(url);

    try {
        // 连接到MongoDB
        await client.connect();
        console.log('连接到MongoDB成功');

        // 选择数据库
        const db = client.db(dbName);

        // 在这里可以执行数据库操作
    } catch (err) {
        console.error('连接到MongoDB失败', err);
    } finally {
        // 关闭连接
        await client.close();
    }
}

main().catch(console.error);

代码解析

• MongoClient: 从 mongodb 包中导入 MongoClient，用于建立数据库连接。
• 连接字符串: 使用 mongodb://localhost:27017 连接到本地MongoDB实例。
• async/await: 使用异步编程来处理连接和数据库操作，确保代码的可读性和简洁性。

数据库基本操作

通过连接成功后，我们可以进行基本的数据库操作，比如插入、查询和更新数据。

插入文档

插入一条文档到集合中：

async function insertDocument(db) {
    const collection = db.collection('users');
    const user = { name: 'Alice', age: 25 };
    
    const result = await collection.insertOne(user);
    console.log(`插入成功，文档 id: ${result.insertedId}`);
}

// 在main函数中调用
await insertDocument(db);

查询文档

查询集合中的文档：

async function findDocuments(db) {
    const collection = db.collection('users');
    
    const users = await collection.find({}).toArray();
    console.log('找到的用户:', users);
}

// 在main函数中调用
await findDocuments(db);

更新文档

更新集合中的文档：

async function updateDocument(db) {
    const collection = db.collection('users');
    const result = await collection.updateOne({ name: 'Alice' }, { $set: { age: 26 } });
    
    console.log(`更新成功，已修改文档数量: ${result.modifiedCount}`);
}

// 在main函数中调用
await updateDocument(db);

删除文档

删除集合中的文档：

async function deleteDocument(db) {
    const collection = db.collection('users');
    const result = await collection.deleteOne({ name: 'Alice' });
    
    console.log(`删除成功，已删除文档数量: ${result.deletedCount}`);
}

// 在main函数中调用
await deleteDocument(db);

完整代码示例

将上述所有操作整合到 main 函数中：

async function main() {
    const client = new MongoClient(url);

    try {
        await client.connect();
        console.log('连接到MongoDB成功');
        const db = client.db(dbName);

        // 插入文档
        await insertDocument(db);
        // 查询文档
        await findDocuments(db);
        // 更新文档
        await updateDocument(db);
        // 删除文档
        await deleteDocument(db);
    } catch (err) {
        console.error('操作失败', err);
    } finally {
        await client.close();
    }
}

总结

在本节中，我们介绍了如何使用Node.js连接MongoDB实例，并执行基本的增、查、改、删操作。通过这些操作，你可以开始构建更复杂的应用程序，利用MongoDB的强大功能。