您好,欢迎访问一九零五行业门户网

使用Nodejs如何来操作MongoDB

这篇文章给大家介绍的文章内容是关于使用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的详细内容。
其它类似信息

推荐信息