Node.js的Mongodb使用實例
安裝mongodb模塊 npm install --save mongodb
數(shù)據(jù)庫連接
var MongoClient = require('mongodb').MongoClient; var assert = require('assert'); //連接test數(shù)據(jù)庫 var url = 'mongodb://localhost:27017/test'; MongoClient.connect(url, (err,db) => { assert.equal(null,err); console.log('連接成功'); db.close(); });
插入數(shù)據(jù)
插入一個文檔對象
var MongoClient = require('mongodb').MongoClient; var assert = require('assert'); //test數(shù)據(jù)庫的路徑 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函數(shù),本身返回一個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); //回調(diào)函數(shù)中返回的r為執(zhí)行完插入操作的對象,insertedCount屬性為已經(jīng)插入的對象個數(shù) 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的機(jī)制,所有幾乎所有耗時的操作都是以回調(diào)函數(shù)的方式完成。但是因為回調(diào)函數(shù)的層次嵌套,一段代碼后面可能會跟上一大段的 });,隨著層級的增加,代碼變得不易理解和維護(hù)。所有在使用MongoDB時,推薦用Promise的方式來解決回調(diào)嵌套的問題。
從上面的代碼可以看出,insertMany([obj...])返回一個Promise對象,我們用.then((r)=>{})接收正常的回調(diào)值,用.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函數(shù),本身返回一個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 //創(chuàng)建一個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}); } //查詢文檔個數(shù) db.myCappedCollection.count() //實際只有18個文檔id為983-1000 即新元素覆蓋了舊元素
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
Node.js(v16.13.2版本)安裝及環(huán)境配置的圖文教程
本文主要介紹了Node.js(v16.13.2版本)安裝及環(huán)境配置的圖文教程,文中通過圖文介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2024-05-05nodejs express搭建服務(wù)并熱更新文件過程詳解
這篇文章主要為大家介紹了nodejs express搭建服務(wù)并熱更新文件過程詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-11-11為nuxt項目寫一個面包屑cli工具實現(xiàn)自動生成頁面與面包屑配置
這篇文章主要介紹了為nuxt項目寫一個面包屑cli工具實現(xiàn)自動生成頁面與面包屑配置,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-09-09node.js中的events.emitter.once方法使用說明
這篇文章主要介紹了node.js中的events.emitter.once方法使用說明,本文介紹了events.emitter.once的方法說明、語法、接收參數(shù)、使用實例和實現(xiàn)源碼,需要的朋友可以參考下2014-12-12