Spring整合Hibernate

  就Hibernate的持久层访问技术而言，Spring提供了如下三个工具类（或接口）来支持DAO组件的实现：HibernateDaoSupport，HibernateTemplate，HibernateCallback。

1.使用HibernateTemplate对象
1.1 定义实体
Person.java：
package test.domain;
public class Person {
    private Integer id;
    private String name;
    private int age;
    public Person() {
    }
    // 初始化全部属性的构造器
    public Person(String name, int age) {
        this.name = name;
        this.age = age;
    }
    public void setId(Integer id) {
        this.id = id;
    }
    public Integer getId() {
        return this.id;
    }
    public void setName(String name) {
        this.name = name;
    }
    public String getName() {
        return this.name;
    }
    public void setAge(int age) {
        this.age = age;
    }
    public int getAge() {
        return this.age;
    }
}

1.2 增加映射Person.hbm.xml：
<?xml version="1.0" encoding="GBK"?>
<!DOCTYPE hibernate-mapping PUBLIC
    "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
    "http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd">
<hibernate-mapping package="test.domain">
    <class name="Person" table="person_inf">
        <id name="id" column="person_id" type="int">
            <generator class="identity"/>
        </id>
        <property name="name" type="string"/>
        <property name="age" type="int"/>
    </class>
</hibernate-mapping>

1.3 定义DAO
PersonDao.java：
package test.dao;
import java.util.List;
import test.domain.*;
public interface PersonDao {
    /**
     * 加载Person实例
     * @param id 需要加载的Person实例的主键值
     * @return 返回加载的Person实例
     */
    Person get(Integer id);
    /**
     * 保存Person实例
     * @param person 需要保存的Person实例
     * @return 刚刚保存的Person实例的标识属性值
     */
    Integer save(Person person);
    /**
     * 修改Person实例
     * @param person 需要修改的Person实例
     */
    void update(Person person);
    /**
     * 删除Person实例
     * @param id 需要删除的Person实例的标识属性值
     */
    void delete(Integer id);
    /**
     * 删除Person实例
     * @param person 需要删除的Person实例
     */
    void delete(Person person);
    /**
     * 根据用户名查找Person
     * @param name 查询的人名
     * @return 指定用户名对应的全部Person
     */
    List<Person> findByName(String name);
    /**
     * 查询全部Person实例
     * @return 全部Person实例
     */
    public List findAllPerson();
    /**
     * 查询数据表中Person实例的总数
     * @return 数据表中Person实例的总数
     */
    long getPersonNumber();
}

PersonDaoImpl.java：

package test.dao.impl;
import java.util.List;
import org.hibernate.SessionFactory;
import org.springframework.orm.hibernate3.HibernateTemplate;
import test.dao.*;
import test.domain.*;
public class PersonDaoImpl implements PersonDao {
    // 定义一个HibernateTemplate对象，用于执行持久化操作
    private HibernateTemplate ht = null;
    // Hibernate持久化操作所需的SessionFactory
    private SessionFactory sessionFactory;
    public void setSessionFactory(SessionFactory sessionFactory) {
        this.sessionFactory = sessionFactory;
    }
    private HibernateTemplate getHibernateTemplate() {
        if (ht == null) {
            ht = new HibernateTemplate(sessionFactory);
        }
        return ht;
    }
    public Person get(Integer id) {
        return getHibernateTemplate().get(Person.class, id);
    }
    public Integer save(Person person) {
        return (Integer) getHibernateTemplate().save(person);
    }
    public void update(Person person) {
        getHibernateTemplate().update(person);
    }
    public void delete(Integer id) {
        getHibernateTemplate().delete(get(id));
    }
    public void delete(Person person) {
        getHibernateTemplate().delete(person);
    }
    public List<Person> findByName(String name) {
        return (List<Person>) getHibernateTemplate().find(
                "from Person p where p.name = ?", name);
    }
    public List findAllPerson() {
        return (List<Person>) getHibernateTemplate().find("from Person");
    }
    public long getPersonNumber() {
        return (Long) getHibernateTemplate().find(
                "select count(*) from Person as p").get(0);
    }
}

