使用HibernateTemplate进行数据库功能开发完成Spring+Hibernate架构

在Spring架构基础上 将其中的JdbcTemplate访问数据库的代码改成用HibernateTemplate访问数据库 最后形成Spring+Hibernate的软件架构

 

准备工作：

1  删除目录\src\com\demo\spring\dao 该目录下面的代码是基于JdbcTemplate开发的DAO层代码 我们将开发基于HibernateTemplate的DAO层来替换它

2  复制jar文件到当前项目的\WEB-INF\lib目录下 使项目来支持Hibernate事务 以及能够提供对Hibernate映射文件的解析

dom4j-1.6.jar

antlr-2.7.5H3.jar

jta.jar

3  基于Hibernate的开发 都需要创建数据库表的映射文件和持久化类 将User.hbm.xml  AbstractUser.java  User.java 复制到当前项目中\src\com\demo\hibernate\beans

 

开发过程：

需要在Bean配置文件中添加一系列组件 这些组件相互注入

• dataSource 为sessionFactory提供数据源
• sessionFactory Hibernate管理工厂 为userDAO的事务管理策略对象transactionManager提供sessionFactory
• transactionManager 为userDAO提供POJO类 利用被注入的数据源 定义一系列的业务操作函数 使用JdbcTemplate来操作POJO类 实现对数据库的操作
• UserDAOProxy userDAO的事务管理策略对象 该对象规定了userDAO的管理策略 因此他需要注入userDAO作为被管理的对象 进行事务管理也需要提供事务管理器 因此需要注入transactionManager作为事务管理器
• Action类 该类是响应处理类 负责调度userDAO函数即可实现数据库的访问 而对于userDAO的访问都将在UserDAOProxy的监管之下

图示：

                              dataSource  定义数据源

                               　｜　　注入数据源

　　　　　　　　　　　　　　　sessionFactory

             注入Hibernate  |             | 注入Hibernate

            POJO         userDAO        transactionManager

                   注入DAO |       |  注入事务 |

                    Action类       UserDAOProxy

步骤：

1 创建数据源dataSource

2 创建sessionFactory 并注入dataSource

3 创建事务管理对象transactionManager 并注入sessionFactory 

4 创建userDAO 并注入sessionFactory

5 创建事务管理策略对象UserDAOProxy 并注入管理策略对象userDAO和所用的事务管理器transactionManager

6 创建Action 并注入userDAO

详细步骤：

1 数据源配置

在applicationContext.xml中添加一个名称为dataSource的 指向的类为DBCP的数据源类

 

<!-- 配置数据源 -->
    <bean id="dataSource"
        class="org.apache.commons.dbcp.BasicDataSource"
        destroy-method="close">
        <property name="driverClassName">
            <value>org.gjt.mm.mysql.Driver</value>
        </property>
        <property name="url">
            <value>jdbc:mysql://localhost:3306/demo</value>
        </property>
        <property name="username">
            <value>root</value>
        </property>
        <property name="password">
            <value></value>
        </property>
    </bean>

 

2 SessionFactory的配置

配置SessionFactory对象 为DAO层提供HIbernate的数据库连接对象 注入配置的dataSource对象

 

<!-- 配置Hibernate -->
    <bean id="sessionFactory"
        class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
        <property name="dataSource">
            <ref local="dataSource" />
        </property>
        <property name="mappingResources">
            <list>
                <value>com/demo/hibernate/beans/User.hbm.xml</value>
            </list>
        </property>
        <property name="hibernateProperties">
            <props>
                <prop key="hibernate.dialect">
                    org.hibernate.dialect.MySQLDialect
                </prop>
                <prop key="hibernate.show_sql">true</prop>
            </props>
        </property>
    </bean>

 

3  配置事务

为SessionFactory对象增加事务配置组件 并注入上面配置的SessionFactory对象

 

<!-- 配置事务 -->
    <bean id="transactionManager"
        class="org.springframework.orm.hibernate3.HibernateTransactionManager">
        <property name="sessionFactory">
            <ref local="sessionFactory" />
        </property>
    </bean>

4  配置DAO组件

我们先配置该组件的Bean对象  一个基于HibernateTemplate的DAO类com.demo.hibernate.dao.UserDAO.java 并为这个对象注入SessionFactory对象

 

<!-- 定义DAO -->
    <bean id="userDAO" class="com.demo.hibernate.dao.UserDAO">
        <property name="sessionFactory">
            <ref local="sessionFactory" />
        </property>
    </bean>

5  配置DAO事务

