Node.js的Mongodb使用实例
安装mongodb模块npminstall--savemongodb
数据库连接
varMongoClient=require('mongodb').MongoClient;
varassert=require('assert');
//连接test数据库
varurl='mongodb://localhost:27017/test';
MongoClient.connect(url,(err,db)=>{
assert.equal(null,err);
console.log('连接成功');
db.close();
});
插入数据
插入一个文档对象
varMongoClient=require('mongodb').MongoClient;
varassert=require('assert');
//test数据库的路径
varurl='mongodb://localhost:27017/test';
//插入文档
varinsertDocument=(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操作
varMongoClient=require('mongodb').MongoClient,
test=require('assert');
MongoClient.connect('mongodb://localhost:27017/test',(err,db)=>{
varblog=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的批量插入操作！
varMongoClient=require('mongodb').MongoClient,
test=require('assert');
MongoClient.connect('mongodb://localhost:27017/test',(err,db)=>{
varblog=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）的批量插入操作
varMongoClient=require('mongodb').MongoClient,
test=require('assert'),
co=require('co');
co(function*(){
vardb=yieldMongoClient.connect('mongodb://localhost:27017/test');
varblog=db.collection('blog');
varr=yieldblog.insertMany([{name:"xiaosBB"},{name:"fzqMM"}]);
test.equal(2,r.insertedCount);
db.close();
});
单个文档插入：insertOne(doc,options,callback)（如果没有callback函数，本身返回一个Promise对象）
简单的插入操作
varMongoClient=require('mongodb').MongoClient,
test=require('assert');
MongoClient.connect('mongodb://localhost:27017/test',(err,db)=>{
varblog=db.collection('blog');
blog.insertOne({name:"xiaos"},(err,r)=>{
test.equal(null,err);
test.equal(1,r.insertedCount);
db.close();
});
});
使用Promise的插入操作
varMongoClient=require('mongodb').MongoClient,
test=require('assert');
MongoClient.connect('mongodb://localhost:27017/test',(err,db)=>{
varblog=db.collection('blog');
blog.insertOne({name:"xiaos"}).then((r)=>{
test.equal(1,r.insertedCount);
db.close();
});
});
使用生成器的插入操作
varMongoClient=require('mongodb').MongoClient,
test=require('assert'),
co=require('co');
co(function*(){
vardb=yieldMongoClient.connect('mongodb://localhost:27017/test');
varblog=db.collection('blog');
varr=yieldblog.insertOne({name:"xiaosBB"});
test.equal(1,r.insertedCount);
db.close();
});
mapReduce(map,reduce,options,callback)returnPromiseifnocallback
varMongoClient=require('mongodb').MongoClient,
test=require('assert');
MongoClient.connect()
isCapped(callback)returnPromiseifnocallback
varMongoClient=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();
});
});
});
cappedcollection是指固定大小的集合，新元素插入后会覆盖掉旧的元素，保持整个集合的大小不变。
//在命令行中输入mongo
//创建一个1024大小的myCappedCollection集合
db.createCollection('myCappedCollection',{'capped':true,'size':1024});
//插入1000条记录
for(vari=1;i<=1000;i++){
db.myCappedCollection.save({id:i,name:'xiaos'+i});
}
//查询文档个数
db.myCappedCollection.count()
//实际只有18个文档id为983-1000即新元素覆盖了旧元素
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。