前言

自从发了通用Mapper-0.1.0版本后，我觉得对少数人来说，这可能是他们正好需要的一个工具。至少目前的通用DAO中，很少能有比这个更强大的。

但是对另一部分人来说，使用Mybatis代码生成器（我正在和一些朋友翻译这个文档，地址:MyBatis Generator）生成xml很方便，不需要使用通用Mapper。

实际上如果你无法在自己的业务中提取出通用的单表（多表实际上能实现，但是限制会增多，不如手写xml）操作，通用的Mapper除了能增加你的初始效率以及更干净的xml配置外，没有特别大的优势。

为了更方便的扩展通用Mapper，我对0.1.0版本进行了重构。目前已经发布了0.2.0版本，这里要讲如何开发自己需要的通用Mapper。

如何开发自己的通用Mapper

要求

  1. 自己定义的通用Mapper必须包含泛型，例如MysqlMapper<T>。

  2. 自定义的通用Mapper接口中的方法需要有合适的注解。具体可以参考Mapper

  3. 需要继承MapperTemplate来实现具体的操作方法。

  4. 通用Mapper中的Provider一类的注解只能使用相同的type类型（这个类型就是第三个要实现的类。）。实际上method也都写的一样。

HsqldbMapper实例

第一步，创建HsqldbMapper<T>

public interface HsqldbMapper<T> {
}

这个接口就是我们定义的通用Mapper，具体的接口方法在**第三步**写。其他的Mapper可以继承这个HsqldbMapper<T>。

第二部，创建HsqldbProvider

public class HsqldbProvider extends MapperTemplate {//继承父类的方法public HsqldbProvider(Class<?> mapperClass, MapperHelper mapperHelper) {super(mapperClass, mapperHelper);}
}

这个类是实际处理操作的类，需要继承MapperTemplate，具体代码在**第四步**写。

第三步，在HsqldbMapper<T>中添加通用方法

这里以一个分页查询作为例子。 public interface HsqldbMapper { /** * 单表分页查询 * * @param object * @param offset * @param limit * @return */ @SelectProvider(type=HsqldbProvider.class,method = "dynamicSQL") List selectPage(@Param("entity") T object, @Param("offset") int offset, @Param("limit") int limit); }

返回结果为List,入参分别为查询条件和分页参数。在Mapper的接口方法中，当有多个入参的时候建议增加@Param注解，否则就得用param1,param2...来引用参数。

同时必须在方法上添加注解。查询使用SelectProvider，插入使用@InsertProvider，更新使用UpdateProvider，删除使用DeleteProvider。不同的Provider就相当于xml中不同的节点，如<select>,<insert>,<update>,<delete>。

因为这里是查询，所以要设置为SelectProvider，这4个Provider中的参数都一样，只有type和method。

type必须设置为实际执行方法的HasqldbProvider.class,method必须设置为"dynamicSQL"。

通用Mapper处理的时候会根据type反射HasqldbProvider查找方法，而Mybatis的处理机制要求method必须是type类中只有一个入参，且返回值为String的方法。"dynamicSQL"方法定义在MapperTemplate中，该方法如下：

public String dynamicSQL(Object record) {return "dynamicSQL";
}

这个方法只是为了满足Mybatis的要求，没有任何实际的作用。

第四步，在HsqldbProvider中实现真正处理Sql的方法

在这里有一点要求，那就是HsqldbProvider处理HsqldbMapper<T>中的方法时，方法名必须一样，因为这里需要通过反射来获取对应的方法，方法名一致一方面是为了减少开发人员的配置，另一方面和接口对应看起来更清晰。

除了方法名必须一样外，入参必须是MappedStatement ms，除此之外返回值可以是void或者SqlNode之一。

这里先讲一下通用Mapper的实现原理。通用Mapper目前是通过拦截器在通用方法第一次执行的时候去修改MappedStatement对象的SqlSource属性。而且只会执行一次，以后就和正常的方法没有任何区别。

