zoukankan      html  css  js  c++  java
  • nodejs操作mongodb数据库(mongodb)

    1.增加

    var MongoClient = require("mongodb").MongoClient;
    var DB_URL = "mongodb://localhost:27017/chm";
    
    function insertData(db)
    {
        var devices = db.collection('vip');
        var data = {"name":"node","age":22,"addr":"nb","addTime":new Date()};
        devices.insert(data,function(error, result){
            if(error)
            {
                console.log('Error:'+ error);
            }else{
    
                console.log(result.result.n);
            }
            db.close();
        });
    }
    
    MongoClient.connect(DB_URL, function(error, db){
        console.log('连接成功!');
        insertData(db);
    });

    这里写图片描述
    2.查找

    var mongodb = require('mongodb')
    var MongoClient = require('mongodb').MongoClient;
    var DB_CONN_STR = 'mongodb://localhost:27017/chm';  
    
    var selectData = function(db, callback) {  
      //连接到表  
      var collection = db.collection('vip');
      //查询数据
      var whereStr = {"name":'node'};
      collection.find(whereStr,function(error, cursor){
        cursor.each(function(error,doc){
            if(doc){
                //console.log(doc);
                if (doc.addTime) {
                    console.log("addTime: "+doc.addTime);
                }
            }
        });
    
      });
    
    }
    
    MongoClient.connect(DB_CONN_STR, function(err, db) {
      console.log("连接成功!");
      selectData(db, function(result) {
        console.log(result);
        db.close();
      });
    });

    3.更新

    var MongoClient = require("mongodb").MongoClient;
    var DB_URL = "mongodb://localhost:27017/chm";
    
    MongoClient.connect(DB_URL, function(error, db){
        console.log("连接成功!");
        updateData(db);
    });
    
    function updateData(db)
    {
        var devices = db.collection('vip');
        var whereData = {"name":"node"}
        var updateDat = {$set: {"age":26}}; //如果不用$set,替换整条数据
        devices.update(whereData, updateDat, function(error, result){
            if (error) {
                console.log('Error:'+ error);
            }else{
                console.log(result);
            }
            db.close();
        });
    }

    4.删除

    var MongoClient = require('mongodb').MongoClient;
    var DB_URL = "mongodb://localhost:27017/chm";
    
    MongoClient.connect(DB_URL, function(error, db){
        console.log("连接成功");
        deleteData(db);
    });
    
    function deleteData(db)
    {
        var devices = db.collection('vip');
        var data = {"name":"node"};
        devices.remove(data, function(error, result){
            if (error) {
                console.log('Error:'+ error);
            }else{
                console.log(result.result.n);
            }
            db.close();
        })
    }

    存储过程

    在mongodb中创建存储过程

    这里写图片描述

    所有存储过程都存放在db.system.js中,通过db.eval(“存储过程ID()”);调用存储过程。

    在代码中调用:

    var MongoClient = require("mongodb").MongoClient;
    var DB_URL = "mongodb://localhost:27017/chm";
    
    MongoClient.connect(DB_URL, function(error,db){
        console.log("连接成功!");
        callProcess(db)
    });
    
    function callProcess(db)
    {
        db.eval("get_vip_count()",function(error, result){
            if (error) {
                console.log(error);
            }else{
                console.log("count:"+result);
            }
            db.close();
        });
    }
  • 相关阅读:
    北京高考零分作文(看到最后一句笑喷了!)
    关于前几天无法访问的问题
    用 PHP 读取和编写 XML DOM[转]
    Delphi对INI文件的详细操作方法
    如何在WebService中获取客户端的IP地址
    正则表达式30分钟入门教程
    [原创]shell对xml操作的脚本
    预防SQL注入攻击之我见(好文章)
    表驱动方法(非常好的数据结构)
    请教shell读写XML问题
  • 原文地址:https://www.cnblogs.com/pyj63/p/8350718.html
Copyright © 2011-2022 走看看