node怎么连接mongodb数据库

Posted 2023-05-12

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了node怎么连接mongodb数据库相关的知识，希望对你有一定的参考价值。

参考技术A 一、写在前面人人都想成为全栈码农，作为一个web前端开发人员，通往全栈的简洁之路，貌似就是node/dist/v0.6.1/node-v0.6.1.msi 下载电脑适配的安装包（这个是windows的，买不起mac啊），然后根据引导安装就可以了，默认安装在C:\Program Files\nodejs文件下，并将该目录添加进PATH环境变量。具体做法，右击”我的电脑“-”属性“-“系统高级”-”高级“-”环境变量“-选择“变量名：PATH”；“改变量值：在最后面添加【C:\Program Files\nodejs】（根据自己的安装目录而定）”。打开cmd直接运行命令： node -v 可以输出当前版本号。node文件里已经集成了npm，之后使用npm install XXX 来安装需要的插件或者模块。三、使用express框架忙活了一阵，终于可用npm命令进行初始化、安装express框架，然后写个hello world 爽一下了。为什么要选择express框架了，当然有它的特别之处，对新手来说最怕的就是麻烦还容易出错。express当然为我们考虑到了，所以提供了快速生成器：express-generator 1、通过命令：npm install express-generator -g 安装到全局 2、在用express 命令生成项目结构 express myapp 其中的myapp是你的项目名称 3、通过cd myapp 进入项目文件中通过npm install 初始化依赖模块通过set DEBUG=myapp & npm start 启动web服务器 4、在浏览器中打开 localhost:3000/ 网址就可以看到这个应用了。默认情况下用的模版引擎是jade，项目里也已经配置好了这个模版。四、介绍express 生成器的项目 1、myapp项目的机构如下： 2、package.json 这个可以说是模块管理包，项目信息和模块的版本号，其实你会发现在项目模块初始化的时候就是由这里的配置去查找生成的。 3、app.js 是项目的启动文件，可以说是项目的核心。主要写一些公共的功能。 4、bin 文件下有个无后缀的www文件，这是项目的入口文件，配置web服务端口和一些监听事件。 5、node_modules是项目的依赖的的文件模块，之后导入的包也会被放在其中，比如连接数据库的mongoose模块，后面会详细讲。 6、public 是项目的静态资源文件集，很容易看出图片、css文件、js文件都放在这里。 7、routes 是项目的路由模块，其中已经默认了index.js和user.js文件。在这里其实也包括一般后台语言中的控制器内容，当然在大的项目上是可以分离开来的。 8、views是项目的模版文件，是jade模版引擎，这个模版很简洁，但是坑也比较多，比如对空格的要求都非常严格，多一个少一个空格都会报错的，曾经踩过很多坑，其实它的性能也不是很高还不如用ejs呢。五、安装mongoDB 1、同样在官网(/downloads)上直接下载msi文件 2、简单的下一步进行安装，有默认的就让其默认，有选择的就全选了 3、然后配置环境变量，和node的一样不再累述，不过可以放中图，哈哈哈…… 4、接下来是启动mongoDB服务 5、通过命令：mongod --dbpath f:\MongoDB\data 其中 f:\MongoDB\data是文件存放路径，看到如下信息说明成功了 6、MongoDB监听的是27017端口，同时打开浏览器输入127.0.0.1:27017，则会看到如下提示：　　It looks like you are trying to access MongoDB over HTTP on the native driver port. 7、然后，再打开一个cmd，输入mongo命令链接数据库，出现如下提示：　　2015-05-02T17:10:19.467+0800 I CONTROL Hotfix KB2731284 or later update is not installed, will zero-out data files MongoDB shell version: 3.0.2 connecting to: test 8、这样windows环境下的monogDB就安装成功了。补充： 9、如果你嫌每次用命令打开服务麻烦的话，可以写成批处理文件，就是新建一个后缀.bat的文件，写上如下代码：　　start mongod --dbpath F:\MongoDB\data 10、当然了，你也可以将MongoDB以服务的方式启动，不过我觉得在学习的过程中用处不大，小伙伴们可以自己尝试一下，如果有需要的话，我在后面会补上。 11、要是觉得命令行不好用，推荐一个带图形化界面的软件：MongoVUE，就和navicat差不多，它有免费版的，就是功能少点，但学习过程中完全足够了六、在node项目中使用monogDB 1、导入monogDB连接模块，express 官方介绍的是mongoskin模块，这个我就不说了，这里介绍通过mongoose安装 2、在myapp项目下执行命令 npm install mongoose -save 安装保存到node_modules，也可以在package.json中配置"mongoose": "^4.4.12",然后命令npm install 安装。 3、在app.js文件中　a、导入mongoose模块： var mongoose = require('mongoose'); b、创建数据库连接 mongoose.connect('mongodb://localhost/myDB') //连接本地数据库 4、在项目根目录下新建文件夹schemas，这个是数据集模块，在模块下新建users.js文件 var mongoose = require('mongoose'); //申明一个mongoons对象 var UsersSchema = new mongoose.Schema( name: String, paw: String, meta: createAt: type: Date, default: Date.now() , updateAt: type: Date, default: Date.now() ) //每次执行都会调用,时间更新操作 UsersSchema.pre('save', function(next) if(this.isNew) this.meta.createAt = this.meta.updateAt = Date.now(); else this.meta.updateAt = Date.now(); next(); ) //查询的静态方法 UsersSchema.statics = fetch: function(cb) //查询所有数据 return this .find() .sort('meta.updateAt') //排序 .exec(cb) //回调 , findById: function(id, cb) //根据id查询单条数据 return this .findOne(_id: id) .exec(cb) //暴露出去的方法 module.exports = UsersSchema 5、在根目录新增modules文件，这个是数据模型模块，在模块下新增users.js文件 var mongoose = require('mongoose') var UsersSchema = require('../schemas/users') //拿到导出的数据集模块 var Users = mongoose.model('Users', UsersSchema) // 编译生成Movie 模型 module.exports = Users 6、在routes文件中的users.js文件中添加路由控制器代码 var express = require('express'); var mongoose = require('mongoose');//导入mongoose模块 var Users = require('../models/users');//导入模型数据模块 var router = express.Router(); /* GET users listing. */ router.get('/', function(req, res, next) res.send('respond with a resource'); ); //查询所有用户数据 router.get('/users', function(req, res, next) Users.fetch(function(err, users) if(err) console.log(err); res.render('users',title: '用户列表', users: users) //这里也可以json的格式直接返回数据res.json(data: users); ) ) module.exports = router; 7、在views文件下新增users.jade extends layout block content h1= title //jade取值方式 ul each user in users //jade模版的遍历方式 li h4 #user.name span #user.paw 8、最后在浏览器中打开网址：localhost:3000/users/users，查看效果。到这里一个从数据库到前端展现的项目就完成了。以上就是本文的全部内容，希望对大家的学习有所帮助。