使用Provider注解的这个Mapper方法，Mybatis本身会处理成ProviderSqlSource(一个SqlSource的实现类），由于之前的配置，这个ProviderSqlSource种的SQL是上面代码中返回的"dynamicSQL"。这个SQL没有任何作用，如果不做任何修改，执行这个代码肯定会出错。所以在拦截器中拦截符合要求的接口方法，遇到ProviderSqlSource就通过反射调用如HsqldbProvider中的具体代码去修改原有的SqlSource。

最简单的处理Mybatis SQL的方法是什么？就是创建SqlNode，使用DynamicSqlSource，这种情况下我们不需要处理入参，不需要处理代码中的各种类型的参数映射。比执行SQL的方式容易很多。

有关这部分的内容建议查看通用Mapper的源码和Mybatis源码了解，如果不了解在这儿说多了反而会乱。

下面在HsqldbProvider中添加public SqlNode selectPage(MappedStatement ms)方法：

/*** 分页查询* @param ms* @return*/
public SqlNode selectPage(MappedStatement ms) {Class<?> entityClass = getSelectReturnType(ms);//修改返回值类型为实体类型setResultType(ms, entityClass);List<SqlNode> sqlNodes = new ArrayList<SqlNode>();//静态的sql部分:select column ... from tablesqlNodes.add(new StaticTextSqlNode("SELECT "+ EntityHelper.getSelectColumns(entityClass)+ " FROM "+ tableName(entityClass)));//获取全部列List<EntityHelper.EntityColumn> columnList = EntityHelper.getColumns(entityClass);List<SqlNode> ifNodes = new ArrayList<SqlNode>();boolean first = true;//对所有列循环，生成<if test="property!=null">[AND] column = #{property}</if>for (EntityHelper.EntityColumn column : columnList) {StaticTextSqlNode columnNode= new StaticTextSqlNode((first ? "" : " AND ") + column.getColumn()+ " = #{entity." + column.getProperty() + "} ");if (column.getJavaType().equals(String.class)) {ifNodes.add(new IfSqlNode(columnNode, "entity."+column.getProperty()+ " != null and " + "entity."+column.getProperty() + " != '' "));} else {ifNodes.add(new IfSqlNode(columnNode, "entity."+column.getProperty() + " != null "));}first = false;}//将if添加到<where>sqlNodes.add(new WhereSqlNode(ms.getConfiguration(), new MixedSqlNode(ifNodes)));//处理分页sqlNodes.add(new IfSqlNode(new StaticTextSqlNode(" LIMIT #{limit}"),"offset==0"));sqlNodes.add(new IfSqlNode(new StaticTextSqlNode(" LIMIT #{limit} OFFSET #{offset} "),"offset>0"));return new MixedSqlNode(sqlNodes);
}

注：对这段代码感觉吃力的，可以对比本页最下面**结构**部分XML形式的查看。

首先这段代码要实现的功能是这样，根据传入的实体类参数中不等于null（字符串也不等于'')的属性作为查询条件进行查询，根据分页参数进行分页。

先看这两行代码：

//获取实体类型
Class<?> entityClass = getSelectReturnType(ms);
//修改返回值类型为实体类型
setResultType(ms, entityClass);

首先获取了实体类型，然后通过setResultType将返回值类型改为entityClass，就相当于resultType=entityClass。

这里为什么要修改呢？因为默认返回值是T，Java并不会自动处理成我们的实体类，默认情况下是Object，对于所有的查询来说，我们都需要手动设置返回值类型。

对于insert,update,delete来说，这些操作的返回值都是int，所以不需要修改返回结果类型。

之后从List<SqlNode> sqlNodes = new ArrayList<SqlNode>();代码开始拼写SQL，首先是SELECT查询头，在EntityHelper.getSelectColumns(entityClass)中还处理了别名的情况。

然后获取所有的列，对列循环创建<if entity.property!=null>column = #{entity.property}</if>节点。最后把这些if节点组成的List放到一个<where>节点中。

这一段使用属性时用的是 entity. + 属性名，entity来自哪儿？来自我们前面接口定义处的Param("entity")注解，后面的两个分页参数也是。如果你用过Mybatis，相信你能明白。

