一、在Nodejs中使用Mongodb
Nodejs需要引入的包
npm install mongodb --save -dev 或者使用镜像 cnpm install mongodb --save -dev
Mongodb官网的学习地址：
https://docs.mongodb.com/getting-started/node/introduction/
http://mongodb.github.io/node-mongodb-native/2.2/quick-start/quick-start/
二、Nodejs连接Mongodb数据库
var express = require("express");
//数据库引用
var MongoClient = require('mongodb').MongoClient;
var app = express();
//数据库连接的地址，最后的斜杠表示数据库名字
var shujukuURL = 'mongodb://localhost:27017/news';
app.get("/",function(req,res){
//连接数据库，这是一个异步的操作
MongoClient.connect(shujukuURL, function(err, db) {
res.writeHead(200,{"Content-Type":"text/html;charset=UTF8"});
if(err){
res.send("数据库连接失败");
return;
}
res.write("恭喜，数据库已经成功连接 \n");
db.collection("user").insertOne({"name":"哈哈"},function(err,result){
if(err){
res.send("数据库写入失败");
return;
}
res.write("恭喜，数据已经成功插入");
res.end();
//关闭数据库
db.close();
});
});
});
app.listen(8020);
三、Nodejs查找Mongodb数据库集合
MongoClient.connect(dbUrl,function(err,db){
if(err){ /*数据库连接失败*/
console.log('数据库连接失败');
return;
}
var result=[];
var userRel=db.collection('user').find();
//res.send(userRel);
userRel.each(function(err, doc) {
if(err){
res.write("游标遍历错误");
return;
}
if (doc != 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('user').insertOne({
"name" : name,
"age" : age,
"score" : {
"shuxue" : shuxuechengji,
"yuwen" : yuwenchengji
}
},function(err,result){
if(err){
console.log('写入数据失败');
}
//关闭数据库
db.close();
//res.redirect('/add');
res.redirect('/'); /*路由跳转*/
res.end();
////res.location('/add')
})
})
五、Nodejs修改Mongodb数据
MongoClient.connect(dbUrl,function(err,db){
if(err){
console.log('数据库连接错误');
return;
}
db.collection('user').updateOne({"_id":ObjectID(id)}, {
"name": name,
"age": age,
"score": {"shuxue": shuxue,
"yuwen": yuwen
}
},function (err, results) {
console.log(results);
db.close();
res.redirect('/'); /*路由跳转*/
res.end('end');
})
})
六、Nodejs删除Mongodb数据
MongoClient.connect(dbUrl,function(err,db){
if(err){
throw new Error("数据库连接失败");
return;
}
db.collection('user').deleteOne({"_id":ObjectID(id)},function(error,result){
if(error)
{
throw new Error('删除数据失败');
return;
}
db.close();
res.redirect('/'); /*路由跳转*/
})
})
七、Nodejs操作Mongodb3.x数据库方法
//http://mongodb.github.io/node-mongodb-native/3.0/quick-start/quick-start/ /*
nodejs操作mongodb数据库 1.安装mongodb、 cnpm install mongodb --save 2.引入mongodb下面的MongoClient
var MongoClient = require('mongodb').MongoClient; 3.定义数据库连接的地址 以及配置数据库
qianfeng数据库的名称 var url = 'mongodb://localhost:27017/'; var dbName = 'shop' 4.nodejs连接数据库 MongoClient.connect(url,function(err,client){ const db = client.db(dbName); 数据库db对象 }) 5.操作数据库 MongoClient.connect(url,function(err,client){ const db = client.db(dbName); 数据库db对象 MongoClient.connect(url,function(err,db){ db.collection('user').insertOne({"name":"张三"},function(err,result){ db.close() //关闭连接
}) }) }) */
var MongoClient = require('mongodb').MongoClient; //定义连接数据库的地址 const url = 'mongodb://localhost:27017/';
var dbName = 'shop' //连接数据库
MongoClient.connect(url,(err,client)=>{ if(err){
console.log('数据连接失败');
return false;
}
let db=client.db(dbName); /*获取db对象*/ db.collection("admin").insertOne({"name":"mongodb3.0","age":10},function(err){ if(err){
console.log('增加失败');
return false;
}
console.log('增加成功');
client.close(); /*关闭数据库*/
}) })