luobo2ni 发表于 2018-10-25 12:42:00

Node与Mongodb实战

  在听陈鸿宇的《理想三旬》。好听~
  上两篇博文中提到了在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,);  说明:host:服务器所在地址,默认本地localhost;port:服务器端口号,默认27017;options:可选配置参数。
  3:创建MongoDB的db对象
  var db = new mongo.Db(databasename,server,);
  说明: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",看到如下结果,就成功啦。
  testNodenode testMongo.js
  成功建立数据库连接
  关闭数据库连接
  三:数据集合
  MongoDb操作的是数据集合!!!数据的操作就是数据集合的操作。
db.collection(collectionname,,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",看到如下结果,就成功啦。
  testNodenode testMongo.js
  成功建立数据库连接
  成功连接数据集合
  关闭数据库连接
  四:MongoDb-增
  数据集合的insert方法,实现添加数据的操作。
  collection.insert(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
页: [1]
查看完整版本: Node与Mongodb实战