Nodejs操作MongoDb数据库

在 Nodejs 中使用 MongoDB

需要引包&＃xff1a;

npm install mongodb --save-dev


Nodejs 连接 MongoDB 数据库

var express &＃61; require("express");
//数据库引用
var MongoClient &＃61; require(&＃39;mongodb&＃39;).MongoClient;
var app &＃61; express();
//数据库连接的地址&＃xff0c;最后的斜杠表示数据库名字
var shujukuURL &＃61; &＃39;mongodb://localhost:27017/news&＃39;;
app.get("/",
function(req, res) {//连接数据库&＃xff0c;这是一个异步的操作MongoClient.connect(shujukuURL,function(err, db) {res.writeHead(200, {"Content-Type": "text/html;charset&＃61;UTF8"});if (err) {res.send("数据库连接失败");return;}res.write("恭喜&＃xff0c;数据库已经成功连接 \n");db.collection("user").insertOne({"name": "哈哈"},function(err, result) {if (err) {res.send("数据库写入失败");return;}res.write("恭喜&＃xff0c;数据已经成功插入");res.end();//关闭数据库db.close();});});
});
app.listen(8020);


Nodejs 查找 MongoDB 数据库集合

MongoClient.connect(dbUrl,
function(err, db) {if (err) {/*数据库连接失败*/console.log(&＃39;数据库连接失败&＃39;);return;}var result &＃61; [];var userRel &＃61; db.collection(&＃39;user&＃39;).find();//res.send(userRel);userRel.each(function(err, doc) {if (err) {res.write("游标遍历错误");return;}if (doc !&＃61; null) {result.push(doc);} else {console.log(result);//遍历完毕db.close();res.render("index", {"result": result});}});
})


Nodejs 给 MongoDB 增加数据

MongoClient.connect(dbUrl,
function(err, db) {if (err) {return}db.collection(&＃39;user&＃39;).insertOne({"name": name,"age": age,"score": {"shuxue": shuxuechengji,"yuwen": yuwenchengji}},function(err, result) {if (err) {console.log(&＃39;写入数据失败&＃39;);}//关闭数据库db.close();//res.redirect(&＃39;/add&＃39;);res.redirect(&＃39;/&＃39;);/*路由跳转*/res.end();res.location(&＃39;/add&＃39;)})
})


Nodejs 修改 MongoDB 数据

MongoClient.connect(dbUrl,
function(err, db) {if (err) {console.log(&＃39;数据库连接错误&＃39;);return;}db.collection(&＃39;user&＃39;).updateOne({"_id": ObjectID(id)},{"name": name,"age": age,"score": {"shuxue": shuxue,"yuwen": yuwen}},function(err, results) {console.log(results);db.close();res.redirect(&＃39;/&＃39;);/*路由跳转*/res.end(&＃39;end&＃39;);})
})


Nodejs 删除 MongoDB 数据

MongoClient.connect(dbUrl,
function(err, db) {if (err) {throw new Error("数据库连接失败");return;}db.collection(&＃39;user&＃39;).deleteOne({"_id": ObjectID(id)},function(error, result) {if (error) {throw new Error(&＃39;删除数据失败&＃39;);return;}db.close();res.redirect(&＃39;/&＃39;);/*路由跳转*/})
})