如果文档存在，如何进行 rethinkdb 原子更新，否则插入？

Question

如果文档存在，如何进行 rethinkdb 原子更新，否则插入？

我想做类似的事情：

var tab = r.db('agflow').table('test');
r.expr([{id: 1, n: 0, x: 11}, {id: 2, n: 0, x: 12}]).forEach(function(row){
  var _id = row('id');
  return r.branch(
    tab.get(_id).eq(null),  // 1
    tab.insert(row),        // 2 
    tab.get(_id).update(function(row2){return {n: row2('n').add(row('n'))}}) // 3
  )})

然而，这并不是完全原子的，因为在我们检查文档是否存在 (1) 和插入它 (2) 之间，其他线程可能会插入它。

如何使这个查询原子化？

Answer 1

我认为解决方案正在通过

conflict="update"

到插入方法。

另见RethinkDB documentation on insert

Answer 2

要使内部原子化，可以使用replace：

tab.get(_id).replace(function(row2){
  return r.expr({id: _id, n: row2('n').add(row('n'))})
          .default(row)
})

使用replace 是目前使用非平凡更新操作执行完全原子更新插入的唯一方法。

Answer 3

这是一种称为“upsert”的标准数据库操作。

RethinkDB 是否支持 upserts？

塞尔吉奥的另一个问题 图连采夫。第一个公开版本不包括支持 upserts，但现在可以通过向插入传递额外的标志来完成：

r.table('marvel').insert({ 
      superhero: 'Iron Man', 
      superpower: 'Arc Reactor' 
  }, {upsert: true}).run() 

当设置为 true 时，新文档 from insert 将覆盖现有的。

_{引用：Answers to common questions about RethinkDB}

Answer 4

好的，我想出了办法。

解决方法是先尝试insert，如果失败我们就做update：

var tab = r.db('agflow').table('test');
tab.delete();
r.expr([{id: 1, n: 0, x: 11}, {id: 2, n: 0, x: 12}]).forEach(function(row){
  var _id = row('id');
  var res = tab.insert(row);
  return r.branch(
    res('inserted').eq(1),
    res,
    tab.get(_id).update(function(row2){return {n: row2('n').add(1)}})
  )})