1.从Node.js链接到MongoDB

MongoDB采用了MongoDB Node.js驱动程序作为标准。

1.安装MongoDB驱动

npm install mongoDB
npm install mongoose

require('mongodb')可以访问mongodb模块

2.从Node.js连接到MongoDB

可以通过打开到MongoDB服务器的连接开始从Node.js应用程序访问MongoDB.

连接用来:创建,更新存取MongoDB数据库中的接口

访问MongoDB最佳方法:通过mongodb模块中的MongoClient类。

1)创建MongoClient对象的一个实例,通过该对象创建和管理MongoDB的连接。

2)使用连接字符串进行连接

2.1.写入关注

连接和更新MongoDB服务器上的数据前,要决定连接上实现什么级别的写入关注。

write concern 指的是:在报告写操作成功的时候,MongoDB连接提供的保证

2.2.了解Server对象

MongoClient连接利用了在后台的Server对象。这个对象定义了MongoDB驱动程序应该怎样连接到服务器。

Server对象包含:创建连接时所用的主机,端口,池的大小,以及套接字的超时值的信息。

Server对象选项:readPreference ssl poolSize socketOptions auto_reconnect

2.3.通过client对象连接到MongoDB

使用MongoClient对象连接到MongoDB涉及创建客户端的一个实例,打开到数据库的连接,以及如果需要,验证到数据库,然后根据需要处理注销和关闭。

MongoClient(Server,options)

Server为第一个参数,第二个参数规定了数据库的连接选项

var client=new MongoClient(new Server('localhost',27017,{poolSize:5}),retryMiliSeconds:500);

一旦创建了MongoClient,可以通过open(callback)打开到服务器的MongoDB数据库的连接。

(新版本废除了client.open()方法)

client.open(function(err,client){...})

连接到特定的数据库,需要在client对象上使用db(databasename)方法创建数据库实例。可以使用数据库连接选项,创建可用于访问特定数据库的集合中的db对象实例。如果启用了身份验证,在尝试访问前:

db.authenticate(username,password,callback)验证到数据库

var db=client.db("testDB");
db.authenticate("dbadmin","test",function(err,results){...})

要注销数据库,使用对象上的logout()方法。将关闭到数据库的连接

db.logout();

要关闭到MongoDB的连接,在客户端上调用close()

client.close()

2.4.通过连接字符串连接到MongoDB

可以使用一个简单的连接字符串创建,打开,并验证到数据库的连接。

用于连接到数据库的Server和MongoClient选项在后台生成。

MongoClient.connect(connString,options,callback)

connString字符串的语法如下:

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

options可以包含db,server,rplSet和mongos属性的一个对象  

3.在MongoDB Node.js驱动程序中的对象

MongoDB Node.js驱动程序使用了大量的结构化对象与数据库进行交互。  

Db对象:提供对数据库的访问。(连接,添加用户,访问集合) 数据库创建,Db对象被创建

Admin对象:对MongoDB数据库执行管理职能。专门代表到admin数据库的连接

Collection对象:数据库的集合。可以使用Collection对象访问集合中的条目,添加文档,查询文档。。

4.访问和操作数据库

提供了从Node.js应用程序创建并管理数据库的能力。

列出数据库

var MongoClient=require('mongodb').

4.1.列出数据库  

要列出一个系统中的数据库,需要在Admin对象上使用listDatabases()

数据库列表在回调函数的第二个参数中返回,并且是数据库对象的一个简单的数组。

var MongoClient=require('mongodb').MongoClient;
MongoClient.connect("mongodb://localhost/admin",function(err,db){
var admainDB=db.admin();
adminDB.listDatabases(function(err,databases){
console.log("before add database list: ");
console.log(database);
})
})

4.2.创建数据库

MongoClient连接Db对象上的Db()方法创建一个新的Db对象实例。调用Db对象实例上的createCollection()来创建数据库。

新版直接用 var newDB=db.db("newDB");

4.3.删除数据库

Db实例的dropDatabase()方法删除  

var MongoClient=require('mongodb').MongoClient;
MongoClient.connect("mongodb://localhost/",function(err,db){
var adminDB=db.admin();
adminDB.listDatabases(function(err,databases){
console.log("before add database list:");
console.log(databases);
});
var newDB=db.db("newDB");
newDB.createCollection("newCollection",function(err,collection){
if(!err){
console.log("new database and collection created");
adminDB.listDatabases(function(err,databases){
console.log("after add database list:");
console.log(databases);
db.db("newDB").dropDatabase(function(err,results){
if(!err){
console.log("database dropped");
setTimeout(function(){
adminDB.listDatabases(function(err,results){
var found=false;
for(var i=0;i<results.databases.length;i++){
if(results.databases[i].name=="newDB")
found=true;
}
if(!found){
console.log('after delete database list: ');
console.log(results);
}
db.close();
})
},1500)
}
})
})
}
})
})

4.5.获取MongoDB服务器的状态

admin对象的另一大特性,具有获取有关MongoDB的服务器状态信息的能力。

主机名,版本,运行时间,打开的游标

Admin对象的serverStatus()方法

  

 

  

  

  

  

上一篇:Volatile关键字&&DCL单例模式,volatile 和 synchronized 的区别


下一篇:【转】volatile和synchronized的区别