Hibernate之旅一：创建demo

前言

　　最近在学习Hibernate，貌似起步晚了些。以前都只是在用，没有进行系统地学习。刚刚开通了博客，想写一些学习笔记。如有错误之处，望列位指正，不甚感激。

环境准备

jdk1.8、eclipse、mysql数据库。
相关jar包。antlr.jar、cglib.jar、asm.jar、asm-attrs.jar、commons-collections.jar、commons-logging.jar、ehcache.jar、hibernate3.jar、jta.jar、dom4.jar、log4j.jar。(创建maven工程更为方便，我这儿恰好有相关jar包就直接导入了）。

数据库准备

首先创建数据库hibernatedb：CREATE DATABASE hibernatedb DEFAULT CHARACTER SET utf8 COLLATE utf8_general_ci;
创建用户user1,密码也是user1：CREATE USER ‘user1‘@‘localhost‘ IDENTIFIED BY ‘user1‘;--该处为localhost则代表只能本地访问；如果为%表示匹配所有主机（并不包括localhost）。
授权给用户：GRANT ALL PRIVILEGES ON hibernatedb.* TO user1; --ALL PRIVILEGES表示所有权限，*代表整个数据库。
刷新用户权限：FLUSH PRIVILEGES;
创建表userinfo：

USE DATABASE hibernatedb;--使用hibernatedb数据库

CREATE TABLE userinfo(

userId INT PRIMARY KEY AUTO_INCREMENT,

userName VARCHAR(20) NOT NULL,

userPassword VARCHAR(20) NOT NULL

);

最终数据库和表结构如下。

技术分享

创建demo

hibernate基本配置文件:hibernate.cfg.xml；该配置文件放置在类路径下。

 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 <hibernate-configuration>
 6     <session-factory>
 7         <property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property>
 8         <property name="hibernate.connection.username">user1</property>
 9         <property name="hibernate.connection.password">user1</property>
10         <property name="hibernate.connection.url">jdbc:mysql://localhost:3306/hibernatedb</property>
11         <!-- 配置数据库方言 -->
12         <property name="hibernate.dialect">org.hibernate.dialect.MySQLDialect</property>
13         <property name="connection.pool_size">1</property>
14         <!-- 输出运行时生成的SQL语句 -->
15         <property name="show_sql">true</property>
16         <!-- 列出所有的映射文件 -->
17         <mapping resource="org/hibernate/entity/UserInfo.hbm.xml" />
18     </session-factory>
19 </hibernate-configuration>

新建一个简单的JavaBean:UserInfo类。持久化类都要求有无参构造器，Hibernate必须使用Java反射机制来创建对象。

 1 package org.hibernate.entity;
 2 /**
 3  * 
 4  * 功能：测试用用户类
 5  * @author liaody
 6  * @version 1.0
 7  * @date 2017年3月5日 上午12:26:20
 8  */
 9 public class UserInfo {
10     
11     private int userId;
12     private String userName;
13     private String userPassword;
14     
15     /**
16      * default constructor
17      */
18     public UserInfo (){
19         
20     }
21     
22     /**
23      * full constructor
24      * @param userId
25      * @param userName
26      * @param userPassword
27      */
28     public UserInfo(int userId,String userName,String userPassword){
29         this.userId = userId;
30         this.userName = userName;
31         this.userPassword = userPassword;
32     }
33 
34     /**
35      * @return the userId
36      */
37     public int getUserId() {
38         return this.userId;
39     }
40 
41     /**
42      * @return the userName
43      */
44     public String getUserName() {
45         return this.userName;
46     }
47 
48     /**
49      * @return the userPassword
50      */
51     public String getUserPassword() {
52         return this.userPassword;
53     }
54 
55     /**
56      * @param userId the userId to set
57      */
58     public void setUserId(int userId) {
59         this.userId = userId;
60     }
61 
62     /**
63      * @param userName the userName to set
64      */
65     public void setUserName(String userName) {
66         this.userName = userName;
67     }
68 
69     /**
70      * @param userPassword the userPassword to set
71      */
72     public void setUserPassword(String userPassword) {
73         this.userPassword = userPassword;
74     }
75     
76 
77     
78 
79 }

UserInfo类的映射文件UserInfo.hbm.xml，该文件放置在与UserInfo类同一个包（org.hibernate.entity）下。

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
 3 "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
 4 <hibernate-mapping>
 5     <class name="org.hibernate.entity.UserInfo" table="USERINFO">
 6         <id name="userId" type="java.lang.Integer" column="userid">
 7             <generator class="increment" />
 8         </id>
 9         <property name="userName" type="java.lang.String">
10             <column name="userName" length="20"></column>
11         </property>
12         <property name="userPassword" type="java.lang.String">
13             <column name="userPassword" length="20"></column>
14         </property>
15     </class>
16 </hibernate-mapping>

创建辅助工具类HibernateUtil，用于获取和管理Session。

 1 package org.hibernate.util;
 2 
 3 import org.hibernate.*;
 4 import org.hibernate.cfg.*;
 5 
 6 public class HibernateUtil {
 7     private static SessionFactory sessionFactory;
 8     private static Configuration configuration = new Configuration();
 9     // 创建线程局部变量threadLocal，用来保存Hibernate的Session
10     private static final ThreadLocal<Session> threadLocal = new ThreadLocal<Session>();
11     // 使用静态代码块初始化Hibernate
12     static {
13         try {
14             Configuration cfg = new Configuration().configure(); // 读取配置文件hibernate.cfg.xml
15             sessionFactory = cfg.buildSessionFactory(); // 创建SessionFactory
16         } catch (Throwable ex) {
17             throw new ExceptionInInitializerError(ex);
18         }
19     }
20 
21     // 获得SessionFactory实例
22     public static SessionFactory getSessionFactory() {
23         return sessionFactory;
24     }
25 
26     // 获得ThreadLocal 对象管理的Session实例.
27     public static Session getSession() throws HibernateException {
28         Session session = (Session) threadLocal.get();
29         if (session == null || !session.isOpen()) {
30             if (sessionFactory == null) {
31 
32                 rebuildSessionFactory();
33             }
34             // 通过SessionFactory对象创建Session对象
35             session = (sessionFactory != null) ? sessionFactory.openSession()
36                     : null;
37             // 将新打开的Session实例保存到线程局部变量threadLocal中
38             threadLocal.set(session);
39         }
40         return session;
41     }
42 
43     // 关闭Session实例
44     public static void closeSession() throws HibernateException {
45         // 从线程局部变量threadLocal中获取之前存入的Session实例
46         Session session = (Session) threadLocal.get();
47         threadLocal.set(null);
48         if (session != null) {
49             session.close();
50         }
51     }
52 
53     // 重建SessionFactory
54     public static void rebuildSessionFactory() {
55         try {
56             configuration.configure("/hibernate.cfg.xml"); // 读取配置文件hibernate.cfg.xml
57             sessionFactory = configuration.buildSessionFactory(); // 创建SessionFactory
58         } catch (Exception e) {
59             System.err.println("Error Creating SessionFactory ");
60             e.printStackTrace();
61         }
62     }
63 
64     // 关闭缓存和连接池
65     public static void shutdown() {
66         getSessionFactory().close();
67     }
68 }

Dao接口

 1 package org.hibernate.dao;
 2 
 3 import org.hibernate.entity.UserInfo;
 4 
 5 public interface UserInfoDao {
 6 
 7     void save(UserInfo user); // 添加用户
 8 
 9     UserInfo findById(int id); // 根据用户标识查找指定用户
10 
11     void delete(UserInfo user); // 删除用户
12 
13     void update(UserInfo user); // 修改用户信息
14 }

Dao接口实现

 1 package org.hibernate.dao.impl;
 2 
 3 import org.hibernate.Session;
 4 import org.hibernate.Transaction;
 5 import org.hibernate.dao.UserInfoDao;
 6 import org.hibernate.entity.UserInfo;
 7 import org.hibernate.util.HibernateUtil;
 8 
 9 public class UserInfoDaoImpl implements UserInfoDao {
10     // 添加用户
11     public void save(UserInfo user) {
12         Session session = HibernateUtil.getSession(); // 生成Session实例
13         Transaction tx = session.beginTransaction(); // 创建Transaction实例
14         try {
15             session.save(user); // 使用Session的save方法将持久化对象保存到数据库
16             tx.commit(); // 提交事务
17         } catch (Exception e) {
18             e.printStackTrace();
19             tx.rollback(); // 回滚事务
20         } finally {
21             HibernateUtil.closeSession(); // 关闭Session实例
22         }
23     }
24 
25     // 根据用户标识查找指定用户
26     public UserInfo findById(int userId) {
27         UserInfo user = null;
28         Session session = HibernateUtil.getSession(); // 生成Session实例
29         Transaction tx = session.beginTransaction(); // 创建Transaction实例
30         try {
31             user = (UserInfo) session.get(UserInfo.class, userId); // 使用Session的get方法获取指定id的用户到内存中
32             tx.commit(); // 提交事务
33         } catch (Exception e) {
34             e.printStackTrace();
35             tx.rollback(); // 回滚事务
36         } finally {
37             HibernateUtil.closeSession(); // 关闭Session实例
38         }
39         return user;
40     }
41 
42     // 删除用户
43     public void delete(UserInfo user) {
44         Session session = HibernateUtil.getSession(); // 生成Session实例
45         Transaction tx = session.beginTransaction(); // 创建Transaction实例
46         try {
47             session.delete(user); // 使用Session的delete方法将持久化对象删除
48             tx.commit(); // 提交事务
49         } catch (Exception e) {
50             e.printStackTrace();
51             tx.rollback(); // 回滚事务
52         } finally {
53             HibernateUtil.closeSession(); // 关闭Session实例
54         }
55     }
56 
57     // 修改用户信息
58     public void update(UserInfo user) {
59         Session session = HibernateUtil.getSession(); // 生成Session实例
60         Transaction tx = session.beginTransaction(); // 创建Transaction实例
61         try {
62             session.update(user); // 使用Session的update方法更新持久化对象
63             tx.commit(); // 提交事务
64         } catch (Exception e) {
65             e.printStackTrace();
66             tx.rollback(); // 回滚事务
67         } finally {
68             HibernateUtil.closeSession(); // 关闭Session实例
69         }
70     }
71 
72 }

测试

 1 package org.hibernate.test;
 2 
 3 import org.hibernate.dao.UserInfoDao;
 4 import org.hibernate.dao.impl.UserInfoDaoImpl;
 5 import org.hibernate.entity.UserInfo;
 6 import org.junit.Before;
 7 import org.junit.Test;
 8 
 9 public class UserInfoTest {
10     
11     @Before
12     public void setUp() throws Exception {
13 
14     }
15 
16     @Test
17     public void testSave() {
18         UserInfoDao userdao = new UserInfoDaoImpl();
19         UserInfo  user = new UserInfo(); // 创建UserInfo对象
20         // 设置UserInfo对象中的各个属性值
21         user.setUserName("liaody");
22         user.setUserPassword("456");
23         userdao.save(user); // 使用UserInfoDao的save方法将UserInfo对象存入数据库
24 
25     }
26 }