ruby - 续集(Ruby)，如何以安全的方式递增和使用数据库计数器？

Question

我找到了 4 种“正确”的方法来做到这一点:

1. 在the cheat sheet for ActiveRecord users ActiveRecord 的 increment 和 increment_counter 的替代品应该是 album.values[:column] -= 1 # or += 1 for increment 和 album.update(:counter_name=>Sequel.+(:counter_name, 1))
2. 在SO solution update_sql 建议用于相同的效果 s[:query_volume].update_sql(:queries => Sequel.expr(3) + :queries)
3. 在random thread我找到了这个 dataset.update_sql(:exp => 'exp + 10'.lit)
4. 在the Sequels API docs for update我找到了这个解决方案 http://sequel.jeremyevans.net/rdoc/classes/Sequel/Dataset.html#method-i-update

然而，没有任何解决方案以安全、原子的方式实际更新值并返回结果。

据我所知，基于“添加一个值然后保存”的解决方案应该在多处理环境中不确定地失败，从而导致错误，例如:

1. 相册的计数器为 0
2. 线程A和线程B都获取相册
3. 线程 A 和线程 B 都递增 hash/model/etc 中的值
4. 线程 A 和线程 B 都将计数器更新为相同的值
5. 结果:A 和 B 都将计数器设置为 1 并使用计数器值 1

Sequel.expr 和 Sequel.+ 在另一方面实际上并不返回一个值，而是一个 Sequel::SQL::NumericExpression 和(afaik)你没有办法在做另一次数据库往返之前得到它，这意味着这可能发生:

1. 相册的计数器为 0
2. 线程A和B都递增value，value递增2
3. 线程 A 和 B 都从数据库中获取行
4. 结果:A 和 B 都将计数器设置为 2 并使用计数器值 2

那么，如果不编写自定义锁定代码，解决方案是什么？如果没有，那就是编写自定义锁定代码 :) 最好的方法是什么？

更新1

我通常不喜欢说我想要太多生活的答案，正如 1 个答案所暗示的那样:)

相册只是文档中的一个示例。

例如，假设您在电子商务 POS 上有一个交易柜台，它可以在不同的主机上同时接受 2 笔交易，您需要向银行发送一个 24 小时内唯一的整数计数器(称为 systan) ，发送具有相同系统的 2 个 trx 和 1 个将被拒绝，或者更糟的是，警告计数中的差距(因为它们暗示“丢失的交易”)所以不可能使用数据库的 ID 值。

一个不太严重的例子，但与我的用例更相关，多个文件导出在后台工作程序中同时触发，每个文件目标都有自己的计数器。计数器中的间隙会被警告，工作人员在不同的主机上(因此互斥量没有用)。而且我有一种感觉，无论如何我很快就会解决更严重的问题。

DB 序列也不好，因为这意味着在添加每个终端时执行 DDL，而我们在这里谈论的是 1000s。即使在我不太严重的用例中，网络门户操作上的 DDLing 仍然是一个 PITA，甚至可能无法工作，具体取决于下面的缓存方案(由于 ActiveRecord 和 Sequel 的实现) - 在我的情况下，我同时使用两者 - 可能需要重新启动服务器才能注册商家)。

Redis 可以做到这一点，但是当您使用符合 ACID 的数据库时，为计数器添加另一个基础设施组件似乎很疯狂。

Answer 1

如果您使用的是 PostgreSQL，则可以使用 UPDATE RETURNING:DB[:table].returning(:counter).update(:counter => Sequel.expr(1) + :counter)

但是，如果不支持 UPDATE RETURNING 或类似的东西，则无法在返回增量值的同时自动增量。