spring4+mybatis3+maven-项目Demo

package com.viathink.frame.core.dao.impl; import java.util.List; import java.util.Map; import org.apache.commons.lang3.StringUtils; import org.apache.ibatis.session.RowBounds; import org.apache.ibatis.session.SqlSession; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.domain.Page; import org.springframework.data.domain.PageImpl; import org.springframework.data.domain.Pageable; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.Assert; import com.viathink.frame.core.dao.BaseDao; import com.viathink.frame.core.dao.constants.SqlId; import com.viathink.frame.core.dao.domain.Identifiable; import com.viathink.frame.core.exception.DaoException; import com.viathink.frame.core.utils.BeanUtils; import com.viathink.frame.core.utils.UUIDUtils; /** * 基础Dao接口实现类，实现改类的子类必须设置泛型类型 * @author LiuJunGuang * @date 2014年3月3日下午1:02:31 */ public abstract class BaseDaoImpl<T extends Identifiable> implements BaseDao<T> { @Autowired(required = true) protected SqlSession sqlSessionTemplate; public static final String SQLNAME_SEPARATOR = "."; /** * @fields sqlNamespace SqlMapping命名空间 */ private String sqlNamespace = getDefaultSqlNamespace(); /** * 获取泛型类型的实体对象类全名 * @author LiuJunGuang * @return * @date 2014年3月3日下午6:17:46 */ protected String getDefaultSqlNamespace() { Class<?> genericClass = BeanUtils.getGenericClass(this.getClass()); return genericClass == null ? null : genericClass.getName(); } /** * 获取SqlMapping命名空间 * @author LiuJunGuang * @return SqlMapping命名空间 * @date 2014年3月4日上午12:33:15 */ public String getSqlNamespace() { return sqlNamespace; } /** * 设置SqlMapping命名空间。 以改变默认的SqlMapping命名空间， * 不能滥用此方法随意改变SqlMapping命名空间。 * @author LiuJunGuang * @param sqlNamespace SqlMapping命名空间 * @date 2014年3月4日上午12:33:17 */ public void setSqlNamespace(String sqlNamespace) { this.sqlNamespace = sqlNamespace; } /** * 将SqlMapping命名空间与给定的SqlMapping名组合在一起。 * @param sqlName SqlMapping名 * @return 组合了SqlMapping命名空间后的完整SqlMapping名 */ protected String getSqlName(String sqlName) { return sqlNamespace + SQLNAME_SEPARATOR + sqlName; } /** * 生成主键值。 默认使用{@link UUIDUtils#create()}方法 * 如果需要生成主键，需要由子类重写此方法根据需要的方式生成主键值。 * @param entity 要持久化的对象 */ protected String generateId() { return UUIDUtils.create(); } /* (non-Javadoc) * @see com.viathink.core.dao.BaseDao#selectOne(java.io.Serializable) */ @Override public <V extends T> V selectOne(T query) { Assert.notNull(query); try { Map<String, Object> params = BeanUtils.toMap(query); return sqlSessionTemplate.selectOne(getSqlName(SqlId.SQL_SELECT), params); } catch (Exception e) { throw new DaoException(String.format("查询一条记录出错！语句：%s", getSqlName(SqlId.SQL_SELECT)), e); } } /* (non-Javadoc) * @see com.viathink.core.dao.BaseDao#selectById(java.io.Serializable) */ @Override public <V extends T> V selectById(String id) { Assert.notNull(id); try { return sqlSessionTemplate.selectOne(getSqlName(SqlId.SQL_SELECT_BY_ID), id); } catch (Exception e) { throw new DaoException(String.format("根据ID查询对象出错！语句：%s", getSqlName(SqlId.SQL_SELECT_BY_ID)), e); } } /* (non-Javadoc) * @see com.viathink.core.dao.BaseDao#selectList(java.io.Serializable) */ @Override public <V extends T> List<V> selectList(T query) { try { Map<String, Object> params = BeanUtils.toMap(query); return sqlSessionTemplate.selectList(getSqlName(SqlId.SQL_SELECT), params); } catch (Exception e) { throw new DaoException(String.format("查询对象列表出错！语句：%s", getSqlName(SqlId.SQL_SELECT)), e); } } /* (non-Javadoc) * @see com.viathink.core.dao.BaseDao#selectAll() */ @Override public <V extends T> List<V> selectAll() { try { return sqlSessionTemplate.selectList(getSqlName(SqlId.SQL_SELECT)); } catch (Exception e) { throw new DaoException(String.format("查询所有对象列表出错！语句：%s", getSqlName(SqlId.SQL_SELECT)), e); } } /* (non-Javadoc) * @see com.viathink.core.dao.BaseDao#selectMap(java.io.Serializable, java.lang.String) */ @Override public <K, V extends T> Map<K, V> selectMap(T query, String mapKey) { Assert.notNull(mapKey, "[mapKey] - must not be null!"); try { Map<String, Object> params = BeanUtils.toMap(query); return sqlSessionTemplate.selectMap(getSqlName(SqlId.SQL_SELECT), params, mapKey); } catch (Exception e) { throw new DaoException(String.format("查询对象Map时出错！语句：%s", getSqlName(SqlId.SQL_SELECT)), e); } } /** * 设置分页 * @param pageInfo 分页信息 * @return SQL分页参数对象 */ protected RowBounds getRowBounds(Pageable pageable) { RowBounds bounds = RowBounds.DEFAULT; if (null != pageable) { bounds = new RowBounds(pageable.getOffset(), pageable.getPageSize()); } return bounds; } /** * 获取分页查询参数 * @param query 查询对象 * @param pageable 分页对象 * @return Map 查询参数 */ protected Map<String, Object> getParams(T query, Pageable pageable) { Map<String, Object> params = BeanUtils.toMap(query, getRowBounds(pageable)); if (pageable != null && pageable.getSort() != null) { String sorting = pageable.getSort().toString(); params.put("sorting", sorting.replace(":", "")); } return params; } /* (non-Javadoc) * @see com.viathink.core.dao.BaseDao#selectList(com.viathink.core.dao.domain.Identifiable, org.springframework.data.domain.Pageable) */ @Override public <V extends T> List<V> selectList(T query, Pageable pageable) { try { return sqlSessionTemplate.selectList(getSqlName(SqlId.SQL_SELECT), getParams(query, pageable)); } catch (Exception e) { throw new DaoException(String.format("根据分页对象查询列表出错！语句:%s", getSqlName(SqlId.SQL_SELECT)), e); } } /* (non-Javadoc) * @see com.viathink.core.dao.BaseDao#selectPageList(com.viathink.core.dao.domain.Identifiable, org.springframework.data.domain.Pageable) */ @Override public <V extends T> Page<V> selectPageList(T query, Pageable pageable) { try { List<V> contentList = sqlSessionTemplate.selectList(getSqlName(SqlId.SQL_SELECT), getParams(query, pageable)); return new PageImpl<V>(contentList, pageable, this.selectCount(query)); } catch (Exception e) { throw new DaoException(String.format("根据分页对象查询列表出错！语句:%s", getSqlName(SqlId.SQL_SELECT)), e); } } /* (non-Javadoc) * @see com.viathink.core.dao.BaseDao#selectMap(com.viathink.core.dao.domain.Identifiable, java.lang.String, org.springframework.data.domain.Pageable) */ @Override public <K, V extends T> Map<K, V> selectMap(T query, String mapKey, Pageable pageable) { try { return sqlSessionTemplate.selectMap(getSqlName(SqlId.SQL_SELECT), getParams(query, pageable), mapKey); } catch (Exception e) { throw new DaoException(String.format("根据分页对象查询列表出错！语句:%s", getSqlName(SqlId.SQL_SELECT)), e); } } /* (non-Javadoc) * @see com.viathink.core.dao.BaseDao#selectCount() */ @Override public Long selectCount() { try { return sqlSessionTemplate.selectOne(getSqlName(SqlId.SQL_SELECT_COUNT)); } catch (Exception e) { throw new DaoException(String.format("查询对象总数出错！语句：%s", getSqlName(SqlId.SQL_SELECT_COUNT)), e); } } /* (non-Javadoc) * @see com.viathink.core.dao.BaseDao#selectCount(java.io.Serializable) */ @Override public Long selectCount(T query) { try { Map<String, Obje