node.js操作MongoDB時,需要安裝mongodb包
1、使用npm安裝cnpm
npm install -g cnpm --registry=https://registry.npm.taobao.org
2、使用cnpm安裝mongodb包
cnpm install mongodb
node.js操作MongoDB時的四種方式:插入數據、更新數據、刪除數據、查找數據。
操作步驟
步驟1 創建執行文件xx.js
步驟2 終端調用執行文件 node xx.js
注意:
操作前需要啟動服務器
同時需要設置操作的數據庫、操作的集合
1、插入數據
var MongoClient = require('mongodb').MongoClient;var DB_CONN_STR = 'mongodb://localhost:27017/col';var writeData = function(db, callback) { // 連接到集合 var collection = db.collection('person'); // 插入數據 var data = [{'name':'20170906','age':'22'}]; collection.insert(data, function(error, result) { if (error) { console.log('error:' + error); return; }; callback(result); });}MongoClient.connect(DB_CONN_STR, function(error, db) { console.log('連接成功'); writeData(db, function(result) { console.log(result); db.close(); })})
2、更新數據
var MongoClient = require('mongodb').MongoClient;var DB_CONN_STR = 'mongodb://localhost:27017/col';var updateData = function(db, callback) { // 連接到集合 var collection = db.collection('person'); // 修改數據 var where = {'name':'20170906'}; var update = {$set:{'age':'33'}}; collection.update(where, update, function(error, result) { if (error) { console.log('error:' + error); return; }; callback(result); });}MongoClient.connect(DB_CONN_STR, function(error, db) { console.log('連接成功'); updateData(db, function(result) { console.log(result); db.close(); })})
3、刪除數據
var MongoClient = require('mongodb').MongoClient;var DB_CONN_STR = 'mongodb://localhost:27017/col';var removeData = function(db, callback) { // 連接到集合 var collection = db.collection('person'); // 刪除數據 var where = {'age':'22'}; collection.remove(where, function(error, result) { if (error) { console.log('error:' + error); return; }; callback(result); });}MongoClient.connect(DB_CONN_STR, function(error, db) { console.log('連接成功'); removeData(db, function(result) { console.log(result); db.close(); })})
4、查找數據
var MongoClient = require('mongodb').MongoClient;var DB_CONN_STR = 'mongodb://localhost:27017/col';var readData = function(db, callback) { // 連接到集合 var collection = db.collection('person'); // 查詢數據 var where = {'name':'20170906'}; collection.find(where).toArray(function(error, result) { if (error) { console.log('error:' + error); return; }; callback(result); });}MongoClient.connect(DB_CONN_STR, function(error, db) { console.log('連接成功'); readData(db, function(result) { console.log(result); db.close(); })})
如有疑問請留言或者到本站社區交流討論,感謝閱讀,希望能幫助到大家,謝謝大家對本站的支持!
新聞熱點
疑難解答