zoukankan      html  css  js  c++  java
  • node 查找和更新数据

    1.全部查询 -- find

    var MongoClient = require('mongodb').MongoClient;
    var url = require('./config/keys').mongoURI;
    
    /**
     * 全部查询
     * find
    */
    MongoClient.connect(url, { useNewUrlParser: true, useUnifiedTopology: true }, function(err, db) {
      if(err) throw err;
      var dbo = db.db('koa'); // koa 库名
      dbo.collection('users').find({}).toArray(function(err, res) { // 返回集合中的所有数据
        if (err) throw err;
        console.log(res);
        db.close();
      })
    });
    

    2.条件查询 -- find

    var MongoClient = require('mongodb').MongoClient;
    var url = require('./config/keys').mongoURI;
    
    /**
     * 条件查询
     * find
    */
    MongoClient.connect(url, { useNewUrlParser: true, useUnifiedTopology: true }, function(err, db) {
      if(err) throw err;
      var dbo = db.db('koa'); // koa 库名
      // var whereStr = {"name": "张三"}; // 查询条件
      var whereStr = {"name": {
        $in: ['张三', '李四'] // 包含
      }};
      dbo.collection('users').find(whereStr).toArray(function(err, res) { // 返回集合中的所有数据
        if (err) throw err;
        console.log(res);
        db.close();
      })
    });
    

    3.单条更新 -- updateOne

    var MongoClient = require('mongodb').MongoClient;
    var url = require('./config/keys').mongoURI;
    
    /**
     * 单条更新
     * updateOne
    */
    MongoClient.connect(url, { useNewUrlParser: true, useUnifiedTopology: true }, function(err, db) {
      if(err) throw err;
      var dbo = db.db('koa'); // koa 库名
      var whereStr = {"name": "张三"}; // 查询条件
      var updateStr = { $set: { type: 2 }}; // 更新条件
      dbo.collection('users').updateOne(whereStr, updateStr, function(err, res) {
        if (err) throw err;
        console.log("文档更新成功");
        db.close();
      });
    });
    

    4.批量更新 -- updateMany

    var MongoClient = require('mongodb').MongoClient;
    var url = require('./config/keys').mongoURI;
    
    /**
     * 批量更新
     * updateMany
    */
    MongoClient.connect(url, { useNewUrlParser: true, useUnifiedTopology: true }, function(err, db) {
      if(err) throw err;
      var dbo = db.db('koa'); // koa 库名
      var whereStr = {"name": "张三"}; // 查询条件
      var updateStr = { $set: { type: 2 }}; // 更新条件
      dbo.collection('users').updateOne(whereStr, updateStr, function(err, res) {
        if (err) throw err;
        console.log(res.modifiedCount + ' 条文档被更新');
        db.close();
      });
    });
    

    .

  • 相关阅读:
    golang获取变量数据类型
    有道云笔记隐藏广告
    golang搭建web服务器
    node.js搭建https服务器
    Linux查看CPU和内存信息
    go语言中文处理
    node.js压缩和解压缩
    关于同步、异步、阻塞、非阻塞简单总结
    Nginx部署静态网站
    node.js分片上传文件
  • 原文地址:https://www.cnblogs.com/crazycode2/p/15110228.html
Copyright © 2011-2022 走看看