同 必须先打开数据库 mongod --dbpath E:\mongodb 不能关闭
1、先下载好 mongodb 模块
npm install mongodb --save
2、var MongoClient = require("mongodb").MongoClient;
3、如数据库地址 var dbUrl = ""mongodb://127.0.0.1:27017/user";"
（mongodb://127.0.0.1:27017可以在 cmd 中打 mongo获取
（/ user 为数据库名字）
4、数据库的连接
MongoClient.connect(dbUrl,function(err,db){
if(err){
console.log(err);
return;
}
5、进行数据库操作（）
})
5.1、数据库的插入
5.1.1、 单个的插入(insertOne)
db.collection("user").insertOne({"name":"pzm"},function(err){
});
5.1.2、多个数据插入(insertMany)格式[{ },{ }]
db.collection("user").insertMany([{},{}],function(err){
})
5.1.3、当爬虫获取它人数据的时候，由于异步，单个插入的时候要回调获取数据(data是通过获取的数据)
（function insertOne(i){
if( i == data.length){
return false;
}
db.collection("user").insertOne({"name":data[i].name,"age":data[i].age}, function(err){
if(err){
console.log(err);
return;
}
insertOne(++i);
})
}）（0）
5.2数据的 删除
5.2.1 单个的删除
db.collection("user").deteleOne({"name":"pzm"})
5.2.2 多个的删除
db.collection("user").deteleMany([{},{}])
5.2.3 当删除id 时
必须 先引入
var ObjectID = require("mongodb").ObjectID
db.collection("user").deleteOne({"_id":new ObjectID("12121215")})
5.3数据的的查询
5.3.1查询所有
var result = db.collection("user").find({}); //这个得出的只是对象
result.toArray(function(err,data){
if(err){
console.log(err);
return;
}
console.log(data)
//data输出格式为[{},{},{},{}]具体用法看（ejs笔记）
})
5.3.1查询id
必须先引入
varObjectId = require("mongodb").ObjectId
var result = db.collection("user").find({"_id":new ObjectID(id)})
网友评论