博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Nodejs操作MongoDB
阅读量:6879 次
发布时间:2019-06-26

本文共 3040 字,大约阅读时间需要 10 分钟。

转载:

先用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();    });});
你可能感兴趣的文章
jQuery结合lhgdialog弹出窗口,关闭时出现没有权限错误
查看>>
EXTJS学习系列提高篇:第二十八篇(转载)作者殷良胜,ext2.2打造Ext.form.ComboBox系列--分页显示...
查看>>
如何完成.Net下XML文档的读写操作
查看>>
QTP的那些事--对已经存在Excel文件修改后保存时,会弹出一个询问对话框
查看>>
UVA 11174 Stand in a Line 树dp+算
查看>>
C语言中函数strcpy ,strncpy ,strlcpy的用法【转】
查看>>
mysql join 的同时可以筛选数据
查看>>
Code First开发系列之管理并发和事务
查看>>
Spark SQL概念学习系列之为什么使用 Spark SQL?(二)
查看>>
VirtualBox-Linux系统安装增强功能
查看>>
ssh/ssh2登录
查看>>
mongodb对数组元素及内嵌文档进行增删改查操作(转)
查看>>
【python3.5】安装lxml中没有etree模块的问题解决方法
查看>>
pgpool-II的性能缺陷
查看>>
spin_lock浅析【转】
查看>>
MVC前台Post/Get异步获得数据时参数的取值问题
查看>>
8086/8088指令详解
查看>>
iOS:自定义代码块{ }
查看>>
C# 远程链接指定计算机,获取该计算机的计算机名等信息
查看>>
[Flume][Kafka]Flume 与 Kakfa结合例子(Kakfa 作为flume 的sink 输出到 Kafka topic)
查看>>