Hibernate關聯關系映射之一對一（主鍵關聯）

 

在業務成的域模型中，類和類之間最普遍的關系就是關聯關系，而關聯也是有方向的。

就以例子來說明：一個人對應一張身份證。對其進行增刪改。

對於人在數據創建表的時候，我們就給他兩個字段，一個是id號，一個就是名字。

那么對於身份證也就是兩個字段，一個對應於一個人相同的id號，一個就是身份證碼。

1 那么來創建數據庫表：

 人為主表，身份證為從表。

create table person(
id bigint primary key auto_increment,
userName varchar(20)
);
 
create table card(
id bigint primary key,
cardNo varchar(18)
);

創建實體類的時候，人要引用身份證卡的信息，同樣身份證卡也要引用人這個類。

2 那么來創建實體類：

人：

package com.cy.beans;

import java.io.Serializable;

public class Person implements Serializable {

    private static final long serialVersionUID = 1L;
    private long id;
    private String userName;
    private Card card;// 卡 一對一關聯

    public void person() {

    }

    public long getId() {
        return id;
    }

    public void setId(long id) {
        this.id = id;
    }

    public String getUserName() {
        return userName;
    }

    public void setUserName(String userName) {
        this.userName = userName;
    }

    public Card getCard() {
        return card;
    }

    public void setCard(Card card) {
        this.card = card;
    }

    @Override
    public String toString() {
        return "Person [id=" + id + ", userName=" + userName + ", card=" + card
                + "]";
    }

}

 

身份證：

package com.cy.beans;

import java.io.Serializable;

public class Card implements Serializable{

    
    private static final long serialVersionUID = 1L;
    
    private long id;
    private String cardNo;
    private Person person;//人  一對一關聯
    
    public Card(){
        
    }
    public long getId() {
        return id;
    }
    public void setId(long id) {
        this.id = id;
    }
    public String getCardNo() {
        return cardNo;
    }
    public void setCardNo(String cardNo) {
        this.cardNo = cardNo;
    }
    public Person getPerson() {
        return person;
    }
    public void setPerson(Person person) {
        this.person = person;
    }
    @Override
    public String toString() {
        return "Card [id=" + id + ", cardNo=" + cardNo + ", person=" + person
                + "]";
    }
    

}

 

 現在創建映射文件

Person.hbm.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE hibernate-mapping PUBLIC 
    "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
    "http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd">
    
    <hibernate-mapping>
    
    <class name="com.cy.beans.Person" table="person" catalog="j2ee">   <!-- catalog數據庫 -->
    
              <id name="id" type="java.lang.Long"><!-- 此行的ID，為對象的屬性ID -->
                  <column name="id"></column><!-- 此行的ID，為表字段ID -->
                  <generator class="increment"></generator><!-- 給id指定生成策略 -->
              </id>
    
              <property name="userName" type="java.lang.String">
                 <column name="userName"></column>
              </property>
              
         <!--站在主對象的一方來設置級聯關系 -->
         <!-- cascade定義的是關系兩端對象到對象的級聯關系,cascade有四個取值，all，none，save-update，delete
                all : 所有情況下均進行關聯操作。 
                none：所有情況下均不進行關聯操作。這是默認值。 
                save-update:在執行save/update/saveOrUpdate時進行關聯操作。 
                delete：在執行delete時進行關聯操作。 -->
        <one-to-one name="card" class="com.cy.beans.Card" cascade="all"></one-to-one>
  
    
    </class>
     
    </hibernate-mapping>

 