1.4 编写Spring配置文件bean.xml
    当通过Hibernate进行持久层访问时，必须先获得SessionFactory对象，它是单个数据库映射关系编译后的内存镜像。一旦在Spring容器的IoC容器中配置了SessionFactory Bean，它将随应用的启动而加载，并可以充分利用IoC容器的功能，将SessionFactory Bean注入任何Bean，比如DAO组件。如下：

<?xml version="1.0" encoding="GBK"?>
<!-- Spring配置文件的根元素，使用spring-beans-3.0.xsd语义约束 -->
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns="http://www.springframework.org/schema/beans"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
    http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">
    <!-- 定义数据源Bean，使用C3P0数据源实现 -->
    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"
        destroy-method="close">
        <!-- 指定连接数据库的驱动 -->
        <property name="driverClass" value="com.mysql.jdbc.Driver"/>
        <!-- 指定连接数据库的URL -->
        <property name="jdbcUrl" value="jdbc:mysql://localhost/aaa"/>
        <!-- 指定连接数据库的用户名 -->
        <property name="user" value="root"/>
        <!-- 指定连接数据库的密码 -->
        <property name="password" value="root"/>
        <!-- 指定连接数据库连接池的最大连接数 -->
        <property name="maxPoolSize" value="40"/>
        <!-- 指定连接数据库连接池的最小连接数 -->
        <property name="minPoolSize" value="1"/>
        <!-- 指定连接数据库连接池的初始化连接数 -->
        <property name="initialPoolSize" value="1"/>
        <!-- 指定连接数据库连接池的连接的最大空闲时间 -->
        <property name="maxIdleTime" value="20"/>
    </bean>
    <!-- 定义Hibernate的SessionFactory -->
    <bean id="sessionFactory"
        class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
        <!-- 依赖注入数据源，注入正是上面定义的dataSource -->
        <property name="dataSource" ref="dataSource"/>
        <!-- mappingResouces属性用来列出全部映射文件 -->
        <property name="mappingResources">
            <list>
                <!-- 以下用来列出Hibernate映射文件，可使用classpath*:/test/domain/*.xml统一引用 -->
                <value>test/domain/Person.hbm.xml</value>
            </list>
        </property>
        <!-- 定义Hibernate的SessionFactory的属性 -->
        <property name="hibernateProperties">
            <!-- 配置Hibernate属性 -->
            <value>
            hibernate.dialect=org.hibernate.dialect.MySQLInnoDBDialect
            hibernate.hbm2ddl.auto=update
            hibernate.show_sql=true
            hibernate.format_sql=true;
            </value>
        </property>
    </bean>
    <!-- 定义DAO Bean-->
    <bean id="personDao"
        class="test.dao.impl.PersonDaoImpl">
        <!-- 注入持久化操作所需的SessionFactory -->
        <property name="sessionFactory" ref="sessionFactory"/>
    </bean>
</beans>

1.5 测试

package test;
import org.springframework.context.*;
import org.springframework.context.support.*;
import test.dao.*;
import test.domain.*;
public class HibernateTest {
    public static void main(String[] args) {
        // 创建Spring容器
        ApplicationContext ctx = new ClassPathXmlApplicationContext("bean.xml");
        // 获取DAO组件
        PersonDao pdao = (PersonDao) ctx.getBean("personDao");
        // 循环插入10条记录
        for (int i = 0; i < 10; i++) {
            pdao.save(new Person(i + "", i + 10));
        }
        // 调用DAO组件的方法
        System.out.println(pdao.getPersonNumber());
    }
}

2.使用HibernateCallback实例
package test;
import org.springframework.orm.hibernate3.HibernateCallback;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
import org.hibernate.Session;
import org.hibernate.Query;
import org.hibernate.HibernateException;
import java.sql.SQLException;
import java.util.List;
public class YeekuHibernateDaoSupport extends HibernateDaoSupport {
    /**
     * 使用hql语句进行分页查询
     *
     * @param hql  需要查询的hql语句
     * @param offset 第一条记录索引
     * @param pageSize 每页需要显示的记录数
     * @return 当前页的所有记录
     */
    public List findByPage(final String hql, final int offset,
            final int pageSize) {
        // 通过一个HibernateCallback对象来执行查询
        List list = getHibernateTemplate().executeFind(new HibernateCallback() {
            // 实现HibernateCallback接口必须实现的方法
            public Object doInHibernate(Session session)
                    throws HibernateException, SQLException {
                // 执行Hibernate分页查询
                List result = session.createQuery(hql).setFirstResult(offset)
                        .setMaxResults(pageSize).list();
                return result;
            }
        });
        return list;
    }
    /**
     * 使用hql语句进行分页查询
     * @param hql 需要查询的hql语句
     * @param value 如果hql有一个参数需要传入，value就是传入hql语句的参数
     * @param offset 第一条记录索引
     * @param pageSize 每页需要显示的记录数
     * @return 当前页的所有记录
     */
    public List findByPage(final String hql, final Object value,
            final int offset, final int pageSize) {
        // 通过一个HibernateCallback对象来执行查询
        List list = getHibernateTemplate().executeFind(new HibernateCallback() {
            // 实现HibernateCallback接口必须实现的方法
            public Object doInHibernate(Session session)
                    throws HibernateException, SQLException {
                // 执行Hibernate分页查询
                List result = session.createQuery(hql)
                        // 为hql语句传入参数
                        .setParameter(0, value).setFirstResult(offset)
                        .setMaxResults(pageSize).list();
                return result;
            }
        });
        return list;
    }
    /**
     * 使用hql语句进行分页查询
     * @param hql 需要查询的hql语句
     * @param values 如果hql有多个个参数需要传入，values就是传入hql的参数数组
     * @param offset 第一条记录索引
     * @param pageSize 每页需要显示的记录数
     * @return 当前页的所有记录
     */
    public List findByPage(final String hql, final Object[] values,
            final int offset, final int pageSize) {
        // 通过一个HibernateCallback对象来执行查询
        List list = getHibernateTemplate().executeFind(new HibernateCallback() {
            // 实现HibernateCallback接口必须实现的方法
            public Object doInHibernate(Session session)
                    throws HibernateException, SQLException {
                // 执行Hibernate分页查询
                Query query = session.createQuery(hql);
                // 为hql语句传入参数
                for (int i = 0; i < values.length; i++) {
                    query.setParameter(i, values[i]);
                }
                List result = query.setFirstResult(offset).setMaxResults(
                        pageSize).list();
                return result;
            }
        });
        return list;
    }
}

