`
yuanlanjun
  • 浏览: 1183866 次
文章分类
社区版块
存档分类
最新评论

Struts2、Spring3、MyBatis3整合ExtJS,完成ColumnTree 【一】

 
阅读更多

开发环境:

System:Windows

WebBrowser:IE6+、Firefox3+

JavaEE Server:tomcat5.0.2.8、tomcat6

IDE:eclipse、MyEclipse 8

Database:MySQL

开发依赖库:

JavaEE5、Spring 3.0.5、Mybatis 3.0.4、myBatis-spring-1.0、Struts2.2.3、junit4.8.2、ext2.2.2

Email:hoojo_@126.com

Blog:http://blog.csdn.net/IBM_hoojo

http://hoojo.cnblogs.com/

上次介绍过Spring3、SpringMVC、MyBatis3整合,在线博文:http://www.cnblogs.com/hoojo/archive/2011/04/15/2016324.html

一、准备工作

1、 下载jar包

Struts2 jar下载:

http://labs.renren.com/apache-mirror//struts/library/struts-2.2.3-lib.zip

Spring3 jar下载:

http://ebr.springsource.com/repository/app/library/version/detail?name=org.springframework.spring&version=3.0.5.RELEASE

MyBatis3 jar 下载:http://www.mybatis.org/java.html

2、 添加的jar包如下:

image

二、Spring、MyBatis整合

1、 需要的jar文件如下:

clip_image002

2、 在src目录中加入mybatis.xml,内容如下:

xml version="1.0" encoding="UTF-8" ?>
<!--CRLF-->
DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">
<!--CRLF-->
configuration>
<!--CRLF-->

<!--CRLF-->

    
    -- 别名 -->
<!--CRLF-->
    typeAliases>
<!--CRLF-->
        typeAlias type="com.hoo.entity.Account" alias="account"/>
<!--CRLF-->
    typeAliases>
<!--CRLF-->
    
<!--CRLF-->
configuration>
<!--CRLF-->

上面的配置文件中,可以加入一些公共、常用的MyBatis方面的全局配置。如handler、objectFactory、plugin、以及mappers的映射路径(由于在applicationContext-common中的SqlSessionFactoryBean有配置mapper的location,这里就不需要配置)等。这个类的文件名称和下面的applicationContext-common.xml中的configLocation中的值对应,不是随便写的。

3、 在src目录中添加applicationContext-common.xml中加入内容如下:

xml version="1.0" encoding="UTF-8"?>
<!--CRLF-->
beans xmlns="http://www.springframework.org/schema/beans"
<!--CRLF-->
    xmlns:aop="http://www.springframework.org/schema/aop" 
<!--CRLF-->
    xmlns:tx="http://www.springframework.org/schema/tx"
<!--CRLF-->
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
<!--CRLF-->
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
<!--CRLF-->
    http://www.springframework.org/schema/beans/spring-beans-3.0.xsd 
<!--CRLF-->
    http://www.springframework.org/schema/aop 
<!--CRLF-->
    http://www.springframework.org/schema/aop/spring-aop-3.0.xsd 
<!--CRLF-->
    http://www.springframework.org/schema/tx  
<!--CRLF-->
    http://www.springframework.org/schema/tx/spring-tx-3.0.xsd ">
<!--CRLF-->
    
<!--CRLF-->
    -- 配置DataSource数据源 -->
<!--CRLF-->
    bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<!--CRLF-->
        property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<!--CRLF-->
        property name="url" value="jdbc:mysql://10.0.0.131:3306/ash2"/>
<!--CRLF-->
        property name="username" value="dev"/>
<!--CRLF-->
        property name="password" value="dev"/>
<!--CRLF-->
    bean>
<!--CRLF-->

<!--CRLF-->

    
    -- 配置SqlSessionFactoryBean -->
<!--CRLF-->
    bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
<!--CRLF-->
        property name="dataSource" ref="dataSource"/>
<!--CRLF-->
        property name="configLocation" value="classpath:mybatis.xml"/>
<!--CRLF-->
        -- mapper和resultmap配置路径 --> 
<!--CRLF-->
        property name="mapperLocations">
<!--CRLF-->
            list>
<!--CRLF-->
                -- 表示在com.hoo.resultmap包或以下所有目录中以-resultmap.xml结尾所有文件 --> 
<!--CRLF-->
                value>classpath:com/hoo/resultmap/**/*-resultmap.xmlvalue>
<!--CRLF-->
                value>classpath:com/hoo/entity/*-resultmap.xmlvalue>
<!--CRLF-->
                value>classpath:com/hoo/mapper/**/*-mapper.xmlvalue>
<!--CRLF-->
            list>
<!--CRLF-->
        property>
<!--CRLF-->
    bean>
<!--CRLF-->
    
<!--CRLF-->
    -- 配置事务管理器注意这里的dataSource和SqlSessionFactoryBean的dataSource要一致不然事务就没有作用了 -->
<!--CRLF-->
    bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<!--CRLF-->
        property name="dataSource" ref="dataSource" />
<!--CRLF-->
    bean>
<!--CRLF-->

<!--CRLF-->

    
    -- 配置事务的传播特性 -->
<!--CRLF-->
    bean id="baseTransactionProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean" abstract="true">
<!--CRLF-->
        property name="transactionManager" ref="transactionManager" />
<!--CRLF-->
        property name="transactionAttributes">
<!--CRLF-->
            props>
<!--CRLF-->
                prop key="add*">PROPAGATION_REQUIREDprop>
<!--CRLF-->
                prop key="edit*">PROPAGATION_REQUIREDprop>
<!--CRLF-->
                prop key="remove*">PROPAGATION_REQUIREDprop>
<!--CRLF-->
                prop key="insert*">PROPAGATION_REQUIREDprop>
<!--CRLF-->
                prop key="update*">PROPAGATION_REQUIREDprop>
<!--CRLF-->
                prop key="del*">PROPAGATION_REQUIREDprop>
<!--CRLF-->
                prop key="*">readOnlyprop>
<!--CRLF-->
            props>
<!--CRLF-->
        property>
<!--CRLF-->
    bean>
<!--CRLF-->
    
<!--CRLF-->
    -- 通过扫描的模式扫描目录在com/hoo/mapper目录下所有的mapper都继承SqlMapper接口的接口这样一个bean就可以了 -->
<!--CRLF-->
    bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<!--CRLF-->
        property name="basePackage" value="com.hoo.mapper"/>
<!--CRLF-->
        property name="markerInterface" value="com.hoo.mapper.SqlMapper"/>
<!--CRLF-->
    bean>
<!--CRLF-->
beans>
<!--CRLF-->

DataSource,这里的是采用jdbc的dataSource;

SqlSessionFactory,是MyBatis团队提供整合Spring的SqlSession工厂Bean用它可以完成Spring和MyBatis的整合。SqlSessionFactoryBean需要注入DataSource,配置myBatis配置文件的location,以及配置mapper.xml和resultMap.xml文件的路径,可以用通配符模式配置。其实mapper里面是可以存放resultMap的内容的。由于resultMap文件的内容是和JavaBean及数据库表对象进行映射的。一般一张表、一个JavaBean(Model)对应一个resultMap文件。将resultMap独立出来提供可读性、维护性。

TransactionManager,事务管理器是采用jdbc的管理器。需要注入DataSource数据源,这里注入的数据源和SqlSessionFactory是同一个数据源。如果不同的数据源,事务将无法起到作用。

baseTransactionProxy,事务的传播特性才有spring提供的TransactionProxyFactoryBean这个事务代理工厂的拦截器类来完成。其他的暂时还没有可以支持事务配置的传播特性和隔离级别的方法,关于这里你可以参考:http://www.cnblogs.com/hoojo/archive/2011/04/15/2017447.html

MapperScannerConfigurer是MyBatis的mapper接口的扫描器,通过这个配置可以完成对指定basePackage报下的类进行扫描,如果这些类有继承SqlMapper这个类的,将会是MyBatis的接口。不需要单独配置mapper,而完成注入。

4、 在src目录添加applicationContext-beans.xml这个文件,文件内容如下:

xml version="1.0" encoding="UTF-8"?>
<!--CRLF-->
beans xmlns="http://www.springframework.org/schema/beans"
<!--CRLF-->
    xmlns:context="http://www.springframework.org/schema/context"
<!--CRLF-->
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
<!--CRLF-->
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
<!--CRLF-->
    http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
<!--CRLF-->
    http://www.springframework.org/schema/context
<!--CRLF-->
    http://www.springframework.org/schema/context/spring-context-3.0.xsd">
<!--CRLF-->
    -- 注解探测器 -->
<!--CRLF-->
    context:component-scan base-package="com.hoo"/>
<!--CRLF-->
    
<!--CRLF-->
beans>
<!--CRLF-->

这里面可以完成一下Action、Bean的注入配置

5、 JavaBean(Model、Entity)相关类、及resultMap.xml文件内容

Bean

package com.hoo.entity;
<!--CRLF-->

<!--CRLF-->

    
import java.io.Serializable;
<!--CRLF-->
import java.util.Date;
<!--CRLF-->

<!--CRLF-->

    
public class Account implements Serializable {
<!--CRLF-->

<!--CRLF-->

    
    private static final long serialVersionUID = -7970848646314840509L;
<!--CRLF-->

<!--CRLF-->

    
    private Integer accountId;
<!--CRLF-->
    private String username;
<!--CRLF-->
    private String password;
<!--CRLF-->
    private Date createTime;
<!--CRLF-->
    
<!--CRLF-->
    public Account() {
<!--CRLF-->
        super();
<!--CRLF-->
    }
<!--CRLF-->
    //getter、setter
<!--CRLF-->
    
<!--CRLF-->
    @Override
<!--CRLF-->
    public String toString() {
<!--CRLF-->
        return this.accountId + "#" + this.username +  "#" + this.password +  "#" + this.createTime;
<!--CRLF-->
    }
<!--CRLF-->
}
<!--CRLF-->

account-resultMap.xml

xml version="1.0" encoding="UTF-8"?>
<!--CRLF-->
DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" 
<!--CRLF-->
    "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<!--CRLF-->
mapper namespace="accountMap">
<!--CRLF-->
    resultMap type="com.hoo.entity.Account" id="accountResultMap">
<!--CRLF-->
        id property="accountId" column="account_id"/>
<!--CRLF-->
        result property="username" column="username"/>
<!--CRLF-->
        result property="password" column="password"/>
<!--CRLF-->
        result property="createTime" column="create_time"/>
<!--CRLF-->
    resultMap>
<!--CRLF-->
mapper>
<!--CRLF-->

<!--CRLF-->

resultMap的type属性和对应的classpath对应,id会在mapper.xml文件中用到。下面的属性property是JavaBean的属性,column和数据库的字段对应。

6、 上面的applicationContext-common.xml中配置了SqlMapper,下面是SqlMapper代码,就一个空接口

package com.hoo.mapper;
<!--CRLF-->

<!--CRLF-->

    
/**
<!--CRLF-->
 * function:所有的Mapper继承这个接口
<!--CRLF-->
 * @author hoojo
<!--CRLF-->
 * @createDate 2011-4-12 下午04:00:31
<!--CRLF-->
 * @file SqlMapper.java
<!--CRLF-->
 * @package com.hoo.mapper
<!--CRLF-->
 * @project MyBatisForSpring
<!--CRLF-->
 * @blog http://blog.csdn.net/IBM_hoojo
<!--CRLF-->
 * @email hoojo_@126.com
<!--CRLF-->
 * @version 1.0
<!--CRLF-->
 */
<!--CRLF-->
public interface SqlMapper {
<!--CRLF-->
}
<!--CRLF-->

7、 定制我们自己的增删改查(CRUD)组件,接口如下

package com.hoo.mapper;
<!--CRLF-->

<!--CRLF-->

    
import java.util.List;
<!--CRLF-->
import org.springframework.dao.DataAccessException;
<!--CRLF-->

<!--CRLF-->

    
/**
<!--CRLF-->
 * function: BaseSqlMapper继承SqlMapper,对Mapper进行接口封装,提供常用的增删改查组件;
<!--CRLF-->
 * 也可以对该接口进行扩展和封装
<!--CRLF-->
 * @author hoojo
<!--CRLF-->
 * @createDate 2011-4-14 上午11:36:41
<!--CRLF-->
 * @file BaseSqlMapper.java
<!--CRLF-->
 * @package com.hoo.mapper
<!--CRLF-->
 * @project MyBatisForSpring
<!--CRLF-->
 * @blog http://blog.csdn.net/IBM_hoojo
<!--CRLF-->
 * @email hoojo_@126.com
<!--CRLF-->
 * @version 1.0
<!--CRLF-->
 */
<!--CRLF-->
public interface BaseSqlMapperT> extends SqlMapper {
<!--CRLF-->
    
<!--CRLF-->
    public void add(T entity) throws DataAccessException;
<!--CRLF-->
    
<!--CRLF-->
    public void edit(T entity) throws DataAccessException;
<!--CRLF-->
    
<!--CRLF-->
    public void remvoe(T entity) throws DataAccessException;
<!--CRLF-->
    
<!--CRLF-->
    public T get(T entity) throws DataAccessException;
<!--CRLF-->
    
<!--CRLF-->
    public ListT> getList(T entity) throws DataAccessException;
<!--CRLF-->
}
<!--CRLF-->

当然实际开发中,增删改查组件一定不止这几个方法。这里只是随便挪列几个方法做一个示例。实际中可以根据需求进行添加方法,这里添加的方法可以用一个mapper.xml进行实现,然后注入这个mapper即可完成操作。也可以定义其他的mapper,如AccountMapper继承这个接口。然后为AccountMapper提供实现也是可以的。

8、 下面看看AccountMapper接口

package com.hoo.mapper;
<!--CRLF-->

<!--CRLF-->

    
import java.util.List;
<!--CRLF-->
import com.hoo.entity.Account;
<!--CRLF-->

<!--CRLF-->

    
/**
<!--CRLF-->
 * function:继承SqlMapper,MyBatis数据操作接口;此接口无需实现类
<!--CRLF-->
 * @author hoojo
<!--CRLF-->
 * @createDate 2010-12-21 下午05:21:20
<!--CRLF-->
 * @file AccountMapper.java
<!--CRLF-->
 * @package com.hoo.mapper
<!--CRLF-->
 * @project MyBatis
<!--CRLF-->
 * @blog http://blog.csdn.net/IBM_hoojo
<!--CRLF-->
 * @email hoojo_@126.com
<!--CRLF-->
 * @version 1.0
<!--CRLF-->
 */
<!--CRLF-->
public interface AccountMapperT extends Account> extends BaseSqlMapperT> {
<!--CRLF-->
    
<!--CRLF-->
    public ListT> getAllAccount();
<!--CRLF-->
}
<!--CRLF-->

上面的AccountMapper继承了BaseSqlMapper,并且提供了自己所需要的方法。下面实现这个Mapper中和父接口的方法。

account-mapper.xml

xml version="1.0" encoding="UTF-8"?>
<!--CRLF-->
DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" 
<!--CRLF-->
    "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<!--CRLF-->
-- namespace和定义的Mapper接口对应并实现其中的方法 -->
<!--CRLF-->
mapper namespace="com.hoo.mapper.AccountMapper">
<!--CRLF-->

<!--CRLF-->

    
    select id="getList" parameterType="com.hoo.entity.Account" resultType="list" resultMap="accountResultMap">
<!--CRLF-->
            select * from account where username like '%' #{username} '%'
<!--CRLF-->
    select>
<!--CRLF-->
    
<!--CRLF-->
    select id="getAllAccount" resultType="list" resultMap="accountResultMap">
<!--CRLF-->
            select * from account
<!--CRLF-->
    select>
<!--CRLF-->
    
<!--CRLF-->
    -- accountResultMap是account-resultmap.xml中定义的resultmap -->
<!--CRLF-->
    select id="get" parameterType="account" resultType="com.hoo.entity.Account" resultMap="accountResultMap">
<!--CRLF-->
        [CDATA[
<!--CRLF-->
            select * from account where account_id = #{accountId}
<!--CRLF-->
        ]]>
<!--CRLF-->
    select>
<!--CRLF-->
    
<!--CRLF-->
    -- 自动生成id策略 -->
<!--CRLF-->
    insert id="add" useGeneratedKeys="true" keyProperty="account_id" parameterType="account">
<!--CRLF-->
        insert into account(account_id, username, password)
<!--CRLF-->
        values(#{accountId}, #{username}, #{password})
<!--CRLF-->
    insert>
<!--CRLF-->
    
<!--CRLF-->
    
<!--CRLF-->
    update id="edit" parameterType="account">
<!--CRLF-->
        update account set
<!--CRLF-->
        username = #{username},
<!--CRLF-->
        password = #{password}
<!--CRLF-->
        where account_id = #{accountId}
<!--CRLF-->
    update>
<!--CRLF-->
    
<!--CRLF-->
    delete id="remove" parameterType="account">
<!--CRLF-->
        delete from account where account_id = #{accountId}
<!--CRLF-->
    delete>
<!--CRLF-->
    
<!--CRLF-->
mapper>
<!--CRLF-->
mapper的namespace和接口的classpath对应,里面的sql语句的id和方法名称对应。这样就完成了AccountMapper的实现。

9、 下面来测试下AccountMapper的功能,代码如下:

package com.hoo.mapper;
<!--CRLF-->

<!--CRLF-->

    
import java.util.List;
<!--CRLF-->
import javax.inject.Inject;
<!--CRLF-->
import org.springframework.test.context.ContextConfiguration;
<!--CRLF-->
import org.springframework.test.context.junit38.AbstractJUnit38SpringContextTests;
<!--CRLF-->
import com.hoo.entity.Account;
<!--CRLF-->

<!--CRLF-->

    
/**
<!--CRLF-->
 * function: AccountMapper JUnit测试类
<!--CRLF-->
 * @author hoojo
<!--CRLF-->
 * @createDate 2011-4-12 下午04:21:50
<!--CRLF-->
 * @file AccountMapperTest.java
<!--CRLF-->
 * @package com.hoo.mapper
<!--CRLF-->
 * @project MyBatisForSpring
<!--CRLF-->
 * @blog http://blog.csdn.net/IBM_hoojo
<!--CRLF-->
 * @email hoojo_@126.com
<!--CRLF-->
 * @version 1.0
<!--CRLF-->
 */
<!--CRLF-->

<!--CRLF-->

    
@ContextConfiguration("classpath:applicationContext-*.xml")
<!--CRLF-->
public class AccountMapperTest extends AbstractJUnit38SpringContextTests {
<!--CRLF-->
    
<!--CRLF-->
    @Inject
<!--CRLF-->
    private AccountMapperAccount> mapper;
<!--CRLF-->
    
<!--CRLF-->
    public void testGetAccount() {
<!--CRLF-->
        Account acc = new Account();
<!--CRLF-->
        acc.setAccountId(28);
<!--CRLF-->
        System.out.println(mapper.get(acc));
<!--CRLF-->
    }
<!--CRLF-->
    
<!--CRLF-->
    public void testAdd() {
<!--CRLF-->
        Account account = new Account();
<!--CRLF-->
        account.setUsername("lisi@155.com");
<!--CRLF-->
        account.setPassword("abc");
<!--CRLF-->
        mapper.add(account);
<!--CRLF-->
    }
<!--CRLF-->
    
<!--CRLF-->
    public void testEditAccount() {
<!--CRLF-->
        Account acc = new Account();
<!--CRLF-->
        acc.setAccountId(28);
<!--CRLF-->
        acc = mapper.get(acc);
<!--CRLF-->
        System.out.println(acc);
<!--CRLF-->
        acc.setUsername("Zhangsan22");
<!--CRLF-->
        acc.setPassword("123123");
<!--CRLF-->
        mapper.edit(acc);
<!--CRLF-->
        System.out.println(mapper.get(acc));
<!--CRLF-->
    }
<!--CRLF-->
    
<!--CRLF-->
    public void testRemoveAccount() {
<!--CRLF-->
        Account acc = new Account();
<!--CRLF-->
        acc.setAccountId(28);
<!--CRLF-->
        mapper.remvoe(acc);
<!--CRLF-->
        System.out.println(mapper.get(acc));
<!--CRLF-->
    }
<!--CRLF-->
    
<!--CRLF-->
    public void testAccountList() {
<!--CRLF-->
        ListAccount> acc = mapper.getAllAccount();
<!--CRLF-->
        System.out.println(acc.size());
<!--CRLF-->
        System.out.println(acc);
<!--CRLF-->
    }
<!--CRLF-->
    
<!--CRLF-->
    public void testList() {
<!--CRLF-->
        Account acc = new Account();
<!--CRLF-->
        acc.setUsername("@qq.com");
<!--CRLF-->
        ListAccount> list = mapper.getList(acc);
<!--CRLF-->
        System.out.println(list.size());
<!--CRLF-->
        System.out.println(list);
<!--CRLF-->
    }
<!--CRLF-->
}
<!--CRLF-->

运行上面的方法,没有错误基本上就算完成了Mapper的功能了。

10、 下面来写一个数据库操作的基类Dao,代码如下:

package com.hoo.dao;
<!--CRLF-->

<!--CRLF-->

    
import java.util.List;
<!--CRLF-->
import com.hoo.mapper.BaseSqlMapper;
<!--CRLF-->

<!--CRLF-->

    
/**
<!--CRLF-->
 * function:
<!--CRLF-->
 * @author hoojo
<!--CRLF-->
 * @createDate 2011-4-14 上午11:30:09
<!--CRLF-->
 * @file BaseMapperDao.java
<!--CRLF-->
 * @package com.hoo.dao
<!--CRLF-->
 * @project MyBatisForSpring
<!--CRLF-->
 * @blog http://blog.csdn.net/IBM_hoojo
<!--CRLF-->
 * @email hoojo_@126.com
<!--CRLF-->
 * @version 1.0
<!--CRLF-->
 */
<!--CRLF-->
public interface BaseMapperDaoT> {
<!--CRLF-->
    
<!--CRLF-->
    @SuppressWarnings("unchecked")
<!--CRLF-->
    public void setMapperClass(Class? extends BaseSqlMapper> mapperClass);
<!--CRLF-->
    
<!--CRLF-->
    public BaseSqlMapperT> getMapper();
<!--CRLF-->
    
<!--CRLF-->
    public boolean add(T entity) throws Exception;
<!--CRLF-->
    
<!--CRLF-->
    public boolean edit(T entity) throws Exception;
<!--CRLF-->
    
<!--CRLF-->
    public boolean remove(T entity) throws Exception;
<!--CRLF-->
    
<!--CRLF-->
    public T get(T entity) throws Exception;
<!--CRLF-->
    
<!--CRLF-->
    public ListT> getAll(T entity) throws Exception;
<!--CRLF-->
}
<!--CRLF-->

这个Dao定义了BaseSqlMapper中的方法,还提供了一个setMapperClass的方法。目的是在使用这个dao的时候,需要设置一个Mapper的class。且这个Mapper必须要是BaseSqlMapper或它的子类。所有的dao都可以用BaseMapperDao来完成CRUD操作即可,当BaseMapperDao的方法不够用的情况下,可以在接口中提供SqlSession、SqlSessionTemplate方法,让底层人员自己扩展所需要的方法。这里的dao和mapper好像有点冗余,因为dao和mapper完成的功能都是类似或是相同的。但是你可以在dao中,同时调用不同的mapper,来完成当前模块的dao所需要的功能。

11、 看看BaseMapperDao的实现代码

package com.hoo.dao.impl;
<!--CRLF-->

<!--CRLF-->

    
import java.util.List;
<!--CRLF-->
import javax.inject.Inject;
<!--CRLF-->
import org.apache.ibatis.session.SqlSessionFactory;
<!--CRLF-->
import org.mybatis.spring.SqlSessionTemplate;
<!--CRLF-->
import org.springframework.stereotype.Repository;
<!--CRLF-->
import com.hoo.dao.BaseMapperDao;
<!--CRLF-->
import com.hoo.mapper.BaseSqlMapper;
<!--CRLF-->

<!--CRLF-->

    
/**
<!--CRLF-->
 * function:运用SqlSessionTemplate封装Dao常用增删改方法,可以进行扩展
<!--CRLF-->
 * @author hoojo
<!--CRLF-->
 * @createDate 2011-4-14 下午12:22:07
<!--CRLF-->
 * @file BaseMapperDaoImpl.java
<!--CRLF-->
 * @package com.hoo.dao.impl
<!--CRLF-->
 * @project MyBatisForSpring
<!--CRLF-->
 * @blog http://blog.csdn.net/IBM_hoojo
<!--CRLF-->
 * @email hoojo_@126.com
<!--CRLF-->
 * @version 1.0
<!--CRLF-->
 */
<!--CRLF-->
@SuppressWarnings("unchecked")
<!--CRLF-->
@Repository
<!--CRLF-->
public class BaseMapperDaoImplT> extends SqlSessionTemplate implements BaseMapperDaoT> {
<!--CRLF-->
    
<!--CRLF-->
    @Inject
<!--CRLF-->
    public BaseMapperDaoImpl(SqlSessionFactory sqlSessionFactory) {
<!--CRLF-->
        super(sqlSessionFactory);
<!--CRLF-->
    }
<!--CRLF-->
    
<!--CRLF-->
    private Class? extends BaseSqlMapper> mapperClass;
<!--CRLF-->
    
<!--CRLF-->
    public void setMapperClass(Class? extends BaseSqlMapper> mapperClass) {
<!--CRLF-->
        this.mapperClass = mapperClass;
<!--CRLF-->
    }
<!--CRLF-->

<!--CRLF-->

    
    public BaseSqlMapperT> getMapper() {
<!--CRLF-->
        return this.getMapper(mapperClass);
<!--CRLF-->
    }
<!--CRLF-->
    
<!--CRLF-->
    public boolean add(T entity) throws Exception {
<!--CRLF-->
        boolean flag = false;
<!--CRLF-->
        try {
<!--CRLF-->
            this.getMapper().add(entity);
<!--CRLF-->
            flag = true;
<!--CRLF-->
        } catch (Exception e) {
<!--CRLF-->
            flag = false;
<!--CRLF-->
            throw e;
<!--CRLF-->
        }
<!--CRLF-->
        return flag;
<!--CRLF-->
    }
<!--CRLF-->

<!--CRLF-->

    
    public boolean edit(T entity) throws Exception {
<!--CRLF-->
        boolean flag = false;
<!--CRLF-->
        try {
<!--CRLF-->
            this.getMapper().edit(entity);
<!--CRLF-->
            flag = true;
<!--CRLF-->
        } catch (Exception e) {
<!--CRLF-->
            flag = false;
<!--CRLF-->
            throw e;
<!--CRLF-->
        }
<!--CRLF-->
        return flag;
<!--CRLF-->
    }
<!--CRLF-->

<!--CRLF-->

    
    public T get(T entity) throws Exception {
<!--CRLF-->
        return this.getMapper().get(entity);
<!--CRLF-->
    }
<!--CRLF-->

<!--CRLF-->

    
    public ListT> getAll() throws Exception {
<!--CRLF-->
        return this.getMapper().getList(null);
<!--CRLF-->
    }
<!--CRLF-->

<!--CRLF-->

    
    public boolean remove(T entity) throws Exception {
<!--CRLF-->
        boolean flag = false;
<!--CRLF-->
        try {
<!--CRLF-->
            this.getMapper().remvoe(entity);
<!--CRLF-->
            flag = true;
<!--CRLF-->
        } catch (Exception e) {
<!--CRLF-->
            flag = false;
<!--CRLF-->
            throw e;
<!--CRLF-->
        }
<!--CRLF-->
        return flag;
<!--CRLF-->
    }
<!--CRLF-->
}
<!--CRLF-->

这个实现类继承了SqlSessionTemplate,并且要注入SqlSessionFactory。提供的setMapperClass方法需要设置其BaseSqlMapper或它的子类。

好了,至此基本的CRUD的mapper和dao就算完成了。现在我们可以定义我们自己的业务模块,调用公共组件来完成增删改查操作。

12、 下面测试下这个BaseMapperDao功能

package com.hoo.dao;
<!--CRLF-->

<!--CRLF-->

    
import javax.inject.Inject;
<!--CRLF-->
import org.junit.Before;
<!--CRLF-->
import org.springframework.test.context.ContextConfiguration;
<!--CRLF-->
import org.springframework.test.context.junit38.AbstractJUnit38SpringContextTests;
<!--CRLF-->
import com.hoo.entity.Account;
<!--CRLF-->
import com.hoo.mapper.AccountMapper;
<!--CRLF-->

<!--CRLF-->

    
/**
<!--CRLF-->
 * function:
<!--CRLF-->
 * @author hoojo
<!--CRLF-->
 * @createDate 2011-4-14 下午01:08:49
<!--CRLF-->
 * @file BaseMapperDaoImplTest.java
<!--CRLF-->
 * @package com.hoo.dao
<!--CRLF-->
 * @project MyBatisForSpring
<!--CRLF-->
 * @blog http://blog.csdn.net/IBM_hoojo
<!--CRLF-->
 * @email hoojo_@126.com
<!--CRLF-->
 * @version 1.0
<!--CRLF-->
 */
<!--CRLF-->
@ContextConfiguration("classpath:applicationContext-*.xml")
<!--CRLF-->
public class BaseMapperDaoImplTest extends AbstractJUnit38SpringContextTests {
<!--CRLF-->
    
<!--CRLF-->
    @Inject
<!--CRLF-->
    private BaseMapperDaoAccount> dao;
<!--CRLF-->
    
<!--CRLF-->
    @Before
<!--CRLF-->
    public void init() {
<!--CRLF-->
        System.out.println(dao);
<!--CRLF-->
        dao.setMapperClass(AccountMapper.class);
<!--CRLF-->
    }
<!--CRLF-->
    
<!--CRLF-->
    public void testGet() throws Exception {
<!--CRLF-->
        init();
<!--CRLF-->
        Account acc = new Account();
<!--CRLF-->
        acc.setAccountId(28);
<!--CRLF-->
        System.out.println(dao.get(acc));
<!--CRLF-->
    }
<!--CRLF-->
    
<!--CRLF-->
    public void testAdd() throws Exception {
<!--CRLF-->
        init();
<!--CRLF-->
        Account account = new Account();
<!--CRLF-->
        account.setUsername("temp@156.com");
<!--CRLF-->
        account.setPassword("abc");
<!--CRLF-->
        System.out.println(dao.add(account));
<!--CRLF-->
    }
<!--CRLF-->
}
<!--CRLF-->

13、 下面定义AccountDao接口

package com.hoo.dao;
<!--CRLF-->

<!--CRLF-->

    
import java.util.List;
<!--CRLF-->
import org.springframework.dao.DataAccessException;
<!--CRLF-->

<!--CRLF-->

    
/**
<!--CRLF-->
 * function: Account数据库操作dao接口
<!--CRLF-->
 * @author hoojo
<!--CRLF-->
 * @createDate 2011-4-13 上午10:21:38
<!--CRLF-->
 * @file AccountDao.java
<!--CRLF-->
 * @package com.hoo.dao
<!--CRLF-->
 * @project MyBatisForSpring
<!--CRLF-->
 * @blog http://blog.csdn.net/IBM_hoojo
<!--CRLF-->
 * @email hoojo_@126.com
<!--CRLF-->
 * @version 1.0
<!--CRLF-->
 */
<!--CRLF-->
public interface AccountDaoT> {
<!--CRLF-->
    
<!--CRLF-->
    /**
<!--CRLF-->
     * function: 添加Account对象信息
<!--CRLF-->
     * @author hoojo
<!--CRLF-->
     * @createDate 2011-4-13 上午11:50:05
<!--CRLF-->
     * @param entity Account
<!--CRLF-->
     * @return boolean 是否成功
<!--CRLF-->
     * @throws DataAccessException
<!--CRLF-->
     */
<!--CRLF-->
    public boolean addAccount(T entity) throws DataAccessException;
<!--CRLF-->
    
<!--CRLF-->
    /**
<!--CRLF-->
     * function: 根据id对到Account信息
<!--CRLF-->
     * @author hoojo
<!--CRLF-->
     * @createDate 2011-4-13 上午11:50:45
<!--CRLF-->
     * @param id 编号id
<!--CRLF-->
     * @return Account
<!--CRLF-->
     * @throws DataAccessException
<!--CRLF-->
     */
<!--CRLF-->
    public T getAccount(Integer id) throws DataAccessException;
<!--CRLF-->
    
<!--CRLF-->
    /**
<!--CRLF-->
     * function: 查询所有Account信息
<!--CRLF-->
     * @author hoojo
<!--CRLF-->
     * @createDate 2011-4-13 上午11:51:45
<!--CRLF-->
     * @param id 编号id
<!--CRLF-->
     * @return Account
<!--CRLF-->
     * @throws DataAccessException
<!--CRLF-->
     */
<!--CRLF-->
    public ListT> getList() throws DataAccessException;
<!--CRLF-->
}
<!--CRLF-->

14、 AccountDao实现类

package com.hoo.dao.impl;
<!--CRLF-->

<!--CRLF-->

    
import java.util.List;
<!--CRLF-->
import javax.inject.Inject;
<!--CRLF-->
import org.springframework.dao.DataAccessException;
<!--CRLF-->
import org.springframework.stereotype.Repository;
<!--CRLF-->
import com.hoo.dao.AccountDao;
<!--CRLF-->
import com.hoo.dao.BaseMapperDao;
<!--CRLF-->
import com.hoo.entity.Account;
<!--CRLF-->
import com.hoo.mapper.AccountMapper;
<!--CRLF-->

<!--CRLF-->

    
/**
<!--CRLF-->
 * function: Account数据库操作dao
<!--CRLF-->
 * @author hoojo
<!--CRLF-->
 * @createDate 2011-4-13 上午10:25:02
<!--CRLF-->
 * @file AccountDaoImpl.java
<!--CRLF-->
 * @package com.hoo.dao.impl
<!--CRLF-->
 * @project MyBatisForSpring
<!--CRLF-->
 * @blog http://blog.csdn.net/IBM_hoojo
<!--CRLF-->
 * @email hoojo_@126.com
<!--CRLF-->
 * @version 1.0
<!--CRLF-->
 */
<!--CRLF-->
@SuppressWarnings("unchecked")
<!--CRLF-->
@Repository
<!--CRLF-->
public class AccountDaoImplT extends Account> implements AccountDaoT> {
<!--CRLF-->
    
<!--CRLF-->
    @Inject
<!--CRLF-->
    private BaseMapperDaoAccount> dao;
<!--CRLF-->
    
<!--CRLF-->
    public boolean addAccount(T entity) throws DataAccessException {
<!--CRLF-->
        dao.setMapperClass(AccountMapper.class);
<!--CRLF-->
        boolean flag = false;
<!--CRLF-->
        try {
<!--CRLF-->
            dao.add(entity);
<!--CRLF-->
            flag = true;
<!--CRLF-->
        } catch (DataAccessException e) {
<!--CRLF-->
            flag = false;
<!--CRLF-->
            throw e;
<!--CRLF-->
        } catch (Exception e) {
<!--CRLF-->
            throw new RuntimeException(e); 
<!--CRLF-->
        }
<!--CRLF-->
        return flag;
<!--CRLF-->
    }
<!--CRLF-->

<!--CRLF-->

    
    public T getAccount(Integer id) throws DataAccessException {
<!--CRLF-->
        dao.setMapperClass(AccountMapper.class);
<!--CRLF-->
        Account acc = new Account();
<!--CRLF-->
        T entity = null;
<!--CRLF-->
        try {
<!--CRLF-->
            acc.setAccountId(id);
<!--CRLF-->
            entity  = (T) dao.get(acc);
<!--CRLF-->
        } catch (DataAccessException e) {
<!--CRLF-->
            throw e;
<!--CRLF-->
        } catch (Exception e) {
<!--CRLF-->
            throw new RuntimeException(e); 
<!--CRLF-->
        }
<!--CRLF-->
        return entity;
<!--CRLF-->
    }
<!--CRLF-->

<!--CRLF-->

    
    public ListT> getList() throws DataAccessException {
<!--CRLF-->
        dao.setMapperClass(AccountMapper.class);
<!--CRLF-->
        ListT> list = null;
<!--CRLF-->
        try {
<!--CRLF-->
            list = (ListT>) ((AccountMapper)dao.getMapper()).getAllAcount();
<!--CRLF-->
        } catch (DataAccessException e) {
<!--CRLF-->
            throw e;
<!--CRLF-->
        } catch (Exception e) {
<!--CRLF-->
            throw new RuntimeException(e); 
<!--CRLF-->
        }
<!--CRLF-->
        return list;
<!--CRLF-->
    }
<!--CRLF-->
}
<!--CRLF-->

注意,上面的方法都设置了MapperClass,表示当前dao的Mapper是AccountMapper对象。所有的mapper方法都是调用AccountMapper这个对象中的方法。

15、 下面定义服务器层接口

package com.hoo.biz;
<!--CRLF-->

<!--CRLF-->

    
import java.util.List;
<!--CRLF-->
import org.springframework.dao.DataAccessException;
<!--CRLF-->

<!--CRLF-->

    
/**
<!--CRLF-->
 * function: biz层Account接口
<!--CRLF-->
 * @author hoojo
<!--CRLF-->
 * @createDate 2011-4-13 上午11:33:04
<!--CRLF-->
 * @file AccountBiz.java
<!--CRLF-->
 * @package com.hoo.biz
<!--CRLF-->
 * @project MyBatisForSpring
<!--CRLF-->
 * @blog http://blog.csdn.net/IBM_hoojo
<!--CRLF-->
 * @email hoojo_@126.com
<!--CRLF-->
 * @version 1.0
<!--CRLF-->
 */
<!--CRLF-->
public interface AccountBizT> {
<!--CRLF-->
    /**
<!--CRLF-->
     * function: 添加Account对象信息
<!--CRLF-->
     * @author hoojo
<!--CRLF-->
     * @createDate 2011-4-13 上午11:50:05
<!--CRLF-->
     * @param entity Account
<!--CRLF-->
     * @return boolean 是否成功
<!--CRLF-->
     * @throws DataAccessException
<!--CRLF-->
     */
<!--CRLF-->
    public boolean addAccount(T entity) throws DataAccessException;
<!--CRLF-->
    
<!--CRLF-->
    public boolean execute(T entity) throws DataAccessException;
<!--CRLF-->
    
<!--CRLF-->
    /**
<!--CRLF-->
     * function: 根据id对到Account信息
<!--CRLF-->
     * @author hoojo
<!--CRLF-->
     * @createDate 2011-4-13 上午11:50:45
<!--CRLF-->
     * @param id 编号id
<!--CRLF-->
     * @return Account
<!--CRLF-->
     * @throws DataAccessException
<!--CRLF-->
     */
<!--CRLF-->
    public T getAccount(Integer id) throws DataAccessException;
<!--CRLF-->
    
<!--CRLF-->
    /**
<!--CRLF-->
     * function: 查询所有Account信息
<!--CRLF-->
     * @author hoojo
<!--CRLF-->
     * @createDate 2011-4-13 上午11:51:45
<!--CRLF-->
     * @param id 编号id
<!--CRLF-->
     * @return Account
<!--CRLF-->
     * @throws DataAccessException
<!--CRLF-->
     */
<!--CRLF-->
    public ListT> getList() throws DataAccessException;
<!--CRLF-->
}
<!--CRLF-->

16、 AccountBiz的实现代码

package com.hoo.biz.impl;
<!--CRLF-->

<!--CRLF-->

    
import java.util.List;
<!--CRLF-->
import javax.inject.Inject;
<!--CRLF-->
import org.springframework.dao.DataAccessException;
<!--CRLF-->
import org.springframework.stereotype.Component;
<!--CRLF-->
import com.hoo.biz.AccountBiz;
<!--CRLF-->
import com.hoo.dao.AccountDao;
<!--CRLF-->
import com.hoo.entity.Account;
<!--CRLF-->
import com.hoo.exception.BizException;
<!--CRLF-->

<!--CRLF-->

    
/**
<!--CRLF-->
 * function: Account Biz接口实现
<!--CRLF-->
 * @author hoojo
<!--CRLF-->
 * @createDate 2011-4-13 上午11:34:39
<!--CRLF-->
 * @file AccountBizImpl.java
<!--CRLF-->
 * @package com.hoo.biz.impl
<!--CRLF-->
 * @project MyBatisForSpring
<!--CRLF-->
 * @blog http://blog.csdn.net/IBM_hoojo
<!--CRLF-->
 * @email hoojo_@126.com
<!--CRLF-->
 * @version 1.0
<!--CRLF-->
 */
<!--CRLF-->
//@Component
<!--CRLF-->
@Service
<!--CRLF-->
public class AccountBizImplT extends Account> implements AccountBizT> {
<!--CRLF-->
    
<!--CRLF-->
    @Inject
<!--CRLF-->
    private AccountDaoT> dao;
<!--CRLF-->
    
<!--CRLF-->
    public boolean addAccount(T entity) throws DataAccessException {
<!--CRLF-->
        if (entity == null) {
<!--CRLF-->
            throw new BizException(Account.class.getName() + "对象参数信息为Empty!");
<!--CRLF-->
        }
<!--CRLF-->
        return dao.addAccount(entity);
<!--CRLF-->
    }
<!--CRLF-->

<!--CRLF-->

    
    public T getAccount(Integer id) throws DataAccessException {
<!--CRLF-->
        return dao.getAccount(id);
<!--CRLF-->
    }
<!--CRLF-->

<!--CRLF-->

    
    public ListT> getList() throws DataAccessException {
<!--CRLF-->
        return dao.getList();
<!--CRLF-->
    }
<!--CRLF-->

<!--CRLF-->

    
    public boolean execute(T entity) throws DataAccessException {
<!--CRLF-->
        
<!--CRLF-->
        if (entity == null) {
<!--CRLF-->
            throw new BizException(Account.class.getName() + "对象参数信息为Empty!");
<!--CRLF-->
        }
<!--CRLF-->
        return dao.addAccount(entity);
<!--CRLF-->
    }
<!--CRLF-->
}
<!--CRLF-->

直接注入AccountDao完成相关操作即可

17、 如果你需要在业务层设置事务传播特性,需要在applicationContext-bean.xml中加入配置如下:

-- 为AccountBiz接口配置事务拦截器baseTransactionProxy是事务拦截器在Action中获取这个对象 -->
<!--CRLF-->
bean id="accountBiz" parent="baseTransactionProxy">
<!--CRLF-->
    -- 设置target也就是AccountBiz的实现类 -->
<!--CRLF-->
    property name="target" ref="accountBizImpl"/>
<!--CRLF-->
bean>
<!--CRLF-->

这样在Action中注入accountBiz这个对象后,那么当这个对象出现DataAccessException异常的时候,就会自动回滚事务。

至此,Spring和MyBatis的整合就完成了。

分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics