MongoDB 系列 - 掌握基本的数据处理操作 CURD

增删改查是业务的基础，也是使用最多和最广泛的，本文通过 MongoDB 客户端 mongo shell 来演示基本的增、删、改、查操作。

插入数据（Create）

MongoDB 中插入数据使用 insert 关键字，相当于关系型数据中的 INSERT INTO。

插入单条数据

向 demo_admin 表中插入数据，mongo 中使用 json 格式以键值对的方式插入数据，会自动创建一个 _id（ObjectID） 字段，在全局范围内不会重复。

db.user.insert({name: 'Jack'}) 

循环插入数据

写法类似于 JavaScript 中的语法，通过一个 for 循环插入数据。

for(i=0;i<10;i++) {
 db.user.insert({name: 'Jack' + i})
}

插入多条

db.user.insertMany([{name: 'Jack'}, {name: 'Tom'}]) 

与关系型数据库插入数据区别

在关系型数据库中插入数据，使用 INSERT INFO 关键字。

INSERT INTO user (name)
VALUES ('Jack');

读取数据（Retrieve）

MongoDB 中查询数据使用 find 关键字，相当于关系型数据中的 SELECT。

find 返回的是一个游标对象，需要遍历才能拿到结果，在终端经过了处理所以我们可以直接的看到结果，如果你是通过程序读取的，例如在 Node.js 中需要使用 toArray() 转为数组或使用异步迭代器遍历数据。

查找所有

> db.user.find()
{ "_id" : ObjectId("61371542ffd35c79530231b6"), "name" : "Jack" }
{ "_id" : ObjectId("61371548ffd35c79530231b7"), "name" : "Jack0" }
{ "_id" : ObjectId("61371548ffd35c79530231b8"), "name" : "Jack1" }
{ "_id" : ObjectId("61371548ffd35c79530231b9"), "name" : "Jack2" }
{ "_id" : ObjectId("61371548ffd35c79530231ba"), "name" : "Jack3" }
{ "_id" : ObjectId("61371548ffd35c79530231bb"), "name" : "Jack4" }
{ "_id" : ObjectId("61371548ffd35c79530231bc"), "name" : "Jack5" }
{ "_id" : ObjectId("61371548ffd35c79530231bd"), "name" : "Jack6" }
{ "_id" : ObjectId("61371548ffd35c79530231be"), "name" : "Jack7" }
{ "_id" : ObjectId("61371548ffd35c79530231bf"), "name" : "Jack8" }
{ "_id" : ObjectId("61371548ffd35c79530231c0"), "name" : "Jack9" }

Node.js 中可通过以下两种方式使用 find() 命令查询数据。

const users = await userColl.find().toArray();
console.log(users);
// 或以下方式
const users = await userColl.find();
for await (const user of users) {
  console.log(user);
}

指定条件查找

> db.user.find({ name: 'Jack' })
{ "_id" : ObjectId("61371542ffd35c79530231b6"), "name" : "Jack" }

按条件或查找

> db.user.find({'$or': [{name: 'Tom'}, {name: 'Jack'}]})
{ "_id" : ObjectId("61371542ffd35c79530231b6"), "name" : "Jack" }

使用count数据统计

> db.user.find().count()
11

指定正则表达式查找

> db.user.find({'name': /^Jack/i})

// Node.js 可采用以下两种写法 
{ name: new RegExp('Jack', 'i') }
{ name: { $regex: 'Jack' } } 

投影

MongoDB 的投影可指定返回的字段，_id 默认返回，我们可以指定为不返回。

> db.user.find({ name: 'Jack' }, { _id: 0, name: 1 })

其他查找方法

• skip(3)：表示过滤掉前 3 条
• limit(2)：显示 2 条结果
• sort({x:1})：使用 x:1 递增排序 ASC，-1 时递减排序 DESC

> db.user.find().skip(3).limit(2).sort({_id: -1});
{ "_id" : ObjectId("61371548ffd35c79530231bd"), "name" : "Jack6" }
{ "_id" : ObjectId("61371548ffd35c79530231bc"), "name" : "Jack5" }

查询单条数据

使用 findOne 查询单条数据，如果有多个符合条件的数据，也只会返回一条结果。注意 findOne() 返回的不是一个游标。