3.使用HibernateDaoSupport工具类
PersonDaoImpl.java（其它代码同上面一样）
package test.dao.impl;
import java.util.List;
import org.springframework.orm.hibernate3.support.*;
import test.dao.*;
import test.domain.*;
public class PersonDaoImpl extends HibernateDaoSupport implements PersonDao {
    /**
     * 加载Person实例
     * @param id 需要加载的Person实例的标识属性值
     * @return 指定id对应的Person实例
     */
    public Person get(Integer id) {
        return getHibernateTemplate().get(Person.class, id);
    }
    /**
     * 保存Person实例
     * @param person 需要保存的Person实例
     * @return 刚刚保存的Person实例的标识属性值
     */
    public Integer save(Person person) {
        return (Integer) getHibernateTemplate().save(person);
    }
    /**
     * 修改Person实例
     * @param person 需要修改的Person实例
     */
    public void update(Person person) {
        getHibernateTemplate().update(person);
    }
    /**
     * 删除Person实例
     * @param id 需要删除的Person实例的标识属性值
     */
    public void delete(Integer id) {
        getHibernateTemplate().delete(get(id));
    }
    /**
     * 删除Person实例
     * @param person 需要删除的Person实例
     */
    public void delete(Person person) {
        getHibernateTemplate().delete(person);
    }
    /**
     * 根据用户名查找Person
     * @param name 查询的人名
     * @return 指定用户名对应的全部Person
     */
    public List<Person> findByName(String name) {
        return (List<Person>) getHibernateTemplate().find(
                "from Person p where p.name = ?", name);
    }
    /**
     * 查询全部Person实例
     * @return 全部Person实例
     */
    public List findAllPerson() {
        return (List<Person>) getHibernateTemplate().find("from Person");
    }
    /**
     * 查询数据表中Person实例的总数
     * @return 数据表中Person实例的总数
     */
    public long getPersonNumber() {
        return (Long) getHibernateTemplate().find(
                "select count(*) from Person as p").get(0);
    }
}

