Spring IBatis Struts2 集成(包含junit)

#c3p0 数据源配置;
jdbc.driverClassName=oracle.jdbc.OracleDriver
jdbc.url=jdbc:oracle:thin:@192.168.0.8:1521:orcl10
jdbc.username=aofeng
jdbc.password=aofeng

# 连接池完成初始化后建立的连接数量
initialPoolSize=0

# 连接池的最小连接数量
minPoolSize=2

# 连接池的最大连接数量
maxPoolSize=10

# 连接的最大空闲时间（单位：秒），当连接空闲超时此时间后，连接将被回收
maxIdleTime=1000

idleConnectionTestPeriod=1000

/**
 * 建立时间：2011-3-19
 */
package cn.aofeng.sis.domain;

import java.util.Date;

/**
 * 表USER对应的持久层POJO.
 *
 * @author 傲风 <a href="mailto:[email protected]">[email protected]</a>
 */
public class User {

    /**
     * This field corresponds to the database column USER.USER_ID
     */
    private Long userId;

    /**
     * This field corresponds to the database column USER.USER_TYPE
     */
    private Short userType;

    /**
     * This field corresponds to the database column USER.USER_STATUS
     */
    private Short userStatus;

    /**
     * This field corresponds to the database column USER.USER_NAME
     */
    private String userName;

    /**
     * This field corresponds to the database column USER.USER_PASSWD
     */
    private String userPasswd;

    /**
     * This field corresponds to the database column USER.CREATE_TIME
     */
    private Date createTime;

    /**
     * This field corresponds to the database column USER.UPDATE_TIME
     */
    private Date updateTime;

    /**
     * This field corresponds to the database column USER.LAST_LOGIN_TIME
     */
    private Date lastLoginTime;

    /**
     * This method returns the value of the database column USER.USER_ID
     *
     * @return the value of USER.USER_ID
     */
    public Long getUserId() {
        return userId;
    }

    /**
     * This method sets the value of the database column USER.USER_ID
     *
     * @param userId the value for USER.USER_ID
     */
    public void setUserId(Long userId) {
        this.userId = userId;
    }

    /**
     * This method returns the value of the database column USER.USER_TYPE
     *
     * @return the value of USER.USER_TYPE
     */
    public Short getUserType() {
        return userType;
    }

    /**
     * This method sets the value of the database column USER.USER_TYPE
     *
     * @param userType the value for USER.USER_TYPE
     */
    public void setUserType(Short userType) {
        this.userType = userType;
    }

    /**
     * This method returns the value of the database column USER.USER_STATUS
     *
     * @return the value of USER.USER_STATUS
     */
    public Short getUserStatus() {
        return userStatus;
    }

    /**
     * This method sets the value of the database column USER.USER_STATUS
     *
     * @param userStatus the value for USER.USER_STATUS
     */
    public void setUserStatus(Short userStatus) {
        this.userStatus = userStatus;
    }

    /**
     * This method returns the value of the database column USER.USER_NAME
     *
     * @return the value of USER.USER_NAME
     */
    public String getUserName() {
        return userName;
    }

    /**
     * This method sets the value of the database column USER.USER_NAME
     *
     * @param userName the value for USER.USER_NAME
     */
    public void setUserName(String userName) {
        this.userName = userName;
    }

    /**
     * This method returns the value of the database column USER.USER_PASSWD
     *
     * @return the value of USER.USER_PASSWD
     */
    public String getUserPasswd() {
        return userPasswd;
    }

    /**
     * This method sets the value of the database column USER.USER_PASSWD
     *
     * @param userPasswd the value for USER.USER_PASSWD
     */
    public void setUserPasswd(String userPasswd) {
        this.userPasswd = userPasswd;
    }

    /**
     * This method returns the value of the database column USER.CREATE_TIME
     *
     * @return the value of USER.CREATE_TIME
     */
    public Date getCreateTime() {
        return createTime;
    }

    /**
     * This method sets the value of the database column USER.CREATE_TIME
     *
     * @param createTime the value for USER.CREATE_TIME
     */
    public void setCreateTime(Date createTime) {
        this.createTime = createTime;
    }

    /**
     * This method returns the value of the database column USER.UPDATE_TIME
     *
     * @return the value of USER.UPDATE_TIME
     */
    public Date getUpdateTime() {
        return updateTime;
    }

