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();
  });
});

.