這篇文章要跟大家介紹的文章內容是關於使用Nodejs如何來操作MongoDB，有很好的參考價值，希望可以幫助到有需要的朋友。
先用npm安裝mongodb
npm install mongodb
安裝成功後，繼續在上面操作所建立的庫和表中操作
插入
var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/wilsondb1';
var insertData = function(db, callback) {
//连接到表
var collection = db.collection('tb2');
//插入数据
var data = [{"name":'wilson001',"age":21},{"name":'wilson002',"age":22}];
collection.insert(data, function(err, result) {
if(err)
{
console.log('Error:'+ err);
return;
}
callback(result);
});
}
MongoClient.connect(DB_CONN_STR, function(err, db) {
console.log("连接成功！");
insertData(db, function(result) {
console.log(result);
db.close();
});
});查詢
var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/wilsondb1';
var selectData = function(db, callback) {
//连接到表
var collection = db.collection('tb2');
//查询数据
var whereStr = {"name":'wilson001'};
collection.find(whereStr).toArray(function(err, result) {
if(err)
{
console.log('Error:'+ err);
return;
}
callback(result);
});
}
MongoClient.connect(DB_CONN_STR, function(err, db) {
console.log("连接成功！");
selectData(db, function(result) {
console.log(result);
db.close();
});
});修改
var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/wilsondb1';
var updateData = function(db, callback) {
//连接到表
var collection = db.collection('tb2');
//更新数据
var whereStr = {"name":'wilson001'};
var updateStr = {$set: { "age" : 100 }};
collection.update(whereStr,updateStr, function(err, result) {
if(err)
{
console.log('Error:'+ err);
return;
}
callback(result);
});
}
MongoClient.connect(DB_CONN_STR, function(err, db) {
console.log("连接成功！");
updateData(db, function(result) {
console.log(result);
db.close();
});
});刪除
var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/wilsondb1';
var delData = function(db, callback) {
//连接到表
var collection = db.collection('tb2');
//删除数据
var whereStr = {"name":'wilson001'};
collection.remove(whereStr, function(err, result) {
if(err)
{
console.log('Error:'+ err);
return;
}
callback(result);
});
}
MongoClient.connect(DB_CONN_STR, function(err, db) {
console.log("连接成功！");
delData(db, function(result) {
console.log(result);
db.close();
});
});呼叫預存程序
var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://localhost:27017/wilsondb1';
var invokeProcData = function(db, callback) {
//存储过程调用
db.eval('get_tb2_count()', function(err, result) {
if(err)
{
console.log('Error:'+ err);
return;
}
callback(result);
});
}
MongoClient.connect(DB_CONN_STR, function(err, db) {
console.log("连接成功！");
invokeProcData(db, function(result) {
console.log(result);
db.close();
});
});相關推薦：
#以上是使用Nodejs如何來操作MongoDB的詳細內容。更多資訊請關注PHP中文網其他相關文章！