Card.hbm.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE hibernate-mapping PUBLIC 
    "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
    "http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd">
    
    <hibernate-mapping>
    <class name="com.cy.beans.Card" table="card" catalog="j2ee">   <!-- catalog數據庫 -->
              <id name="id" type="java.lang.Long"><!-- 此行的ID，為對象的屬性ID -->
                 <column name="id"></column><!-- 此行的ID，為表字段ID -->
                   <generator class="foreign"><!-- foreign主鍵生成器 -->
                       <param name="property">person</param><!--類屬性  -->
                   </generator>
              </id>
    
              <property name="cardNo" type="java.lang.String">
                 <column name="cardNo"></column>
              </property>
         <!--站在從對象的一方來設置交出約束  -->
         <!-- name:一對一節點  ，constrained： 約束（必須為true） -->
         <one-to-one name="person"  class="com.cy.beans.Person" constrained="true"></one-to-one>
  
    </class>
    </hibernate-mapping>

 在hibernate.cfg.xml里添加對象xml文件：

1         <mapping resource="com/cy/xmls/Person.hbm.xml"/> 
        <mapping resource="com/cy/xmls/Card.hbm.xml"/> 

 工具類：

package com.cy.tools;

import org.hibernate.SessionFactory;
import org.hibernate.boot.registry.StandardServiceRegistryBuilder;
import org.hibernate.cfg.Configuration;
import org.hibernate.service.ServiceRegistry;

/**
 * session工廠的工具類
 * @author acer
 *
 */

public class HibernateUtils {
    
    private static Configuration cfg;
    private static SessionFactory sessionFactory;
    private static ServiceRegistry serviceRegistry;
    
    static{
        
        cfg = new Configuration().configure();
        serviceRegistry = new StandardServiceRegistryBuilder().applySettings(cfg.getProperties()).build();
        sessionFactory = cfg.buildSessionFactory(serviceRegistry);
    
    }
    
    public static SessionFactory getSessionFactory(){
        return sessionFactory;
    }
         
    

}

 

IPersonDao.java接口，定義方法：

package com.cy.dao;

import java.io.Serializable;

import com.cy.beans.Person;

public interface IPersonDao {
    /**
     * 添加
     * @param p
     */
    public void savePerson(Person p);
    /**
     * 修改
     * @param p
     */
    public void updatePerson(Person p);
    /**
     * 刪除
     * @param p
     */
    public void deletePerson(Person p);
    /**
     * 根據id查詢數據
     * @param cls
     * @param pk
     * @return
     */
    public Person getPerson(Class<?> cls,Serializable pk);
    
    public void findPerson(Person p);

}

 

寫接口實現：PersonDaoImpl.java

package com.cy.dao.impl;

import java.io.Serializable;

import org.hibernate.Session;
import org.hibernate.Transaction;

import com.cy.beans.Person;
import com.cy.dao.IPersonDao;
import com.cy.tools.HibernateUtils;

public class PersonDaoImpl implements IPersonDao {

    @Override
    public void savePerson(Person p) {
        //獲得Session
        Session session=null;
        Transaction transaction=null;
        
        try {
            session=HibernateUtils.getSessionFactory().openSession();//
            transaction=session.beginTransaction();//開啟事務
            session.save(p);//添加
            transaction.commit();//提交事務
        } catch (Exception e) {
            e.printStackTrace();
            transaction.rollback();//回滾事務
        }finally{
            session.close();//關閉session
        }

    }

    @Override
    public void updatePerson(Person p) {
        Session session=null;
        Transaction transaction=null;
        
        try {
            session=HibernateUtils.getSessionFactory().openSession();
            transaction=session.beginTransaction();
            session.update(p);//修改
            transaction.commit();
        } catch (Exception e) {
            e.printStackTrace();
            transaction.rollback();
        }finally{
            session.close();
        }

    }

    @Override
    public Person getPerson(Class<?> cls, Serializable pk) {
        Session session=null;
        Transaction transaction=null;
        Person    person=null;
        try {
            session=HibernateUtils.getSessionFactory().openSession();
            transaction=session.beginTransaction();
            person=(Person) session.get(cls, pk);//根據id查詢。pk這里指的就是id
            transaction.commit();
            
        } catch (Exception e) {
            e.printStackTrace();
            transaction.rollback();
        }finally{
            session.close();
        }

        return person;
    }
    @Override
    public void deletePerson(Person p) {
        Session session=null;
        Transaction transaction=null;
        
        try {
            session=HibernateUtils.getSessionFactory().openSession();
            transaction=session.beginTransaction();
            session.delete(p);//刪除
            transaction.commit();
        } catch (Exception e) {
            e.printStackTrace();
            transaction.rollback();
        }finally{
            session.close();
        }

    }


