NodeJS操做MongoDB数据库

时间  2019-12-15
标签 nodejs mongodb 数据库 栏目 MongoDB 繁體版
原文   原文链接

1、node.js对于mongodb的基本操做

一、数据库的开机

首先咱们要先对数据库进行开机的操做，创建一个文件夹用于存放数据库文档。如D:\mongo，接下去在cmd当中键入命令-> mongod --dbpath D:\mongo来实现数据库的开机。以下图所示：node

接下去就保持这个cmd控制面板处于这种状态，以确保数据库处于开机状态。mongodb

二、链接数据库

在node.js当中操做mongodb数据库须要引入第三方模块包mongodb。因此咱们先在项目文件夹下键入命令-> npm install mongodb来完成下载包。接下去再用const MongoClient = require('mongodb').MongoClient;来完成引包。示例代码以下所示：typescript

const MongoClient = require('mongodb').MongoClient;
var dburl = "mongodb://127.0.0.1:27017/test";
MongoClient.connect(dburl,(err,db)=>{
    if(err){
        console.log('数据库链接失败！');
        return;
    };
    console.log(db);
});

咱们先定义一个dburl变量用于指定本机上27017端口号（mongodb的默认端口号）上的数据库地址。test为自定义的数据库的名字。若该数据库不存在则会自动完成该数据库的新建。接下去完成与本机上test数据库的链接，这是一个异步函数，当链接完成以后，触发执行其回调函数，参数db指代这个数据库自己。接下去对数据库的增删改查操做都写在链接的回调函数当中。数据库

三、插入数据

数据插入操做，指的是对数据库的某个指定集合进行文档对象的插入。一样是在完成数据库链接的回调函数当中对db这个对象进行操做。示例代码以下所示：npm

const MongoClient = require('mongodb').MongoClient;
var dburl = "mongodb://127.0.0.1:27017/test";
MongoClient.connect(dburl,(err,db)=>{
    if(err){
        console.log('数据库链接失败！');
        return;
    };
    db.collection('student').insertOne({"name":"qianqian"},(err,result)=>{
        if(err){
            console.log('数据插入失败！');
            db.close();
            return;
        };
        console.log(result);
        db.close();
    });
});

在用node命令运行该文件以后，这时候咱们能够在控制台或在可视化工具当中查看插入结果。json

在db对象的collection方法当中写入集合的名字，若该集合不存在则自动完成新建，使用方法insertOne()来完成一条文档的插入，第一个参数为一个json对象，即插入的那一条文档数据。当完成插入操做以后触发执行其回调函数，result表示对插入结果的反馈。因为数据库不能进行长链接，咱们通常都在完成数据库操做的回调函数的最后加上db.close();来关闭数据库。下一次数据库操做时须要从新链接数据库。数组

四、删除数据

数据删除操做，指的是对数据库的某个指定集合当中匹配上筛选条件的文档进行删除。一样是在完成数据库链接的回调函数当中对db这个对象进行操做。示例代码以下所示：异步

const MongoClient = require('mongodb').MongoClient;
var dburl = "mongodb://127.0.0.1:27017/test";
MongoClient.connect(dburl,(err,db)=>{
    if(err){
        console.log('数据库链接失败！');
        return;
    };
    db.collection('student').deleteMany({"name":"qianqian"},(err,result)=>{
        if(err){
            console.log('数据删除失败！');
            db.close();
            return;
        };
        console.log(result);
        db.close();
    });
});

使用方法deleteMany()来对该集合当中全部符合筛选条件的文档所有进行删除，第一个参数为一个json对象，即筛选条件。当完成删除操做以后触发执行其回调函数，result表示对删除结果的反馈。函数

五、修改数据

数据修改操做，指的是对数据库的某个指定集合当中匹配上筛选条件的全部文档进行修改。一样是在完成数据库链接的回调函数当中对db这个对象进行操做。示例代码以下所示：工具

const MongoClient = require('mongodb').MongoClient;
var dburl = "mongodb://127.0.0.1:27017/test";
MongoClient.connect(dburl,(err,db)=>{
    if(err){
        console.log('数据库链接失败！');
        return;
    };
    db.collection('student').updateMany({"name":"qianqian"},{$set:{"age":18}},(err,result)=>{
        if(err){
            console.log('数据修改失败！');
            db.close();
            return;
        };
        console.log(result);
        db.close();
    });
});

使用方法updateMany()来对该集合当中全部符合筛选条件的文档所有进行修改，第一个参数为一个json对象，即筛选条件。第二个参数为一个json对象，即修改条件，语法如上所示。当没有写$set这个关键字，即{"age":18}表明把匹配上的文档进行替换。当完成修改操做以后触发执行其回调函数，result表示对修改结果的反馈。

六、查找数据

数据查找操做，指的是对数据库的某个指定集合当中匹配上筛选条件的全部文档进行查找。一样是在完成数据库链接的回调函数当中对db这个对象进行操做。示例代码以下所示：

const MongoClient = require('mongodb').MongoClient;
var dburl = "mongodb://127.0.0.1:27017/test";
MongoClient.connect(dburl,(err,db)=>{
    if(err){
        console.log('数据库链接失败！');
        return;
    };
    var cursor = db.collection("student").find({"name":"qianqian"});
    var result = [];
    cursor.each((err,doc)=>{
        if(err){
            console.log('数据查找失败！');
            db.close();
            return;
        };
        if(doc!=null){
            result.push(doc);
        }else{
            console.log(result);
            db.close();
        };
    });
});
使用方法find
来对该集合当中全部符合筛选条件的文档所有进行查找，第一个参数为一个对象，即筛选条件。先定义一个空数组，用于存放符合条件的文档对象，当完成查找操做以后触发执行其回调函数，这里的表示符合条件的文档对象的数组。()jsonresult

