RethinkDB 原子操作

Question

假设我有一份文档

{
    id: 1,
    fruits: []
}

这里的fruits作为一个SET进行操作

现在我想要对主键为1的文档中的fruits数组进行原子性添加值，如果该文档不存在则创建它（即在底层使用SetInsert ReQL）

我还需要对增量进行相同的操作（ReQL .Add）

显然这不能在客户端代码中完成，因为它会破坏原子性并导致不一致的数据

希望能够像这样实现

r.table('results').insert({
  id: '62c70132-6516-4279-9803-8daf407ffa5c',
  counter: r.row('counter').add(1).default(0)
}, {conflict: "update"})

但是它会出现“RqlCompileError: r.row在此上下文中未定义”的错误。

任何帮助/指导都将不胜感激，谢谢！

- let4be

---

r.row 在 ReQL 语言中基本上表示"针对每一行你将进行操作的当前行"。在插入中，r.row 没有意义，这就是出现错误的原因。然而，如果你正在寻找特定的文档，那么你可以通过子查询获取文档的字段，可以参考下面的解答 :) - Chris Foster

Answer 1

目前使用insert是不可能的。另一种解决方案由于使用子查询而不是原子性的。

我们正在https://github.com/rethinkdb/rethinkdb/issues/3753中为此寻找解决方案。

但是，您可以使用replace进行原子性的upsert操作：

r.table('results').get('62c70132-6516-4279-9803-8daf407ffa5c')
 .replace({
  id: '62c70132-6516-4279-9803-8daf407ffa5c',
  counter: r.row('counter').add(1).default(0)
})

replace实际上会执行插入操作，如果文档不存在的话。

- Daniel Mewes

---

感谢你的帮助，Daniel！ - let4be

Answer 2

在RethinkDB中，所有单个查询的更新都是原子操作。如果Rethink不认为特定的更新/替换操作将是原子性的，则会抛出错误并要求您向查询添加非原子标志。因此，通常情况下，您不必过多担心它。然而，这只适用于update和replace查询。使用insert无法实现原子性。

如果您在客户端检索该文档，然后在客户端对其进行更新，然后将其放回到数据库中，那么它的本质上是非原子性的更新。

但是，在单个查询中，您可以执行以下操作，它实际上是一种与您使用insert相同的upsert方式，但使用replace：

r.table('FruitStore')
.get(1)
.replace({
  id : 1, 
  fruits : r.row('fruits').default([]).append('orange') 
})

...这将是原子的。同样，要使用add操作：

r.table('FruitStore')
.get(1)
.replace({
  id : 1, 
  count : r.row('count').default(0).add(1) 
})

- Chris Foster

---

非常感谢Chris的快速回答和解释！ - let4be

我唯一的担心是关于http://rethinkdb.com/docs/architecture/中的"How does the atomicity model work?"。他们声明：“无法证明确定性的操作无法以原子方式更新文档。目前，通过执行JavaScript代码获得的值、随机值和作为子查询结果获得的值（例如将属性的值增加到不同文档中属性的值）无法以原子方式执行”。这里使用了子查询。 - let4be

@sfireman 你说得对，文档确实存在矛盾。这个子查询使用的是与其更新的文档相同的文档，因此理论上应该是原子性的。然而，根据文档，你也可以基于另一个文档的属性结果来更新此文档，而不会引发RethinkDB错误。我现在很难为你找到一个明确的答案... - Chris Foster

刚刚尝试了一下带有 get(2) 命令的代码，确实 rethinkdb 没有抛出错误，但这与文档相反... - let4be

@sfireman 可以使用 merge 在 replace 中模拟 update。例如：table.get(...).replace(r.branch(r.row.eq(null), {id: ..., counter: 0}, r.row.merge({counter: r.row('counter').add(1)}))) - Daniel Mewes