    @Override
    public void findPerson(Person p) {

    }

}

 寫IPersonServer.java接口

package com.cy.server;

import java.io.Serializable;

import com.cy.beans.Person;

public interface IPersonServer {
    /**
     * 添加
     * @param p
     */
    public void savePerson(Person p);
    /**
     * 修改
     * @param p
     */
    public void updatePerson(Person p);
    /**
     * 刪除
     * @param p
     */
    public void deletePerson(Long id);
    /**
     * 根據id查詢
     * @param cls
     * @param pk
     * @return
     */
    public Person getPerson(Class<?> cls,Serializable pk);
    
    public void findPerson(Person p);
}

 

寫PersonServerImpl.java實現；

package com.cy.server.impl;

import java.io.Serializable;

import com.cy.beans.Person;
import com.cy.dao.IPersonDao;
import com.cy.dao.impl.PersonDaoImpl;
import com.cy.server.IPersonServer;

public class PersonServerImpl implements IPersonServer {
    IPersonDao dao = new PersonDaoImpl();

    @Override
    public void savePerson(Person p) {
        dao.savePerson(p);

    }

    @Override
    public void updatePerson(Person p) {
        dao.updatePerson(p);
    }

    @Override
    public void deletePerson(Long id) {
        Person p = dao.getPerson(Person.class, id);
        if (p != null) {
            dao.deletePerson(p);
        }

    }

    @Override
    public Person getPerson(Class<?> cls, Serializable pk) {

        return dao.getPerson(cls, pk);
    }

    @Override
    public void findPerson(Person p) {

    }

}

 

 寫個PersonAction測試；

package com.cy.action;

import com.cy.beans.Card;
import com.cy.beans.Person;
import com.cy.server.IPersonServer;
import com.cy.server.impl.PersonServerImpl;

public class PersonAction {
    public static void main(String[] args) {
        
//        savePerson();    
//        updatePerson();
          deletePerson();
    }

    private static void deletePerson() {
        IPersonServer ps=new PersonServerImpl();
        ps.deletePerson(Long.valueOf(1));
        
        
    }

    private static void updatePerson() {
        IPersonServer ps=new PersonServerImpl();
        Person p=ps.getPerson(Person.class, Long.valueOf(1));
        p.setUserName("小紅");
        ps.updatePerson(p);
        /*Hibernate: //這些hibernate所執行語句    修查詢  后修改
            select
                person0_.id as id1_1_0_,
                person0_.userName as userName2_1_0_,
                card1_.id as id1_0_1_,
                card1_.cardNo as cardNo2_0_1_ 
            from
                j2ee.person person0_ 
            left outer join
                j2ee.card card1_ 
                    on person0_.id=card1_.id 
            where
                person0_.id=?
        Hibernate: 
            update
                j2ee.person 
            set
                userName=? 
            where
                id=?
        Hibernate: 
            update
                j2ee.card 
            set
                cardNo=? 
            where
                id=?
*/
        
        
    }

    private static void savePerson() {
        IPersonServer ps=new PersonServerImpl();
        Person p=new Person();
        p.setUserName("小明");        
        Card c=new Card();
        c.setCardNo("511123************");
        //設置相互
        p.setCard(c);
        c.setPerson(p);
        ps.savePerson(p);
        /*Hibernate:   添加時 先查詢主表的最大的id，先添加主表，在添加從表。   刪除時則是先刪除從表，在刪除主表。
            select
                max(id) 
            from
                person
        Hibernate: 
            insert 
            into
                j2ee.person
                (userName, id) 
            values
                (?, ?)
        Hibernate: 
            insert 
            into
                j2ee.card
                (cardNo, id) 
            values
                (?, ?)

        
    */
        
    }
}