MongoDB原子操作

7个月前 (04-28)
维护原子性的方法是保留所有相关信息,并将这些信息使用嵌入式文档的形式更新到文档中,这将确保单个文档的所有更新都是原子的。假设我们已经创建了一个名为 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 } ] }