Node.js 连接 MongoDB-7

先安装模块：

npm install --save mongodb

当然，首先你要打开mongodb服务端：

mongod --bind_ip 127.0.0.1

创建数据库

要在 MongoDB 中创建一个数据库，首先我们需要创建一个 MongoClient 对象，然后配置好指定的 URL 和端口号。

如果数据库不存在，MongoDB 将创建数据库并建立连接。

在mongo客户端将mydatabase数据库创建出来：

> show dbs
admin   0.000GB
config  0.000GB
local   0.000GB
> use mydatabase
switched to db mydatabase
> show dbs
admin   0.000GB
config  0.000GB
local   0.000GB
>

然后运行：

var MongoClient = require(‘mongodb‘).MongoClient;
var url = "mongodb://localhost:27017/mydatabase"; //连接服务端
MongoClient.connect(url, function(err, db) {
    if (err) throw err;
    console.log("数据库已创建!");
    db.close();
});

users-MacBook-Pro:test-mongodb user$ node index.js
(node:26745) DeprecationWarning: current URL string parser is deprecated, and will be removed in a future version. To use the new parser, pass option { useNewUrlParser: true } to MongoClient.connect.
数据库已创建!

根据上面的警告，将添加相应的option，改为：

MongoClient.connect(url, { useNewUrlParser: true } ,function(err, db) {
    if (err) throw err;
    console.log("数据库已创建!");
    db.close();
});

数据库已创建!

创建集合

我们可以使用 createCollection() 方法来创建集合mycollection：

var MongoClient = require(‘mongodb‘).MongoClient;
var url = ‘mongodb://localhost:27017/mydatabase‘;
MongoClient.connect(url, { useNewUrlParser: true }, function (err, db) {
    if (err) throw err;
    console.log(‘数据库已创建‘);
    var dbase = db.db("mydatabase");
    dbase.createCollection(‘mycollection‘, function (err, res) {
        if (err) throw err;
        console.log("创建集合!");
        db.close();
    });
});

