时间戳

首页 > 解决方案 > 带有两个数据库的spring批处理和JPA

java - 带有两个数据库的spring批处理和JPA

问题描述

我有两个使用 MySQL 的数据库阅读器和使用 spring h2 的编写器的 spring 批处理。所以两者都配置了模型和各自的存储库。即使模型是相同的，也可以作为模型列表读取，同时写入具有相同类型的模型的另一个 repo 会引发类型转换错误。所以我尝试了 n 数字类型的对象来保存，但仍然抛出错误。感谢您的帮助。 错误：

java.lang.IllegalArgumentException: Unknown entity: net.guides.springboot2.springboot2jpacrudexample.model.Employee
    at org.hibernate.internal.SessionImpl.firePersist(SessionImpl.java:787) ~[hibernate-core-5.2.17.Final.jar:5.2.17.Final]

项目阅读器：

@Autowired
    private EmployeeRepository employeeRepositoryMYSQL;
        @Override
    public Employee1 read() throws Exception, UnexpectedInputException, ParseException, NonTransientResourceException
    {
    
        return employeeRepositoryMYSQL.findAll;
    }

项目作者:: - 这里是值的来源，但由于类型转换而在保存时弹出错误！

 @Autowired
    private EmployeeRepository2 employeeRepositoryH2;

    @Override
    public void write(List<? extends Employee2> Employees) throws Exception {
      employeeRepositoryH2.saveAll(Employees);
    }

型号1：

@Entity
@Table(name = "employees")
public class Employee1 {

    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "USER_SEQ_GENERATOR")
    private Long id;
    private String first_name;
    private String last_name;
    private String email_address;
    public Employee1() {
        
    }
    

    @Id
    /* @GeneratedValue(strategy=GenerationType.SEQUENCE) */
    
    @SequenceGenerator(
          name = "USER_SEQ_GENERATOR",
          sequenceName = "USER_SEQ",
          initialValue = 1, allocationSize = 1)
    
    public Long getId() {
        return id;
    }
    public void setId(int i) {
        this.id = id;
    }

    public String getFirst_name()
    {
        return first_name;
    }

    public void setFirst_name(String first_name)
    {
        this.first_name = first_name;
    }

    public String getLast_name()
    {
        return last_name;
    }

    public void setLast_name(String last_name)
    {
        this.last_name = last_name;
    }

    public String getEmail_address()
    {
        return email_address;
    }

    public void setEmail_address(String email_address)
    {
        this.email_address = email_address;
    }

型号2：

Entity
@Table(name = "employees")
public class Employee2 {

    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "USER_SEQ_GENERATOR")
    private BigInteger id;
    private String first_name;
    private String last_name;
    private String email_address;
    public Employee2() {
        
    }
    

    @Id
    /* @GeneratedValue(strategy=GenerationType.SEQUENCE) */
    
    @SequenceGenerator(
          name = "USER_SEQ_GENERATOR",
          sequenceName = "USER_SEQ",
          initialValue = 1, allocationSize = 1)
    
    public BigInteger getId() {
        return id;
    }
    public void setId(BigInteger id) {
        this.id = id;
    }


    public String getFirst_name()
    {
        return first_name;
    }


    public void setFirst_name(String first_name)
    {
        this.first_name = first_name;
    }


    public String getLast_name()
    {
        return last_name;
    }


    public void setLast_name(String last_name)
    {
        this.last_name = last_name;
    }


    public String getEmail_address()
    {
        return email_address;
    }


    public void setEmail_address(String email_address)
    {
        this.email_address = email_address;
    }

标签： javaspringspring-bootspring-data-jpaspring-batch

解决方案

即使模型是相同的，也可以作为模型列表读取，同时写入具有相同模型的另一个 repo 抛出类型转换错误

模型是相同的（概念上相同的字段），但类是不同的：Employee1和Employee2.

在没有处理器的面向块的步骤中，读取器返回的项目以块的形式“交给”写入器（用于批量更新）。这意味着它们必须属于同一类型。但是，这不是一个要求。如果读取项与写入项的类型不同，ItemProcessor则可以使用 an 进行转换。数据转换是项目处理器的典型用例。

因此，在您的情况下，您需要在ItemProcessor<Employee1, Employee2>步骤中添加一个。

推荐阅读