欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Nodejs使用Mongodb存储与提供后端CRD服务详解

程序员文章站 2024-02-02 22:44:34
前言 众所周知js是脚本语言,脚本语言都需要一个解析器才能运行。对于写在html页面里的js,浏览器充当了解析器的角色。而对于需要独立运行的js,nodejs就是一个解析...

前言

众所周知js是脚本语言,脚本语言都需要一个解析器才能运行。对于写在html页面里的js,浏览器充当了解析器的角色。而对于需要独立运行的js,nodejs就是一个解析器。

每一种解析器都是一个运行环境,不但允许js定义各种数据结构,进行各种计算,还允许js使用运行环境提供的内置对象和方法做一些事情。例如运行在浏览器中的js的用途是操作dom,浏览器就提供了document之类的内置对象。而运行在nodejs中的js的用途是操作磁盘文件或搭建http服务器,nodejs就相应提供了fs、http等内置对象。

本文会把一个对象todo对象(有属性{id,name})存储到mongodb,做查询删除的测试(create remove delete = crd)。这个测试包括使用mongodb shell,使用callback古典风格的访问代码,以及使用await/async的现代风格的代码。完成这个这个验证后,就可以掌握最初步的mongodb了。

我使用的nodejs是10.7 。操作系统环境为mac os x high sierra。

准备环境

安装和运行mongodb daemon

brew install mongodb
mongodb

访问验证

首先执行mongodb shell:

mongo

输入命令,查询数据库清单:

> show dbs
local  0.000gb

创建一个数据库

use todos

(若database不存在,则会创建一个,此时若不做任何操作直接退出,则mongodb会删除该数据库)

db.todos.insert({id:1,name:"reco"})
db.todos.insert({id:2,name:"rita"})

查询 :

db.todos.find()

{ "_id" : objectid("5b727c0846b6c71a98d3af52"), "id" : 1, "name" : "reco" }
{ "_id" : objectid("5b727c7046b6c71a98d3af53"), "id" : 2, "name" : "reta" }

删除记录:

db.todo.remove({id:1})

删除数据库

db.todo.drop()

使用nodejs方式访问mongodb

使用nodejs执行类似shell对对象的crd,代码如下:

var mongoclient = require('mongodb').mongoclient;
var url = "mongodb://localhost:27017/todos";
mongoclient.connect(url, function(err, db) {
 if (err) throw err;
 console.log("database created!");
 var dbo = db.db("todos");
 // var myobj = { id: 1, name: "reco" };
 // dbo.collection("todo").insertone(myobj, function(err, res) {
 // if (err) throw err;
 // console.log("1 document inserted");
 // db.close();
 // });
 var myobj = [
 { id: 1, name: 'reco'},
 { id: 2, name: 'rita'},
 ];
 dbo.collection("todo").insertmany(myobj, function(err, res) {
 if (err) throw err;
 console.log("number of documents inserted: " + res.insertedcount);
 dbo.collection("todo").find({}).toarray(function(err, result) {
 if (err) throw err;
 console.log(result);
 var myquery = { id: 1 };
 dbo.collection("todo").deletemany(myquery, function(err, obj) {
 if (err) throw err;
 console.log("document deleted");
 db.close();
 });
 }); 
 });
})

代码非常简单,无需更多解释。此代码使用了mongodb模块,需要首先安装:

npm init -y
npm i mongodb --save

然后使用node index.js运行即可看到效果:

database created!
number of documents inserted: 2
[ { _id: 5b72ab9e3245f169ef5f43d2, id: 1, name: 'reco' },
 { _id: 5b72ab9e3245f169ef5f43d3, id: 2, name: 'rita' } ]
document deleted

利用高级异步特性

使用await/async特性,可以有效的减少代码中的回调地狱现象。同样的功能,可以使用这样的代码:

const mongoclient = require('mongodb').mongoclient;
const connectionstring = 'mongodb://localhost:27017';
(async () => {
 const client = await mongoclient.connect(connectionstring,
  { usenewurlparser: true });
 const dbo = client.db('todos');
 try {
  var res = await dbo.collection('todo').insertmany(
  [{id:1,name:"reco"}, {id:2,name:"rita"}]);
  console.log("number of documents inserted: " + res.insertedcount);
  var r = await dbo.collection("todo").find().toarray()
  console.log(r);
  var myquery = { id: 1 };
 var r = await dbo.collection("todo").deletemany(myquery)
 console.log("document deleted");
 }
 finally {
  client.close();
 }
})().catch(err => console.error(err));

执行此代码,输出如下:

number of documents inserted: 2
[ { _id: 5b72ae8a1c674a6ac1c5aa6e, id: 1, name: 'reco' },
  { _id: 5b72ae8a1c674a6ac1c5aa6f, id: 2, name: 'rita' } ]
document deleted

总结:

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对的支持。