go - 在 RethinkDB 的 Do-function 中更新对象

标签 go rethinkdb rethinkdb-go

rooms 表中的示例数据:

{
    "id": "8ae9865-b602-41f7-8637-9fd5517095d9",
    "members": {
        "12345": {
            "Id": 12345,
            "Name": "User1",
            "LastUpdated": timestamp
        }
    }
}

我的查询:

        result, err := r.DB(rethinkdbDatabase).Table("rooms").Filter(
            r.Row.Field("members").HasFields(playerIdStr)).Nth(0).Default(nil).Do(func(room r.Term) interface{} {
            return r.Branch(
                    room.Ne(nil),
                    room.Update(map[string]interface{}{
                            "LastUpdate": r.Now(),
                    }),
                    r.DB(rethinkdbDatabase).Table("rooms").Insert(map[string]interface{}{
                            "id": r.UUID(),
                            "members": map[string]interface{}{
                                    playerIdStr: map[string]interface{}{
                                            "LastUpdate": r.Now(),
                                            "Name":       request.Player.Name,
                                            "Id":         request.Player.Id,
                                    },
                            },
                    }, r.InsertOpts{
                            Durability: "hard",
                    }),
            )
    }).Run(rethinkdbClient)

它给出了以下错误:

gorethink: Expected type SELECTION but found DATUM:
{
    "id":   "08ae9865-b602-41f7-8637-9fd5517095d9",
    "members":      {
    "7360165":      {
    "Id":   7360165,
    "LastUpdate":   {
    "$reql_type$":  "TIME",
    "epoch_time":   1486826898.51,
    "timezone":     "+00:00"
    },
    "Name": "Player1"
    }
    }
} in:
r.Do(func(var_10 r.Term) r.Term { return r.Branch(var_10.Ne(<nil>), var_10.Update({LastUpdate=r.Now()}), r.DB("drill_dev").Table("rooms").Insert({id=r.UUID(), members={7360165={LastUpdate=r.Now(), Name="Player1", Id=7360165}}}, durability="hard")) }, r.DB("drill_dev").Table("rooms").Filter(func(var_9 r.Term) r.Term { return r.Row.Field("members").HasFields("7360165") }).Nth(0).Default(<nil>))

据我了解,问题似乎是,room 变量的类型是 OBJECT,它与更新函数不兼容,因此调用 room.Update ({...}) 不起作用。如何使用 room 变量更新嵌套文档中的“LastUpdated”字段而无需再次过滤表格?

最佳答案

因为文档 room 有一个 id,你可以通过 id 选择文档(而不是第二次过滤整个表)并以这种方式更新它。

关于go - 在 RethinkDB 的 Do-function 中更新对象,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42178117/

相关文章:

go - 如何通过初始化是否确定struct的字段为零值?

node.js - NodeJS 与 rethinkDB 的 promise

rethinkdb - 限制 rethinkdb 查询中的嵌套对象结果

ruby - RethinkDB 单个请求中的多个查询

go - 使用 WaitGroup 完成goroutine

go - 你如何在 Go 中实现不同类型的容器?

从 C 调用 Go 函数