users-MacBook-Pro:test-mongodb user$ node index.js
数据库已创建
创建集合!

客户端查看：

> show collections
mycollection

数据库操作( CURD )

插入数据

以下实例我们连接数据库 mydatabase 的 mycollection 表，并插入一条数据条数据，使用 insertOne()：

与 MySQL 不同的是 MongoDB 会自动创建数据库和集合，所以使用前我们不需要手动去创建。

var MongoClient = require(‘mongodb‘).MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
    if (err) throw err;
    var dbo = db.db("mydatabase");
    var myobj = { name: "菜鸟教程", url: "www.mydatabase" };
    dbo.collection("mycollection").insertOne(myobj, function(err, res) {
        if (err) throw err;
        console.log("文档插入成功");
        db.close();
    });
});

users-MacBook-Pro:test-mongodb user$ node index.js
文档插入成功

客户端查看：

> db.mycollection.find()
{
    "_id" : ObjectId("5c026cae5ae97668886fafaa"),
    "name" : "菜鸟教程",
    "url" : "www.mydatabase"
}

如果要插入多条数据可以使用 insertMany()：

var MongoClient = require(‘mongodb‘).MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
    if (err) throw err;
    var dbo = db.db("mydatabase");
    var myobj = [
        { name: ‘菜鸟工具‘, url: ‘https://c.runoob.com‘, type: ‘cn‘},
        { name: ‘Google‘, url: ‘https://www.google.com‘, type: ‘en‘},
        { name: ‘Facebook‘, url: ‘https://www.google.com‘, type: ‘en‘}
    ];
    dbo.collection("mycollection"). insertMany(myobj, function(err, res) {
        if (err) throw err;
        console.log("文档插入成功");
        console.log("插入的文档数量为: " + res.insertedCount);
        db.close();
    });
});

users-MacBook-Pro:test-mongodb user$ node index.js
文档插入成功
插入的文档数量为: 3

客户端查看：

> db.mycollection.find()
{ "_id" : ObjectId("5c026cae5ae97668886fafaa"), "name" : "菜鸟教程", "url" : "www.mydatabase" }
{ "_id" : ObjectId("5c026d49ccbd816889e6bb3e"), "name" : "菜鸟工具", "url" : "https://c.runoob.com", "type" : "cn" }
{ "_id" : ObjectId("5c026d49ccbd816889e6bb3f"), "name" : "Google", "url" : "https://www.google.com", "type" : "en" }
{ "_id" : ObjectId("5c026d49ccbd816889e6bb40"), "name" : "Facebook", "url" : "https://www.google.com", "type" : "en" }

查询数据

可以使用 find() 来查找数据, find() 可以返回匹配条件的所有数据。如果未指定条件，find() 返回集合中的所有数据。

var MongoClient = require(‘mongodb‘).MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
    if (err) throw err;
    var dbo = db.db("mydatabase");
    dbo.collection("mycollection"). find({}).toArray(function(err, result) { // 返回集合中所有数据
        if (err) throw err;
        console.log(result);
        db.close();
    });
});

users-MacBook-Pro:test-mongodb user$ node index.js
[ { _id: 5c026cae5ae97668886fafaa,
    name: ‘菜鸟教程‘,
    url: ‘www.mydatabase‘ },
  { _id: 5c026d49ccbd816889e6bb3e,
    name: ‘菜鸟工具‘,
    url: ‘https://c.runoob.com‘,
    type: ‘cn‘ },
  { _id: 5c026d49ccbd816889e6bb3f,
    name: ‘Google‘,
    url: ‘https://www.google.com‘,
    type: ‘en‘ },
  { _id: 5c026d49ccbd816889e6bb40,
    name: ‘Facebook‘,
    url: ‘https://www.google.com‘,
    type: ‘en‘ } ]

查询指定条件 name 为 "菜鸟教程" 的实例：

var MongoClient = require(‘mongodb‘).MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
    if (err) throw err;
    var dbo = db.db("mydatabase");
    var whereStr = {"name":‘菜鸟教程‘}; // 查询条件
    dbo.collection("mycollection").find(whereStr).toArray(function(err, result) {
        if (err) throw err;
        console.log(result);
        db.close();
    });
});

