Ich probiere gerade eine Many-to-many-Beziehung in JPA aus. Ich habe die Tabellen "tblcourse" und "tblStudent" erstellt, ein Student kann sich für viele Kurse anmelden,
create table tblcourse(
id integer primary key,
name varchar(100),
duration integer
);
create table tblcourseStudent(
studentid integer references tblstudent(studentId),
courseId integer references tblcourse(id),
constraint pk_composit_cs primary key(studentid,courseId)
)
Create table tblStudent(
studentId integer primary key,
……..
….
);
Die JPA-Darstellung der obigen Beziehung lautet wie folgt, Dies ist der Code für StudentEntity.java,
@Entity
@Table(name="TBLSTUDENT")
public class StudentEntity implements Serializable{
private static final long serialVersionUID = 100034222342L;
@Id
@Column(name="STUDENTID")
private Integer studentId;
@Column(name="STUDENTNAME")
private String studentName;
@Column(name="CONTACTNO")
private String contactNumber;
@Embedded
private StudentAddress address;
@ManyToOne(fetch=FetchType.LAZY)
@JoinColumn(name="DEPTID")
private DeptEntity deptEntity;
@ManyToMany(fetch=FetchType.LAZY)
@JoinTable(name="tblcourseStudent",
joinColumns=@JoinColumn(name="studentid"),
inverseJoinColumns=@JoinColumn(name="courseId"))
private List<CourseEntity> courseList;
....
.....
.....
}
Dies ist der Code für CourseEntity.java,
@Entity
@Table(name="TBLCOURSE")
public class CourseEntity implements Serializable{
public CourseEntity(){
}
public CourseEntity(Integer courseId,String courseName,Integer courseDuration){
this.courseId = courseId;
this.courseName = courseName;
this.courseDuration = courseDuration;
}
/**
*
*/
private static final long serialVersionUID = -2192479237310864341L;
@Id
@Column(name="ID")
private Integer courseId;
@Column(name="NAME")
private String courseName;
@Column(name="DURATION")
private Integer courseDuration;
@ManyToMany(fetch=FetchType.LAZY)
@JoinTable(name="tblcourseStudent",
joinColumns=@JoinColumn(name="courseId"),
inverseJoinColumns=@JoinColumn(name="studentid"))
private List<StudentEntity> studentList;
.........
}
Wenn ich nun versuche, Kurse über StudentEntity.java einzufügen, lauten die im Backend abgefeuerten SQL-Abfragen
delete
from
tblcourseStudent
where
studentid=?
insert
into
tblcourseStudent
(studentid, courseId)
values
(?, ?)
insert
into
tblcourseStudent
(studentid, courseId)
values
(?, ?)
Und wenn ich versuche, Studenten über CourseEntity.java einzufügen, werden die folgenden SQL-Abfragen ausgelöst,
delete
from
tblcourseStudent
where
courseId=?
insert
into
tblcourseStudent
(courseId, studentid)
values
(?, ?)
In beiden Fällen werden die Datensätze gelöscht und dann wird die neue Zuordnung eingefügt. Wenn ich also Kurse für einen Studenten einfüge, werden zunächst alle vorherigen Kurse für den Studenten aus der dritten Tabelle gelöscht und die neuen Kurse eingegeben,
Meine Frage ist also, wenn ich die alten Kurse nicht löschen und die neuen Kurse für den Studenten hinzufügen möchte, wie kann ich das erreichen, d.h. ich möchte die alte Beziehung beibehalten,
Ob ich dies programmatisch erreichen muss, oder ob ich die Annotation ändern muss, Ich warte auf die Antwort
Dieser Code wurde in StudentServiceBean.java geschrieben und die Methode "mapStudentToCourses" wird aufgerufen, wenn wir einen einzelnen Studenten mehreren Kursen zuordnen
@Stateless
@TransactionManagement(TransactionManagementType.CONTAINER)
public class StudentServiceBean implements StudentService{
@PersistenceContext(unitName="forPractise")
private EntityManager entityMgr;
@Resource
private SessionContext sessionContext;
@EJB
private DeptService deptService;
..........
......
...
@Override
@TransactionAttribute(TransactionAttributeType.REQUIRED)
public void mapStudentToCourses(Integer studentId,String courseIdList) throws Exception{
List<CourseEntity> courseList = null;
StudentEntity studentEntity = null;
TypedQuery<CourseEntity> courseQuery = null;
String query = "select c from CourseEntity c where c.courseId in ("+courseIdList+")";
try{
courseQuery = entityMgr.createQuery(query,CourseEntity.class);
courseList = courseQuery.getResultList();
studentEntity = entityMgr.find(StudentEntity.class, studentId);
studentEntity.setCourseList(courseList);
entityMgr.merge(studentEntity);
}catch(Exception e){
sessionContext.setRollbackOnly();
throw e;
}
}
So sieht der Code aus, wenn ein Kurs mehreren Studenten zugeordnet ist: CourseServiceBean.java
@Stateless
@TransactionManagement(TransactionManagementType.CONTAINER)
public class CourseServiceBean implements CourseService{
@PersistenceContext(name="forPractise")
private EntityManager em;
@Resource
private SessionContext sessionCtx;
private Map<Integer, String> durationCode = null;
@EJB
private StudentService studentService;
........
......
...
@Override
@TransactionAttribute(TransactionAttributeType.REQUIRED)
public void mapCourseToStudents(Integer courseId,String studentIdList) throws Exception{
List<StudentEntity> studentEntityList = null;
TypedQuery<StudentEntity> studentQuery = null;
String query = "select s from StudentEntity s where s.studentId IN ("+studentIdList+")";
CourseEntity courseEntity = null;
try{
studentQuery = em.createQuery(query, StudentEntity.class);
studentEntityList = studentQuery.getResultList();
courseEntity = em.find(CourseEntity.class,courseId);
courseEntity.setStudentList(studentEntityList);
em.merge(courseEntity);
}catch(Exception e){
sessionCtx.setRollbackOnly();
throw e;
}
}
}
diese meine persistence.xml-Datei,
<?xml version="1.0" encoding="UTF-8"?>
<persistence 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"
version="2.0">
<persistence-unit name="forPractise" transaction-type="JTA">
<provider>org.hibernate.ejb.HibernatePersistence</provider>
<jta-data-source>jdbc/app</jta-data-source>
<class>com.entity.StudentEntity</class>
<class>com.entity.DeptEntity</class>
<class>com.entity.CourseEntity</class>
<properties>
<property name="hibernate.dialect" value="org.hibernate.dialect.DerbyDialect" />
<property name="hibernate.show_sql" value="true" />
<property name="hibernate.format_sql" value="true" />
</properties>
</persistence-unit>
</persistence>
Warten auf die Antwort....