使用Spring JPA/Hibernate进行条件插入

Question

我正在开发一个在集群环境中运行的项目,其中有许多节点和一个数据库.该项目使用Spring-data-JPA(1.9.0)和Hibernate(5.0.1).我无法解决如何防止重复行问题.

例如,这是一个简单的表格

@Entity
@Table(name = "scheduled_updates")
public class ScheduledUpdateData {
    public enum UpdateType {
        TYPE_A,
        TYPE_B
    }

    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    @Column(name = "id")
    private UUID id;

    @Column(name = "type", nullable = false)
    @Enumerated(EnumType.STRING)
    private UpdateType type;

    @Column(name = "source", nullable = false)
    private UUID source;
}

重要的是有一个UNIQUE(type, source)约束.

当然,匹配示例存储库:

@Repository
public class ScheduledUpdateRepository implements JpaRepository<ScheduledUpdateData, UUID> {
    ScheduledUpdateData findOneByTypeAndSource(final UpdateType type, final UUID source);

    //...
}

这个例子的想法是,系统的某些部分可以插入行以安排定期运行的事件,在所述运行之间任意次数.无论什么东西实际运行,它都不必担心两次操作相同的东西.

如何编写有条件地插入此表的服务方法？我已经试过了几件事情不工作是:

1. 查找>操作 - 服务方法将使用存储库查看条目是否已存在,然后根据需要更新找到的条目或保存新条目.这不起作用.
2. 如果失败,请尝试插入>更新 - 服务方法将尝试插入,由于唯一约束而捕获异常,然后执行更新.这不起作用,因为事务已经处于回滚状态,并且不能在其中进行进一步的操作.

3. 使用"INSERT INTO ... WHERE NOT EXISTS ..."的本机查询* - 存储库有一个新的本机查询:

   @Repository
   public class ScheduledUpdateRepository implements JpaRepository<ScheduledUpdateData, UUID> {
       // ...
   
       @Modifying
       @Query(nativeQuery = true, value = "INSERT INTO scheduled_updates (type, source)" +
                                          " SELECT :type, :src" +
                                          " WHERE NOT EXISTS (SELECT * FROM scheduled_updates WHERE type = :type AND source = :src)")
       void insertUniquely(@Param("type") final String type, @Param("src") final UUID source);
   }
   

   遗憾的是,这也不起作用,因为Hibernate似乎首先执行了SELECT该WHERE子句的使用- 这意味着最终会尝试多次插入,从而导致唯一的约束违规.

我绝对不知道JTA,JPA或Hibernate的许多细节.关于如何跨多个JVM插入具有唯一约束(超出主键)的表的任何建议？

编辑2016-02-02

使用Postgres(2.3)作为数据库,尝试使用隔离级别SERIALIZABLE - 遗憾的是,这仍然导致约束违规异常.

Answer 1

Hibernate 及其查询语言提供对插入语句的支持。因此，您实际上可以使用 HQL 编写该查询。浏览此处获取更多信息。http://docs.jboss.org/hibernate/orm/5.0/userguide/html_single/Hibernate_User_Guide.html#_hql_syntax_for_insert