users-MacBook-Pro:test-mongodb user$ node index.js
[ { _id: 5c026cae5ae97668886fafaa,
    name: ‘菜鸟教程‘,
    url: ‘www.mydatabase‘ } ]

更新数据

我们也可以对数据库的数据进行修改，以下实例将 name 为 "菜鸟教程" 的 url 改为 https://www.runoob.com：

var MongoClient = require(‘mongodb‘).MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
    if (err) throw err;
    var dbo = db.db("mydatabase");
    var whereStr = {"name":‘菜鸟教程‘}; // 查询条件
    var updateStr = {$set: { "url" : "https://www.runoob.com" }};
    dbo.collection("mycollection").updateOne(whereStr, updateStr, function(err, res) {
        if (err) throw err;
        console.log("文档更新成功");
        db.close();
    });
});

客户端查看：

> db.mycollection.find()
{ "_id" : ObjectId("5c026cae5ae97668886fafaa"), "name" : "菜鸟教程", "url" : "https://www.runoob.com" }
{ "_id" : ObjectId("5c026d49ccbd816889e6bb3e"), "name" : "菜鸟工具", "url" : "https://c.runoob.com", "type" : "cn" }
{ "_id" : ObjectId("5c026d49ccbd816889e6bb3f"), "name" : "Google", "url" : "https://www.google.com", "type" : "en" }
{ "_id" : ObjectId("5c026d49ccbd816889e6bb40"), "name" : "Facebook", "url" : "https://www.google.com", "type" : "en" }

如果要更新所有符合条的文档数据可以使用 updateMany()：

var MongoClient = require(‘mongodb‘).MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
    if (err) throw err;
    var dbo = db.db("mydatabase");
    var whereStr = {"type":‘en‘}; // 查询条件
    var updateStr = {$set: { "url" : "https://www.runoob.com" }};
    dbo.collection("mycollection").updateMany(whereStr, updateStr, function(err, res) {
        if (err) throw err;
        console.log(res.result.nModified + " 条文档被更新");
        db.close();
    });
});

users-MacBook-Pro:test-mongodb user$ node index.js
2 条文档被更新

客户端查看：

> db.mycollection.find()
{ "_id" : ObjectId("5c026cae5ae97668886fafaa"), "name" : "菜鸟教程", "url" : "https://www.runoob.com" }
{ "_id" : ObjectId("5c026d49ccbd816889e6bb3e"), "name" : "菜鸟工具", "url" : "https://c.runoob.com", "type" : "cn" }
{ "_id" : ObjectId("5c026d49ccbd816889e6bb3f"), "name" : "Google", "url" : "https://www.runoob.com", "type" : "en" }
{ "_id" : ObjectId("5c026d49ccbd816889e6bb40"), "name" : "Facebook", "url" : "https://www.runoob.com", "type" : "en" }

删除数据

以下实例将 name 为 "菜鸟教程" 的数据删除 :

var MongoClient = require(‘mongodb‘).MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
    if (err) throw err;
    var dbo = db.db("mydatabase");
    var whereStr = {"name":‘菜鸟教程‘}; // 查询条件
    dbo.collection("mycollection").deleteOne(whereStr, function(err, obj) {
        if (err) throw err;
        console.log("文档删除成功");
        db.close();
    });
});

users-MacBook-Pro:test-mongodb user$ node index.js
文档删除成功

客户端查看：

> db.mycollection.find()
{ "_id" : ObjectId("5c026d49ccbd816889e6bb3e"), "name" : "菜鸟工具", "url" : "https://c.runoob.com", "type" : "cn" }
{ "_id" : ObjectId("5c026d49ccbd816889e6bb3f"), "name" : "Google", "url" : "https://www.runoob.com", "type" : "en" }
{ "_id" : ObjectId("5c026d49ccbd816889e6bb40"), "name" : "Facebook", "url" : "https://www.runoob.com", "type" : "en" }

如果要删除多条语句可以使用 deleteMany() 方法

以下实例将 type 为 en 的所有数据删除 :

var MongoClient = require(‘mongodb‘).MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
    if (err) throw err;
    var dbo = db.db("mydatabase");
    var whereStr = { type: "en" }; // 查询条件
    dbo.collection("mycollection").deleteMany(whereStr, function(err, obj) {
        if (err) throw err;
        console.log(obj.result.n + " 条文档被删除");
        db.close();
    });
});

