6

我想要这样的东西:

  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操作,所以我的代码是不安全的。

我怎样才能在原子操作中做到这一点

4

1 回答 1

16

这里的方法.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,它的状态取决于参数ReturnNew中的值,是您想要原始文档的位置。Changefalse

基本上所有参数的形式都与.findAndModify()

于 2015-08-11T09:04:33.757 回答