> db.user.findOne({'name': 'Jack'})
{ "_id" : ObjectId("61371542ffd35c79530231b6"), "name" : "Jack" }

更新数据（Update）

使用 update 更新数据，如果没有使用操作符（例如 $set）是全部字段更新，如果有字段没有指定更新成功之后以前的字段数据就没有了。

可有使用 updateOne 或 updateMany 这两个方法，需要指定操作符，都是指定的字段才会更新。

语法

• a 代表修改条件
• b 代表的是新的数据内容
• c 值为 bool 类型，作用是如果修改的数据在数据库中不存在，是否插入数据库默认 false，表示不插入
• d 作用是同样条件的数据，只修改一条还是修改所有默认 false

db.user.update(a, b, c, d);

b 值测试

> db.user.update({"x":1},{"x":111}) 
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })

c 值测试

设置 c 值为 true，插入一条新的数据

> db.user.update({"y":999}, {"y":9999}, true)
WriteResult({
  "nMatched" : 0,
  "nUpserted" : 1,
  "nModified" : 0,
  "_id" : ObjectId("5a6e85a36c2de84d2e5a69d6")
})

设置 c 值为 false，则不会插入数据

> db.user.update({"y":999},{"y":9999888}, false)
WriteResult({ "nMatched" : 0, "nUpserted" : 0, "nModified" : 0 })

d 值测试

db.user.update({"a":2},{$set:{"a":222}},false,true);
db.user.update({"x":100},{$set:{"y":99}})

updateOne/updateMany

updateOne/updateMany 这两个方法分别表示更新一条、更新多条，并且要跟随以下操作符，否则会报错。

• $push
• $pushAll
• $pop
• $pull
• $pullAll
• $addToSet：如果不存在增加一个值到数据，如果存在会报错。

db.user.updateOne({name: 'Jack', age: 18})
db.user.updateMany({name: 'Jack', info: 'info...'})

MongoDB 对象数组更新

例如，使用 update 对集合中的 orderNo 为 o111111 字段下的 userInfo 数组对象下的 cardNo 等于 123456789 这个对象中的 logs 字段和 status 字段(在更新的时候没有 status 字段将会创建) 进行日志更新。

{
 "_id" : ObjectId("59546c5051eb690367d457fa"),
 "orderNo" : "o111111"
 "userInfo" : [
  {
   "name" : "o1111",
   "cardNo" : "123456789",
   "logs" : [
    "2017-08-09 timeline ...",
   ]
  }
  ...
 ]
},
...
}

可以使用 $push 在找到 logs 数组后依次添加日志信息

let condition = {"orderNo":"o111111","userInfo.cardNo":"123456789"}

let update = {
 $push: {
  "passengers.$.logs": "2017-08-10 timeline1 ..."
 }
}
db.collections.findOneAndUpdate(condition, update, { returnOriginal: false })

也可以使用 $set 对某个字段进行更新

let condition = {"orderNo":"o111111","userInfo.cardNo":"123456789"}

let update = {
 $set: {"passengers.$.status": "已更新"}
}

db.orderColl.updateOne(condition,update)

需要注意的点是位置运算符 $ 只能在查询中使用一次，官方对于这个问题提出了一个方案 https://jira.mongodb.org/browse/SERVER-831 如果能在未来发布这将是非常有用的。如果，目前你需要在嵌套层次很深的情况下想对数组的内容进行修改可以采用 forEach() 方法操作，像下面这样：

db.post
  .find({"answers.comments.name": "jeff"})
  .forEach(function(post) {
    if (post.answers) {
      post.answers.forEach(function(answer) {
        if (answer.comments) {
          answer.comments.forEach(function(comment) {
            if (comment.name === "jeff") {
              comment.name = "joe";
            }
          });
        }
      });

      db.post.save(post);
    }
});

删除数据（Delete）

删除操作需谨慎，数据一旦删除很难再恢复。

remove 删除一条数据

> db.demo_admin.remove({a:222})
WriteResult({ "nRemoved" : 1 })

drop 删除一张表

返回 true 删除成功, false 删除失败。

> db.demo_admin.drop()
true

- END -