加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 大数据 > 正文

java – Spring JPA/Hibernate事务强制插入而不是更新

发布时间:2020-12-15 01:33:03 所属栏目:大数据 来源:网络整理
导读:编辑.虽然扩展基础存储库类并添加插入方法可以使更优雅的解决方案似乎在实体中实现Persistable.见可能的解决方案2 我正在使用springframework.data.jpa创建一个服务,使用Hibernate作为ORM,使用JpaTransactionManager. 遵循本教程的基础. http://www.petrikai

编辑.虽然扩展基础存储库类并添加插入方法可以使更优雅的解决方案似乎在实体中实现Persistable.见可能的解决方案2

我正在使用springframework.data.jpa创建一个服务,使用Hibernate作为ORM,使用JpaTransactionManager.

遵循本教程的基础.
http://www.petrikainulainen.net/spring-data-jpa-tutorial/

我的实体存储库扩展了org.springframework.data.repository.CrudRepository

我正在使用遗留数据库,该数据库使用有意义的主键而不是自动生成的ID

这种情况不应该真的发生,但是由于测试中的错误我遇到了它.订单表具有OrderNumber(M000001等)的有意义的键.主键值在代码中生成,并在保存之前分配给对象.旧数据库不使用自动生成的ID密钥.

我有一个创建新订单的交易.由于存在错误,我的代码生成了一个已存在于数据库中的订单号(M000001)

执行repository.save会导致更新现有订单.我想要的是强制插入并由于重复的主键导致事务失败.

我可以在每个存储库中创建一个Insert方法,在执行保存之前执行查找,如果存在行则执行失败.某些实体具有带有OrderLinePK对象的复合主键,因此我无法使用基本弹簧FindOne(ID id)方法

在春季JPA中有这样一种干净的方法吗?

我之前使用spring / Hibernate和我自己的基础库创建了一个没有jpa存储库的测试服务.我实现了Insert方法和Save方法,如下所示.

这似乎工作正常.
使用getSession().saveOrUpdate的save方法给出了我现在正在经历的现有行更新.

使用getSession()的insert方法.使用重复的主键保存失败,如我所愿.

@Override
public Order save(Order bean) {

    getSession().saveOrUpdate(bean);
    return bean;
}

@Override
public Order insert(Order bean) {
    getSession().save(bean);
    return bean;
}

可能的解决方案1

基于这里的春季文档的1.3.2章
http://docs.spring.io/spring-data/jpa/docs/1.4.1.RELEASE/reference/html/repositories.html

可能不是最有效的,因为我们正在进行额外的检索以检查插入之前行的存在,但它是主键.

除了save之外,还扩展存储库以添加插入方法.这是第一次削减.

我必须将密钥传递给插入以及实体.我可以避免这个吗?

我实际上并不想要返回数据. entitymanager没有exists方法(确实存在只需要计数(*)来检查行的存在吗?)

import java.io.Serializable;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.repository.NoRepositoryBean;

/**
 *
 * @author Martins
 */
@NoRepositoryBean
public interface IBaseRepository 

实现:自定义存储库基类.
注意:如果我沿着这条路线走下去,将会创建一个自定义异常类型.

import java.io.Serializable;
import javax.persistence.EntityManager;
import org.springframework.data.jpa.repository.support.JpaEntityInformation;
import org.springframework.data.jpa.repository.support.SimpleJpaRepository;
import org.springframework.transaction.annotation.Transactional;


public class BaseRepositoryImpl

自定义存储库工厂bean

import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.support.JpaRepositoryFactory;
import org.springframework.data.jpa.repository.support.JpaRepositoryFactoryBean;
import org.springframework.data.repository.core.RepositoryMetadata;
import org.springframework.data.repository.core.support.RepositoryFactorySupport;

import javax.persistence.EntityManager;
import java.io.Serializable;

/**
 * This factory bean replaces the default implementation of the repository interface 
 */
public class BaseRepositoryFactoryBean

最后在配置中连接自定义存储库基类

// Define this class as a Spring configuration class
@Configuration

// Enable Spring/jpa transaction management.
@EnableTransactionManagement

@EnableJpaRepositories(basePackages = {"com.savant.test.spring.donorservicejpa.dao.repository"},repositoryBaseClass = com.savant.test.spring.donorservicejpa.dao.repository.BaseRepositoryImpl.class)

可能的解决方案2

遵循patrykos91的建议

为实体实现Persistable接口并覆盖isNew()

用于管理回调方法以设置持久标志的基本实体类

import java.io.Serializable;
import javax.persistence.MappedSuperclass;
import javax.persistence.PostLoad;
import javax.persistence.PostPersist;
import javax.persistence.PostUpdate;


@MappedSuperclass
public abstract class BaseEntity implements Serializable{

    protected transient boolean persisted;


    @PostLoad
    public void postLoad() {
        this.persisted = true;
    }

    @PostUpdate
    public void postUpdate() {
        this.persisted = true;
    }

    @PostPersist
    public void postPersist() {
        this.persisted = true;
    }

}

然后每个实体必须实现isNew()和getID()

import java.io.Serializable;
import javax.persistence.Column;
import javax.persistence.EmbeddedId;
import javax.persistence.Entity;
import javax.persistence.Table;
import javax.xml.bind.annotation.XmlRootElement;
import org.springframework.data.domain.Persistable;

@Entity
@Table(name = "MTHSEQ")
@XmlRootElement

public class Sequence extends BaseEntity implements Serializable,Persistable

抽象出isNew()会很好,但我认为不行. getId不能作为实体具有不同的Id,因为您可以看到这个具有复合PK.

最佳答案
我之前从未这样做,但有点黑客,也许可以做到这一点.

实体有一个Persistable接口.它有一个方法boolean isNew(),它在实现时将用于“评估”实体是否在数据库中是新的.根据该决定,在您从Repository调用.save()之后,EntityManager应决定在该实体上调用.merge()或.persist().

顺便说一句,如果你实现isNew()总是返回true,那么.persist()应该被称为no mater what,并且应该抛出错误.

如我错了请纠正我.不幸的是,我现在无法在实时代码上测试它.

有关可持久性的文档:http://docs.spring.io/spring-data/commons/docs/current/api/org/springframework/data/domain/Persistable.html

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读