MongoDB原子操作

发布时间：2024-03-30 14:30:01

维护原子性的推荐方法是保留所有相关信息，并将这些信息使用嵌入式文档的形式更新到文档中，这将确保单个文档的所有更新都是原子的。假设我们已经创建了一个名为 productDetails 的集合，并在其中插入了一个文档，如下所示：

> db.productDetails.insert(
... {
... "product_name": "Samsung S3",
... "category": "mobiles",
... "product_total": 5,
... "product_available": 3,
... "product_bought_by": [
... {
... "customer": "john",
... "date": "7-Jan-2014"
... },
... {
... "customer": "mark",
... "date": "8-Jan-2014"
... }
... ]
... }
... )
WriteResult({ "nInserted" : 1 })

在上面的文档中，我们将购买产品的客户的信息嵌入到 product_bought_by 字段中。当有新客户购买该产品时，我们首先会使用 product_available 字段检查该产品是否仍然可用。如果可用，我们就减少 product_available 字段的值，并在 product_bought_by 字段中插入新客户的信息。

我们可以使用 findAndModify 命令来实现上述功能，如下所示：

> db.productDetails.findAndModify({query:{_id:ObjectId("603f31435e514debed504a38"), product_available:{$gt:0}}, update:{$inc:{product_available:-1}, $push:{product_bought_by:{customer:"rob", date:"9-Jan-2014"}}}})
{
        "_id" : ObjectId("603f31435e514debed504a38"),
        "product_name" : "Samsung S3",
        "category" : "mobiles",
        "product_total" : 5,
        "product_available" : 3,
        "product_bought_by" : [
                {
                        "customer" : "john",
                        "date" : "7-Jan-2014"
                },
                {
                        "customer" : "mark",
                        "date" : "8-Jan-2014"
                }
        ]
}

上面的示例中我们使用 findAndModify 来查询并更新文档，这样可以确保只有在产品可用时才更新产品购买信息。而且整个过程都在同一个查询中完成。

与此相反，假如我们将产品的可用性信息与购买记录分开保存，那么在上面的示例中我们需要先使用一个查询来检查产品是否可用，然后再通过另一个查询来更新购买信息。但是，在执行这两个查询的过程中，可能有其他的用户购买了该产品，导致该产品不可用。在不知道这一点的情况下，我们的第二个查询将根据第一个查询的结果更新购买信息，这就会导致两个文档中的数据不一致。

常用的原子操作命令

$set

用来指定一个键并更新键值，若键不存在则创建。

{ $set : { field : value } }

$unset

用来删除一个键。

{ $unset : { field : 1} }

$inc

用来对文档的某个数值类型的键值进行增减操作。

{ $inc : { field : value } }

$push

用来向文档中追加一些信息。

{ $push : { field : value } }

把 value 追加到 field 里面去，field 一定要是数组类型才行，如果 field 不存在，则会新增一个数组类型加进去。

$pushAll

与 $push 类似，它可以一次追加多个值到一个数组类型的字段内。

{ $pushAll : { field : value_array } }

$pull

从数组 field 内删除一个等于 value 的值。

{ $pull : { field : _value } }

$pop

删除数组的第一个或最后一个元素。

{ $pop : { field : 1 } }

$rename

修改字段的名称。

{ $rename : { old_field_name : new_field_name } }

$bit

位操作，integer 类型。

{$bit : { field : {and : 5}}}

偏移操作符

> t.find() { "_id" : ObjectId("4b97e62bf1d8c7152c9ccb74"), "title" : "ABC", "comments" : [ { "by" : "joe", "votes" : 3 }, { "by" : "jane", "votes" : 7 } ] }
> t.update( {'comments.by':'joe'}, {$inc:{'comments.$.votes':1}}, false, true )
> t.find() { "_id" : ObjectId("4b97e62bf1d8c7152c9ccb74"), "title" : "ABC", "comments" : [ { "by" : "joe", "votes" : 4 }, { "by" : "jane", "votes" : 7 } ] }