Node.js教程（07）｜MongoDB 开发

MongoDB 驱动安装（链接：Node.js MongoDB 驱动）

npm install mongodb --save

连接数据库

var MongoClient = require('mongodb').MongoClient
var url = 'mongodb://localhost:27017/test'

MongoClient.connect(url, {useNewUrlParser: true}, function(err, db) {
    if (err) throw err
    console.log('数据库连接成功')
    db.close()
})

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

创建集合

var MongoClient = require('mongodb').MongoClient
var url = 'mongodb://localhost:27017/test'

MongoClient.connect(url, {useNewUrlParser: true}, function(err, db) {
    if (err) throw err
    console.log('数据库连接成功')
    
    var dbase = db.db('test')
    // 创建集合
    dbase.createCollection('site', function(err, res) {
        if (err) throw err
        console.log('集合创建成功')
        db.close()
    })
})

事实上：与 MySQL 不同的是，MongoDB 会自动创建数据库和集合。当我们尝试连接一个不存在的数据库或集合时，MongoDB会自动帮我创建它们，因此我们通常不必手动去创建它们。

插入一条数据 insertOne() / 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("test");
    var myobj = { name: "evatsai", url: "www.evatsai.com" };
    dbo.collection("site").insertOne(myobj, function(err, res) {
        if (err) throw err;
        console.log("文档插入成功");
        db.close();
    });
});

更新一条数据 updateOne() / 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("runoob");
    var whereStr = {"name":'evatsai'};    // 查询条件
    var updateStr = {$set: { "url" : "http://geekxia.cn" }};
    dbo.collection("site").updateOne(whereStr, updateStr, function(err, res) {
        if (err) throw err;
        console.log("文档更新成功");
        db.close();
    });
});

删除数据 deleteOne() / deleteMany()

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("runoob");
    var whereStr = {"name":'evatsai'};    // 查询条件
    dbo.collection("site").deleteOne(whereStr, function(err, obj) {
        if (err) throw err;
        console.log("文档删除成功");
        db.close();
    });
});

查询数据 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("runoob");
     var whereStr = {"name":'evatsai'};   // 查询条件
    dbo.collection("site").find(whereStr).toArray(function(err, result) {
        if (err) throw err;
        console.log(result);
        db.close();
    });
});

• sort() ： 配合使用该方法，可以实现数据排序。
• limit() ： 配合使用该方法，可以实现分页查询。
• skip() ： 使用该方法，可以跳过若干条数据。

数据库 左连接
MongoDB 不是一个关系型数据库，但我们可以使用 $lookup 来实现左连接。例如我们有两个集合数据分别为：

集合 orders：
[
  { _id: 1, product_id: 154, status: 1 }
]

集合 products：
[
  { _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("runoob");
  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();
  });
});

删除集合 drop()

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("test");
    // 删除 test 集合
    dbo.collection("site").drop(function(err, delOK) {  // 执行成功 delOK 返回 true，否则返回 false
        if (err) throw err;
        if (delOK) console.log("集合已删除");
        db.close();
    });
});

Node.js完整教程 本篇结束！