咱们在find()方法后面继续加上sort()方法能够实现对查找的文档对象的排序操做，参数一样是一个json对象。此外mongodb模块还提供了两个函数limit()表示限制读取的条数，skip()表示略过的条数。其参数均为number类型。如把上述代码修改成： var cursor = db.collection("student").find({"name":"qianqian"}).sort({"age":-1}).skip(0).limit(2);查找结果为：

七、获取该集合当中文档对象的总数

一样是在完成数据库链接的回调函数当中对db这个对象进行操做。示例代码以下所示：

const MongoClient = require('mongodb').MongoClient;
var dburl = "mongodb://127.0.0.1:27017/test";
MongoClient.connect(dburl,(err,db)=>{
    if(err){
        console.log('数据库链接失败！');
        return;
    };
    db.collection("student").count({}).then(function(count){
        console.log(count);
        db.close();
    });
});

在回调函数当中的count即表明数据库的student这个集合当中数据文档的数目。

2、node.js操做mongodb的经常使用函数的封装

咱们写一个db.js模块，在该模块当中封装对数据库的一些基本操做函数。其中db.js的示例代码以下所示：

const MongoClient = require('mongodb').MongoClient;
var dburl = "mongodb://127.0.0.1:27017/test";
//链接数据库操做
function _connectDB(callback){
    MongoClient.connect(dburl,(err,db)=>{
        callback(err,db);
    });
};
//插入函数的封装
module.exports.insertOne = function(collection,json,callback){
    _connectDB(function(err,db){
        if(err){
            console.log('数据库链接失败！');
            return;
        };
        db.collection(collection).insertOne(json,(err,result)=>{
            callback(err,result);
            db.close();
        })
    })
};
//删除函数的封装
module.exports.deleteMany = function(collection,json,callback){
    _connectDB(function(err,db){
        if(err){
            console.log('数据库链接失败！');
            return;
        };
        db.collection(collection).deleteMany(json,(err,result)=>{
            callback(err,result);
            db.close();
        });
    });
};
//修改函数的封装
module.exports.updateMany = function(collection,json1,json2,callback){
    _connectDB(function(err,db){
        if(err){
            console.log('数据库链接失败！');
            return;
        };
        db.collection(collection).updateMany(json1,json2,(err,result)=>{
            callback(err,result);
            db.close();
        });
    });
};
//获取集合当中文档的总条数
module.exports.getAllCount = function(collection,callback){
    _connectDB(function(err,db){
        if(err){
            console.log('数据库链接失败！');
            return;
        };
        db.collection(collection).count({}).then(function(count){
            callback(count);
            db.close();
        });
    });
};
//查找函数的封装
module.exports.find = function(collection,json,C,D){
    if(arguments.length == 3){
        var callback = C;
        var skipnumber = 0;
        var limit = 0;
        var sort = {};
    }else if(arguments.length == 4){
        var callback = D;
        var args = C;
        var skipnumber = args.pageamount * args.page;
        var limit = args.pageamount;
        var sort = args.sort;
    }else{
        throw new Error('find函数参数个数不正确！');
        return;
    }
    var result = [];
    _connectDB(function(err,db){
        if(err){
            console.log('数据库链接失败！');
            return;
        };
        var cursor = db.collection(collection).find(json).sort(sort).limit(limit)
        .skip(skipnumber);
        cursor.each((err,doc)=>{
            if(err){
                callback(err,null);
                db.close();
                return;
            };
            if(doc!=null){
                result.push(doc);
            }else{
                callback(null,result);
                db.close();
            }
        })
    });
};

咱们每次在使用该模块以前，先对本机上的mongodb数据库进行开机操做，而后在项目文件夹下下载mongodb这个第三方模块包，而后修改db.js当中的dburl的值，接下去只要在咱们本身的主文件用require的方式进行引入便可。如主文件1.js与db.js处于同一目录下，则在1.js当中使用const db = require('./db.js');对该模块进行引入便可。下面给出主文件的示例代码，做为该模块的使用示范：

const db = require('./db.js');
db.insertOne('student',{'name':'qianqiang'},(err,result)=>{
    if(err){
        console.log('数据插入失败！');
        db.close();
        return;
    };
    console.log(result);
});
db.deleteMany('student',{'age':11},(err,result)=>{
    if(err){
        console.log('数据删除失败！');
        db.close();
        return;
    };
    console.log(result);
});
db.updateMany('student',{'age':18},{$set:{'age':25}},(err,result)=>{
    if(err){
        console.log('数据修改失败！');
        db.close();
        return;
    };
    console.log(result);
});
db.find('student',{},{'pageamount':2,'page':4,'sort':{}},(err,result)=>{
    if(err){
        console.log('数据查找失败！');
        db.close();
        return;
    };
    console.log(result);
});
db.getAllCount('student',function(count){
   console.log(count);
});

其中find函数当中的pageamount表示每页显示的文档对象的条数，page表示显示第几页的内容（从第0页开始计数）。以此来实现对查找数据分页显示的功能。

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程