tags: [小小商城, SSM]
categories: [技术实战]

提要

　　本文是 小小商城-SSM版的 细节详解系列 之一，项目 github：https://github.com/xenv/S-mall-ssm 本文代码大部分在 github 中 可以找到。

　　这篇文章其实和 SSH开发 | 配合Hibernate，通过泛型实现 BaseService ，抽象增改删查方法 大致一样，只是具体实现有一点区别。

　　在 SSM 开发中，Service层会有许多重复的，调用 mapper 层的，增改删查的方法。对于重复的方法，我们可以用一个 BaseService 抽象出来。如图所示：

SSM开发 - 配合Mybatis，通过泛型实现 BaseService ，抽象增改删查方法 - 图1 　　普通 Service 的增改删查操作统一被抽象到 BaseService，普通Service继承BaseService后，只需实现少量独有的代码即可

　　这样，在 Controller 层调用的时候，只需直接 categoryService.get(id) 就可以完成获取操作。

具体实现

　　BaseService实现的难点在于，不知道 继承它的 普通 Service 对应的 mapper和example 是哪个，从而不能获取到相应的 mapper 类（mybatis动态代理过之后的）和example类，那么，怎么来解决这个问题呢？

　　其实很简单，利用 泛型 ，子类在继承父类的时候实现泛型，初始化时，父类就可以读取到子类的泛型信息，从而实现了 子类 向 父类 传 数据。

　　父类根据子类携带的实体类信息，把mapper接口变成 mapper 实体，子类在泛型继承的时候，就自动会调用对应mapper，从而做到了抽象的效果。

　　在 小小商城 项目中，核心实现是这两个文件，BaseServiceImpl.java 和 Service4DAOImpl.java下面，我会一步步教大家实现。

1.初始化时读取子类的泛型信息，获取 mapper实体类 和 example 类

　　完整实现：Service4DAOImpl.java，如果不使用通用 mapper （SSM开发 | 实现 Mybatis 的通用 Mapper），则注入的是mybatis 的 SqlSessionTemplate而不是MapperFactory，注入SqlSessionTemplate需要配置 Spring文件 ，具体可参见前面的链接

  1. public class Service4DAOImpl<M, E> implements Service4DAO, InitializingBean {
  3.     @Resource
  4.     private MapperFactory mapperFactory;
  6.     Mapper mapper;
  8.     @Override
  9.     /*
  10.     加载完 Service 后执行，获取对应 Service 和 Mapper
  11.      */
  12.     public void afterPropertiesSet() throws Exception {
  13.         mapper = getMapper();
  14.     }
  16.     public Mapper getMapper() throws Exception {
  17.         // 读取泛型第一个 M 的类型，
  18.         ParameterizedType t = (ParameterizedType) (getClass().getGenericSuperclass());
  19.         Class mapperClass = null;
  20.         if (t != null) {
  21.             mapperClass = (Class) t.getActualTypeArguments()[0];
  22.         }
  23.         return getMapper(mapperClass);
  24.     }
  26.     public Mapper getMapper(Class mapperInterface) throws Exception {
  27.         return mapperFactory.getMapper(mapperInterface);
  28.     }
  30.     public BaseExample getExample() throws Exception {
  31.         ParameterizedType t = (ParameterizedType) (getClass().getGenericSuperclass());
  32.         Class exampleClass = null;
  33.         if (t != null) {
  34.             exampleClass = (Class) t.getActualTypeArguments()[1];
  35.         }
  36.         return (BaseExample) exampleClass.newInstance();
  37.     }
  38. }

　　这里其实暗藏一个大坑，就是 SqlSessionTemplate 的注入是在类初始化之后的，这样我们就没有办法使用在构造函数中使用 SqlSessionTemplate，正确的做法是 afterPropertiesSet(…)函数，Spring会自动在全部注入完成后调用这个函数，往这个Service里面注入对应的mapper。Example也是同理的。

