douyan8266 2015-08-11 08:52
浏览 130
已采纳

如何使用golang在mongodb中找到并修改一条记录?

I want something like this:

  1. find one record in mongo db old_record
  2. update this record to new_record
  3. return old_record

I write code like this:

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

but, I think find and update should be an atomic operation, so my code is not safe.

how can I do this in an atomic operation

  • 写回答

1条回答 默认 最新

  • duanlu1959 2015-08-11 09:04
    关注

    The method here is .Apply() which takes a Change type and returns ChangeInfo.

    Direct example in the documentation:

    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)
    

    Where doc is document that is found, and it's state depending on the value of ReturnNew in the Change arguments, being false where you want the original document.

    Basically all arguments are in the same form as with .findAndModify()

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥500 火焰左右视图、视差(基于双目相机)
  • ¥100 set_link_state
  • ¥15 虚幻5 UE美术毛发渲染
  • ¥15 CVRP 图论 物流运输优化
  • ¥15 Tableau online 嵌入ppt失败
  • ¥100 支付宝网页转账系统不识别账号
  • ¥15 基于单片机的靶位控制系统
  • ¥15 真我手机蓝牙传输进度消息被关闭了,怎么打开?(关键词-消息通知)
  • ¥15 装 pytorch 的时候出了好多问题,遇到这种情况怎么处理?
  • ¥20 IOS游览器某宝手机网页版自动立即购买JavaScript脚本