nodeJS連接MongoDB的方法

分別使用Client對象和字符串連接

 

使用Client對象：

即使用MongoDB的MongoClient類

該對象接受兩個參數：MongoClient(Server,options)

其中Server對象定義了MongoDB驅動程序應該怎樣連接到服務器，包含諸如所使用的主機、端口、池的大小，

options : 數據庫連接選項

 

以下實例：

var MongoClient=require('mongodb').MongoClient,  
    Server=require('mongodb').Server;
var client=new MongoClient(new Server('localhost',28008,{
                            socketOptions:{connectTimeoutMS:500},
                            poolSize:5,
                            auto_reconnect:true
                        },{
                            numberOfRetries:3,
                            retryMiliSeconds:500
                        }));

client.open(function(err,client){
    if (err) {
        console.log('Connection Failed');
    }else{
        var db=client.db("testDB");
        if (db) {
            console.log('conncetion success by Object of Client');
            client.close();
            console.log("db has closed");
        }
    }
});

 

使用字符串方法：

通過使用MongoClient類的connect（）方法

使用語法：

MongoClient.connect(connString,options,callback)

connString語法如下：

mongodb://username:password@host:port/datebase?options

options : 數據庫連接選項

 

以下是實例：

var MongoClient=require('mongodb').MongoClient,
    Server=require('mongodb').Server;

MongoClient.connect("mongodb://localhost:28008/foobar",{
    db:{w:1,native_parser:false},
    server:{
        poolSize:5,
        socketOptions:{connectTimeoutMS:500},
        auto_reconnect:true
    },
    replSet:{},
    mongos:{}
    },function(err,db){
        if (err) {
            console.log("connect failed");
        }else{
            console.log("conenct success by string of mongodb");
            db.logout(function(err,result){
                if (!err) {
                    console.log('logged out success');
                }
                db.close();
                console.log('connect close');
            })
        }
    });