之后在<where>节点后添加分页参数，当offset==0时和offset>0时的分页代码不同。

最后封装成一个MixedSqlNode返回。

返回后通用Mapper是怎么处理的，这里贴下源码：

SqlNode sqlNode = (SqlNode) method.invoke(this, ms);
DynamicSqlSource dynamicSqlSource = new DynamicSqlSource(ms.getConfiguration(), sqlNode);
setSqlSource(ms, dynamicSqlSource);

返回SqlNode后创建了DynamicSqlSource，然后修改了ms原来的SqlSource。

第五步，配置通用Mapper接口到拦截器插件中

<plugins><plugin interceptor="com.github.abel533.mapper.MapperInterceptor"><!--================================================--><!--可配置参数说明(一般无需修改)--><!--================================================--><!--UUID生成策略--><!--配置UUID生成策略需要使用OGNL表达式--><!--默认值32位长度:@java.util.UUID@randomUUID().toString().replace("-", "")--><!--<property name="UUID" value="@java.util.UUID@randomUUID().toString()"/>--><!--主键自增回写方法,默认值MYSQL,详细说明请看文档--><property name="IDENTITY" value="HSQLDB"/><!--序列的获取规则,使用{num}格式化参数，默认值为{0}.nextval，针对Oracle--><!--可选参数一共3个，对应0,1,2,分别为SequenceName，ColumnName,PropertyName--><property name="seqFormat" value="{0}.nextval"/><!--主键自增回写方法执行顺序,默认AFTER,可选值为(BEFORE|AFTER)--><!--<property name="ORDER" value="AFTER"/>--><!--支持Map类型的实体类，自动将大写下划线的Key转换为驼峰式--><!--这个处理使得通用Mapper可以支持Map类型的实体（实体中的字段必须按常规方式定义，否则无法反射获得列）--><property name="cameHumpMap" value="true"/><!--通用Mapper接口，多个用逗号隔开--><property name="mappers" value="com.github.abel533.mapper.Mapper,com.github.abel533.hsqldb.HsqldbMapper"/></plugin>
</plugins>

这里主要是**mappers**参数：

<property name="mappers" value="com.github.abel533.mapper.Mapper,com.github.abel533.hsqldb.HsqldbMapper"/>

多个通用Mapper可以用逗号隔开。

测试

接下来编写代码进行测试。

public interface CountryMapper extends Mapper<Country>,HsqldbMapper<Country> {
}

在CountryMapper上增加继承HsqldbMapper<Country>。

编写如下的测试：

