新建数据库User：

  1. CREATE TABLE user (
  2.     name VARCHAR(100) NOT NULL,
  3.     phone VARCHAR(50) NOT NULL,
  4.     age INT,
  5.     PRIMARY KEY(name, phone)
  6. );

现将name和phone定义成复合主键。分别使用2种方法如下：

方法1.复合主键字段直接包含在PO类中。

User.java（需要实现Serializable接口，并定义equals()和hashCode()方法）

  1. package com.hb3.pack_03.model;

  3. import java.io.Serializable;
  4. import org.apache.commons.lang.builder.EqualsBuilder;
  5. import org.apache.commons.lang.builder.HashCodeBuilder;

  7. public class User implements Serializable {

  9.     private static final long serialVersionUID = -8377583111386512407L;

  11.     private String name;
  12.     private String phone;
  13.     private Integer age;
  14.     
  15.     public User() {
  16.     }

  18.     public Integer getAge() {
  19.         return age;
  20.     }

  22.     public void setAge(Integer age) {
  23.         this.age = age;
  24.     }

  26.     public String getName() {
  27.         return name;
  28.     }

  30.     public void setName(String name) {
  31.         this.name = name;
  32.     }

  34.     public String getPhone() {
  35.         return phone;
  36.     }

  38.     public void setPhone(String phone) {
  39.         this.phone = phone;
  40.     }
  41.     
  42.     public boolean equals(Object obj) {
  43.         if(obj == this) {
  44.             return true;
  45.         }
  46.         
  47.         if(!(obj instanceof User)) {
  48.             return false;
  49.         }
  50.         
  51.         User user = (User) obj;
  52.         return new EqualsBuilder()
  53.                  .append(this.name, user.getName())
  54.                  .append(this.phone, user.getPhone())
  55.                  .isEquals();
  56.     }
  57.     
  58.     public int hashCode() {
  59.         return new HashCodeBuilder()
  60.                  .append(this.name)
  61.                  .append(this.phone)
  62.                  .toHashCode();
  63.     }
  64. }

在定义equals和hashCode方法时使用了apache的common-lang包。

User.hbm.xml文件：

  1. <?xml version="1.0" encoding="UTF-8"?>

  3. <!DOCTYPE hibernate-mapping PUBLIC
  4.     "-//Hibernate/Hibernate Mapping DTD 3.0//EN" 
  5.     "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">

  7. <hibernate-mapping> 

  9.     <class name="com.hb3.pack_03.model.User" table="user">
  10.     
  11.         <composite-id>
  12.         
  13.             <key-property name="name" 
  14.                           column="name" 
  15.                           type="java.lang.String"/>
  16.             <key-property name="phone" 
  17.                           column="phone" 
  18.                           type="java.lang.String"/>
  19.         </composite-id>

  21.         <property name="age" column="age" type="java.lang.Integer"/>
  22.     
  23.     </class> 
  24.     
  25. </hibernate-mapping>

hibernate.cfg.xml中修改：

......

<mapping resource="com/hb3/pack_03/model/User.hbm.xml" />

......

 

测试代码如下：

  1. package com.hb3.pack_03;

  3. import org.hibernate.Session;
  4. import org.hibernate.SessionFactory;
  5. import org.hibernate.Transaction;
  6. import org.hibernate.cfg.Configuration;

  8. import com.hb3.pack_03.model.User;

  10. public class BusinessService {

  12.     public static void main(String[] args) {
  13.         
  14.         Configuration config = new Configuration().configure();
  15.         SessionFactory sessionFactory = config.buildSessionFactory();      
  16.         Session session = sessionFactory.openSession();

  18.         User user = new User();
  19.         user.setName("shenbin");
  20.         user.setPhone("0970123456");
  21.         user.setAge(28);
  22.         Transaction tx = session.beginTransaction();
  23.         session.save(user);
  24.         tx.commit();
  25.         
  26.         user = (User) session.load(User.class, user);
  27.                 
  28.         System.out.println(user.getAge() + "\t" +  user.getName() + "\t" + user.getPhone());

  30.         session.close();
  31.         sessionFactory.close();
  32.     }
  33. }

请注意：在实际测试过程中，如果数据库已经有数据存在，则不需要上面的黑题部分向数据库追加数据。

另外还请留意的是，光有session.save(user);而没有tx.commit();的话,数据不会被持久到数据库中的。

 

