SSH架构开发流程2

Hibernate开发第二步

 

2  开发并配置Hibernate DAO层AddressDAO.java

开发一个DAO类的AddressDAO.java 使用HibernateTemplate实现对数据表address的增 删 改 查的操作

 

[1]实现接口类IAddressDAO.java

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

package com.demo.hibernate.dao;

import java.util.List;

import com.demo.hibernate.beans.Address;


public interface IAddressDAO {

    public List findAllByUsername(final String username);


    public Address findById(String id);

    public boolean i***ist(final String username, final String name);

    public void insert(Address address);

    public void update(Address address);

    public void delete(String id);
}

 

[2]开发实现类AddressDAO.java

下面依次实现接口中的函数 根据用户登录和用户注册的实际操作逻辑 实现这些函数

package com.demo.hibernate.dao;

import java.util.List;

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

import com.demo.hibernate.beans.Address;
import com.demo.struts.util.Constants;



public class AddressDAO extends HibernateDaoSupport implements IAddressDAO {

    /**
     * get address list
     */
    public List findAllByUsername(final String username) {
        return (List) getHibernateTemplate().execute(new HibernateCallback() {
            public Object doInHibernate(Session session)
                    throws HibernateException {
                List result = session.createCriteria(Address.class).add(
                        Restrictions.eq("username", username)).list();
                return result;
            }
        });
    }


        public Address findById(String id) {
        return (Address) getHibernateTemplate().get(Address.class,
                new Integer(id));
    }

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

    public void insert(Address address) {
        getHibernateTemplate().save(address);
    }

    public void update(Address address) {
        getHibernateTemplate().update(address);
    }

    public void delete(String id) {
        Object p = getHibernateTemplate().load(Address.class, new Integer(id));
        getHibernateTemplate().delete(p);
    }

}

 

 

 

[3]在applicationContext.xml中配置DAO及其代理

 

开发完了基于HibernateTemplate的DAO类com.demo.hibernate.dao.AddressDAO.java 下面在applicationContext.xml中配置改组件的Bean对象 并为改对象注入SessionFactory对象 同时为该DAO对象配置事务组件 使得对addressDAO的访问都在Spring的事务监管之下 该组件需要注入上面配置的事务对象transactionManager DAO对象addressDAO 并配置事务管理的策略

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


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