Nodejs调用MongoDB

淡淡的烟草味﹌ 2022-11-19 11:26 208阅读 0赞

# Nodejs调用MongoDB #

*  要在 MongoDB 中创建一个数据库，首先我们需要创建一个 MongoClient 对象，然后配置好指定的 URL 和 端口号。
    
    如果数据库不存在，MongoDB 将创建数据库并建立连接。

1.  导入MongoDB包：

cnpm install mongodb --save

1.  引入MongoDB文件：

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

1.  定义数据库连接地址url，定义要操作的数据库dbName， 实例化MongoClient 传入数据库连接地址：

const url = 'mongodb://127.0.0.1:27017';
    
    const dbName = 'aniu';
    
    const client = new MongoClient(url, { useUnifiedTopology: true });

1.  连接数据库：

client.connect((err)=>{
    	if(err){
    		console.log(err);
    		return;
    	}
      console.log('数据库连接成功');
    });

## 操作数据库 ##

1.  查找数据：

db.collection('user').find({ "age": 13 }).toArray((err, data) => {
            console.log(data);
            // 操作数据库完成以后要关闭数据库连接
            client.close();
    
        })

1.  增加数据：

db.collection('user').insertOne({ 'username': 'nodejs操作mongodb', 'age': 10 }, (err, result) => {
            if (err) {
                console.log(err);
                return;
            }
            console.log("增加成功")
            console.log(result);
            // 操作数据库完成以后要关闭数据库连接
            client.close();
        })

1.  修改数据：

db.collection('user').updateOne({ 'username': 'kko1' }, { $set: { 'age': 111222 } }, (err, result) => {
            if (err) {
                console.log(err);
                return;
            }
            console.log('修改成功');
            console.log(result);
            // 操作数据库完成以后要关闭数据库连接
            client.close();
        })

1.  删除一条数据：

db.collection('user').deleteOne({ 'name': 'aniu' }, (err) => {
            if (err) {
                console.log(err);
                return;
            }
            console.log('删除一条数据成功');
            client.close();
        })

1.  删除多条数据：

db.collection('user').deleteMany({ 'name': 'zhangsan' }, (err) => {
            if (err) {
                console.log(err);
                return;
            }
            console.log('删除多条数据成功');
            client.close();
        })

总结：

// cnpm istall mongodb --save
    
    //  引入mongodb文件
    const { MongoClient } = require('mongodb');
    
    // 定义数据库连接的地址
    const url = 'mongodb://127.0.0.1:27017';
    
    // 定义要操作的数据库
    const dbName = 'aniu';
    
    
    // 实例化MongoClient 传入数据库连接地址
    const client = new MongoClient(url, { useUnifiedTopology: true });
    // 连接数据库
    client.connect((err) => {
        if (err) {
            conssole.log(err);
            return;
        }
        console.log('数据库连接成功');
        let db = client.db(dbName);
    
    
        // 1.查找数据
        // db.collection('user').find({ "age": 13 }).toArray((err, data) => {
        //     console.log(data);
    
        //     // 操作数据库完成以后要关闭数据库连接
        //     client.close();
    
        // })
    
        // 2.增加数据
        // db.collection('user').insertOne({ 'username': 'nodejs操作mongodb', 'age': 10 }, (err, result) => {
        //     if (err) {
        //         console.log(err);
        //         return;
        //     }
        //     console.log("增加成功")
        //     console.log(result);
        //     操作数据库完成以后要关闭数据库连接
        //     client.close();
        // })
    
        // 3.修改数据
        // db.collection('user').updateOne({ 'username': 'kko1' }, { $set: { 'age': 111222 } }, (err, result) => {
        //     if (err) {
        //         console.log(err);
        //         return;
        //     }
        //     console.log('修改成功');
        //     console.log(result);
        //     // 操作数据库完成以后要关闭数据库连接
        //     client.close();
        // })
    
        // 4.删除一条数据
        // db.collection('user').deleteOne({ 'name': 'aniu' }, (err) => {
        //     if (err) {
        //         console.log(err);
        //         return;
        //     }
        //     console.log('删除一条数据成功');
        //     client.close();
        // })
    
        // 5.删除多条数据
        // db.collection('user').deleteMany({ 'name': 'zhangsan' }, (err) => {
        //     if (err) {
        //         console.log(err);
        //         return;
        //     }
        //     console.log('删除多条数据成功');
        //     client.close();
        // })
    
    });

## nodejs服务器端操纵数据库 ##

我们要通过在页面中输入数据传入数据库中，并保持页面与数据库的动态相连。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NjM1MTU5Mw_size_16_color_FFFFFF_t_70_pic_center]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NjM1MTU5Mw_size_16_color_FFFFFF_t_70_pic_center 1]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NjM1MTU5Mw_size_16_color_FFFFFF_t_70_pic_center 2]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NjM1MTU5Mw_size_16_color_FFFFFF_t_70_pic_center 3]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NjM1MTU5Mw_size_16_color_FFFFFF_t_70_pic_center 4]

app.js

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7
 *  8
 *  9
 *  10
 *  11
 *  12
 *  13
 *  14
 *  15
 *  16
 *  17
 *  18
 *  19
 *  20
 *  21
 *  22
 *  2

index.ejs

<!DOCTYPE html>
    <html lang="en">
    
    <head>
        <meta charset="UTF-8">
        <meta name="viewport" content="width=device-width, initial-scale=1.0">
        <title>Document</title>
    </head>
    
    <body>
        <h2>获取用户列表数据</h2>
        <ul>
            <%for(var i=0;i<list.length;i++){%>
                <li>
                    <%=list[i].name%>---
                        <%=list[i].age%>
                </li>
                <%}%>
        </ul>
    </body>
    
    </html>

<!DOCTYPE html>
    <html lang="en">
    
    <head>
        <meta charset="UTF-8">
        <meta name="viewport" content="width=device-width, initial-scale=1.0">
        <title>Document</title>
        <link rel="stylesheet" href="./css/style.css">
    </head>
    
    <body>
        <h2>注册页面</h2>
        <form action="/doRegister" method="POST">
            用户名： <input type="text" name="name">
            <br>
            <br> 年龄： <input type="text" name="age">
            <br>
            <br>
            <input type="submit" value="提交">
        </form>
    </body>
    
    </html>

route.js

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NjM1MTU5Mw_size_16_color_FFFFFF_t_70_pic_center]: /images/20221119/802c0408418749838f7d81955922b9a3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NjM1MTU5Mw_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221119/320484af626d48a8816af54c3229f6f2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NjM1MTU5Mw_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221119/f62c3d2a0d114137b1fb9c0d1800d8c6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NjM1MTU5Mw_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20221119/e667b4ec8d594f1aaec4a72040e2b893.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NjM1MTU5Mw_size_16_color_FFFFFF_t_70_pic_center 4]: /images/20221119/4cdcc310d5ad46078f46181a224f1cda.png