如何解决春季批处理和具有两个数据库的JPA
我有两个使用MySQL的数据库读取器和一个使用spring h2的writer的春季批处理。因此,两者都配置有模型和各自的存储库。 即使模型完全相同,也可以将其读为模型列表,同时以相同的模型抛出类型转换错误将其写入另一个回购中。 因此,我尝试用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]
ItemReader:
@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;
}
Model2:
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",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;
}
解决方法
即使模型是相同的,也要作为模型列表阅读,同时以相同的模型抛出类型转换错误写入另一个仓库中
模型相同(概念上相同的字段),但类别不同:Employee1
和Employee2
。
在没有处理器的面向块的步骤 中,将读取器返回的项目以块的形式“交给”编写器(用于批量更新)。这意味着它们必须是同一类型。但是,这不是必需的。如果阅读项目与书面项目的类型不同,则可以使用ItemProcessor
进行转换。数据转换是项目处理器的typical use case。
因此,在您的情况下,您需要在步骤中添加ItemProcessor<Employee1,Employee2>
。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。