Node.js中创建一个Collection对象实例的方法:
var MongoClient = require('mongodb').MongoClient; MongoClient.connect("mongodb://localhost:27017",function(err,db){ dbo = db.db("test"); collectionIns = dbo.collection("products"); console.log(collectionIns); db.close(); });
其中 collectionIns是一个collection对象实例
下面是Collection对象的基本方法
1,insert(docs,[callback])
将一个或多个文档插入到集合,回调函数接收error和result参数
var MongoClient = require('mongodb').MongoClient; MongoClient.connect("mongodb://localhost:27017",function(err,db){ dbo = db.db("test"); collectionIns = dbo.collection("products"); obj = {"_id":166,"name":"白菜在练习"}; collectionIns.insert(obj,function(err,res){ console.log(res); db.close(); }); });
运行结果:
{ result: { ok: 1, n: 1 }, ops: [ { _id: 167, name: '白菜在练习' } ], insertedCount: 1, insertedIds: { '0': 167 } }
2,remove([query],[options],[callback])
从集合中删除文档,query是用于确定要删除的文档的一个参数。如果没有则删除所有。options允许你在修改文档时,使用w,wtimeout,upset,以及新的选项来指定写入关注。当使用写入关注时你必须包括回调函数,回调函数接收error和results
var MongoClient = require('mongodb').MongoClient; url = "mongodb://localhost:27017/test" MongoClient.connect(url,function(err,db){ dbo = db.db("test"); collectionIns = dbo.collection("products"); obj = {"_id":167,"name":"白菜在练习"}; collectionIns.remove(obj,function(err,res){ console.log("删除数据成功"); db.close(); }); });
3,rename(newName,callback)
把集合重命名为newName
4,save([doc],[options],[callback])
把doc参数中的文档保存到数据库
5,update(query,document,[options],[callbakc])
用document参数中指定的信息来更新数据库中雨query对象匹配的文档,回调函数接受error,res
6,find(query,[options],callback)
查找匹配query的文档,回调函数接受error和cursor参数
7,findOne(query,[options],calllback)
查找第一个匹配query的文档,回调函数接收err和cursor
8,findAndModify(query,sort,update,[options],callback)
对于query参数匹配的文档进行修改。sort参数确定哪些对象先被修改。update参数指定要在文档上进行的更改,回调函数接收err,res
9,findAndRemove(query,sort,[options],callback)
删除与query匹配的字符串,sort决定哪些字符串先被修改,callback接收err和res
10,distinct(key,[query],callback)
在集合中为一个特定的文档key创建不同的值的列表。如果指定query参数那么只有与query匹配的文档在内。回调函数接受error,values
11,count([query],callback)
计算集合中文档的数量,
12,drop(callback)
删除当前集合
13,stats(callback)
获取集合的统计信息,包括条目数量,在磁盘上的大小,平均对象大小,以及更多的信息。
var MongoClient = require('mongodb').MongoClient; url = "mongodb://localhost:27017/test" MongoClient.connect(url,function(err,db){ dbo = db.db("test"); collectionIns = dbo.collection("products"); obj = {"_id":167,"name":"白菜在练习"}; collectionIns.stats(obj,function(err,stats){ console.log(stats); db.close(); }); });