    /**
     * This method sets the value of the database column USER.UPDATE_TIME
     *
     * @param updateTime the value for USER.UPDATE_TIME
     */
    public void setUpdateTime(Date updateTime) {
        this.updateTime = updateTime;
    }

    /**
     * This method returns the value of the database column USER.LAST_LOGIN_TIME
     *
     * @return the value of USER.LAST_LOGIN_TIME
     */
    public Date getLastLoginTime() {
        return lastLoginTime;
    }

    /**
     * This method sets the value of the database column USER.LAST_LOGIN_TIME
     *
     * @param lastLoginTime the value for USER.LAST_LOGIN_TIME
     */
    public void setLastLoginTime(Date lastLoginTime) {
        this.lastLoginTime = lastLoginTime;
    }

}

/**
 * 建立时间：2011-3-19
 */
package cn.aofeng.sis.dao;

import cn.aofeng.sis.domain.User;

/**
 * 账号表User DAO接口定义.
 *
 * @author 傲风 <a href="mailto:[email protected]">[email protected]</a>
 */
public interface UserDAO {

    /**
     * 根据账号ID删除账号.
     * 
     * @param userId 账号ID.
     * @return 返回1表示成功，返回0表示失败.
     */
    int deleteByUserId(Long userId);
    
    /**
     * 根据账号ID查询账号信息.
     * 
     * @param userId 账号ID.
     * @return 如果查询成功返回一个@{link com.ailk.dm.odomain.testportal.domain.TestPtlUser}实例；查找不到返回null.
     */
    User selectByUserId(Long userId);
    
    /**
     * 根据账号名称询账号信息.
     * 
     * @param userName 账号名称.
     * @return 如果查询成功返回一个@{link com.ailk.dm.odomain.testportal.domain.TestPtlUser}实例；查找不到返回null.
     */
    User selectByUserName(String userName);

}

/**
 * 建立时间：2011-3-19
 */
package cn.aofeng.sis.dao;

import cn.aofeng.sis.domain.User;

import javax.annotation.Resource;

import org.springframework.orm.ibatis.SqlMapClientTemplate;
import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

/**
 * 账号表User DAO IBatis实现.
 *
 * @author 傲风 <a href="mailto:[email protected]">[email protected]</a>
 */
@Repository("userDAO")
@Transactional(propagation=Propagation.SUPPORTS, readOnly=true)
public class UserDAOImpl implements UserDAO {
    
    @Resource(name="sqlMapClientTemplate")
    private SqlMapClientTemplate _sqlMapClientTemplate;
    
    protected SqlMapClientTemplate getSqlMapClientTemplate() {
        return _sqlMapClientTemplate;
    }
    
    protected String getNamespace() {
        return "USER";
    }
    
    @Transactional(propagation=Propagation.REQUIRED, readOnly=false)
    public int deleteByUserId(Long userId) {
        int result = getSqlMapClientTemplate().delete(getNamespace() + ".deleteByUserId", userId);
        
        return result;
    }

    public User selectByUserId(Long userId) {
        User param = new User();
        param.setUserId(userId);
        
        return (User) getSqlMapClientTemplate().queryForObject(getNamespace() + ".selectByUserIdOrUserName", param);
    }

    public User selectByUserName(String userName) {
        User param = new User();
        param.setUserName(userName);
        
        return (User) getSqlMapClientTemplate().queryForObject(getNamespace() + ".selectByUserIdOrUserName", param);
    }

}

/**
 * 建立时间：2011-3-19
 */
package cn.aofeng.sis.dao;

import java.util.Date;

import org.springframework.test.context.junit4.AbstractTransactionalJUnit4SpringContextTests;

import cn.aofeng.sis.domain.UserStatus;
import cn.aofeng.sis.domain.UserType;

/**
 * DAO单元测试公用类.
 *
 * @author 傲风 <a href="mailto:[email protected]">[email protected]</a>
 */
public class DaoBaseTestCase extends AbstractTransactionalJUnit4SpringContextTests {

    /**
     * Default constructor.
     */
    public DaoBaseTestCase() {
        
    }

