mongodb的增删改查操作指南

电玩女神 2022-06-09 07:52 360阅读 0赞

### 安装相关模块 ###

如果使用这个的话，你需要先自己安装一下他需要的模块，在根目录输入

npm install mongodb --save
     
      
       1
      
     
      
       1

进行模块安装，安装成功以后就可以进行以下的步骤。

### 文件的引入 ###

以下是我书写的相关代码，放到你可以引用的相关目录，本人放到了express的根目录

function Mongo(options) { 
        this.settings = {
            url: 'mongodb://localhost:27017/jk',
            MongoClient:require('mongodb').MongoClient,
            assert:require('assert')
        };
    
        for(let i in options){
            this.settings[i] = options[i];
        }
    
        this._run = function (fun) { 
            let that = this;
            let settings = this.settings;
            this.settings.MongoClient.connect(this.settings.url, function (err, db) { 
                settings.assert.equal(null, err);
                console.log("Connected correctly to server");
    
                fun(db, function () { 
                    db.close();
                });
            });
        };
    
        this.insert = function (collectionName, data, func) { 
            //增加数据
            let insertDocuments = function (db, callback) { 
                let collection = db.collection(collectionName);
                collection.insertMany([
                    data
                ], function (err, result) { 
                    if (!err) {
                        func(true);
                    } else {
                        func(false);
                    }
                    callback(result);
                });
            };
    
            this._run(insertDocuments);
        };
    
        this.update = function (collectionName, updateData, data, func) { 
            //更新数据
            let updateDocument = function (db, callback) { 
                let collection = db.collection(collectionName);
                collection.updateOne(updateData
                    , {$set: data}, function (err, result) { 
                        if (!err) {
                            func(true);
                        } else {
                            func(false);
                        }
                        callback(result);
                    });
            };
    
            this._run(updateDocument);
        };
    
        this.delete = function (collectionName, data, func) { 
            //删除数据
            let deleteDocument = function (db, callback) { 
                let collection = db.collection(collectionName);
                collection.deleteOne(data, function (err, result) { 
                    if (!err) {
                        func(true);
                    } else {
                        func(false);
                    }
                    callback(result);
                });
            };
    
            this._run(deleteDocument);
        };
    
        this.find = function (collectionName, data, func) { 
            //查找数据
            let findDocuments = function (db, callback) { 
                // Get the documents collection
                let collection = db.collection(collectionName);
                // Find some documents
                collection.find(data).toArray(function (err, docs) { 
                    if (!err) {
                        func(true,docs);
                    }
                    else {
                        func(false, err);
                    }
                    callback(docs);
                });
            };
    
            this._run(findDocuments);
        };
    }
    
    module.exports = Mongo;
    
     
      
       1
       2
       3
       4
       5
       6
       7
       8
       9
       10
       11
       12
       13
       14
       15
       16
       17
       18
       19
       20
       21
       22
       23
       24
       25
       26
       27
       28
       29
       30
       31
       32
       33
       34
       35
       36
       37
       38
       39
       40
       41
       42
       43
       44
       45
       46
       47
       48
       49
       50
       51
       52
       53
       54
       55
       56
       57
       58
       59
       60
       61
       62
       63
       64
       65
       66
       67
       68
       69
       70
       71
       72
       73
       74
       75
       76
       77
       78
       79
       80
       81
       82
       83
       84
       85
       86
       87
       88
       89
       90
       91
       92
       93
       94
       95
       96
       97
       98
       99
       100
       101
       102
      
     
      
       1
       2
       3
       4
       5
       6
       7
       8
       9
       10
       11
       12
       13
       14
       15
       16
       17
       18
       19
       20
       21
       22
       23
       24
       25
       26
       27
       28
       29
       30
       31
       32
       33
       34
       35
       36
       37
       38
       39
       40
       41
       42
       43
       44
       45
       46
       47
       48
       49
       50
       51
       52
       53
       54
       55
       56
       57
       58
       59
       60
       61
       62
       63
       64
       65
       66
       67
       68
       69
       70
       71
       72
       73
       74
       75
       76
       77
       78
       79
       80
       81
       82
       83
       84
       85
       86
       87
       88
       89
       90
       91
       92
       93
       94
       95
       96
       97
       98
       99
       100
       101
       102

我存入到了一个名字叫server.[js][]的文件名内

### 使用 ###

我们在需要使用页面先将模块引入，比如我在路由文件index.js里面引入：

const Server = require("../server.js");
     
      
       1
      
     
      
       1

然后需要实例化对象，如下：

let server = new Server();
     
      
       1
      
     
      
       1

