mongodb - 如何使用golang在mongodb中findAndModify一条记录？

Question

我想要这样的东西:

1. 在 mongo db 中找到一条记录 old_record
2. 将此记录更新为 new_record
3. 返回old_record

我这样写代码:

ret = nil
// First, Find the obj
obj := &orm.QuerySetObj{}
err2 := this.querySetCollection.With(session).Find(objKey).One(obj)
if nil != err2 {
    this.logger.Println("Error find obj")
    return
}

ret = obj

// Then, update this obj
obj.updateTime = time.Now().Unix()
err3 := this.querySetCollection.With(session).Upsert(objKey, obj)
if nil != err3 {
    this.logger.Println("Error update obj")
    return
}

return

但是，我认为 find 和 update 应该是 atomic 操作，所以我的代码不安全。

如何在原子操作中做到这一点

Answer 1

这里的方法是.Apply()这需要 Change输入并返回 ChangeInfo .

文档中的直接示例:

change := mgo.Change{
        Update: bson.M{"$inc": bson.M{"n": 1}},
        ReturnNew: false,
}
info, err = col.Find(M{"_id": id}).Apply(change, &doc)
fmt.Println(doc.N)

其中 doc 是找到的文档，它的状态取决于 Change 参数中 ReturnNew 的值，即 false 你想要原始文档的地方。

基本上所有参数的格式都与 .findAndModify() 相同。