Node.js的Mongodb使用

安裝mongodb模塊 npm install --save mongodb

數據庫連接

var MongoClient = require(‘mongodb‘).MongoClient;
var assert = require(‘assert‘);

//連接test數據庫
var url = ‘mongodb://localhost:27017/test‘;
MongoClient.connect(url, (err,db) => {
    assert.equal(null,err);
    console.log(‘連接成功‘);
    db.close();
});
 

插入數據

插入一個文檔對象

var MongoClient = require(‘mongodb‘).MongoClient;
var assert = require(‘assert‘);

//test數據庫的路徑
var url = ‘mongodb://localhost:27017/test‘;

//插入文檔
var insertDocument = (db,callback) => {
    //在test庫下blog集合中 新增json文檔
    db.collection(‘blog‘).insertOne({
        name:"xiaos",
        age:22
    }, (err, result) => {
        assert.equal(err,null);
        console.log(‘新增文檔成功‘);
        callback();
    });
};

//插入操作
MongoClient.connect(url, (err,db) => {
    assert.equal(null,err);
    insertDocument(db, ()=>{
        db.close();
    });
});
 

批量插入操作：insertMany(doc,options,callback)（如果沒有callback函數，本身返回一個Promise對象）

簡單的insertMany操作

var MongoClient = require(‘mongodb‘).MongoClient,
    test = require(‘assert‘);

MongoClient.connect(‘mongodb://localhost:27017/test‘,(err, db) => {
    var blog = db.collection(‘blog‘);
    //新增兩個文檔對象
    blog.insertMany([{name:"shen"},{name:"fzq"}],(err,r) => {
        test.equal(null,err);
        //回調函數中返回的r為執行完插入操作的對象，insertedCount屬性為已經插入的對象個數
        test.equal(2,r.insertedCount);
        db.close();
    });
});    
 

使用Promise的批量插入操作！

var MongoClient = require(‘mongodb‘).MongoClient,
    test = require(‘assert‘);
MongoClient.connect(‘mongodb://localhost:27017/test‘, (err,db) => {
    var blog = db.collection(‘blog‘);
    blog.insertMany([{name:"xiaosGG"},{name:"fzqDD"}]).then((r) => {
        test.equal(2,r.insertedCount);
        db.close();
    });
});

因為mongodb和nodejs都是異步io的機制，所有幾乎所有耗時的操作都是以回調函數的方式完成。但是因為回調函數的層次嵌套，一段代碼後面可能會跟上一大段的 });，隨著層級的增加，代碼變得不易理解和維護。所有在使用MongoDB時，推薦用Promise的方式來解決回調嵌套的問題。
從上面的代碼可以看出，insertMany([obj...])返回一個Promise對象，我們用.then((r)=>{})接收正常的回調值，用.catch((err) => {})來抓取異常。

使用生成器（Generator）的批量插入操作

var MongoClient = require(‘mongodb‘).MongoClient,
    test = require(‘assert‘),
    co = require(‘co‘);
    
co(function*(){
    var db = yield MongoClient.connect(‘mongodb://localhost:27017/test‘);
    var blog = db.collection(‘blog‘);
    var r = yield blog.insertMany([{name:"xiaosBB"},{name:"fzqMM"}]);
    test.equal(2,r.insertedCount);
    db.close();
});

單個文檔插入：insertOne(doc,options,callback)（如果沒有callback函數，本身返回一個Promise對象）

簡單的插入操作

var MongoClient = require(‘mongodb‘).MongoClient,
    test = require(‘assert‘);
MongoClient.connect(‘mongodb://localhost:27017/test‘,(err,db)=>{
    var blog = db.collection(‘blog‘);
    blog.insertOne({name:"xiaos"},(err,r) => {
        test.equal(null,err);
        test.equal(1,r.insertedCount);
        db.close();
    });
});

使用Promise的插入操作

var MongoClient = require(‘mongodb‘).MongoClient,
    test = require(‘assert‘);
MongoClient.connect(‘mongodb://localhost:27017/test‘,(err,db)=>{
    var blog = db.collection(‘blog‘);
    blog.insertOne({name:"xiaos"}).then((r)=>{
        test.equal(1,r.insertedCount);
        db.close();
    });
});

使用生成器的插入操作

var MongoClient = require(‘mongodb‘).MongoClient,
    test = require(‘assert‘),
    co = require(‘co‘);
    
co(function*(){
    var db = yield MongoClient.connect(‘mongodb://localhost:27017/test‘);
    var blog = db.collection(‘blog‘);
    var r = yield blog.insertOne({name:"xiaosBB"});
    test.equal(1,r.insertedCount);
    db.close();
});

mapReduce(map,reduce,options,callback) return Promise if no callback

var MongoClient = require(‘mongodb‘).MongoClient,
    test = require(‘assert‘);

MongoClient.connect()

isCapped(callback) return Promise if no callback

var MongoClient = require(‘mongodb‘).MongoClient,
    test = require(‘assert‘);
MongoClient.connect(‘mongodb://localhost:27017/test‘,(err,db) => {
    db.createCollection(‘newBlog‘,{‘capped‘:true,‘size‘:1024},(err,collection) => {
        test.equal(‘newBlog‘,collection.collectionName);        
        collection.isCapped((err,capped) => {
            test.equal(true,capped);
            db.close();
        });
    });
});

capped collection是指固定大小的集合，新元素插入後會覆蓋掉舊的元素，保持整個集合的大小不變。

//在命令行中輸入mongo
//創建一個1024大小的myCappedCollection集合
db.createCollection(‘myCappedCollection‘,{‘capped‘:true,‘size‘:1024});
//插入1000條記錄
for (var i = 1;i <= 1000;i++){
    db.myCappedCollection.save({id:i,name:‘xiaos‘+i});
}
//查詢文檔個數
db.myCappedCollection.count()
//實際只有18個文檔id為983-1000 即新元素覆蓋了舊元素

Nodejs中Mongodb的基本使用