1.安裝mongodb nodejs driver
要安裝mongodb nodejs的原生driver,可以通過npm,也可以通過github下載:
npm install mongodb
2連接到數(shù)據(jù)庫
var mongo = require('mongodb'),
Server = mongo.Server,
Db = mongo.Db;
var server = new Server('localhost', 27017, {auto_reconnect: true});
var db = new Db('foo', server);
db.open(function(err, db) {
if(!err) {
console.log("We are connected");
}
});
查詢Get
db.open(function(err, db) {
if(!err) {
console.log("We are connected");
db.collection('bar', function(err, collection){
collection.find().toArray(function(error, bars){console.log(bars);});
collection.find({a:1}).toArray(function(error, bars){console.log(bars);});
collection.findOne({a: 1}, function(error, bar){console.log(bar)});
});
}
});
這里一旦用find獲取到結果集之后捉超,需要調(diào)用toArray方法,并傳遞回調(diào)函數(shù)唯绍,這個時候才能拿到真正的數(shù)據(jù)拼岳。第二個find語句則是查找所有a=1的文檔。第三個find語句則是只找第一個滿足條件的文檔况芒。具體更多的過濾條件可以參考官方的Query語句惜纸。這里有個有趣的事情需要注意,find本身并不執(zhí)行查詢绝骚,它只是返回一個Cursor實例耐版,你可以遍歷這個Cursor來查詢數(shù)據(jù)。如下面的例子:
// Cursors don't run their queries until you actually attempt to retrieve data
// from them.
// Find returns a Cursor, which is Enumerable. You can iterate:
collection.find(function(err, cursor) {
cursor.each(function(err, item) {
if(item != null) console.dir(item);
});
});
// You can turn it into an array
collection.find(function(err, cursor) {
cursor.toArray(function(err, items) {
console.log("count: " + items.length);
});
});
插入Insert
db.open(function(err, db) {
if(!err) {
db.collection('bar', function(err, collection) {
var doc1 = {a: 1};
var doc2 = {a: 2, b: 'b2'};
var docs = [{a:3}, {a:4}];
collection.insert(doc1);
collection.insert(doc2, {safe:true}, function(err, result) {});
collection.insert(docs, {safe:true}, function(err, result) {});
});
}
});
第一個insert和第二個insert的區(qū)別在于压汪,增加了一個option對象參數(shù)({safe:true})以及一個回調(diào)函數(shù)粪牲。MongoDB的
insert/update/remove都是異步的,也就是說發(fā)出insert命令之后止剖,就不管數(shù)據(jù)庫是否執(zhí)行成功了腺阳。要想知道數(shù)據(jù)庫是否執(zhí)行成功,需
要再發(fā)出一個查詢請求來獲取連接(Connection)的最后一個錯誤狀態(tài)穿香。為了簡化這個過程亭引,也就支持{safe:true}這個參數(shù),使得
insert和錯誤狀態(tài)查詢能夠一起執(zhí)行,一旦設置這個參數(shù)皮获,一定要增加回調(diào)函數(shù)作為第三個參數(shù)焙蚓。具體地,我們可以看下面地例子來理解這個
{safe:true}的意義:
db.collection('bar', function(err, collection){
collection.insert({a:996, _id:'1'}, function(error, bars){
console.log('insert success without safe');
console.log(error);
console.log(bars);
collection.insert({a:996, _id:'1'}, {safe:true}, function(error, bars){
console.log('insert fail with safe and get error');
console.log(error);
console.log(bars);
collection.insert({a:996, _id:'1'}, function(error, bars){
console.log('insert fail without safe but no error');
console.log(error);
console.log(bars);
});
});
});
});
# output result
[app.js] insert success without safe
[app.js] null
[app.js] [ { a: 996, _id: '1' } ]
[app.js] insert fail with safe and get error
[app.js] { [MongoError: E11000 duplicate key error index: foo.bar.$_id_ ?dup key: { : "1" }]
name: 'MongoError',
err: 'E11000 duplicate key error index: foo.bar.$_id_ ?dup key: { : "1" }',
code: 11000,
n: 0,
connectionId: 38,
ok: 1 }
[app.js] undefined
[app.js] insert fail without safe but no error
[app.js] null
[app.js] [ { a: 996, _id: '1' } ]
這里的_id是mongodb默認的主鍵,是不允許重復的购公。如果你傳入了_id則以傳入的值作為主鍵赵哲,如果沒有傳入則會自動生成。你可以看到君丁,第一次insert枫夺,我們也不關心是不是真的插入了,幸運的是真的成功了绘闷,因為不存在_id為1的數(shù)據(jù)橡庞。第二次插入的時候,我們設置{safe:true}以確保一定插入成功印蔗,這是會報主鍵重復的錯誤扒最。第三次同樣的插入,但是不設置{safe:true}华嘹,這個時候發(fā)現(xiàn)并沒有報錯吧趣,而且回調(diào)函數(shù)還拿到了要插入的數(shù)據(jù)。是不是第三次插入成功了呢耙厚?不是的强挫,其實正像第二次插入的一樣,肯定是主鍵重復了薛躬,但是由于我們并沒有要求返回最后的錯誤狀態(tài)俯渤,所以mongodb drvier直接回調(diào)了我們傳入的回調(diào)函數(shù),并且設置error為null型宝,bars為要插入的數(shù)據(jù)八匠。總結一下趴酣,如果你要確保數(shù)據(jù)是否更新(insert/update/remove)成功必須要設置{safe:true}選項梨树。
更新Update
collection.update({a:996}, {$push: {b:'b'}}, function(error, bars){});
collection.update({a:996}, {$set: {a:997}}, function(error, bars){});
注意,這里為了代碼簡單岖寞,我們沒有設置{safe:true}抡四。你可以看到update的第一個參數(shù)是條件,即對a=996的文檔進行更新慎璧。第二個參數(shù)則
是表示要如何更新文檔床嫌,譬如第一個update是增加一個屬性b,且設置其值為字符串'b'胸私;第二個update是修改a的值為997厌处。可以看出岁疼,第二個
參數(shù)是一個對象阔涉,其屬性名是一個操作符缆娃,以$開頭,值為一個對象瑰排。這些操作符除了這里的$push和$set贯要,還有其它的$inc, $unset,
$pushAll等等,具體可以參考這里椭住。
刪除Delete
collection.remove({a:997}, {safe:true}, function(error, count){
console.log(error);
console.log(count);
collection.remove();
});
這里第一個remove是刪除a=997的所有文檔崇渗。回調(diào)函數(shù)的第二個參數(shù)是表示相應刪除的文檔數(shù)量京郑。第二個remove則是刪除該collection中的所有文檔宅广。