Nodejs操作MongoDB資料庫示例
阿新 • • 發佈:2018-12-24
//mongodb_demo.js
/**
cnpm install mongodb
*/
var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://test:[email protected]:27017/test'; // 資料庫為 test
var insertData = function (db, callback) {
//連線到表 site
var collection = db.collection('site');
//插入資料
var data = [{ "name" : "網站1", "url": "www.test1.com" }, { "name": "網站2", "url": "www.test2.com" }];
collection.insert(data, function (err, result) {
if (err) {
console.log('Error:' + err);
return;
}
callback(result);
});
}
var selectData = function (db, callback) {
//連線到表
var collection = db.collection('site');
//查詢資料
var whereStr = { "name": '網站1' };
collection.find(whereStr).toArray(function (err, result) {
if (err) {
console.log('Error:' + err);
return;
}
callback(result);
});
}
var updateData = function (db, callback) {
//連線到表
var collection = db.collection('site');
//更新資料
var whereStr = { "name": '網站1' };
var updateStr = { $set: { "url": "https://www.test1.com" } };
collection.update(whereStr, updateStr, function (err, result) {
if (err) {
console.log('Error:' + err);
return;
}
callback(result);
});
}
var delData = function (db, callback) {
//連線到表
var collection = db.collection('site');
//刪除資料
var whereStr = { "name": '網站1' };
collection.remove(whereStr, function (err, result) {
if (err) {
console.log('Error:' + err);
return;
}
callback(result);
});
}
MongoClient.connect(DB_CONN_STR, function (err, db) {
if (err) {
console.log(err);
return;
}
console.log("連線成功!");
//1、插入
insertData(db, function (result) {
console.log(result);
db.close();
});
//2、查詢資料
selectData(db, function (result) {
console.log(result);
db.close();
});
//3、更新資料
updateData(db, function (result) {
console.log(result);
db.close();
});
//4、刪除資料
delData(db, function (result) {
console.log(result);
db.close();
});
});
執行:node mongodb_demo.js