node.js操作Mongodb数据库

SKYZACK 发布于2019-06-26 17:25 / 3514人阅读

摘要：接下去完成与本机上数据库的连接，这是一个异步函数，当连接完成之后，触发执行其回调函数，参数指代这个数据库本身。同样是在完成数据库连接的回调函数当中对这个对象进行操作。当完成修改操作之后触发执行其回调函数，表示对修改结果的反馈。

一、node.js对于mongodb的基本操作

1、数据库的开机

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

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

2、连接数据库

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

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指代这个数据库本身。接下去对数据库的增删改查操作都写在连接的回调函数当中。

3、插入数据

数据插入操作，指的是对数据库的某个指定集合进行文档对象的插入。同样是在完成数据库连接的回调函数当中对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").insertOne({"name":"qianqian"},(err,result)=>{
        if(err){
            console.log("数据插入失败！");
            db.close();
            return;
        };
        console.log(result);
        db.close();
    });
});

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

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

4、删除数据

数据删除操作，指的是对数据库的某个指定集合当中匹配上筛选条件的文档进行删除。同样是在完成数据库连接的回调函数当中对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表示对删除结果的反馈。

5、修改数据

数据修改操作，指的是对数据库的某个指定集合当中匹配上筛选条件的所有文档进行修改。同样是在完成数据库连接的回调函数当中对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表示对修改结果的反馈。

6、查找数据

数据查找操作，指的是对数据库的某个指定集合当中匹配上筛选条件的所有文档进行查找。同样是在完成数据库连接的回调函数当中对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()来对该集合当中所有符合筛选条件的文档全部进行查找，第一个参数为一个json对象，即筛选条件。先定义一个空数组，用于存放符合条件的文档对象，当完成查找操作之后触发执行其回调函数，这里的result表示符合条件的文档对象的数组。

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

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

同样是在完成数据库连接的回调函数当中对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这个集合当中数据文档的数目。

二、node.js操作mongodb的常用函数的封装

我们根据 node.js当中模块化开发的基本流程写一个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页开始计数）。以此来实现对查找数据分页显示的功能。

云服务器 GPU云服务器读取node.js数据库操作mongodb mongodb操作 MongoDB操作类

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/19129.html

Node.js操作MongoDB数据库

摘要：使用操作是基于开发的驱动，可以在异步的环境下执行。比如，启动，直接在终端输入就可以启动啦默认运行在。还可以自定义端口或者输入的使用首先新建一个名为的文件夹，该文件夹就是数据库目录。使用Mongoose操作MongoDB Mongoose是基于node-mongodb-native开发的MongoDB nodejs驱动，可以在异步的环境下执行。关于在Mac下安装和使用MongoDB...

chaosx110 2019-06-26 16:56 评论0 收藏0
初尝node.js + Express + MongoDB + Vue.js 项目构建(2)

摘要：使用内在模块发送响应数据监听端口终端打印如下信息使用框架本项目使用的框架来起服务器。数据库中文档每一行的数据的数据结构和基本一样，所有存储在集合中的数据都是格式，是一种类的一种二进制形式的存储格式，简称。前言经过上一篇经济基础构建的完成，那么现在正式开始码代码吧！项目架构 showImg(https://segmentfault.com/img/bVNkQM?w=322&h=58...

kevin 2019-08-22 11:04 评论0 收藏0
初尝node.js + Express + MongoDB + Vue.js 项目构建(2)

摘要：使用内在模块发送响应数据监听端口终端打印如下信息使用框架本项目使用的框架来起服务器。数据库中文档每一行的数据的数据结构和基本一样，所有存储在集合中的数据都是格式，是一种类的一种二进制形式的存储格式，简称。前言经过上一篇经济基础构建的完成，那么现在正式开始码代码吧！项目架构 showImg(https://segmentfault.com/img/bVNkQM?w=322&h=58...

zhisheng 2019-06-26 17:15 评论0 收藏0
在Node中基于Mongoose对MongoDB进行增删查改（CRUD）操作（一）

摘要：如图连接成功后，显示你的数据库，在这个节目可以对数据库进行操作。如图安装与加载首先假定你已经安装了，命令行工具输入在使用的文件中即可。创建读取更新删除单值读取上文是在中基于对进行增删查改操作的简单介绍，以后会有进阶的文章。关键词：mongodb安装 mongoose使用 robomongo mongoose的CRUD操作 mongoose的查询，增加，修改，删除工具介绍 Mon...

lemon 2019-08-21 10:57 评论0 收藏0
在Node中基于Mongoose对MongoDB进行增删查改（CRUD）操作（一）

摘要：如图连接成功后，显示你的数据库，在这个节目可以对数据库进行操作。如图安装与加载首先假定你已经安装了，命令行工具输入在使用的文件中即可。创建读取更新删除单值读取上文是在中基于对进行增删查改操作的简单介绍，以后会有进阶的文章。关键词：mongodb安装 mongoose使用 robomongo mongoose的CRUD操作 mongoose的查询，增加，修改，删除工具介绍 Mon...

SillyMonkey 2019-06-26 17:03 评论0 收藏0