时间:2021-05-26
安装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 即新元素覆盖了旧元素以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
本文实例讲述了Node.js操作MongoDB数据库。分享给大家供大家参考,具体如下:Node.js操作MongoDBnpminitnpmimongodb--s
前言Mongoose是在node.js异步环境下对mongodb进行便捷操作的对象模型工具那么要使用它,首先你得装上node.js和mongodb,关于mong
node.js操作MongoDB时,需要安装mongodb包1、使用npm安装cnpmnpminstall-gcnpm--registry=https://re
Linux使用Node.js建立访问静态网页的服务实例详解一、安装node.js运行所需要的环境,:二、创建node目录(/node/www),并在目录下创建n
本文实例讲述了Node.js中SQLite3和MongoDB的用法。分享给大家供大家参考,具体如下:setup.js:初始化数据库varutil=require