@Test
public void testDynamicSelectPage() {SqlSession sqlSession = MybatisHelper.getSqlSession();try {CountryMapper mapper = sqlSession.getMapper(CountryMapper.class);//带查询条件的分页查询Country country = new Country();country.setCountrycode("US");List<Country> countryList = mapper.selectPage(country, 0, 10);//查询总数Assert.assertEquals(1, countryList.size());//空参数的查询countryList = mapper.selectPage(new Country(), 100, 10);Assert.assertEquals(10, countryList.size());} finally {sqlSession.close();}
}

测试输出日志如下：

DEBUG [main] - ==>  Preparing: SELECT ID,COUNTRYNAME,COUNTRYCODE FROM COUNTRY WHERE COUNTRYCODE = ? LIMIT ?
DEBUG [main] - ==> Parameters: US(String), 10(Integer)
TRACE [main] - <==    Columns: ID, COUNTRYNAME, COUNTRYCODE
TRACE [main] - <==        Row: 174, United States of America, US
DEBUG [main] - <==      Total: 1
DEBUG [main] - ==>  Preparing: SELECT ID,COUNTRYNAME,COUNTRYCODE FROM COUNTRY LIMIT ? OFFSET ?
DEBUG [main] - ==> Parameters: 10(Integer), 100(Integer)
TRACE [main] - <==    Columns: ID, COUNTRYNAME, COUNTRYCODE
TRACE [main] - <==        Row: 101, Maldives, MV
TRACE [main] - <==        Row: 102, Mali, ML
TRACE [main] - <==        Row: 103, Malta, MT
TRACE [main] - <==        Row: 104, Mauritius, MU
TRACE [main] - <==        Row: 105, Mexico, MX
TRACE [main] - <==        Row: 106, Moldova, Republic of, MD
TRACE [main] - <==        Row: 107, Monaco, MC
TRACE [main] - <==        Row: 108, Mongolia, MN
TRACE [main] - <==        Row: 109, Montserrat Is, MS
TRACE [main] - <==        Row: 110, Morocco, MA
DEBUG [main] - <==      Total: 10

测试没有任何问题。

这里在来点很容易实现的一个功能。上面代码中：

countryList = mapper.selectPage(new Country(), 100, 10);

传入一个没有设置任何属性的Country的时候会查询全部结果。有些人会觉得传入一个空的对象不如传入一个null。我们修改测试代码看看结果。

执行测试代码后抛出异常：

Caused by: org.apache.ibatis.ognl.OgnlException: source is null for getProperty(null, "id")

为什么会异常呢，因为我们上面代码中直接引用的entity.property，在引用前并没有判断entity != null，因而导致了这里的问题。

我们修改HsqldbProvider中的selectPage方法，将最后几行代码进行修改，原来的代码：

//将if添加到<where>
sqlNodes.add(new WhereSqlNode(ms.getConfiguration(), new MixedSqlNode(ifNodes)));

修改后：

//增加entity!=null判断
IfSqlNode ifSqlNode = new IfSqlNode(new MixedSqlNode(ifNodes),"entity!=null");
//将if添加到<where>
sqlNodes.add(new WhereSqlNode(ms.getConfiguration(), ifSqlNode));

之后再进行测试就没有问题了。

更多例子

更多例子可以参考通用Mapper中的Mapper<T>和MapperProvider进行参考。代码量不是很大但是实现了常用的这些功能。

当你了解了原理以及掌握了SqlNode的结构后，相信你能写出更多更强大的通用Mapper。

我曾经说过会根据不同的数据库写一些针对性的通用Mapper,当我开始考虑重构的时候，我就想，我应该教会需要这个插件的开发人员如何自己实现。

一个人的能力是有限的，而且写一个东西开源出来给大家用很容易，但是维护不易。所以呢，我希望觉得这篇文档有用的各位能够分享自己的实现。

我个人如果有时间，我会考虑增加通用的Example查询。Example类的设计比较复杂，对应的SqlNode结构并不是很复杂。如果有人有兴趣，我可以协助开发Example通用查询。

结构

对于刚刚了解上述内容的开发人员来说，SqlNode可能没有那么直观，为了便于理解。我在这里将上面最后修改完成的SqlNode以xml的形式写出来。

<select id="selectPage" resultType="com.github.abel533.model.Country">SELECT ID,COUNTRYNAME,COUNTRYCODE FROM COUNTRY<where><if test="entity!=null><if test="entity.id!=null">id = #{entity.id}</if><if test="entity.countryname!=null">countryname = #{entity.countryname}</if><if test="entity.countrycode!=null">countrycode = #{entity.countrycode}</if></if></where><if test="offset==0">LIMIT #{limit}</if><if test="offset>0">LIMIT #{limit} OFFSET #{offset}</if>
</select>

看到这个结构，再和上面代码一一对应应该就不难理解了。熟悉以后，你可能也会觉得JAVA代码方式处理通用的Mapper会容易很多。

如何开发自己的通用Mapper相关推荐

  1. MyBatis_通用mapper注解开发

    文章目录 9. 通用mapper注解开发 9.1. 通过mapper入门案例 9.1.1. 添加mapper依赖 9.1.2. 相关配置文件 - jdbc.properties - mybatis-c ...

  2. MyBatis 为什么需要通用 Mapper ? 1

    版权声明:版权归博主所有,转载请带上本文链接!联系方式:abel533@gmail.com https://blog.csdn.net/isea533/article/details/83045335 ...

  3. MyBatis 为什么需要通用 Mapper ?

    一.通用 Mapper 的用途 ? 我个人最早用 MyBatis 时,先是完全手写,然后用上了 MyBatis 代码生成器(简称为 MBG),在使用 MBG 过程中,发现一个很麻烦的问题,如果数据库字 ...

  4. Mybatis 通用 Mapper 使用 ①

    简介 官网链接:https://mapperhelper.github.io/docs/ 通用Mapper都可以极大的方便开发人员.可以随意的按照自己的需要选择通用方法,还可以很方便的开发自己的通用方 ...

  5. 通用mapper和分类实现

    1 通用Mapper 1.1 通用Mapper介绍 1.1.1 架构设计 说明:使用了通用Mapper后,单表的增删改查操作会自动的进行维护. 问题:如何才能实现数据的通用并且是动态的? 1.2 JP ...

  6. 通用返回_Springboot项目整合通用mapper

    1.简介 什么是通用mapper 什么是通用mapper,用一句话概括就是,它就是一个辅助mybatis开发的组件,它不是替代mybatis,而是使mybatis更方便的开发.通用mapper提供极其 ...

  7. Springboot集成mybatis通用Mapper与分页插件PageHelper

    Springboot集成mybatis通用Mapper与分页插件PageHelper 插件介绍 通用 Mapper 是一个可以实现任意 MyBatis 通用方法的框架,项目提供了常规的增删改查操作以及 ...

  8. 通用mapper版+SpringBoot+MyBatis框架+mysql数据库的整合

    转:https://blog.csdn.net/qq_35153200/article/details/79538440 开发环境: 开发工具:Intellij IDEA 2017.2.3 JDK : ...

  9. 智能一代云平台（二十九）:通用mapper的改造

    [前言] 最近研究一下Mybatis的通用mapper,然后对其进行了一些改造以适合我们的系统,接下来为大家分享一下我的研究思路以及研究成果. [研究之路]      一.ORM框架选型: 1.我们最 ...

最新文章

  1. 如何判断车与路边线距离_6家快递公司共享分拣线配送车，效果如何？
  2. mysql与php驱动,用PHP和MySQL构建一个数据库驱动的网站(四)-PHP教程,PHP基础
  3. 学习笔记(47):Python实战编程-pack布局
  4. 面象对象设计6大原则之四：接口隔离原则
  5. redis 持久化 + 主从复制+ 集群
  6. 国内开源社区软件 PHPWind 团队已解散
  7. Redis实现计数器---接口防刷
  8. 一天赚148万元，科大讯飞2018年净利润达5.42亿，但53%为政府补助
  9. iocp三层架构服务器模型
  10. php中在页面显示多选的内容,在html页面的表单选项中如何能有多选功能?（示例）...
  11. [工具] Sublime Text 使用指南
  12. c语言2010试题答案,2010年c语言试题及答案
  13. 用python画钢铁侠图片_Photoshop快速把钢铁侠图片转为素描水墨风格教程
  14. matlab无法打开wps的xls文件,WPS无法打开XLS文件怎么办 XLS文件出现异常无法打开怎么处理...
  15. Openwrt Web gui LUCI 流程浅析
  16. Windows、Linux密码破解—John、Hydra、hashcat、Mimikatz等工具基本使用
  17. python 自动上色_Github | 线稿自动上色
  18. Hadoop学习笔记（四）HDFS部分下
  19. linux drm 源码,Linux DRM那些事-内核代码
  20. QTP10破解时，运行mgn-mqt82.exe 就提示已停止工作

热门文章

  1. 学python能赚钱吗-利用python能怎么挣钱
  2. 升级到AndroidX，遇到appComponentFactory 错误
  3. NN入门，手把手教你用Numpy手撕NN(一)
  4. 戴某某说：“内心永无止境的期盼”
  5. LAD线性判别模型简介及sklearn参数
  6. 零信任架构和访问控制模型ABAC
  7. CRT8.5.4.zip包
  8. 模糊字符串匹配：双音素算法
  9. FL Studio杂项设置页讲解（下）
  10. 专家：程序员不配叫工程师