一尘不染

如何使用Criteria API指定悲观锁?

hibernate

我正在使用Criteria
API检索hibernate中的对象列表。但是,我需要锁定那些对象,因为同时执行的另一个线程将获得确切的对象,并且在没有悲观锁定的情况下,只有一个线程会成功。

我尝试如下,但它不起作用。

List esns = session
    .createCriteria(Reddy_Pool.class)
    .add(Restrictions.eq("status", "AVAILABLE"))
    .add(Restrictions.eq("name", "REDDY2"))
    .addOrder(Order.asc("id"))
    .setMaxResults(n)
    .setLockMode(LockMode.PESSIMISTIC_WRITE) //not working at all
    .list();

更新 :我正在执行此语句之后的更新,以便我希望两个线程都读取不同的行,或者至少第二个线程应该等到第一个线程完成事务并离开锁。

hibernate生成的查询如下。

Hibernate: select this_.id as id1_0_, this_.name as name1_0_, 
this_.orderitem_id as orderitem3_1_0_, this_.status as status1_0_, 
this_.store as store1_0_, this_.vendor as vendor1_0_, this_.version as version1_0_ 
from reddy_pool this_ 
where this_.status=? and and this_.name=? order by this_.id asc limit ?

更新 :这似乎是3.5.2版本中的一个错误,正如Pascal
Thivent(非常感谢Pascal)提到的那样,我已经作为成员加入并观看了此问题。希望它将包含在下一个版本中。

但是,我尝试在此处使用另一种方法session.buildLockRequest()…但我无法弄清楚如何使用它,使用下面的代码根本没有任何效果。

for (int i=0; i < n; i++)
    session.buildLockRequest(LockOptions.UPGRADE).lock(esns.get(i));

阅读 222

收藏
2020-06-20

共1个答案

一尘不染

您正在使用哪个版本的Hibernate?可以是HHH-5275吗?您确定FOR UPDATE未生成该语句吗?您可以显示生成的SQL吗?

2020-06-20