Hibernate一对一双向关联（注解）详解编程语言

 1 package cqvie.yjq.domain; 
 2  
 3 import java.util.Date; 
 4  
 5 import javax.persistence.Column; 
 6 import javax.persistence.Entity; 
 7 import javax.persistence.GeneratedValue; 
 8 import javax.persistence.Id; 
 9 import javax.persistence.JoinColumn; 
10 import javax.persistence.OneToOne; 
11 import javax.persistence.Table; 
12  
13 import org.hibernate.annotations.GenericGenerator; 
14  
15  
16 @Entity 
17 @Table(name = "id_card", catalog = "test") 
18 public class IdCard implements java.io.Serializable { 
19  
20     private static final long serialVersionUID = -5388108961244621175L; 
21      
22     @Id 
23     @GenericGenerator(name = "generator", strategy = "uuid") 
24     @GeneratedValue(generator = "generator") 
25     @Column(name = "card_id", unique = true, nullable = false) 
26     private String id; 
27     @Column(name = "validate") 
28     private Date validateDte; 
29     @OneToOne 
30     @JoinColumn(name = "per") 
31     private Person person; 
32      
33     public String getId() { 
34         return id; 
35     } 
36     public void setId(String id) { 
37         this.id = id; 
38     } 
39     public Date getValidateDte() { 
40         return validateDte; 
41     } 
42     public void setValidateDte(Date validateDte) { 
43         this.validateDte = validateDte; 
44     } 
45     public Person getPerson() { 
46         return person; 
47     } 
48     public void setPerson(Person person) { 
49         this.person = person; 
50     } 
51      
52 }

 1 package cqvie.yjq.domain; 
 2  
 3 import javax.persistence.Column; 
 4 import javax.persistence.Entity; 
 5 import javax.persistence.GeneratedValue; 
 6 import javax.persistence.Id; 
 7 import javax.persistence.JoinColumn; 
 8 import javax.persistence.OneToOne; 
 9 import javax.persistence.Table; 
10  
11 import org.hibernate.annotations.GenericGenerator; 
12  
13 @Entity 
14 @Table(name = "person", catalog = "test") 
15 public class Person implements java.io.Serializable { 
16  
17     private static final long serialVersionUID = 3860690163559279293L; 
18      
19     @Id 
20     @GenericGenerator(name = "generator", strategy = "uuid") 
21     @GeneratedValue(generator = "generator") 
22     @Column(name = "per_id", unique = true, nullable = false) 
23     private String id; 
24     @Column(name = "name", nullable = false, length = 20) 
25     private String name; 
26     @OneToOne 
27     @JoinColumn(name = "id_c") 
28     private IdCard idCard; 
29      
30      
31     public String getId() { 
32         return id; 
33     } 
34     public void setId(String id) { 
35         this.id = id; 
36     } 
37     public String getName() { 
38         return name; 
39     } 
40     public void setName(String name) { 
41         this.name = name; 
42     } 
43     public IdCard getIdCard() { 
44         return idCard; 
45     } 
46     public void setIdCard(IdCard idCard) { 
47         this.idCard = idCard; 
48     } 
49      
50 }

 1 package cqvie.yjq.View; 
 2  
 3 import java.util.Date; 
 4  
 5 import org.hibernate.Session; 
 6 import org.hibernate.Transaction; 
 7 import org.hibernate.cfg.AnnotationConfiguration; 
 8 import org.hibernate.cfg.Configuration; 
 9 import org.hibernate.tool.hbm2ddl.SchemaExport; 
10  
11 import cqvie.yjq.Util.HibernataUtil; 
12 import cqvie.yjq.domain.IdCard; 
13 import cqvie.yjq.domain.Person; 
14  
15 public class Test { 
16  
17     public static void main(String[] args) { 
18      
19         //调用建表语句 
20         exportDDL(); 
21         //添加一组person 
22         Session session = null; 
23         Transaction tx = null; 
24         try { 
25             session = HibernataUtil.getCurrentSession(); 
26             tx = session.beginTransaction(); 
27              
28             Person p1 = new Person(); 
29             p1.setName("张三"); 
30              
31             IdCard idCard = new IdCard(); 
32             idCard.setValidateDte(new Date()); 
33             p1.setIdCard(idCard); 
34             idCard.setPerson(p1); 
35             session.save(p1); 
36             session.save(idCard); 
37              
38             tx.commit(); 
39         } catch (Exception e) { 
40             if(tx != null) { 
41                 tx.rollback(); 
42             } 
43         } finally { 
44             if(session != null && session.isOpen()) { 
45                 session.close(); 
46             } 
47         } 
48          
49     } 
50  
51     //建表语句 
52     public static void exportDDL() {   
53         Configuration configuration = new AnnotationConfiguration().configure();    
54         SchemaExport sexport = new SchemaExport(configuration);   
55         sexport.setFormat(true);//格式化输出   
56           sexport.setDelimiter(";");      //每句sql都以;结尾  不然导入sql的时候会出现错误   
57         sexport.setOutputFile("D://auto.sql");   
58         sexport.create(true, true);   
59     }   
60 }

 1 <?xml version='1.0' encoding='UTF-8'?> 
 2 <!DOCTYPE hibernate-configuration PUBLIC 
 3           "-//Hibernate/Hibernate Configuration DTD 3.0//EN" 
 4           "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd"> 
 5  
 6 <!-- Generated by MyEclipse Hibernate Tools.                   --> 
 7 <hibernate-configuration> 
 8  
 9 <session-factory> 
