//mongodb_demo.js

/**
cnpm install mongodb
 */

var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://test:123456@127.0.0.1:27017/test'; // 数据库为 test

var insertData = function (db, callback) {
    //连接到表 site
    var collection = db.collection('site');
    //插入数据
    var data = [{ "name": "网站1", "url": "www.test1.com" }, { "name": "网站2", "url": "www.test2.com" }];
    collection.insert(data, function (err, result) {
        if (err) {
            console.log('Error:' + err);
            return;
        }
        callback(result);
    });
}
var selectData = function (db, callback) {
    //连接到表
    var collection = db.collection('site');
    //查询数据
    var whereStr = { "name": '网站1' };
    collection.find(whereStr).toArray(function (err, result) {
        if (err) {
            console.log('Error:' + err);
            return;
        }
        callback(result);
    });
}
var updateData = function (db, callback) {
    //连接到表
    var collection = db.collection('site');
    //更新数据
    var whereStr = { "name": '网站1' };
    var updateStr = { $set: { "url": "https://www.test1.com" } };
    collection.update(whereStr, updateStr, function (err, result) {
        if (err) {
            console.log('Error:' + err);
            return;
        }
        callback(result);
    });
}
var delData = function (db, callback) {
    //连接到表
    var collection = db.collection('site');
    //删除数据
    var whereStr = { "name": '网站1' };
    collection.remove(whereStr, function (err, result) {
        if (err) {
            console.log('Error:' + err);
            return;
        }
        callback(result);
    });
}

MongoClient.connect(DB_CONN_STR, function (err, db) {
    if (err) {
        console.log(err);
        return;
    }
    console.log("连接成功!");
    //1、插入
    insertData(db, function (result) {
        console.log(result);
        db.close();
    });
    //2、查询数据
    selectData(db, function (result) {
        console.log(result);
        db.close();
    });
    //3、更新数据
    updateData(db, function (result) {
        console.log(result);
        db.close();
    });
    //4、删除数据
    delData(db, function (result) {
        console.log(result);
        db.close();
    });

});

运行:node mongodb_demo.js

最新文章

  1. Basic Tutorials of Redis(7) -Publish and Subscribe
  2. HTTP协议请求响应过程和HTTPS工作原理
  3. validate插件深入学习-03validate()方法配置项
  4. Atitit 修改密码的功能流程设计 attilax总结
  5. 快速搭建Webservice接口测试环境
  6. JavaScript 语句 for
  7. Oracle 11g RAC 第二节点root.sh执行失败后再次执行root.sh
  8. 树形DP(简单题)(Y HDU4705)
  9. [UEditor]百度编辑器配置总结
  10. 摘录:官方文档对ROWID虚拟行的定义
  11. 去除input[type=number]最右边的spinners(默认加减符号)
  12. C#关闭显示屏,使显示屏处于待机状态
  13. Poj 1269 Intersecting Lines_几何模板
  14. bitmap--Bitmap详解与Bitmap的内存优化
  15. PDO查询语句结果中文乱码
  16. JavaScript使用浏览器内置XMLHttpRequest对象执行Ajax请求
  17. hashlib、logging模块
  18. Web开发——JavaScript基础(JSON教程)
  19. SHA算法:签名串SHA算法Java语言参考(SHAHelper.java)
  20. QPS/TPS/并发量/系统吞吐量的概念

热门文章

  1. 20144303 《Java程序设计》第一周学习总结
  2. $.getJSON()函数内的数据不能传到全局变量是怎么回事?
  3. mybatis映射文件_select_resultMap
  4. 计算java对象的内存占用
  5. PAT1075. PAT Judge (25)
  6. 05_zookeeper_原生API使用1(更新)
  7. Matlab 实现对码功能
  8. PHP数组合并:[“+”运算符]、[array_merge]、[array_merge_recursive]区别
  9. ctci1.4
  10. bootstrap 知识点