如果需要配置相关信息，可以在实例化的时候传入一个对象配置，可以配置[数据库][Link 1]的地址：

let server = new Server({url:"mongodb://localhost:27017/mydb"});
     
      
       1
      
     
      
       1

里面封装了四个方法，添删改查，分别是   
添加方法

server.insert(数据表名,需要插入的数据（键值对的对象）,回调函数);
     
      
       1
      
     
      
       1

更新方法

server.update(数据表名,查询的数据（对象）,更新的数据（对象）,回调函数);
     
      
       1
      
     
      
       1

删除方法

server.delete(数据表名,查询的数据（对象）,回调函数);
     
      
       1
      
     
      
       1

查找方法

server.find(数据表名,查询的数据（对象）,回调函数);
     
      
       1
      
     
      
       1

回调函数都会返回两个值，第一个布尔类型，是否处理成功，第二个值，查找返回查找到的个数，别的都返回处理成功的个数（现在一次只处理一条）

### 使用案例 ###

比如我需要在一个路由里面查找数据，我就需要这样：

server.find("users",{username:"username"},function (bool,data) {
            if(bool){
                console.log("查询到数据为"+data.length+"条");
            }
            else{
                console.log(data);
            }
        });
    });
     
      
       1
       2
       3
       4
       5
       6
       7
       8
       9
      
     
      
      
       
     
      
     
      
       1
       2
       3
       4
       5
       6
       7
       8
       9

上面的代码是查询了users表里面username为username的字段的数据，如果成功，后面data就会返回一个数组，如果出现错误，就直接返回data错误。

[js]: http://lib.csdn.net/base/javascript
[Link 1]: http://lib.csdn.net/base/mysql

发表评论取消回复

表情：

评论列表（有 0 条评论，360人围观）

还没有评论，来说两句吧...

相关阅读

相关学习MongoTemplate操作MongoDB增删改查

学习MongoTemplate操作MongoDB增删改查一、准备 1、依赖 2、yml 3、实体类二、案例

太过爱你忘了你带给我的痛/ 2024年04月06日 14:22/ 0 赞/ 121 阅读

相关 MongoDB 增删改查（三）

MongoDB 增删改查（三）聚合查询 mongodb自带了一个聚合功能，使用聚合功能，可以直接让mongodb来处理数据。聚合功能可以把数据像放入传送带上一样，先把

比眉伴天荒/ 2023年06月23日 14:22/ 0 赞/ 15 阅读

相关 MongoDB——MongoDB安装和增删改查操作

MongoDB基础 MongoDB相关概念 MongoDB 体系结构数据模型 MongoDB的特点 MongoDB安

傷城~/ 2023年01月14日 00:47/ 0 赞/ 192 阅读

相关 MongoDB数据库、集合操作（增删改查）

数据库操作选择和创建数据库 use articledb 都是用的是use，在这里进行创建数据库之后，再进行show dbs 查看数据库，会发现articl

我会带着你远行/ 2022年12月15日 03:45/ 0 赞/ 228 阅读

相关 nestjs操作mongodb实现增删改查

前置步骤见上 [https://blog.csdn.net/yw00yw/article/details/108490087][https_blog.csdn.net_y

客官°小女子只卖身不卖艺/ 2022年12月05日 10:00/ 0 赞/ 371 阅读

相关 mongodb的增删改查操作指南

安装相关模块如果使用这个的话，你需要先自己安装一下他需要的模块，在根目录输入 npm install mongodb --save

电玩女神/ 2022年06月09日 07:52/ 0 赞/ 361 阅读

相关 mongodb基本知识，增删改查操作

添加环境变量管理员cmd 设置数据存储位置 mongod.exe --dbpathE:\\MongoDB\\data\\db 安装至windows

ゝ一纸荒年。/ 2022年06月08日 13:22/ 0 赞/ 324 阅读

相关 mongodb 增删查改

安装模块 pip install pymongo MongoClient对象：用于与MongoDB服务器建立连接 client=MongoClient('主机ip',

淡淡的烟草味﹌/ 2022年01月11日 11:17/ 0 赞/ 535 阅读

相关 SpringBoot操作MongoDB实现增删改查

转自： [https://blog.csdn.net/weixin\_42236165/article/details/91884029][https_blog.csdn.n

港控/mmm°/ 2022年01月06日 00:39/ 0 赞/ 447 阅读

相关 Java操作MongoDB实现增删改查

import com.mongodb.BasicDBObject; import com.mongodb.DB; import com.mongodb.DBCollec

电玩女神/ 2021年09月26日 01:28/ 0 赞/ 466 阅读