Mega Code Archive

 
Categories / Java Tutorial / JPA
 

One To Many Join Table Setup

File: Phone.java import javax.persistence.Column; import javax.persistence.Entity; import javax.persistence.GeneratedValue; import javax.persistence.GenerationType; import javax.persistence.Id; @Entity public class Phone {     @Id @GeneratedValue(strategy=GenerationType.IDENTITY)     private int id;     @Column(name="NUM")     private String number;     private String type;          public int getId() {         return id;     }          public void setId(int id) {         this.id = id;     }          public String getNumber() {         return number;     }          public void setNumber(String phoneNo) {         this.number = phoneNo;     }          public String getType() {         return type;     }          public void setType(String phoneType) {         this.type = phoneType;     }     public String toString() {         return "Phone id: " + getId() +                 ", no: " + getNumber() +                ", type: " + getType();     } } File: Student.java import java.util.ArrayList; import java.util.Collection; import javax.persistence.Entity; import javax.persistence.GeneratedValue; import javax.persistence.GenerationType; import javax.persistence.Id; import javax.persistence.JoinColumn; import javax.persistence.JoinTable; import javax.persistence.OneToMany; @Entity public class Student {     @Id @GeneratedValue(strategy=GenerationType.IDENTITY)     private int id;     private String name;          @OneToMany     @JoinTable(name="EMP_PHONE",            joinColumns=@JoinColumn(name="EMP_ID"),           inverseJoinColumns=@JoinColumn(name="PHONE_ID"))     private Collection<Phone> phones;     public Student() {         phones = new ArrayList<Phone>();     }     public int getId() {         return id;     }          public void setId(int id) {         this.id = id;     }          public String getName() {         return name;     }          public void setName(String name) {         this.name = name;     }     public void addPhone(Phone phone) {         if (!getPhones().contains(phone)) {             getPhones().add(phone);         }     }          public Collection<Phone> getPhones() {         return phones;     }          public String toString() {         return "Student id: " + getId() + " name: " + getName() +                 " with " + getPhones().size() + " phones";     } } File: Main.java import java.util.List; import javax.persistence.EntityManager; import javax.persistence.EntityManagerFactory; import javax.persistence.Persistence; import javax.persistence.Query; public class Main {   static EntityManagerFactory emf = Persistence.createEntityManagerFactory("JPAService");   static EntityManager em = emf.createEntityManager();   public static void main(String[] a) throws Exception {     em.getTransaction().begin();          Student student = new Student();     student.setName("Joe");     em.persist(student);          Phone phone = new Phone();     phone.setNumber("123123123123");     em.persist(phone);          em.flush();          Student emp = em.find(Student.class, 1);     phone = em.find(Phone.class, 1);     emp.addPhone(phone);          Query query = em.createQuery("SELECT e FROM Student e");     List<Student> list = (List<Student>) query.getResultList();     System.out.println(list);          query = em.createQuery("SELECT d FROM Phone d");     List<Phone> dList = (List<Phone>) query.getResultList();     System.out.println(dList);          em.getTransaction().commit();     em.close();     emf.close();          Helper.checkData();   } } File: Helper.java import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.Statement; public class Helper {   public static void checkData() throws Exception {     Class.forName("org.hsqldb.jdbcDriver");     Connection conn = DriverManager.getConnection("jdbc:hsqldb:data/tutorial", "sa", "");     Statement st = conn.createStatement();     ResultSet mrs = conn.getMetaData().getTables(null, null, null, new String[] { "TABLE" });     while (mrs.next()) {       String tableName = mrs.getString(3);       System.out.println("\n\n\n\nTable Name: "+ tableName);       ResultSet rs = st.executeQuery("select * from " + tableName);       ResultSetMetaData metadata = rs.getMetaData();       while (rs.next()) {         System.out.println(" Row:");         for (int i = 0; i < metadata.getColumnCount(); i++) {           System.out.println("    Column Name: "+ metadata.getColumnLabel(i + 1)+ ",  ");           System.out.println("    Column Type: "+ metadata.getColumnTypeName(i + 1)+ ":  ");           Object value = rs.getObject(i + 1);           System.out.println("    Column Value: "+value+"\n");         }       }     }   } } File: persistence.xml <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" version="1.0">   <persistence-unit name="JPAService" transaction-type="RESOURCE_LOCAL">     <properties>       <property name="hibernate.dialect" value="org.hibernate.dialect.HSQLDialect"/>       <property name="hibernate.hbm2ddl.auto" value="update"/>       <property name="hibernate.connection.driver_class" value="org.hsqldb.jdbcDriver"/>       <property name="hibernate.connection.username" value="sa"/>       <property name="hibernate.connection.password" value=""/>       <property name="hibernate.connection.url" value="jdbc:hsqldb:data/tutorial"/>     </properties>   </persistence-unit> </persistence>