索鸟网

  1. 首页
  2. node.js操作Mongodb数据库

node.js操作Mongodb数据库


一、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.jsdb.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页开始计数)。以此来实现对查找数据分页显示的功能。

mongodb node.js

来源地址:https://segmentfault.com/a/1190000011443234 版权归作者所有!

相关教程

  • Mongodb数据库的基本操作

    mongodb是文档型数据库,其官网地址为 https://www.mongodb.com/。我们在官网上下载该软件包,并完成安装。如我们可以设置安装路径为D:\MongoDB\mongodb。我们在完成安装之后,可以看到在该目录的bin文件夹下有如下文件: 接下去我们配置环境变量,为了能在任意目录下都能运行bin这个文件夹下的应用程序。我们在环境变量
  • MongoDB操作命令

    一、数据库常用命令 1、Help查看命令提示 代码如下: help db.help(); db.yourColl.help(); db.youColl.find().help(); rs.help(); 2、切换/创建数据库 代码如下: use yourDB; 当创建一个集合(table)的时候会自动创建当前数据库 3、查询所有数据库 代码如下: show d
  • 基于 Node.js + Express + mongoDB + Bo

    电影网站 GitHub: https://github.com/bxm0927/movie-website 此项目是基于 Node.js + Express + mongoDB + Bootstrap 搭建的电影网站。 主要功能模块: 一期:前台电影展示页、电影详情页、后台电影管理中心(电影录入、电影修改) 二期:用户登录注册注销功能、用户识别和持久化、后台用户管
  • 练习 MongoDB 操作 —— 数据操作(一)

    本文的目标是通过大量的示例,来更好的理解如果在Mongodb中进行数据操作; 初入客户端刚利用 mongod命令进入客户端环境,此时对数据库一无所知; 举目四望,想知道现在有哪些数据库, show dbs; 因为是新装的mongodb环境,所以只看到了admin和local两个默认就存在的数据库;目光慢慢收回,那么当前是处于哪个数据库上呢? db; 通过
  • 【MongoDB】mongodb安装及常用操作命令

    .......................................................................................环境:centos7Ip: 172.16.200.48................................................................
  • JDBC操作数据库

    一.JDBC概述 1.JDBC简介 JDBC(Java DataBase Connectivity)即java数据库连接是Java连接不同数据库的类库,它有三个核心功能:1.连接数据库,2.向数据库发送SQL语句,3.操作SQL语句的返回结果 2.JDBC概念 JDBC是SUN公司提供一套访问数据库的规范(就是一组接口),并提供连接数据库的协议标准,各个数据库厂商遵循SUN的规范提
  • PHP 数据库操作

    PHP操作数据库的2种形式 使用 PDO 扩展类库(推荐) 使用 Mysqli 扩展类库(这是Mysql类库的升级版,但已经不推荐使用) PDO 扩展包含哪三个类 PDO PDOStatement PDOException PDO 与 Mysqli 区别 PDO 可以支持多种数据库,而且操作方法一致 Mysqli 只支持Mysql数据库 如何
  • 数据库操作(jdbc)

    前言 在构建一个系统的过程中难免需要对数据存储,而存储一般会有缓存(内存)、数据库(硬盘)两种存储介质。 本篇文章我们主要来介绍下在我们通过spring构建应用的过程中如何进行数据库连接、以及数据库连接的几种方式进行简单介绍。 spring中连接数据库有如下几种方式: 直接通过驱动连接数据库的方式 spring提供的JdbcTemplate sprin