SpringMVC+Mybatis搭建及封装实例

package com.csr.core.mapper; import java.io.Serializable; import java.lang.reflect.Field; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.lang.reflect.ParameterizedType; import java.lang.reflect.Type; import java.util.HashMap; import java.util.List; import java.util.Map; import javax.annotation.Resource; import org.apache.ibatis.session.SqlSession; import org.apache.ibatis.session.SqlSessionFactory; import org.apache.log4j.Logger; import org.mybatis.spring.support.SqlSessionDaoSupport; import org.springframework.cache.annotation.CacheEvict; import org.springframework.cache.annotation.Cacheable; import org.springframework.stereotype.Repository; @Repository public class BaseMapperImpl<T, PK extends Serializable> extends SqlSessionDaoSupport implements BaseMapper<T, PK> { public static Logger logger = Logger.getLogger(BaseMapperImpl.class); private Class<T> entityClass = null; public BaseMapperImpl() { Class c = getClass(); Type type = c.getGenericSuperclass(); if ((type instanceof ParameterizedType)) { Type[] parameterizedType = ((ParameterizedType)type) .getActualTypeArguments(); this.entityClass = ((Class)parameterizedType[0]); } } @Resource(name="sqlSessionFactory") public void setSuperSqlSessionFactory(SqlSessionFactory sqlSessionFactory) { super.setSqlSessionFactory(sqlSessionFactory); } @CacheEvict(value={"ehcache"}, allEntries=true) public T insert(T entity) { try { Field[] fileds = entity.getClass().getDeclaredFields(); for (Field field : fileds) { if (!field.getName().equals("id")) continue; Method setIdMethod = entity.getClass().getDeclaredMethod( "setId", new Class[] { String.class }); setIdMethod.invoke(entity, new Object[] { IdUtil.getId() }); } } catch (SecurityException e) { e.printStackTrace(); } catch (NoSuchMethodException e) { e.printStackTrace(); } catch (IllegalArgumentException e) { e.printStackTrace(); } catch (IllegalAccessException e) { e.printStackTrace(); } catch (InvocationTargetException e) { e.printStackTrace(); } getSqlSession().insert(entity.getClass().getName() + "Mapper.insert", entity); return entity; } @CacheEvict(value={"ehcache"}, allEntries=true) public void update(T entity) { getSqlSession().update(entity.getClass().getName() + "Mapper.update", entity); } @CacheEvict(value={"ehcache"}, allEntries=true) public void deleteById(PK id) { getSqlSession().delete(this.entityClass.getName() + "Mapper.deleteById", id); } @Cacheable(value={"ehcache"}, key="#id") public T fetch(PK id) { return getSqlSession().selectOne( this.entityClass.getName() + "Mapper.fetch", id); } public List<T> findAll() { return getSqlSession().selectList( this.entityClass.getName() + "Mapper.queryList", null); } public int count(Map<String, Object> condition) { int count = ((Integer)getSqlSession().selectOne( this.entityClass.getName() + "Mapper.count", condition)).intValue(); return count; } @Cacheable(value={"ehcache"}, key="'queryList-'+#condition+'-orderBy-'+#orderBy+'-sortBy-'+#sortBy") public List<T> queryList(Map<String, Object> condition, String orderBy, String sortBy) { if (condition == null) { condition = new HashMap(); condition.put("orderBy", orderBy); condition.put("sortBy", sortBy); } return getSqlSession().selectList( this.entityClass.getName() + "Mapper.queryList", condition); } @Cacheable(value={"ehcache"}, key="'queryOne-'+#condition") public T queryOne(Map<String, Object> condition) { return getSqlSession().selectOne( this.entityClass.getName() + "Mapper.queryOne", condition); } @CacheEvict(value={"ehcache"}, allEntries=true) public T updateOrSave(T t, PK id) { if (fetch(id) != null) { update(t); } else { return insert(t); } return t; } @Cacheable(value={"ehcache"}, key="'findOne-'+#property+'-'+#value") public T findOne(String property, Object value) { Map condition = new HashMap(); condition.put(property, value); return getSqlSession().selectOne( this.entityClass.getName() + "Mapper.findOne", condition); } @Cacheable(value={"ehcache"}, key="'findList-'+#property+'-'+#value") public List<T> findList(String property, Object value) { Map condition = new HashMap(); condition.put(property, value); return getSqlSession().selectList( this.entityClass.getName() + "Mapper.findList", condition); } public Class<T> getEntityClass() { return this.entityClass; } public Integer selectMaxId() { return (Integer)getSqlSession().selectOne( this.entityClass.getName() + "Mapper.selectMaxId"); } @CacheEvict(value={"ehcache"}, allEntries=true) public void deleteByCondition(Map<String, Object> condition) { getSqlSession().delete( this.entityClass.getName() + "Mapper.deleteByCondition", condition); } @CacheEvict(value={"ehcache"}, allEntries=true) public void deleteByProperty(String property, Object value) { Map condition = new HashMap(); condition.put(property, value); deleteByCondition(condition); } @CacheEvict(value={"ehcache"}, allEntries=true) public void updateNull(T entity) { getSqlSession().update(this.entityClass.getName() + "Mapper.updateNull", entity); } @Cacheable(value={"ehcache"}, key="'selectOne-'+#mapperId+'-'+#obj") public T selectOne(String mapperId, Object obj) { return getSqlSession().selectOne( this.entityClass.getName() + "Mapper." + mapperId, obj); } @Cacheable(value={"ehcache"}, key="'selectList-'+#mapperId+'-'+#obj") public List<T> selectList(String mapperId, Object obj) { return getSqlSession().selectList( this.entityClass.getName() + "Mapper." + mapperId, obj); } @CacheEvict(value={"ehcache"}, allEntries=true) public List<T> insertList(List<T> entities) { return getSqlSession().selectList( this.entityClass.getName() + "Mapper.insertList", entities); } public List<T> like(String property, Object value) { Map condition = new HashMap(); condition.put(property, value); return getSqlSession().selectList( this.entityClass.getName() + "Mapper.like", condition); } }