Kela's Blog

log4j.rootLogger=warn, stdout

#設(shè)置顯示 error以上級別log
log4j.logger.org.hibernate=error 

6. 構(gòu)建 POJO 類和Hibernate映射( .hbm.xml)文件
        說明：根據(jù)數(shù)據(jù)庫定義導(dǎo)出表結(jié)構(gòu)，并自動生成對應(yīng)的映射文件和POJO java代碼，是實(shí)際開發(fā)當(dāng)中最常用的方式，也是專家所推薦的。可以使用 MiddleGen -- Hibernate，Hibernate -- Extensions 等的工具，這些工具的使用非常的方便，只修修改相應(yīng)的 ant 構(gòu)建文件即可，在網(wǎng)絡(luò)上可以很容易的找到這些工具的使用方法。
        這里采用手工編寫 POJO 和映射文件的方法，是基于開發(fā)者更好理解 Hibernate 運(yùn)作機(jī)制而考慮。付出手工編寫會產(chǎn)生疏漏和錯誤的代價，我覺得在學(xué)習(xí)階段是值得的。
      以下是這兩個文件，他們的位置都在   com.kela.hb.pojo 下面。
POJO類：com.kela.hb.pojo.KelaStudent
 /**
  * KelaStudent.java
  */
package com.kela.hb.pojo;

import java.io.Serializable;

public class KelaStudent implements Serializable {

 private static final long serialVersionUID = 8365163573354176897L;
 
 String stuID;
 String stuName;
 String stuSex;
 Integer stuAge;
 String stuAddress;
 
 public KelaStudent() {
  
 }

 public String getStuAddress() {
  return stuAddress;
 }

 public void setStuAddress(String stuAddress) {
  this.stuAddress = stuAddress;
 }

 public Integer getStuAge() {
  return stuAge;
 }

 public void setStuAge(Integer stuAge) {
  this.stuAge = stuAge;
 }

 public String getStuID() {
  return stuID;
 }

 public void setStuID(String stuID) {
  this.stuID = stuID;
 }

 public String getStuName() {
  return stuName;
 }

 public void setStuName(String stuName) {
  this.stuName = stuName;
 }

 public String getStuSex() {
  return stuSex;
 }

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

import com.kela.hb.pojo.KelaStudent;
import com.kela.hb.util.HibernateUtil;

public class HelloTest {

    Session session = null;
 
     public void testInsert() {

        Transaction tran = null;

        try {

           //從  HibernateUtil 得到 hibernate的session,  HibernateUtil .java 文件在后
           session = HibernateUtil.currentSession();
           //啟動事務(wù)
           tran = session.beginTransaction();
   
           KelaStudent kelaStudent = new KelaStudent();
           //插入數(shù)據(jù)
           kelaStudent.setStuName("王小二");
           kelaStudent.setStuSex("T");
           kelaStudent.setStuAge(new Integer(26));
           kelaStudent.setStuAddress("甘肅蘭州");
          
           //保存并提交事務(wù)
           session.save(kelaStudent);
           session.flush();
           tran.commit();
   
        } catch (HibernateException he){
   
           System.out.println("運(yùn)行中發(fā)生了錯誤");
           try {
               HibernateUtil.closeSession();
           } catch (HibernateException he2) {
               System.out.println("關(guān)閉 session 沒有成功");
           }
        }
 
    }
 
    public static void main(String[] args) {
        System.out.println(" ========= 開始測試 ==========");
        HelloTest helloTest = new HelloTest();
        helloTest.testInsert();
        System.out.println(" ========= SUCCESS ==========");
    }

}

下面是 HibernateUtil  . java
/**
 * HibernateUtil.java
 */
package com.kela.hb.util;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;

public class HibernateUtil {

   private static Log log = LogFactory.getLog(HibernateUtil.class);

   private static final SessionFactory sessionFactory;

   static {
       try {
           sessionFactory = new Configuration().configure().buildSessionFactory();
       } catch (Throwable ex) {
           log.error("初始化 SessionFactory 發(fā)生錯誤.", ex);
           throw new ExceptionInInitializerError(ex);
       }
    }

     public static final ThreadLocal session = new ThreadLocal();

     public static Session currentSession() {
         Session s = (Session) session.get();
         if (s == null) {
            s = sessionFactory.openSession();
            session.set(s);
        }
     return s;
    }

    public static void closeSession() {
        Session s = (Session) session.get();
        if (s != null)
           s.close();
        session.set(null);
    }

}

8. 運(yùn)行結(jié)果
    運(yùn)行 HelloTest.java 文件，觀察數(shù)據(jù)庫中的結(jié)果，可以看到一條數(shù)據(jù)被添加了進(jìn)來。

   數(shù)據(jù)庫結(jié)果：
   402880fc07c68f690107c68f6dfd0001          王小二         T         26         甘肅蘭州
   
   在控制臺看到如下日志：
    Hibernate:
    insert into KELA_STUDENT (StuName, StuSex, StuAge, StuAddress, StuID) values (?, ?, ?, ?, ?)
  
    就是這么神奇。不需要指定 SQL 語句一樣能實(shí)現(xiàn)SQL的功能。

9. 關(guān)于測試代碼的解釋
    在Hibernate中session完成持久化操作，要創(chuàng)建一個Session實(shí)例大致需要3個步驟：
    A. 初始化Hibernate配置管理類Configuration

         //讀入默認(rèn)的配置文件(hibernate.cfg.xml 或 hibernate.properties)來創(chuàng)建一個Configuration
         Configuration config = new Configuration().configure();  
    B. 通過Configuration類的實(shí)例來創(chuàng)建 Session 的工廠類 SessionFactory：
        
         SessionFactory sessionFactory = config.buildSessionFactory();

    C. 通過SessionFactory得到Session實(shí)例：
  
         session = sessionFactory.openSession();

    D. 通過Session實(shí)例完成持久化操作：

           //啟動事務(wù)
           tran = session.beginTransaction();
   
           KelaStudent kelaStudent = new KelaStudent();
           //插入數(shù)據(jù)
           kelaStudent.setStuName("王小二");
           kelaStudent.setStuSex("T");
           kelaStudent.setStuAge(new Integer(26));
           kelaStudent.setStuAddress("甘肅蘭州");
          
           //保存并提交事務(wù)
           session.save(kelaStudent);
           session.flush();
           tran.commit();

      說明：由于SessionFactory采取了線程安全的設(shè)計(jì)，可以有多個線程并發(fā)調(diào)用，大多數(shù)情況下，一個應(yīng)用中針對一個數(shù)據(jù)庫共享一個SessionFactory實(shí)例即可。
                  Session（這里的Session是Hibernate的Session）可以理解成相當(dāng)于JDBC 的Connection），它的設(shè)計(jì)是非線程安全的也就是說一個Session實(shí)例只可以由一個線程使用。
                  有了以上兩點(diǎn)的考慮，在 HelloTest.java中在得到Session實(shí)例使用了：

           //從  HibernateUtil 得到 hibernate的session,  HibernateUtil .java 文件在后
           session = HibernateUtil.currentSession();
          
           在HibernateUtil.java 文件中創(chuàng)建Session，關(guān)閉Session。（這段代碼來自于Hibernate文檔）
           這就相當(dāng)于我們平時從數(shù)據(jù)庫連接池中得到 Connection，用完了 close.conn() 是一樣的道理。