nodejs系列之七——nodejs與mongoDB
原文： http://ramonblog.cloudfoundry.com/blog/4fd4536715d8f0d91e000002
參考其它內容請看本blog中的nodejs系列提綱
更多關於MongoDB的NodeJS驅動內容請參考MongoDB NodeJS Driver
簡介
No-SQL的一篇比較詳細的中文介紹來自於我自然的部落格。而MongoDB也是NoSQL中的一個實現。只不過它現在比較流行於Web開發，尤其是跟NodeJS的結合。
開始
1. 安裝mongodb on Mac
-
安裝包管理軟體brew
訪問HomeBrew可以輕易地安裝brew，它可以很輕鬆地為你在Mac上安裝Unix的程式，譬如mongodb在linux上很容易安裝，但是並沒有Mac原始的安裝包，由於Mac本身也是基於Unix的，所以brew究提供了類似於Linux的簡單安裝方式。 -
安裝mongodb
首先更新brewbrew update然後安裝mongodb：
brew install mongodb安裝成功之後，會自動把mongodb/bin加入到PATH底下，也就是說你可以直接在命令列下執行mongodb相關的命令。啟動mongodb如下：
mongod
注意:Linux或Windows的安裝可以參考官方文件:Installing MongoDB
2. 命令列訪問mongodb
安裝並執行mongodb成功之後，可以執行下面的命令連線mongo db:
localhost:myblog ramon$ mongo MongoDB shell version: 2.0.3 connecting to: test
類似與mysql，執行show dbs可以檢視當前server有幾個資料庫，例如本機的執行情況：
> show dbs
db 0.203125GB
local (empty)
node-mongo-blog 0.203125GB
test 0.203125GB
可以看出，這裡有4個數據庫。你也可以執行命令help以檢視幫助。現在建立資料庫foo，
> use foo
switched to db foo
輸入命令db可以檢視當前資料庫的名字。而要檢視當前資料庫有哪些集合(Collection),也就是關係資料庫中的表可以用如下的命令
> show collections
顯示沒有任何集合，現在建立collection bar:
> db.bar.insert({a: 1, b: 'b1'})
> show collections
bar
system.indexes
對於collection的操作，必須要在collection前面加上db.才行，否則報錯。只要嘗試往bar插入資料，那麼bar就會被建立，根本不需要事先定義bar，而bar的schema也是任意的，也就是說現在插入的資料是{a:1, b: "b1"}，接下來你也可以插入{c:
2, b: "b2"}.至於在檢視集合的時候，發現有system.indexes，它是系統生成的，用於儲存所有的索引（Index）資訊，參考Mongo Metadata。
> db.bar.insert({c:2, b:'b2'})
> db.bar.find()
{ "_id" : ObjectId("4fde10be4245dec7bc76e27e"), "a" : 1, "b" : "b1" }
{ "_id" : ObjectId("4fde118f4245dec7bc76e27f"), "c" : 2, "b" : "b2" }
我們用find命令來檢視collection的資料。你可以看到自動增加了欄位_id為主鍵。
更多的關於mongodb的入門介紹可以參考官方的Tutorial
3. 安裝mongodb nodejs driver
要安裝mongodb nodejs的原生driver，可以通過npm，也可以通過github下載：
npm install mongodb
連線到資料庫
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獲取到結果集之後，需要呼叫toArray方法，並傳遞迴調函式，這個時候才能拿到真正的資料。第二個find語句則是查詢所有a=1的文件。第三個find語句則是隻找第一個滿足條件的文件。具體更多的過濾條件可以參考官方的Query語句。這裡有個有趣的事情需要注意，find本身並不執行查詢，它只是返回一個Cursor例項，你可以遍歷這個Cursor來查詢資料。如下面的例子：
// 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的區別在於，增加了一個option物件引數({safe:true})以及一個回撥函式。MongoDB的insert/update/remove都是非同步的，也就是說發出insert命令之後，就不管資料庫是否執行成功了。要想知道資料庫是否執行成功，需要再發出一個查詢請求來獲取連線（Connection）的最後一個錯誤狀態。為了簡化這個過程，也就支援{safe:true}這個引數，使得insert和錯誤狀態查詢能夠一起執行,一旦設定這個引數，一定要增加回調函式作為第三個引數。具體地，我們可以看下面地例子來理解這個{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的資料。第二次插入的時候，我們設定{safe:true}以確保一定插入成功，這是會報主鍵重複的錯誤。第三次同樣的插入，但是不設定{safe:true}，這個時候發現並沒有報錯，而且回撥函式還拿到了要插入的資料。是不是第三次插入成功了呢？不是的，其實正像第二次插入的一樣，肯定是主鍵重複了，但是由於我們並沒有要求返回最後的錯誤狀態，所以mongodb drvier直接回調了我們傳入的回撥函式，並且設定error為null，bars為要插入的資料。總結一下，如果你要確保資料是否更新（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的第一個引數是條件，即對a＝996的文件進行更新。第二個引數則是表示要如何更新文件，譬如第一個update是增加一個屬性b，且設定其值為字串'b'；第二個update是修改a的值為997。可以看出，第二個引數是一個物件，其屬性名是一個操作符，以$開頭，值為一個物件。這些操作符除了這裡的$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的所有文件。回撥函式的第二個引數是表示相應刪除的文件數量。第二個remove則是刪除該collection中的所有文件。
高階
1. sort
collection.find({}, {sort: [['created_at', 'desc'], ['body', 'asc']]})
其中'desc'也可以用-1表示，而'asc'可以用1表示。如果是隻有一個sort列，也可以用下面的方式
collection.find({}, {sort: {'created_at': -1}})
注意：這裡用一個物件表示sort的時候，排序方向必須是1（升序）或者-1（降序）。可以說這是一個很垃圾的API設計。首先不應該用陣列的陣列來表示sort；而只用一列排序時只能用數字不能用字串更加是API的不一致
2. limit
collection.find({}, {limit: 10, skip:20})
這個可以用來做分頁，表示獲取從第20條（第1條記錄序號為0）記錄開始的10條記錄.類似與Mysql的limit 20, 10.
3. count
collection.count({}, function(err, count){...} )
第一個引數是query物件，可以省略。第二個引數是callback函式。
更多參考
- MongoDB的基礎介紹
- GitHub裡面官方nodejs驅動自帶的一些例子
- 高階查詢