方法2.复合主键字段独立到另一个类中。

UserPK.java(需要实现Serializable接口，并定义equals()和hashCode()方法)

  1. package com.hb3.pack_04.model;

  3. import java.io.Serializable;

  5. import org.apache.commons.lang.builder.EqualsBuilder;
  6. import org.apache.commons.lang.builder.HashCodeBuilder;

  8. public class UserPK implements Serializable {

  10.     private static final long serialVersionUID = -2457999265373664790L;

  12.     private String name;
  13.     private String phone;

  15.     public String getName() {
  16.         return name;
  17.     }
  18.     public void setName(String name) {
  19.         this.name = name;
  20.     }
  21.     public String getPhone() {
  22.         return phone;
  23.     }
  24.     public void setPhone(String phone) {
  25.         this.phone = phone;
  26.     }
  27.     public boolean equals(Object obj) {
  28.         if(obj == this) {
  29.             return true;
  30.         }
  31.         
  32.         if(!(obj instanceof User)) {
  33.             return false;
  34.         }
  35.         
  36.         UserPK pk = (UserPK) obj;
  37.         return new EqualsBuilder()
  38.                  .append(this.name, pk.getName())
  39.                  .append(this.phone, pk.getPhone())
  40.                  .isEquals();
  41.     }
  42.     
  43.     public int hashCode() {
  44.         return new HashCodeBuilder()
  45.                  .append(this.name)
  46.                  .append(this.phone)
  47.                  .toHashCode();
  48.     }
  49. }

User.java

  1. package com.hb3.pack_04.model;

  3. import java.io.Serializable;

  5. public class User implements Serializable {

  7.     private static final long serialVersionUID = -8630481462628539996L;

  9.     private UserPK userPK;
  10.     private Integer age;
  11.     
  12.     public User() {
  13.     }

  15.     public UserPK getUserPK() {
  16.         return userPK;
  17.     }
  18.     public void setUserPK(UserPK userPK) {
  19.         this.userPK = userPK;
  20.     }
  21.     public Integer getAge() {
  22.         return age;
  23.     }
  24.     public void setAge(Integer age) {
  25.         this.age = age;
  26.     }
  27. }

User.hbm.xml文件：

  1. <?xml version="1.0" encoding="UTF-8"?>

  3. <!DOCTYPE hibernate-mapping PUBLIC
  4.     "-//Hibernate/Hibernate Mapping DTD 3.0//EN" 
  5.     "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">

  7. <hibernate-mapping> 

  9.     <class name="com.hb3.pack_04.model.User" table="user">
  10.     
  11.         <composite-id name="userPK"
  12.                       class="com.hb3.pack_04.model.UserPK"
  13.                       unsaved-value="any">
  14.             <key-property name="name" 
  15.                           column="name" 
  16.                           type="java.lang.String"/>
  17.             <key-property name="phone" 
  18.                           column="phone" 
  19.                           type="java.lang.String"/>
  20.         </composite-id>
  21.         
  22.         <property name="age" column="age" type="java.lang.Integer"/>
  23.     
  24.     </class> 

  26. </hibernate-mapping>

hibernate.cfg.xml中修改：

......

<mapping resource="com/hb3/pack_04/model/User.hbm.xml" />

......

 

测试代码如下：

  1. package com.hb3.pack_04;

  3. import org.hibernate.Session;
  4. import org.hibernate.SessionFactory;
  5. import org.hibernate.cfg.Configuration;

  7. import com.hb3.pack_04.model.User;
  8. import com.hb3.pack_04.model.UserPK;

  10. public class BusinessService {

  12.     public static void main(String[] args) {
  13.         
  14.         Configuration config = new Configuration().configure();
  15.         SessionFactory sessionFactory = config.buildSessionFactory();      
  16.         Session session = sessionFactory.openSession();

  18.         UserPK pk = new UserPK();
  19.         pk.setName("shenbin");
  20.         pk.setPhone("0970123456");
  21.                
  22.         User user = (User) session.load(User.class, pk);
  23.                
  24.         System.out.println(user.getAge() + 
  25.                     "\t" + user.getUserPK().getName() + 
  26.                     "\t" + user.getUserPK().getPhone());

  28.         session.close();
  29.         sessionFactory.close();
  30.     }
  31. }

ExtJS教程- Hibernate教程-Struts2 教程-Lucene教程