4.使用声明式事务
<?xml version="1.0" encoding="GBK"?>
<!-- 指定Spring配置文件的Schema信息 -->
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
    http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    http://www.springframework.org/schema/tx
    http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
    http://www.springframework.org/schema/aop
    http://www.springframework.org/schema/aop/spring-aop-3.0.xsd">
    <!-- 定义数据源Bean，使用C3P0数据源实现 -->
    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"
        destroy-method="close">
        <!-- 指定连接数据库的驱动 -->
        <property name="driverClass" value="com.mysql.jdbc.Driver"/>
        <!-- 指定连接数据库的URL -->
        <property name="jdbcUrl" value="jdbc:mysql://localhost/javaee"/>
        <!-- 指定连接数据库的用户名 -->
        <property name="user" value="root"/>
        <!-- 指定连接数据库的密码 -->
        <property name="password" value="32147"/>
        <!-- 指定连接数据库连接池的最大连接数 -->
        <property name="maxPoolSize" value="40"/>
        <!-- 指定连接数据库连接池的最小连接数 -->
        <property name="minPoolSize" value="1"/>
        <!-- 指定连接数据库连接池的初始化连接数 -->
        <property name="initialPoolSize" value="1"/>
        <!-- 指定连接数据库连接池的连接的最大空闲时间 -->
        <property name="maxIdleTime" value="20"/>
    </bean>
    <!-- 定义Hibernate的SessionFactory -->
    <bean id="sessionFactory"
        class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
        <!-- 依赖注入数据源，注入正是上面定义的dataSource -->
        <property name="dataSource" ref="dataSource"/>
        <!-- mappingResouces属性用来列出全部映射文件 -->
        <property name="mappingResources">
            <list>
                <!-- 以下用来列出Hibernate映射文件 -->
                <value>org/crazyit/app/domain/Person.hbm.xml</value>
            </list>
        </property>
        <!-- 定义Hibernate的SessionFactory的属性 -->
        <property name="hibernateProperties">
            <!-- 配置Hibernate属性 -->
            <value>
            hibernate.dialect=org.hibernate.dialect.MySQLInnoDBDialect
            hibernate.hbm2ddl.auto=update
            hibernate.show_sql=true
            hibernate.format_sql=true;
            </value>
        </property>
    </bean>
    <!-- 定义DAO Bean-->
    <bean id="personDao" class=
    "org.crazyit.app.dao.impl.PersonDaoHibernate">
        <!-- 注入持久化操作所需的SessionFactory -->
        <property name="sessionFactory" ref="sessionFactory"/>
    </bean>
    <!-- 配置一个业务逻辑组件 -->
    <bean id="leeService" class=
    "org.crazyit.app.service.impl.LeeServiceImpl">
        <!-- 注入持久化访问所需的DAO组件 -->
        <property name="personDao" ref="personDao"/>
    </bean>
    <!-- 配置Hibernate的局部事务管理器，使用HibernateTransactionManager类 -->
    <!-- 该类实现PlatformTransactionManager接口，是针对Hibernate的特定实现-->
    <bean id="transactionManager"
        class="org.springframework.orm.hibernate3.HibernateTransactionManager">
        <!-- 配置HibernateTransactionManager时需要依注入SessionFactory的引用 -->
        <property name="sessionFactory" ref="sessionFactory"/>
    </bean>
    <!-- 配置事务增强处理,指定事务管理器 -->
    <tx:advice id="txAdvice" transaction-manager="transactionManager">
        <!-- 用于配置详细的事务语义 -->
        <tx:attributes>
            <!-- 所有以'get'开头的方法是read-only的 -->
            <tx:method name="get*" read-only="true"/>
            <!-- 其他方法使用默认的事务设置 -->
            <tx:method name="*"/>
        </tx:attributes>
    </tx:advice>
    <aop:config>
        <!-- 配置一个切入点 -->
        <aop:pointcut id="leePointcut"
            expression="bean(leeService)"/>
        <!-- 指定在leePointcut切入点应用txAdvice事务增强处理，即在leeService里所有的方法织入事务控制 -->
        <aop:advisor advice-ref="txAdvice"
            pointcut-ref="leePointcut"/>
    </aop:config>
</beans>