使用nodejs怎么對mongodb數據庫進行增加修刪該查操作？相信很多沒有經驗的人對此束手無策，為此本文總結了問題出現的原因和解決方法，通過這篇文章希望你能解決這個問題。
以下是實例代碼：
/**
1.npm install mongodb --save-dev / cnpm install mongodb --save-dev
2.var MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost:27017/test'; 連接數據庫的地址
3.連接數據庫
MongoClient.connect(url, function(err, db) {
});
4.實現增加修改刪除
MongoClient.connect(url, function(err, db) {
db.collection('user').insertOne({'name':'zhangsan'},function(error,data){
})
});
*/
var http=require('http');
var ejs=require('ejs');
var MongoClient = require('mongodb').MongoClient; /*引入數據庫 MongoClient*/
var DBurl = 'mongodb://localhost:27017/userDb'; // 連接數據庫的地址 student表示數據庫的名稱
var url=require('url'); /*引入url模塊*/
var app=require('./model/express-route.js');
http.createServer(app).listen(3000);
app.get('/',function(req,res){
var msg='這是數據庫的數據'
ejs.renderFile('views/index.ejs',{msg:msg},function(err,data){
res.send(data);
})
})
app.get('/add',function(req,res){
//增加數據
MongoClient.connect(DBurl,function(err,db){ /*連接數據庫*/
if(err){
console.log(err);
console.log('數據庫連接失敗');
return;
}
//增加數據
db.collection('user').insertOne({
"name":"loaderman",
"age":10
},function(error,result){
if(error){
console.log('增加數據失敗');
return;
}
res.send('增加數據成功');
db.close();/*關閉數據庫*/
})
})
})
app.get('/edit',function(req,res){
//增加數據
//res.send('修改數據成功');
MongoClient.connect(DBurl,function(err,db){
if(err){
console.log(err);
console.log('數據庫連接失敗');
return;
}
db.collection('user').updateOne({"name":"loaderman"},{$set:{
"age":666
}},function(error,data){
if(error){
console.log('修改數據失敗');
return;
}
console.log(data);
res.send('修改數據成功');
db.close();/*關閉數據庫*/
})
})
})
app.get('/delete',function(req,res){
//增加數據
//delete?name=lisi
//console.log(url.parse(req.url,true));
var query=url.parse(req.url,true).query;
//console.log(query.name);
var name=query.name;
MongoClient.connect(DBurl,function(err,db){
if(err){
console.log(err);
console.log('數據庫連接失敗');
return;
}
db.collection('user').deleteOne({"name":name},function(error,data){
if(error){
console.log('刪除失敗');
return;
}
console.log(data);
res.send('刪除數據成功');
db.close();
})
})
})
app.get('/query',function(req,res){
MongoClient.connect(DBurl,function(err,db){
if(err){
console.log('連接數據庫失敗');
return;
}
//查詢數據
var list=[]; /*放數據庫里面查詢的所有數據*/
var result=db.collection('user').find({});
result.each(function(error,doc){
//console.log(doc);
if(error){
console.log(error);
}else{
if(doc!=null){
list.push(doc);
}else{ /*doc==null表示數據循環完成*/
/*獲取數據以后*/
//console.log(list);
ejs.renderFile('views/index.ejs',{list:list},function(err,data){
res.send(data);
})
}
}
})
//console.log(result);
})
})插入數據
/**
* 插入單條數據
* @param table_name 表名
* @param insertData 插入的數據
* @param callback 回調方法
*/
MongoDbAction.insertData= function (table_name, insertData , callback) {
var node_model = this.getConnection(table_name);
node_model.insertOne(insertData , function (err, res) {
if (err) {
callback(err);
} else {
callback(null, res);
}
});
};查詢數據
/**
* 查詢單條數據
* @param table_name 表名
* @param conditions 查詢條件
* @param callback 回調方法
*/
MongoDbAction.findOne = function (table_name, conditions, callback) {
var node_model = this.getConnection(table_name);
node_model.findOne(conditions, function (err, res) {
if (err) {
callback(err);
} else {
callback(null, res);
}
});
};更新數據
/**
* 更新單條數據
* @param table_name 表名
* @param conditions 查詢條件 {"name":'jackson影琪'};
* @param updateStr 更新數據 {$set: { "url" : "https://www.cnblogs.com/jackson-zhangjiang" }};
* @param callback 回調方法
*/
MongoDbAction.updateOne= function (table_name, conditions，updateStr , callback) {
var node_model = this.getConnection(table_name);
node_model.updateOne(conditions，updateStr, function (err, res) {
if (err) {
callback(err);
} else {
callback(null, res);
}
});
};看完上述內容，你們掌握使用nodejs怎么對mongodb數據庫進行增加修刪該查操作的方法了嗎？如果還想學到更多技能或想了解更多相關內容，歡迎關注億速云行業資訊頻道，感謝各位的閱讀！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
