这篇文章给大家介绍的文章内容是关于使用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(); });});
相关推荐:
mongodb中node中的增删改查的学习
以上就是使用nodejs如何来操作mongodb的详细内容。