10     <property name="dialect"> 
11         org.hibernate.dialect.MySQLDialect 
12     </property> 
13     <property name="connection.url"> 
14         jdbc:mysql://localhost:3306/test 
15     </property> 
16     <property name="connection.username">root</property> 
17     <property name="connection.password">123</property> 
18     <property name="connection.driver_class"> 
19         com.mysql.jdbc.Driver 
20     </property> 
21     <property name="myeclipse.connection.profile">MySQL</property> 
22     <property name="show_sql">true</property> 
23     <!-- 格式化显示SQL --> 
24     <property name="format_sql">true</property> 
25  
26     <property name="current_session_context_class">thread</property> 
27     <!-- 让hibernate自动创建表  update:如果没有表则创建，有表则更新 --> 
28     <property name="hbm2ddl.auto">create</property> 
29     <mapping class="cqvie.yjq.domain.IdCard" /> 
30     <mapping class="cqvie.yjq.domain.Person" /> 
31 </session-factory> 
32  
33 </hibernate-configuration>

  1 package cqvie.yjq.Util; 
  2  
  3 import java.util.List; 
  4  
  5 import org.hibernate.Query; 
  6 import org.hibernate.Session; 
  7 import org.hibernate.SessionFactory; 
  8 import org.hibernate.Transaction; 
  9 import org.hibernate.cfg.AnnotationConfiguration; 
 10  
 11 final public class HibernataUtil { 
 12  
 13     private static SessionFactory sessionFactory = null; 
 14     //使用线程局部模式 
 15     private static ThreadLocal<Session> threadLocal = new ThreadLocal<Session>(); 
 16     private HibernataUtil() {}; 
 17     static { 
 18         sessionFactory = new AnnotationConfiguration().configure().buildSessionFactory(); 
 19     } 
 20     //获取全新的session 
 21     public static Session openSession() { 
 22         return sessionFactory.openSession(); 
 23     } 
 24     //获取和线程关联的session 
 25     public static Session getCurrentSession() { 
 26         Session session = threadLocal.get(); 
 27         //判断是否得到 
 28         if(session == null) { 
 29             session = sessionFactory.openSession(); 
 30             //把session对象设置到threadLocal，相当于已经和线程绑定 
 31             threadLocal.set(session); 
 32         } 
 33         return session; 
 34     } 
 35      
 36     //提供一个统一的修改和删除方法（批量） 
 37     public static void executeUpdate(String hql, String[] parameters) { 
 38         Session s = null; 
 39         Transaction ts = null; 
 40         try { 
 41             s = openSession(); 
 42             ts = s.beginTransaction(); 
 43             Query query = s.createQuery(hql); 
 44             //先判断是否有参数要绑定 
 45             if(parameters != null && parameters.length > 0) { 
 46                 for(int i=0;i<parameters.length;i++) { 
 47                     query.setString(i, parameters[i]); 
 48                 } 
 49             } 
 50             query.executeUpdate(); 
 51             ts.commit(); 
 52         } catch(Exception e) { 
 53             e.printStackTrace(); 
 54             throw new RuntimeException(); 
 55         } finally { 
 56             if(s != null && s.isOpen()) { 
 57                 s.close(); 
 58             } 
 59         } 
 60     } 
 61      
 62     //提供一个统一的添加方法 
 63     public static void sava(Object obj) { 
 64         Session s = null; 
 65         Transaction ts = null; 
 66         try { 
 67             s = openSession(); 
 68             ts = s.beginTransaction(); 
 69             s.save(obj); 
 70             ts.commit(); 
 71         } catch (Exception e) { 
 72             if(ts != null) { 
 73                 ts.rollback(); 
 74             } 
 75             throw new RuntimeException(); 
 76         } finally { 
 77             if(s != null && s.isOpen()) { 
 78                 s.close(); 
 79             } 
 80         } 
 81     } 
 82      
 83     //提供一个统一的查询方法（分页） 
 84     @SuppressWarnings("unchecked") 
 85     public static List executeQueryByPage(String hql, String[] parameters, int pageSize, int pageNow) { 
 86         Session s = null; 
 87         List list = null; 
 88         try { 
 89             s = openSession(); 
 90             Query query = s.createQuery(hql); 
 91             //先判断是否有参数要绑定 
 92             if(parameters != null && parameters.length > 0) { 
 93                 for(int i=0;i<parameters.length;i++) { 
 94                     query.setString(i, parameters[i]); 
 95                 } 
 96             } 
 97             query.setFirstResult((pageNow-1)*pageSize).setMaxResults(pageSize); 
 98             list = query.list(); 
 99         } catch(Exception e) { 
100             e.printStackTrace(); 
101             throw new RuntimeException(); 
102         } finally { 
103             if(s != null && s.isOpen()) { 
104                 s.close(); 
105             } 
106         } 
107         return list; 
108     } 
109      
110      
111     //提供一个统一的查询方法 hql 形式 from 类 where 条件=? 
112     @SuppressWarnings("unchecked") 
113     public List executeQuery(String hql, String[] parameters) { 
114         Session s = null; 
115         List list = null; 
116         try { 
117             s = openSession(); 
118             Query query = s.createQuery(hql); 
119             //先判断是否有参数要绑定 
120             if(parameters != null && parameters.length > 0) { 
121                 for(int i=0;i<parameters.length;i++) { 
122                     query.setString(i, parameters[i]); 
123                 } 
124             } 
125             list = query.list(); 
126         } catch(Exception e) { 
127             e.printStackTrace(); 
128             throw new RuntimeException(); 
129         } finally { 
130             if(s != null && s.isOpen()) { 
131                 s.close(); 
132             } 
133         } 
134         return list; 
135     } 
136 }