2.实现 BaseService ，抽象增改删查方法

  1. public class BaseServiceImpl<M, E> extends Service4DAOImpl<M, E> implements BaseService {
  3.     @Override
  4.     public List list(Object... paramAndObjects) throws Exception {
  5.         BaseExample example = getExample();
  6.         Object criteria = example.createCriteria();
  7.         if (paramAndObjects.length % 2 != 0) {
  8.             return null;
  9.         }
  10.         Pagination pagination = null;
  11.         //默认按id排序
  12.         example.setOrderByClause("id desc");
  13.         //默认对查询进行两次遍历查询
  14.         int depth = 2;
  15.         for (int i = 0; i < paramAndObjects.length; i += 2) {
  16.             if (paramAndObjects[i].equals("order") && paramAndObjects[i + 1] instanceof String) {
  17.                 example.setOrderByClause(paramAndObjects[i + 1].toString());
  18.                 continue;
  19.             }
  20.             if (paramAndObjects[i].equals("depth") && paramAndObjects[i + 1] instanceof Integer) {
  21.                 depth = (Integer) paramAndObjects[i + 1];
  22.                 continue;
  23.             }
  24.             if (paramAndObjects[i].toString().contains("_like") && paramAndObjects[i + 1] instanceof String) {
  25.                 String column = StringUtils.replace(paramAndObjects[i].toString(), "_like", "");
  26.                 criteria.getClass()
  27.                         .getMethod("and" + StringUtils.capitalize(column) + "Like", String.class)
  28.                         .invoke(criteria, "%" + paramAndObjects[i + 1].toString() + "%");
  29.                 continue;
  30.             }
  31.             if (paramAndObjects[i].toString().contains("_gt") && paramAndObjects[i + 1] instanceof Integer) {
  32.                 String column = StringUtils.replace(paramAndObjects[i].toString(), "_gt", "");
  33.                 criteria.getClass()
  34.                         .getMethod("and" + StringUtils.capitalize(column) + "GreaterThan", Integer.class)
  35.                         .invoke(criteria, paramAndObjects[i + 1]);
  36.                 continue;
  37.             }
  38.             if (paramAndObjects[i].equals("pagination") && paramAndObjects[i + 1] instanceof Pagination) {
  39.                 pagination = (Pagination) paramAndObjects[i + 1];
  40.                 continue;
  41.             }
  43.             criteria.getClass()
  44.                     .getMethod("and" + StringUtils.capitalize(paramAndObjects[i].toString()) + "EqualTo"
  45.                             , paramAndObjects[i + 1].getClass())
  46.                     .invoke(criteria, paramAndObjects[i + 1]);
  47.         }
  48.         List list;
  49.         if (pagination != null) {
  50.             PageHelper.offsetPage(pagination.getStart(), pagination.getCount());
  51.             list = mapper.selectByExample(example, depth);
  52.             pagination.setTotal((int) new PageInfo<>(list).getTotal());
  53.         } else {
  54.             list = mapper.selectByExample(example, depth);
  55.         }
  56.         return list;
  57.     }
  59.     @Override
  60.     public Integer add(BasePOJO object) throws Exception {
  61.         return mapper.insert(object);
  62.     }
  64.     @Override
  65.     public void update(BasePOJO object) throws Exception {
  66.         mapper.updateByPrimaryKey(object);
  67.     }
  70.     @Override
  71.     public BasePOJO get(int id) throws Exception {
  72.         BasePOJO object = (BasePOJO) mapper.selectByPrimaryKey(id);
  73.         if (object == null) {
  74.             throw new NoSuchObjectException("访问的id不存在或已经被删除");
  75.         }
  76.         return object;
  77.     }
  79.     /**
  80.      * @see BaseService
  81.      */
  82.     @Override
  83.     public void delete(BasePOJO object) throws Exception {
  84.         object.setDeleteAt(new Date());
  85.         mapper.updateByPrimaryKey(object);
  86.     }
  87. }

　　这里节选了项目里的文件的一部分代码，我们先看 update(Object object) ，我们直接调用 mapper 的 update 方法即可

　　在list方法中，我又对example的使用进行进一步抽象，这样，我们在调用的时候，就可以顺带指定分页、顺序、搜索条件等，更加方便

3.普通Service 附带 上 泛型 信息，继承 BaseService

　　以ProductService为例：

  1. @Service
  2. public class ProductServiceImpl extends BaseServiceImpl<ProductMapper,ProductExample> implements ProductService {
  4. }

　　无需再写任何代码，只需要加上泛型信息即可获取完整的BaseService的所有功能。

4. 在 Controller 中调用

  1. 例如，注入ProductService之后，直接可以调用 BaseService 的 list 方法
  1. productService.list("cid",category.getId(),"order",handleSort(sort),"stock_gt",0);

OK，大功告成。