安裝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 即新元素覆蓋了舊元素以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持武林網。
新聞熱點
疑難解答
