本文實例講述了Nodejs實現的操作MongoDB數據庫功能。分享給大家供大家參考,具體如下:
mongodb_demo.js
/**cnpm install mongodb */var MongoClient = require('mongodb').MongoClient;var DB_CONN_STR = 'mongodb://test:123456@127.0.0.1:27017/test'; // 數據庫為 testvar 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
希望本文所述對大家nodejs程序設計有所幫助。
新聞熱點
疑難解答