Node与Mongodb实战

luobo2ni

　　在听陈鸿宇的《理想三旬》。好听～
　　上两篇博文中提到了在Mac下Mongodb的安装与连接，这次我们来看看如何通过Node操作Mongodb。
　　PS：本文中的数据集合采用上篇博文中'test'库中的"mycollection"。
　　一：安装MongoDB包
　　使用Node中的mongodb模块，需要先安装哦～打开终端，输入如下命令～
npm install mongodb　　二：数据库连接与断开
　　1:引入mongodb模块
var mongo = require("mongodb");　　2:创建MongoDB数据库的服务器对象
var server = new mongo.Server(host,port,[options]);　　说明：host：服务器所在地址，默认本地localhost；port：服务器端口号，默认27017；options：可选配置参数。
　　3:创建MongoDB的db对象
　　var db = new mongo.Db(databasename,server,[options]);
　　说明：databasename：数据库名，这里我们使用上篇的“test”数据库；server：服务器对象；options：可选配置参数。
　　4:执行db的open方法，连接数据库
db.open(callback(err,db));　　说明：callback回调方法，如果连接失败，将抛出err错误，连接数据库成功，会返回db对象。
　　5:执行db的close方法，断开数据库连接
db.close();　　说明：关闭数据库连接时，将会触发监听的close事件，该事件有err和db两参数，意义同上。
　　function(err,db){
　　//回调方法
　　}
　　附：代码片段。将下述代码保存在testMongo.js文件中。
　　var mongo = require("mongodb");
　　var host = "localhost";
　　var port = "27017";
　　var server = new mongo.Server(host,port,{auto_reconnect:true});
　　var db = new mongo.Db("test",server,{safe:true});
　　db.open(function(err,db){
　　if(err){
　　throw err;
　　console.log("连接数据库出错");
　　}else{
　　console.log("成功建立数据库连接");
　　db.close();
　　}
　　});
　　db.on("close",function(err,db){
　　if(err){
　　throw err;
　　console.log("连接数据库出错");
　　}else{
　　console.log("关闭数据库连接")
　　}
　　})
　　新开终端，输入"mongod"打开mongodb。
　　新开终端，输入"node testMongo.js"，看到如下结果，就成功啦。
　　testNode  node testMongo.js
　　成功建立数据库连接
　　关闭数据库连接
　　三：数据集合
　　MongoDb操作的是数据集合！！！数据的操作就是数据集合的操作。
db.collection(collectionname,[options],callback(err,collection));　　说明：collectionname：数据库中数据集合名字，此处是上节的"mycollection"；options：可选配置参数。callback：连接的回调方法，会有连接出错的err参数和连接成功的collecction参数。
　　附：代码片段。保存下述文件到testMongo.js中。
　　var mongo = require("mongodb");
　　var host = "localhost";
　　var port = "27017";
　　var server = new mongo.Server(host,port,{auto_reconnect:true});
　　var db = new mongo.Db("test",server,{safe:true});
　　db.open(function(err,db){
　　if(err){
　　throw err;
　　console.log("连接数据库出错");
　　}else{
　　console.log("成功建立数据库连接");
　　db.collection('mycollection',function(err,collection){
　　if(err){
　　throw err;
　　console.log("连接数据集合出错");
　　}else{
　　console.log("成功连接数据集合");
　　db.close();
　　}
　　});
　　}
　　});
　　db.on("close",function(err,db){
　　if(err){
　　throw err;
　　console.log("连接数据库出错");
　　}else{
　　console.log("关闭数据库连接")
　　}
　　})
　　新开终端，输入"node testMongo.js"，看到如下结果，就成功啦。
　　testNode  node testMongo.js
　　成功建立数据库连接
　　成功连接数据集合
　　关闭数据库连接
　　四：MongoDb－增
　　数据集合的insert方法，实现添加数据的操作。
　　collection.insert(docs,[options],[callback(err,docs)])
　　说明：docs：要插入的数据；options：可选配置参数。可选callback：插入的回调方法，插入出错的err参数和插入成功时的docs（插入的数据）参数。
　　附：代码片段。保存下述文件到testMongo.js中。－－在test库的mycollection数据集合中插入5条Cailala
　　var mongo = require("mongodb");
　　var host = "localhost";
　　var port = "27017";
　　var server = new mongo.Server(host,port,{auto_reconnect:true});
　　var db = new mongo.Db("test",server,{safe:true});
　　db.open(function(err,db){
　　if(err){
　　throw err;
　　console.log("连接数据库出错");
　　}else{
　　console.log("成功建立数据库连接");
　　db.collection('mycollection',function(err,collection){
　　if(err){
　　throw err;
　　console.log("连接数据集合出错");
　　}else{
　　console.log("成功连接数据集合");
　　//insert
　　for(var i = 1;i