    /**
     * 向数据库插入一条账号记录.
     * 
     * @param userId 账号ID.
     * @return 插入记录成功返回1；插入记录失败返回0.
     */
    public int insertUser(Long userId) {
        final String  sql = "insert into USER(USER_ID, USER_TYPE, USER_STATUS, USER_NAME, USER_PASSWD, CREATE_TIME, UPDATE_TIME) values(?, ?, ?, ?, ?, ?, ?)";
        int result = simpleJdbcTemplate.update(sql, userId, UserType.OPERATOR, UserStatus.NORMAL, "aofeng"+userId, "aofeng", new Date(), new Date());
        
        return result;
    }
    
    /**
     * 删除指定账号ID的账号记录.
     * 
     * @param userId 账号ID.
     * @return 删除记录成功返回1；删除记录失败返回0.
     */
    public int deleteUserByUserId(Long userId) {
        final String  sql = "delete from USER where USER_ID = ?";
        int result = simpleJdbcTemplate.update(sql, userId);
        
        return result;
    }

}

/**
 * 建立时间：2011-3-19
 */
package cn.aofeng.sis.dao;

import static org.junit.Assert.*;

import javax.annotation.Resource;

import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.springframework.test.context.ContextConfiguration;

import cn.aofeng.sis.domain.User;

/**
 * {@link cn.aofemg.sis.dao.UserDAOImpl}的单元测试代码.
 *
 * @author 傲风 <a href="mailto:[email protected]">[email protected]</a>
 */
@ContextConfiguration(locations={"/ApplicationContext.xml"}, inheritLocations=false)
public class UserDAOImplTest extends DaoBaseTestCase {

    protected Long _userId = 1L;
    
    @Resource(name="userDAO")
    protected UserDAO _userDAO;
    
    /**
     * @throws java.lang.Exception
     */
    @Before
    public void setUp() throws Exception {
        int result = super.insertUser(_userId);
        
        assertEquals(1, result);
    }
    
    /**
     * @throws java.lang.Exception
     */
    @After
    public void tearDown() throws Exception {
        @SuppressWarnings("unused")
        int result = super.deleteUserByUserId(_userId);
    }
    
    /**
     * Test method for {@link cn.aofeng.sis.dao.UserDAOImpl#deleteByUserId(java.lang.Long)}.
     */
    @Test
    public void testDeleteByUserIdForExist() {
        // 测试删除已经存在的记录.
        int result = _userDAO.deleteByUserId(_userId);
        assertEquals(1, result);
    }
    
    /**
     * Test method for {@link cn.aofeng.sis.dao.UserDAOImpl#deleteByUserId(java.lang.Long)}.
     */
    @Test
    public void testDeleteByUserIdForNotExist() {
        // 测试删除不存在的记录.
        int result = _userDAO.deleteByUserId(100L);
        assertEquals(0, result);
    }

    /**
     * Test method for {@link cn.aofeng.sis.dao.UserDAOImpl#selectByUserId(java.lang.Long)}.
     */
    @Test
    public void testSelectByUserIdForExist() {
        // 测试查询已经存在的记录
        User record = _userDAO.selectByUserId(_userId);
        assertNotNull(record);
        assertEquals(1, record.getUserId().longValue());
        assertEquals("aofeng"+_userId, record.getUserName());
    }
    
    /**
     * Test method for {@link cn.aofeng.sis.dao.UserDAOImpl#selectByUserId(java.lang.Long)}.
     */
    @Test
    public void testSelectByUserIdForNotExist() {
        // 测试查询不存在的记录
        User record = _userDAO.selectByUserId(100L);
        assertNull(record);
    }

    /**
     * Test method for {@link cn.aofeng.sis.dao.UserDAOImpl#selectByUserName(java.lang.String)}.
     */
    @Test
    public void testSelectByUserNameForExist() {
        // 测试查询用户名存在的记录
        User record = _userDAO.selectByUserName("aofeng"+_userId);
        assertNotNull(record);
        assertEquals(1, record.getUserId().longValue());
        assertEquals("aofeng"+_userId, record.getUserName());
    }
    
    /**
     * Test method for {@link cn.aofeng.sis.dao.UserDAOImpl#selectByUserName(java.lang.String)}.
     */
    @Test
    public void testSelectByUserNameForNotExist() {
        // 测试查询用户名不存在的记录
        User record = _userDAO.selectByUserName("userNotExists");
        assertNull(record);
    }

}