广告
返回顶部
首页 > 资讯 > 数据库 >Node与Mongodb实战
  • 407
分享到

Node与Mongodb实战

node.mongodb.增删改查%dmong 2022-10-18 02:10:54 407人浏览 八月长安
摘要

在听陈鸿宇的《理想三旬》。好听~上两篇博文中提到了在Mac下mongoDB的安装与连接,这次我们来看看如何通过node操作MonGodb。PS:本文中的数据集合采用上篇博文中'test'库中的"mycoll

在听陈鸿宇的《理想三旬》。好听~


上两篇博文中提到了在MacmongoDB的安装与连接,这次我们来看看如何通过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<6;i++){

collection.insert({'name':'Cailala'+i},function(err,docs){

console.log(docs);

db.close();

});

}

}

});

}

});


db.on("close",function(err,db){

if(err){

throw err;

console.log("连接数据库出错");

}else{

console.log("关闭数据库连接")

}

})

新开终端,输入"node testMongo.js",看到如下结果,就成功啦。

 testNode  node testMongo.js

成功建立数据库连接

成功连接数据集合

{ result: { ok: 1, n: 1 },

  ops: [ { name: 'Cailala1', _id: 57a1fb5292764dbc5736dcd9 } ],

  insertedCount: 1,

  insertedIds: [ 57a1fb5292764dbc5736dcd9 ] }

关闭数据库连接

{ result: { ok: 1, n: 1 },

  ops: [ { name: 'Cailala2', _id: 57a1fb5292764dbc5736dcda } ],

  insertedCount: 1,

  insertedIds: [ 57a1fb5292764dbc5736dcda ] }

{ result: { ok: 1, n: 1 },

  ops: [ { name: 'Cailala3', _id: 57a1fb5292764dbc5736dcdb } ],

  insertedCount: 1,

  insertedIds: [ 57a1fb5292764dbc5736dcdb ] }

{ result: { ok: 1, n: 1 },

  ops: [ { name: 'Cailala4', _id: 57a1fb5292764dbc5736dcdc } ],

  insertedCount: 1,

  insertedIds: [ 57a1fb5292764dbc5736dcdc ] }

{ result: { ok: 1, n: 1 },

  ops: [ { name: 'Cailala5', _id: 57a1fb5292764dbc5736dcdd } ],

  insertedCount: 1,

  insertedIds: [ 57a1fb5292764dbc5736dcdd ] }

五:MongoDb-查

数据集合的find方法,实现查询数据的操作。

collection.find(selector,[options]).toArray(callback(err,docs))

说明:selector:查询条件;options:可选配置参数。find方法返回的是Cursor游标对象,该对象的toArray方法将返回查询到的所有数据文档,参数callback:查询的回调方法,查询出错的err参数和查询成功时的docs(查询出的数据)参数。

附:代码片段。保存下述文件到testMongo.js中。--查询数据集合中name是Cailala1的数据

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("成功连接数据集合");

//find

collection.find({name:"Cailala1"},{fields:{name:1,_id:0}}).toArray(function(err,docs){

if(err) throw err;

else 

console.log(docs);

db.close();

});

}

});

}

});


db.on("close",function(err,db){

if(err){

throw err;

console.log("连接数据库出错");

}else{

console.log("关闭数据库连接")

}

})

新开终端,输入"node testMongo.js",看到如下结果,就成功啦。

 testNode  node testMongo.js

成功建立数据库连接

成功连接数据集合

[ { name: 'Cailala1' } ]

关闭数据库连接

六:MongoDb-改

数据集合的update方法,实现修改数据的操作。

collection.update(selector,documents,[optiOS],[callback(err,resu)])

说明:selector:需要更新的数据文档;documents:用于更新的文档;options:可选配置参数;可选callback:修改的回调方法,修改出错的err参数和修改成功时的result(成功修改的数据条数)参数。

附:代码片段。保存下述文件到testMongo.js中。--修改name是Cailala1为liujinhuan,并查询输出。

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("成功连接数据集合");

// update

collection.update({name:"Cailala1"},{name:"liujinhuan"},function(err,res){

if(err){

throw err;

}else{

console.log("成功更新 "+JSON.parse(res).n+"  条数据");

collection.find({},{fields:{name:1,_id:0}}).toArray(function(err,docs){

if(err) 

throw err;

else 

console.log(docs);

db.close();

});

}

});

}

});

}

});


db.on("close",function(err,db){

if(err){

throw err;

console.log("连接数据库出错");

}else{

console.log("关闭数据库连接")

}

})

新开终端,输入"node testMongo.js",看到如下结果,就成功啦。

 testNode  node testMongo.js

成功建立数据库连接

成功连接数据集合

成功更新 1  条数据

[ { name: 'liujinhuan' },

  { name: 'Cailala2' },

  { name: 'Cailala3' },

  { name: 'Cailala4' },

  { name: 'Cailala5' } ]

关闭数据库连接

七:MongoDb-删

数据集合的remove方法,实现删除数据的操作。

collection.remove([selector],[options],[callback])

说明:可选selector:删除的条件,不指定则删除全部;可选options:配置参数;可选callback:删除的回调方法,删除出错的err参数和删除成功时的result(成功修改的数据条数)参数。

附:代码片段。保存下述文件到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("成功连接数据集合");

//remove

collection.remove({name:"liujinhuan"},function(err,res){

if(err){

throw err;

}else{

console.log("成功删除 "+JSON.parse(res).n+"  条数据");

collection.find({},{fields:{name:1,_id:0}}).toArray(function(err,docs){

if(err) 

throw err;

else 

console.log(docs);

db.close();

});

}

});

}

});

}

});


db.on("close",function(err,db){

if(err){

throw err;

console.log("连接数据库出错");

}else{

console.log("关闭数据库连接")

}

})

新开终端,输入"node testMongo.js",看到如下结果,就成功啦。

 testNode  node testMongo.js

成功建立数据库连接

成功连接数据集合

成功删除 1  条数据

[ { name: 'Cailala2' },

  { name: 'Cailala3' },

  { name: 'Cailala4' },

  { name: 'Cailala5' } ]

关闭数据库连接



以上就是总结的Node操作的Mongodb。其中的options都是一些可以配置的参数~这里只是基础的用法啦~欢迎吐槽


Mac不能上传结果的截图~又不能上传实例代码~好尴尬呀~


听不懂《理想三旬》。但还是在听~直到听吐为止吧~

您可能感兴趣的文档:

--结束END--

本文标题: Node与Mongodb实战

本文链接: https://www.lsjlt.com/news/36580.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑,方便收藏和打印~

下载Word文档
猜你喜欢
软考高级职称资格查询
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作