首先要安装mongodb,nodejs,啥的,然后要运行起来,这些官网上都有的了,按部就班就好了
那如何在nodejs里面连接到mongodb并且能够执行操作呢
1.连接
按照官网的例子试了一下 , 这里有点小坑,之前不懂以为直接是http://localhost:27017/,然后打印了错误信息,百度了一下,才知道应该是mongodb+srv这种形式
const MongoClient = require('mongodb').MongoClient;
const url = 'mongodb://localhost:27017/';
MongoClient.connect(url, function(err, client) {
assert.equal(null, err);
client.close();
});
好了,终于踏出了第一步,通过nodejs去连接到mongodb数据库了
2.插入
接下来就要尝试操作数据库,就是直接在连接到数据库的回调里面操作,尝试找到inventory这个集合插入一个对象.
MongoClient.connect(url, function(err, client) {
const db = client.db("test");
db.collection('inventory').insertOne({
item: "canvas",
qty: 100,
tags: ["cotton"],
size: { h: 28, w: 35.5, uom: "cm" }
}).then(function(result) {
// process result
})
client.close();
});
3.查询
就是要把刚才插入的对象查询出来看看能不能找到,也是一样找到inventory集合然后利用find找到里面所有对象,然后遍历出来,就是查询的动作了
MongoClient.connect(url, function(err, client) {
const db = client.db("test");
var cursor = db.collection('inventory').find({});
cursor.each(function(err, doc) {
console.log(doc);
});
client.close();
});
然后在查询的时候发现了一个很绝望的事情,我想做一个例如用户名唯一的验证,把用户名传到后台,后台查询数据库然后返回结果是否唯一
app.post(baseUrl + '/getUserName', function (req, res) {
MongoClient.connect(url,{useNewUrlParser:true}, function (err, client) {
const db = client.db("USERDATA");
const dataArr = db.collection('mongo').find({})
dataArr.each(function (err,item) {
if(item.email == req.body.email){
res.send('该邮箱已存在')
client.close();
return false
}
})
res.send('该邮箱可用')
client.close();
});
})
大概写了这段代码一开始以为是each的return不能跳出整个函数,后面加了个flag,后面发现报错了,报了个 Can't set headers after they are sent,就很迷茫了,大概意思就是我res.send发送了两次嘛,导致有问题
app.post(baseUrl + '/getUserName', function (req, res) {
MongoClient.connect(url,{useNewUrlParser:true}, function (err, client) {
const db = client.db("USERDATA");
const dataArr = db.collection('mongo').find({})
let flag = false;
dataArr.each(function (err,item) {
if(item.email == req.body.email){
res.send('该邮箱已存在')
flag = true;
client.close();
return false
}
})
if(flag){
return
}
res.send('该邮箱可用')
client.close();
});
})
这个坑花了我大概两天零零散散的时间,发现了这个恶心的each竟然是异步的??????
这个东西是按照mongodb官网给的示例写的,我用for循环好像遍历出来的东西不一样,也找不到什么关于这个each的东西.
那么现在的问题就成了,这个循环是异步的,你要等整个循环结束,你才能res.send,否则就是多次send,会崩溃报错,
那么如果知道这个each已经遍历完了呢??我尝试了好多方法,在一次把each吼所有的东西都打印出来,发现到最后,会有一个null,也就是空..哦!!!!!!!!!那发现了这个问题,就好办了,整个问题迎刃而解.
app.post(baseUrl + '/getUserName', function (req, res) {
// console.log("主页 POST 请求");
// console.log(req.params);
MongoClient.connect(url,{useNewUrlParser:true}, function (err, client) {
const db = client.db("USERDATA");
db.collection('mongo').find({},function(err,data){
let flag = false;
data.each(function(err,item){
if(!item){ //在每次循环前先判断是否是空对象,如果是空对象,说明遍历结束
if(!flag){ //如果遍历结束flag还是false,说明并没有重复的,反之则有重复的就res.send,然后关闭连接服务器并且直接return跳出去就行了
res.send({
code: 200,
data: '该邮箱可以注册',
message: '该邮箱可以注册'
});
}
client.close();
return false
}
if(req.body.email == item.email){
flag = true;
res.send({
code:400,
data:'该邮箱已注册',
message:'该邮箱已注册'
});
client.close();
return false //这return是为了如果发现有相同的就不用继续遍历了,这样可以节省性能
}
})
})
});
})
好了,会了以上简单的数据库查询和添加操作,就可以完成一个简单的注册功能了!!!!!!
好了,已经有了插入和查询,增删改查,还要一个改动和删除,先尝试下删除吧
4.删除
按照官方文档的代码
db.collection('inventory').deleteOne({
status: "D"
})
.then(function(result) {
// process result
})
看了下数据库里面的数据
如果我想通过这个id去删除,因为这个id一定是唯一的
,但是问题来了,那个id是什么objectId类型的,表示完全不懂,直接用字符串匹配也是匹配不到的,解决办法就只有两种了,第一种就是插入的时候是插入字符串类型的id,第二种就是匹配的时候把那个字符串转成相同类型去匹配.
第一种方式暂时还没找到解决办法,等我找到了再更新呗
第二种方法
在网上花了不少时间,终于找到了第二种方式的解决办法
var ObjectId = require('mongodb').ObjectId;
db.collection('caseData').deleteOne({
_id: ObjectId(req.body.id)
}).then(function(result) {
res.send({
code: 200,
data: '删除成功',
message: '删除成功'
});
})
就是把那个id用ObjejctId包起来就可以了,完美!
5.更新数据
按照官方文档的就行,暂时没遇到啥问题
db.collection('inventory').updateOne(
{ qty: { $lt: 50 } },//这个东西是找到匹配的数据
{ $set: { "size.uom": "in", status: "P" }, //这里是更新的东西
$currentDate: { lastModified: true } }) //这里是更新日期,我觉得不太喜欢,不知道怎么设定日期的格式,还不如我自己填...
.then(function(result) {
// process result
})
这些是最简单最基础的增删改查了