为上面配置的DAO对象配置事务组件 使得对userDAO的访问都在spring的事务监管下 改组件需要注入上面配置的事务对象transactionManager DAO对象userDAO 并配置事务管理的策略

 

<!-- 定义DAO代理 -->
    <bean id="UserDAOProxy"
        class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
        <property name="transactionManager">
            <ref bean="transactionManager" />
        </property>
        <property name="target">
            <ref local="userDAO" />
        </property>
        <property name="transactionAttributes">
            <props>
                <prop key="insert*">PROPAGATION_REQUIRED</prop>
                <prop key="*">PROPAGATION_REQUIRED,readOnly</prop>
            </props>
        </property>
    </bean>

 

6  创建Hibernate DAO 类

  首先创建一个接受类　com.demo.hibernate.dao.IUserDAO.java 创建接口的原因是为了让Spring的AOP机制能够进行事务的管理 因为事务的管理是基于AOP实现的

在接口中声明要实现的操作函数

package com.demo.hibernate.dao;

import java.util.List;

import com.demo.hibernate.beans.User;

public interface IUserDAO {

    public boolean isValid(final String username, final String password);

    public boolean i***ist(String username);

    public void insertUser(User user);

    public User getUser(String userid);

    public List getUsers();

    public void deleteUser(String userid);
}

在UserDAO.java 中实现声明的函数

 

package com.demo.hibernate.dao;

import java.util.List;

import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.hibernate.criterion.Restrictions;
import org.springframework.orm.hibernate3.HibernateCallback;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import com.demo.hibernate.beans.User;

public class UserDAO extends HibernateDaoSupport implements IUserDAO {

    public boolean isValid(final String username, final String password) {
        List list = (List) getHibernateTemplate().execute(new HibernateCallback() {
            public Object doInHibernate(Session session)
                    throws HibernateException {
                List result = session.createCriteria(User.class).add(
                        Restrictions.eq("username", username)).add(
                        Restrictions.eq("password", password)).list();
                return result;
            }
        });
        if (list.size() > 0) {
            return true;
        } else {
            return false;
        }
    }

    public boolean i***ist(final String username) {
        List list = (List) getHibernateTemplate().execute(new HibernateCallback() {
            public Object doInHibernate(Session session)
                    throws HibernateException {
                List result = session.createCriteria(User.class).add(
                        Restrictions.eq("username", username)).list();
                return result;
            }
        });
        if (list.size() > 0) {
            return true;
        } else {
            return false;
        }
    }

    public void insertUser(User user) {
        getHibernateTemplate().saveOrUpdate(user);
    }

    public User getUser(String userid) {
        return (User) getHibernateTemplate().get(User.class,
                new Integer(userid));
    }

    public List getUsers() {
        return getHibernateTemplate().find("from User");
    }

    public void deleteUser(String userid) {
        Object p = getHibernateTemplate().load(User.class, new Integer(userid));
        getHibernateTemplate().delete(p);
    }
}

至此 就完成了使用HibernateTemplate访问数据库的DAO代码的开发了 下面修改Action中的业务函数来调用DAO中的函数

7  修改LoginAction访问UserDAO进行登录验证

首先为LoginAction添加一个变量

 

UserDAO userDAO;

    public UserDAO getUserDAO() {
        return userDAO;
    }

    public void setUserDAO(UserDAO userDAO) {
        this.userDAO = userDAO;
    }

 

为applicationContext.xml中的loginAction的配置注入userDAO变量

 

<!---定义Action-->
    <bean id="loginAction"
        class="com.demo.spring.actions.LoginAction">
        <property name="commandClass">
            <value>com.demo.spring.forms.LoginForm</value>
        </property>
        <!-- 指定DAO类 -->
        <property name="userDAO">
            <ref local="userDAO" />
        </property>
        <!-- 指定验证类 -->
        <property name="validator">
            <ref local="loginValidator" />
        </property>
        <!-- 指定失败要返回的页面 -->
        <property name="formView">
            <value>login</value>
        </property>
        <!-- 指定成功要返回的页面 -->
        <property name="successView">
            <value>welcome</value>
        </property>
    </bean>

修改LoginAction处理类中用户登录验证函数isValid() 使用被注入对象userDAO的isValid()函数

 

public boolean isValid(LoginForm loginForm) {
        /*if (loginForm.getUsername().equals("admin")
                || loginForm.getPassword().equals("admin")) {
            return true;
        } else {
            return false;
        }*/
        if(userDAO.isValid(loginForm.getUsername(), loginForm.getPassword())) {
            return true;
        } else {
            return false;
        }
    }

8  RegisterAction访问UserDAO进行用户注册 

方法如7

这样就形成了Spring+Hibernate架构