扫码关注官方微信

扫码下载APP
返回顶部
首页 > 资讯 > 数据库 >Node与Mongodb实战
  • 407

0
分享到

Node与Mongodb实战

2024-04-02 19:04:59 407人浏览 八月长安
摘要

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

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


上两篇博文中提到了在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<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://lsjlt.com/news/36580.html(转载时请注明来源链接)

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

猜你喜欢
  • Node与Mongodb实战
    在听陈鸿宇的《理想三旬》。好听～上两篇博文中提到了在Mac下Mongodb的安装与连接，这次我们来看看如何通过Node操作Mongodb。PS：本文中的数据集合采用上篇博文中'test'库中的"mycoll...
    99+
    2024-04-02
  • MongoDB实战（7）索引与性能
    一、索引MongoDB提供了多样性的索引支持索引信息被保存在system.indexes中且默认总是为_id创建索引。1、基础索引在字段age上创建索引1(升序);-1(降序)上例显示出来的一共有2个索引其...
    99+
    2024-04-02
  • MongoDB实战（3）固定集合与GridFS
    一、固定集合（Capped Collection） capped collections 是性能出色的有着固定大小的集合,以 LRU(Least Recently Used 最近最少使用)规则和插入顺序进...
    99+
    2024-04-02
  • MongoDB实战（3）固定集合与Gri
    一、固定集合（Capped Collection） capped collections 是性能出色的有着固定大小的集合,以 LRU(Least Recently Used 最近最少使用)规则和插入顺序进行 age-out(老化移出)处理...
    99+
    2023-01-31
    实战 MongoDB Gri
  • 10.网络爬虫—MongoDB详讲与实战
    网络爬虫—MongoDB详讲与实战 MongoDBMongoDB安装创建数据目录1.数据库操作2.集合操作3.文档操作4.索引操作5.聚合操作6.备份与恢复 MongoDB增删改查mong...
    99+
    2023-09-10
    爬虫 mongodb 数据库 python
  • MongoDB实战（4）MapReduce
    在 MongoDB 上使用 Map/Reduce进行并行"统计"很容易。使用 MapReduce 要实现两个函数 Map 函数和 Reduce 函数,Map 函数调用 emit(key, value),遍历...
    99+
    2024-04-02
  • 借助node实战JSONP跨域实例
    一、前言： 浏览器安全是基于同源策略的。所谓同源策略就是三相同： 1、协议相同； 2、域名相同； 3、端口相同。 但，凡事都是有利弊，同源策略也导致了我们想用AJAX跨域请求，但NO！！为了规避这种限制，...
    99+
    2022-06-04
    实战 实例 node
  • 实战MongoDB-Replication之Replica Set
    实战MongoDB Master-Slave   MongoDB支持不同服务之间的异步的数据复制，来实现failover（故障转移，故障切换，故障恢复） and redundancy（数据冗余）。...
    99+
    2024-04-02
  • MongoDB实战（12）Replica Sets + Sharding
    MongoDB Auto-Sharding 解决了海量存储和动态扩容的问题但离实际生产环境所需的高可靠、高可用还有些距离所以有了” Replica Sets ...
    99+
    2024-04-02
  • MongoDB实战（8）性能监控
    一、mongosniff此工具可以从底层监控到底有哪些命令发送给了 MongoDB 去执行,从中就可以进行分析:以 root 身份执行:./mongosniff --source NET lo然后其会监控位...
    99+
    2024-04-02
  • MongoDB实战（11）Sharding 分片（下）
    管理维护Sharding 列出所有的Shard Server 查看Sharding信息 判断是否是Sharding 对现有的表进行Sharding刚才我们是...
    99+
    2024-04-02
  • MongoDB实战（11）Sharding 分片（上）
    这是一种将海量的数据水平扩展的数据库集群系统数据分表存储在sharding 的各个节点上使用者通过简单的配置就可以很方便地构建一个分布式MongoDB 集群。 MongoDB&...
    99+
    2024-04-02
  • .Net Core中使用MongoDB搭建集群与项目实战
    目录安装MongoDBapt直接安装(方法1)apt仓库安装(方法2)方法1、2启动MongoDB通过二进制包安装(方法3)安装依赖deb安装MongoDBtgz安装MongoDB启...
    99+
    2024-04-02
  • Node+Express+MongoDB实现登录注册功能实例
    注入MongoDB 依赖 var mongoose = require("mongoose"); 由于需要进行表单处理，需要用到bodyParser中间件 bodyParser模块来做文件解析，将表单...
    99+
    2022-06-04
    实例 功能 Node
  • MongoDB基础安装（实战部署）
    MongoDB基础安装 MongoDB概述 （1）MongoDB是一个基于分布式文件存储的数据库。由C++语言编写。旨在为WEB应用提供可扩展的高性能数据存储解决方案。 （2）MongoDB是一个介于关系数...
    99+
    2024-04-02
  • MongoDB在物联网领域的应用实践与挑战解析
    随着物联网的快速发展，越来越多的设备开始连接到互联网，产生海量的数据。这些数据的存储和处理成为了一个巨大的挑战，因此，现代的物联网应用普遍采用了大数据技术。MongoDB作为一种NoSQL数据库管理系统，具有高性能、高扩展性和灵活的数据模型...
    99+
    2023-11-02
    物联网 MongoDB 应用实践
  • MongoDB 日志切换（Rotate Log Files）实战
    MongoDB 日志切换（Rotate Log Files）实战 1. 在mongo shell下，执行logRotate命令：    use admin ...
    99+
    2024-04-02
  • MongoDB实战（9）Replica Sets 副本集（上）
    MongoDB 支持在多个机器中通过异步复制达到故障转移和实现冗余。多机器中同一时刻只有一台是用于写操作。正是由于这个情况,为 MongoDB 提供了数据一致性的保障。担当Pr...
    99+
    2024-04-02
  • Mongodb实战之全文搜索功能
    前言 众所周知在传统的关系型数据库中，我们通常将数据结构化，通过一系列表关联、聚合来查询我们所需的结果。而在非结构化的数据中，缺少这种预定义的结构，因而如何快速查询定位到我们所需要的结果，不是一件容易的事。...
    99+
    2024-04-02
  • 怎么使用Node连接mongodb
    本篇内容主要讲解“怎么使用Node连接mongodb”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“怎么使用Node连接mongodb”吧!Mongoose 是一个 Node.js 包，提供了一个...
    99+
    2023-07-05
软考高级职称资格查询
热门wiki
近期文章
推荐阅读
热门问答
热门标签
编程网，编程工程师的家园，是目前国内优秀的开源技术社区之一，形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容，为IT开发者提供了一个发现、使用、并交流开源技术的平台。

  • 官方手机版

  • 微信公众号

  • 商务合作