Spring Data JPA + Hibernate跳过锁定行(PostgreSQL)

本文介绍了Spring Data JPA + Hibernate跳过锁定行(PostgreSQL)的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述

我正在尝试使用Spring Data JPA(2.1)和Hibernate在PostgreSQL上执行SKIP LOCKED查询.查询看起来像这样:

I am trying to execute SKIP LOCKED query on PostgreSQL using Spring Data JPA (2.1) and Hibernate. The query looks like this:

@Lock(LockModeType.PESSIMISTIC_WRITE) @QueryHints({@QueryHint(name = "javax.persistence.lock.timeout", value ="-2")}) List<Obj> findByEntityAndStatus(Entity entity, Status status);

根据 Spring data JPA本机查询跳过锁定和选择从JPA级别锁定的更新跳过，它应该可以工作，但是生成的查询仅选择要更新，而不会跳过锁定的行.

According to Spring data JPA native query skip locked and Select for update skip locked from JPA level it should work but the generated query only selects for update without skipping locked rows.

生成的查询:

休眠:从objs obj0_的左外部联接实体enter1_上选择obj0_.id作为id1_5_，obj0_.name作为名称6_5_，obj0_.entity_id作为实体10_5_，obj0_.status作为status8_5_其中obj0_.entity_id = entity1_.id ?和obj0_.status =?用于更新obj0 _

Hibernate: select obj0_.id as id1_5_, obj0_.name as name6_5_, obj0_.entity_id as entity10_5_, obj0_.status as status8_5_ from objs obj0_ left outer join entities entity1_ on obj0_.entity_id=entity1_.id where entity1_.id=? and obj0_.status=? for update of obj0_

我想念什么?

推荐答案

您可以使用nativeQuery.

You can use nativeQuery.

@Query(value = "SELECT * FROM task LIMIT 10 FOR UPDATE SKIP LOCKED", nativeQuery = true) List<TaskEntity> fetchAllUnlocked();