【发布时间】:2014-11-05 07:10:12
【问题描述】:
我正在处理一种在 oracle 11.2 表中实现的消息队列。我知道,错了,我还有。
表格由id、message、date和status组成。所有新消息都以 NEW 状态插入。我正在开发 java (jdbc) 阅读器,它选择最旧的新消息:
select * from messages
where status = NEW and rownum <= 1
order by date asc
阅读器处理消息并将其状态设置为 DONE。它运作良好,而我们只有一个读者。多个阅读器的问题是,他们都选择了相同的消息。
我正在尝试通过将状态更新为 WORKING 来解决此问题。下面的伪代码正确吗?
//autocommit is on
id = query(select … for update)
query(update messsages set status = WORKING where id = :id)
…do some processing in reader…
query(update messsages set status = DONE where id = :id)
它适用于多个并发阅读器吗?读者会在大部分时间里等待锁吗?或者他们只会得到下一个未锁定的行?
【问题讨论】:
标签: java sql database jdbc oracle11g