2

我正在尝试在 Grails / GORM / mongodb 插件 / MongoDB 中实现一个简单的“插入或更新”（所谓的“upsert”）方法。

我与 Hibernate 一起使用的方法（使用合并）失败并出现重复键错误。我认为可能 merge() 不是 mongodb GORM 中支持的操作，并试图通过 GMongo 获取本机 upsert 方法。

我终于有了一个可以工作的版本（如下所示），但这可能不是最好的方法，因为向正在保存的对象添加任何字段都会默默地破坏代码。

 public void upsertPrefix(p) {
    def o = new BasicDBObject()
    o.put("_id", p.id)
    o.put("someValue", p.someValue)
    o.put("otherValue", p.otherValue)

    // DBObject o = p as DBObject // No signature of method: mypackage.Prefix.keySet() is applicable for argument types: () values: []

    db.prefix.update([_id : p.id], o, true, false)
    // I actually would want to pass p instead of o here, but that fails with:
    // No signature of method: com.gmongo.internal.DBCollectionPatcher$__clinit__closure2.doCall() is applicable for argument types: (java.util.ArrayList) values: [[[_id:keyvalue], mypackage.Prefix : keyvalue, ...]]


    /* All of these other more "Hibernatesque" approaches fail:
    def existing = Prefix.get(p.id)
    if (existing != null) {
        p.merge(flush:true) // E11000 duplicate key error
        // existing.merge(p) // Invocation failed: Message: null
        // Prefix.merge(p) // Invocation failed: Message: null

    } else {
        p.save(flush:true)
    } 
    */
}

我想我可以在混合中引入另一个 POJO-DbObject 映射框架，但这会使事情变得更加复杂，重复 GORM 已经在做的事情，并且可能会引入额外的元数据。

任何想法如何以最简单的方式解决这个问题？

编辑#1：我现在尝试了别的东西：

    def existing = Prefix.get(p.id)
    if (existing != null) {
//      existing.properties = p.properties // E11000 duplicate key error...
        existing.someValue = p.someValue    
        existing.otherValue = p.otherValue  
        existing.save(flush:true)
    } else {
        p.save(flush:true)
    }

未注释的版本再次起作用，但维护性不好。我想做的评论版本失败了。

编辑#2：

有效的版本：

public void upsertPrefix(p) {
    def o = new BasicDBObject()

    p.properties.each {
        if (! (it.key in ['dbo'])) {
            o[it.key] = p.properties[it.key]
        }
    } 
    o['_id'] = p.id

    db.prefix.update([_id : p.id], o, true, false)
}

似乎从不插入任何东西的版本：

def upsertPrefix(Prefix updatedPrefix) {
     Prefix existingPrefix = Prefix.findOrCreateById(updatedPrefix.id)
     updatedPrefix.properties.each { prop ->
          if (! prop.key in ['dbo', 'id']) { // You don't want to re-set the id, and dbo is r/o
                existingPrefix.properties[prop.key] = prop.value
          }
    }
    existingPrefix.save() // Never seems to insert anything
}

仍然因重复键错误而失败的版本：

def upsertPrefix(p) {
    def existing = Prefix.get(p.id)
    if (existing != null) {
        p.properties.each { prop ->
            print prop.key
            if (! prop.key in ['dbo', 'id']) { 
                existingPrefix.properties[prop.key] = prop.value
            }
        }
        existing.save(flush:true) // Still fails with duplicate key error
    } else {
        p.save(flush:true)
    }
}
4

2 回答 2

1

假设您有对象的更新版本，或者需要使用新值更新的属性映射，您可以遍历这些并为每个属性应用更新。

像这样的东西：

def upsert(Prefix updatedPrefix) {
    Prefix existingPrefix = Prefix .findOrCreateById(updatedPrefix.id)
    updatedPrefix.properties.each { prop ->
        if (prop.key != 'id') { // You don't want to re-set the id
            existingPrefix.properties[prop.key] = prop.value
        }
    }
    existingPrefix.save()
}

如何排除更新 ID 可能不太正确，因此您可能需要尝试一下。如果相应的新值与现有值不同，您也可以考虑仅更新属性，但这本质上只是一种优化。

如果您有地图，您也可以考虑按照默认控制器脚手架的方式进行更新：

prefixInstance.properties = params
于 2012-08-02T21:04:46.590 回答
0

MongoDB 原生支持 upsert。请参阅带有 upsert 参数 true的findAndModify 命令。

于 2012-08-02T22:35:41.223 回答