续集(Ruby),如何以安全的方式增加和使用DB计数器？

Question

我找到了4种"正确"的方法:

1. 在ActiveRecord的备忘单中,用户替换ActiveRecord increment,increment_counter并且应该是album.values[:column] -= 1 # or += 1 for increment和album.update(:counter_name=>Sequel.+(:counter_name, 1))
2. 在SO解决方案 update_sql中建议具有相同的效果s[:query_volume].update_sql(:queries => Sequel.expr(3) + :queries)
3. 在一个随机的线程中我找到了这个dataset.update_sql(:exp => 'exp + 10'.lit)
4. 在用于更新的Sequels API文档中,我找到了这个解决方案http://sequel.jeremyevans.net/rdoc/classes/Sequel/Dataset.html#method-i-update

然而,没有一个解决方案实际更新值并以安全,原子的方式返回结果.

基于"添加值然后保存"的解决方案应该在多处理环境中以不确定的方式失败,从而导致错误,例如:

1. 专辑的计数器是0
2. 线程A和线程B都获取 album
3. 线程A和线程B都增加散列/模型/ etc中的值
4. 线程A和线程B都将计数器更新为相同的值
5. 结果:A和B都将计数器设置为1并使用计数器值1

Sequel.expr而Sequel.+在另一方面实际上并不返回一个值,而是一个Sequel::SQL::NumericExpression和(据我所知)你没有得到它的短做一套DB往返的方式,这意味着这可能发生:

1. 专辑的计数器是0
2. 线程A和B都增加值,值增加2
3. 线程A和B都从DB中获取行
4. 结果:A和B都将计数器设置为2并使用计数器值2

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

更新1

我一般不满意答案说我想要太多的生活,因为1回答建议:)

专辑只是文档中的一个例子.

想象一下,例如你在电子商务POS上有一个交易柜台,它可以在不同的主机上同时接受2个交易,并且你需要在24小时内用一个整数计数器发送它们(称为systan),发送2具有相同systan和1的trx将被拒绝,或者更糟糕的是,计数中的间隙被警告(因为它们暗示"缺少事务"),因此不可能使用DB的ID值.

一个不太严重的例子,但与我的用例更相关,几个文件导出在后台worker中同时触发,每个文件目的地都有自己的计数器.计数器中的间隙被警告,工作人员在不同的主机上(因此互斥体没有用).我有一种感觉,我很快就会解决更严重的问题.

数据库序列也不好,因为它意味着在添加每个终端时都要做DDL,我们在这里谈论1000.即使在我不那么严重的用例中,门户网站上的DDLing操作仍然是PITA,甚至可能不起作用,具体取决于下面的缓存方案(由于实现ActiveRecord和Sequel- 并且在我的情况下我使用两者 - 可能需要服务器重启才能注册一个商人).

Redis可以做到这一点,但是当你坐在符合ACID标准的数据库上时,为计数器添加另一个基础架构组件似乎很疯狂.

Answer 1

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

但是,如果不更新退货或类似的东西的支持,就没有办法在同一时间原子方式增加作为回报递增的值.