users-MacBook-Pro:test-mongodb user$ node index.js
2 条文档被删除

客户端查询：

> db.mycollection.find()
{ "_id" : ObjectId("5c026d49ccbd816889e6bb3e"), "name" : "菜鸟工具", "url" : "https://c.runoob.com", "type" : "cn" }

排序

排序使用 sort() 方法，该方法接受一个参数，规定是升序(1)还是降序(-1)。

例如：

{ type: 1 }  // 按 type 字段升序
{ type: -1 } // 按 type 字段降序

按 type 升序排列:

因为之前删的差不多了，再添加几条：

var MongoClient = require(‘mongodb‘).MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
    if (err) throw err;
    var dbo = db.db("mydatabase");
    var myobj = [
        { name: ‘菜鸟工具‘, url: ‘https://c.runoob.com‘, type: ‘an‘},
        { name: ‘Google‘, url: ‘https://www.google.com‘, type: ‘bn‘},
        { name: ‘Facebook‘, url: ‘https://www.google.com‘, type: ‘dn‘}
    ];
    dbo.collection("mycollection"). insertMany(myobj, function(err, res) {
        if (err) throw err;
        console.log("文档插入成功");
        console.log("插入的文档数量为: " + res.insertedCount);
        db.close();
    });
});

客户端：

> db.mycollection.find()
{ "_id" : ObjectId("5c026d49ccbd816889e6bb3e"), "name" : "菜鸟工具", "url" : "https://c.runoob.com", "type" : "cn" }
{ "_id" : ObjectId("5c0270aad64fbc6896311aac"), "name" : "菜鸟工具", "url" : "https://c.runoob.com", "type" : "an" }
{ "_id" : ObjectId("5c0270aad64fbc6896311aad"), "name" : "Google", "url" : "https://www.google.com", "type" : "bn" }
{ "_id" : ObjectId("5c0270aad64fbc6896311aae"), "name" : "Facebook", "url" : "https://www.google.com", "type" : "dn" }

然后排序：

var MongoClient = require(‘mongodb‘).MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
    if (err) throw err;
    var dbo = db.db("mydatabase");
    var mysort = { type: 1 };
    dbo.collection("mycollection").find().sort(mysort).toArray(function(err, result) {
        if (err) throw err;
        console.log(result);
        db.close();
    });
});

users-MacBook-Pro:test-mongodb user$ node index.js
[ { _id: 5c0270aad64fbc6896311aac,
    name: ‘菜鸟工具‘,
    url: ‘https://c.runoob.com‘,
    type: ‘an‘ },
  { _id: 5c0270aad64fbc6896311aad,
    name: ‘Google‘,
    url: ‘https://www.google.com‘,
    type: ‘bn‘ },
  { _id: 5c026d49ccbd816889e6bb3e,
    name: ‘菜鸟工具‘,
    url: ‘https://c.runoob.com‘,
    type: ‘cn‘ },
  { _id: 5c0270aad64fbc6896311aae,
    name: ‘Facebook‘,
    url: ‘https://www.google.com‘,
    type: ‘dn‘ } ]

查询分页

首先客户端查看得到现在的存储状态：

> db.mycollection.find()
{ "_id" : ObjectId("5c026d49ccbd816889e6bb3e"), "name" : "菜鸟工具", "url" : "https://c.runoob.com", "type" : "cn" }
{ "_id" : ObjectId("5c0270aad64fbc6896311aac"), "name" : "菜鸟工具", "url" : "https://c.runoob.com", "type" : "an" }
{ "_id" : ObjectId("5c0270aad64fbc6896311aad"), "name" : "Google", "url" : "https://www.google.com", "type" : "bn" }
{ "_id" : ObjectId("5c0270aad64fbc6896311aae"), "name" : "Facebook", "url" : "https://www.google.com", "type" : "dn" }

如果要设置指定的返回条数可以使用 limit() 方法，该方法只接受一个参数，指定了返回的条数。

var MongoClient = require(‘mongodb‘).MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
    if (err) throw err;
    var dbo = db.db("mydatabase");
    dbo.collection("mycollection").find().limit(2).toArray(function(err, result) {//只得到前两条数据
        if (err) throw err;
        console.log(result);
        db.close();
    });
});

