【发布时间】:2014-04-03 21:22:09
【问题描述】:
我有一个关于 JPA 中的循环关系的问题,尤其是 Eclipselink JPA 实现。对不起,如果问题有点长,但我尽量准确。
让我们以部门和员工的简单示例为例,其中部门具有一对多的“员工”关系(因此从员工到部门的反向多对一“部门”关系)。现在让我们添加一个从部门到雇员的一对一关系“经理”(部门的一名雇员是同一部门的经理)。这会在两个实体之间引入循环关系,并且两个表都有一个引用另一个表的外键。
我希望能够在不违反外键约束的情况下完成所有插入操作。所以,我的想法是先插入所有员工(不设置部门关系),然后插入部门(设置经理),最后更新所有员工设置部门。
我知道我可以使用flush() 来强制插入执行的顺序,但我被告知应该避免它,因此想知道是否有办法告诉 JPA/Eclipselink 应该先插入 Department,然后是 Employee .
在 Eclipselink 中,我确实尝试将 Employee 添加为 Department 类的类描述符的约束依赖,但它仍然随机给出错误。
这是一个说明这一点的代码示例(问题随机发生):
部门类:
package my.jpa.test;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
import javax.persistence.Entity;
import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.FetchType;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.JoinColumn;
import javax.persistence.OneToMany;
import javax.persistence.OneToOne;
import javax.persistence.Persistence;
/**
* Entity implementation class for Entity: Department
*
*/
@Entity
public class Department implements Serializable {
@Id
@GeneratedValue(strategy = GenerationType.AUTO)
private Long id;
@OneToMany(fetch = FetchType.EAGER)
private List<Employee> employees;
@OneToOne
@JoinColumn(name = "manager", nullable = false)
private Employee manager;
private static final long serialVersionUID = 1L;
public Department() {
super();
}
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public List<Employee> getEmployees() {
return employees;
}
public void setEmployees(List<Employee> employees) {
this.employees = employees;
}
public static void main(String[] args) {
EntityManagerFactory emf = Persistence.createEntityManagerFactory("test-jpa");
EntityManager em = emf.createEntityManager();
Department d = new Department();
Employee manager = new Employee();
manager.setLastName("Doe");
d.setManager(manager);
Employee e1 = new Employee();
e1.setLastName("Doe");
Employee e2 = new Employee();
e2.setLastName("Smith");
em.getTransaction().begin();
em.persist(d);
manager.setDepartment(d);
e1.setDepartment(d);
e2.setDepartment(d);
em.persist(e1);
em.persist(e2);
em.persist(manager);
em.persist(d);
manager.setDepartment(d);
e1.setDepartment(d);
e2.setDepartment(d);
em.merge(manager);
em.merge(e1);
em.merge(e2);
em.getTransaction().commit();
em.clear();
Department fetchedDepartment = em.find(Department.class, d.getId());
System.err.println(fetchedDepartment.getManager().getLastName());
System.err.println(new ArrayList<Employee>(fetchedDepartment.getEmployees()));
}
public Employee getManager() {
return manager;
}
public void setManager(Employee manager) {
this.manager = manager;
}
}
员工类:
package my.jpa.test;
import java.io.Serializable;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.ManyToOne;
import javax.persistence.OneToOne;
/**
* Entity implementation class for Entity: Employee
*
*/
@Entity
public class Employee implements Serializable {
private static final long serialVersionUID = 1L;
@Id
@GeneratedValue(strategy = GenerationType.AUTO)
private Long id;
private String lastName;
@ManyToOne
private Department department;
@OneToOne(mappedBy = "manager")
private Department managedDepartment;
public Employee() {
super();
}
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getLastName() {
return lastName;
}
public void setLastName(String lastName) {
this.lastName = lastName;
}
public Department getDepartment() {
return department;
}
public void setDepartment(Department department) {
this.department = department;
}
public Department getManagedDepartment() {
return managedDepartment;
}
public void setManagedDepartment(Department managedDepartment) {
this.managedDepartment = managedDepartment;
}
@Override
public String toString() {
return "Employee " + getLastName();
}
}
persistence.xml:
<?xml version="1.0" encoding="UTF-8"?>
<persistence version="2.0"
xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd">
<persistence-unit name="test-jpa">
<class>my.jpa.test.Department</class>
<class>my.jpa.test.Employee</class>
<properties>
<property name="javax.persistence.jdbc.driver" value="org.h2.Driver" />
<property name="javax.persistence.jdbc.url" value="jdbc:h2:mem:db1;DB_CLOSE_DELAY=-1;MVCC=TRUE" />
<property name="javax.persistence.jdbc.user" value="sa" />
<property name="javax.persistence.jdbc.password" value="" />
<property name="hibernate.hbm2ddl.auto" value="create-drop" />
<property name="eclipselink.ddl-generation" value="drop-and-create-tables" />
<property name="eclipselink.ddl-generation.output-mode" value="database" />
<property name="eclipselink.logging.level" value="FINE"/>
<property name="eclipselink.logging.parameters" value="true"/>
</properties>
</persistence-unit>
</persistence>
Maven 依赖项:
<dependencies>
<dependency>
<groupId>org.eclipse.persistence</groupId>
<artifactId>eclipselink</artifactId>
<version>2.5.1</version>
</dependency>
<dependency>
<groupId>com.h2database</groupId>
<artifactId>h2</artifactId>
<version>1.3.172</version>
</dependency>
</dependencies>
【问题讨论】:
-
你真的需要 oneToOne 是双向的吗?
-
@Gab,可能不会,但我认为如果我从 Employee 实体中删除它,它不会改变任何东西。通过在那里定义它,我们只增强了 JPA 的元模型,但由于它不强制外键约束,Eclipselink 在插入顺序计算时不会考虑它(据我了解 EL)。
-
只要在关系上使用
CascadeType.PERSIST就可以了。 -
为什么告诉你不要使用flush?如果你想先插入部门,保证插入顺序的唯一方法是持久化部门,然后调用flush,然后修复引用并持久化员工。当 EclipseLink 确定存在循环引用时,它将执行浅插入并在插入后的单独语句中更新 FK,因此大多数数据库的另一个解决方案是将约束检查延迟到事务结束。这样,JPA/EclipseLink 可以按任何顺序插入,并且只有在设置完所有内容后才检查约束。
-
@SvetlinZarev 使用
CascadeType.PERSIST不会解决问题。级联的使用是一种对对象图执行操作的简单快捷方式,而不是对图中的每个对象执行一次。你仍然不知道插入的顺序。
标签: java jpa eclipselink