node.js操作MongoDB時(shí),需要安裝mongodb包
1、使用npm安裝cnpm
npm install -g cnpm --registry=https://registry.npm.taobao.org
2、使用cnpm安裝mongodb包
cnpm install mongodb
node.js操作MongoDB時(shí)的四種方式:插入數(shù)據(jù)、更新數(shù)據(jù)、刪除數(shù)據(jù)、查找數(shù)據(jù)。
操作步驟
步驟1 創(chuàng)建執(zhí)行文件xx.js
步驟2 終端調(diào)用執(zhí)行文件 node xx.js
注意:
操作前需要啟動(dòng)服務(wù)器
同時(shí)需要設(shè)置操作的數(shù)據(jù)庫(kù)、操作的集合
1、插入數(shù)據(jù)
var MongoClient = require('mongodb').MongoClient;var DB_CONN_STR = 'mongodb://localhost:27017/col';var writeData = function(db, callback) { // 連接到集合 var collection = db.collection('person'); // 插入數(shù)據(jù) 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、更新數(shù)據(jù)
var MongoClient = require('mongodb').MongoClient;var DB_CONN_STR = 'mongodb://localhost:27017/col';var updateData = function(db, callback) { // 連接到集合 var collection = db.collection('person'); // 修改數(shù)據(jù) 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、刪除數(shù)據(jù)
var MongoClient = require('mongodb').MongoClient;var DB_CONN_STR = 'mongodb://localhost:27017/col';var removeData = function(db, callback) { // 連接到集合 var collection = db.collection('person'); // 刪除數(shù)據(jù) 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、查找數(shù)據(jù)
var MongoClient = require('mongodb').MongoClient;var DB_CONN_STR = 'mongodb://localhost:27017/col';var readData = function(db, callback) { // 連接到集合 var collection = db.collection('person'); // 查詢數(shù)據(jù) 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(); })})
如有疑問(wèn)請(qǐng)留言或者到本站社區(qū)交流討論,感謝閱讀,希望能幫助到大家,謝謝大家對(duì)本站的支持!
新聞熱點(diǎn)
疑難解答
圖片精選
網(wǎng)友關(guān)注