users-MacBook-Pro:test-mongodb user$ node index.js
[ { _id: 5c026d49ccbd816889e6bb3e,
    name: ‘菜鸟工具‘,
    url: ‘https://c.runoob.com‘,
    type: ‘cn‘ },
  { _id: 5c0270aad64fbc6896311aac,
    name: ‘菜鸟工具‘,
    url: ‘https://c.runoob.com‘,
    type: ‘an‘ } ]

如果要指定跳过的条数，可以使用 skip() 方法。

var MongoClient = require(‘mongodb‘).MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
    if (err) throw err;
    var dbo = db.db("mydatabase");
    dbo.collection("mycollection").find().skip(2).limit(2).toArray(function(err, result) {//跳过前两条数据，只得到后两条数据
        if (err) throw err;
        console.log(result);
        db.close();
    });
});

users-MacBook-Pro:test-mongodb user$ node index.js
[ { _id: 5c0270aad64fbc6896311aad,
    name: ‘Google‘,
    url: ‘https://www.google.com‘,
    type: ‘bn‘ },
  { _id: 5c0270aad64fbc6896311aae,
    name: ‘Facebook‘,
    url: ‘https://www.google.com‘,
    type: ‘dn‘ } ]

连接操作

mongoDB 不是一个关系型数据库，但我们可以使用 $lookup 来实现左连接。

例如我们有两个集合数据分别为：

先创建相应的集合：

集合1：orders

var MongoClient = require(‘mongodb‘).MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
    if (err) throw err;
    var dbo = db.db("mydatabase");
    var myobj = { _id: 1, product_id: 154, status: 1 };
    dbo.collection("orders").insertOne(myobj, function(err, res) {
        if (err) throw err;
        console.log("文档插入成功");
        db.close();
    });
});

客户端查看：

> db.orders.find()
{ "_id" : 1, "product_id" : 154, "status" : 1 }

集合2：products

var MongoClient = require(‘mongodb‘).MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
    if (err) throw err;
    var dbo = db.db("mydatabase");
    var myobj = [
        { _id: 154, name: ‘笔记本电脑‘ },
        { _id: 155, name: ‘耳机‘ },
        { _id: 156, name: ‘台式电脑‘ }
    ];
    dbo.collection("products"). insertMany(myobj, function(err, res) {
        if (err) throw err;
        console.log("文档插入成功");
        console.log("插入的文档数量为: " + res.insertedCount);
        db.close();
    });
});

客户端查看：

> db.products.find()
{ "_id" : 154, "name" : "笔记本电脑" }
{ "_id" : 155, "name" : "耳机" }
{ "_id" : 156, "name" : "台式电脑" }
>

实现左连接:

var MongoClient = require(‘mongodb‘).MongoClient;
var url = "mongodb://127.0.0.1:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
    if (err) throw err;
    var dbo = db.db("mydatabase");
    dbo.collection(‘orders‘).aggregate([{ 
        $lookup:{
            from: ‘products‘, // 右集合
            localField: ‘product_id‘, // 左集合 join 字段
            foreignField: ‘_id‘, // 右集合 join 字段
            as: ‘orderdetails‘ // 新生成字段（类型array）
        }
    }]).toArray(function(err, res) {
        if (err) throw err;
        console.log(JSON.stringify(res));
        db.close();
    });
});

users-MacBook-Pro:test-mongodb user$ node index.js
[{"_id":1,"product_id":154,"status":1,"orderdetails":[{"_id":154,"name":"笔记本电脑"}]}]

即orders集合字段"product_id" : 154与products的_id相符合的products的数据将会为字段orderdetails的值，并存放到orders的数据内，然后返回一个值

删除集合

我们可以使用 drop() 方法来删除集合：

var MongoClient = require(‘mongodb‘).MongoClient;
var url = "mongodb://127.0.0.1:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
    if (err) throw err;
    var dbo = db.db("mydatabase");
    dbo.collection("products").drop(function(err, delOK) { // 执行成功 delOK 返回 true，否则返回 false
        if (err) throw err;
        if (delOK) console.log("集合已删除");
        db.close();
    });
});

客户端查询：

> db.products.find()
>

以上是关于node怎么连接mongodb数据库的主要内容，如果未能解决你的问题，请参考以下文章

Node.JS中使用单例封装MongoDB

node.js怎么把数据存入数据库

node怎么连接mongodb数据库

如何在 node.js 中重用 mongodb 连接

yii2 如何mongodb没有密码怎么用

mongoDB - 插入数据