小言_互联网的博客

干掉mapper.xml!MyBatis新特性动态SQL真香!

611人阅读  评论(0)

当我们使用MyBatis的时候,需要在mapper.xml中书写大量的SQL语句。当我们使用MyBatis Generator(MBG)作为代码生成器时,也会生成大量的mapper.xml文件。其实从MBG 1.3.6版本以后,MyBatis官方已经推荐使用Dynamic SQL,使用这一新特性基本就不用写mapper.xml文件了,使用起来非常方便,推荐给大家!

Dynamic SQL简介

在我们使用Spring的时候,有XML和Java两种配置方式。在使用SpringBoot时,已经推荐使用Java配置,基本不用xml配置了。使用Dynamic SQL就好比是使用Java的方式来操作MyBatis。Dynamic SQL是用于生成动态SQL语句的框架,提倡使用Java API的方式来实现SQL操作,支持复杂查询和多表查询。

Dynamic SQL具有如下特性:

  • 类型安全:可以确保参数类型和数据库字段类型相匹配;

  • 富有表现力:语句的构建方式可以清楚地传达其含义;

  • 使用灵活:可以使用and,or和nested条件的任意组合来构建where子句;

  • 扩展性强:可以同时为MyBatis3, Spring JDBC和纯JDBC框架生成SQL语句;

  • 轻量级:只需添加一个小的依赖项,没有传递依赖。

开始使用

首先我们通过一个入门示例将Dynamic SQL用起来,该示例会包含基础的CRUD操作。对MBG使用不了解的朋友可以先看下之前的文章《解放双手!MyBatis官方代码生成工具给力!》

集成Dynamic SQL

  • pom.xml中添加如下依赖,对比之前使用MBG,仅仅多添加了MyBatis的动态SQL依赖;


   
  1. <dependencies>
  2.     <!--SpringBoot整合MyBatis-->
  3.     <dependency>
  4.         <groupId>org.mybatis.spring.boot</groupId>
  5.         <artifactId>mybatis-spring-boot-starter</artifactId>
  6.         <version> 2.1 .3</version>
  7.     </dependency>
  8.     <!--MyBatis分页插件-->
  9.     <dependency>
  10.         <groupId>com.github.pagehelper</groupId>
  11.         <artifactId>pagehelper-spring-boot-starter</artifactId>
  12.         <version> 1.3 .0</version>
  13.     </dependency>
  14.     <!--集成druid连接池-->
  15.     <dependency>
  16.         <groupId>com.alibaba</groupId>
  17.         <artifactId>druid-spring-boot-starter</artifactId>
  18.         <version> 1.1 .10</version>
  19.     </dependency>
  20.     <!-- MyBatis 生成器 -->
  21.     <dependency>
  22.         <groupId>org.mybatis.generator</groupId>
  23.         <artifactId>mybatis-generator-core</artifactId>
  24.         <version> 1.4 .0</version>
  25.     </dependency>
  26.     <!-- MyBatis 动态SQL支持 -->
  27.     <dependency>
  28.         <groupId>org.mybatis.dynamic-sql</groupId>
  29.         <artifactId>mybatis-dynamic-sql</artifactId>
  30.         <version> 1.2 .1</version>
  31.     </dependency>
  32.     <!--Mysql数据库驱动-->
  33.     <dependency>
  34.         <groupId>mysql</groupId>
  35.         <artifactId>mysql-connector-java</artifactId>
  36.         <version> 8.0 .15</version>
  37.     </dependency>
  38. </dependencies>
  • application.yml中对数据源和MyBatis的mapper.xml文件路径进行配置,只需配置自定义mapper.xml路径即可;


   
  1. spring:
  2.   datasource:
  3.     url: jdbc:mysql: //localhost:3306/mall?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
  4.     username: root
  5.     password: root
  6. mybatis:
  7.   mapper-locations:
  8.     - classpath:dao /*.xml
  • 添加Java配置,用于扫描Mapper接口路径,MBG生成的放在mapper包下,自定义的放在dao包下。


   
  1. /**
  2.  * MyBatis配置类
  3.  * Created by macro on 2019/4/8.
  4.  */
  5. @Configuration
  6. @MapperScan({ "com.macro.mall.tiny.mbg.mapper", "com.macro.mall.tiny.dao"})
  7. public class MyBatisConfig {
  8. }

使用代码生成器

  • 在使用MBG生成代码前,我们还需要对其进行一些配置,首先在generator.properties文件中配置好数据库连接信息;


   
  1. jdbc.driverClass=com.mysql.cj.jdbc.Driver
  2. jdbc.connectionURL=jdbc:mysql: //localhost:3306/mall?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
  3. jdbc.userId=root
  4. jdbc.password=root
  • 然后在generatorConfig.xml文件中对MBG进行配置,配置属性说明直接参考注释即可;


   
  1. <?xml version= "1.0" encoding= "UTF-8"?>
  2. <!DOCTYPE generatorConfiguration
  3.         PUBLIC  "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN"
  4.          "http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd">
  5. <generatorConfiguration>
  6.     <properties resource= "generator.properties"/>
  7.     <context id= "MySqlContext" targetRuntime= "MyBatis3DynamicSQL">
  8.         <property name= "beginningDelimiter" value= "`"/>
  9.         <property name= "endingDelimiter" value= "`"/>
  10.         <property name= "javaFileEncoding" value= "UTF-8"/>
  11.         <!-- 为模型生成序列化方法-->
  12.         <plugin  type= "org.mybatis.generator.plugins.SerializablePlugin"/>
  13.         <!-- 为生成的Java模型创建一个toString方法 -->
  14.         <plugin  type= "org.mybatis.generator.plugins.ToStringPlugin"/>
  15.         <!--可以自定义生成model的代码注释-->
  16.         <commentGenerator  type= "com.macro.mall.tiny.mbg.CommentGenerator">
  17.             <!-- 是否去除自动生成的注释 true:是 : false:否 -->
  18.             <property name= "suppressAllComments" value= "true"/>
  19.             <property name= "suppressDate" value= "true"/>
  20.             <property name= "addRemarkComments" value= "true"/>
  21.         </commentGenerator>
  22.         <!--配置数据库连接-->
  23.         <jdbcConnection driverClass= "${jdbc.driverClass}"
  24.                         connectionURL= "${jdbc.connectionURL}"
  25.                         userId= "${jdbc.userId}"
  26.                         password= "${jdbc.password}">
  27.             <!--解决mysql驱动升级到 8.0后不生成指定数据库代码的问题-->
  28.             <property name= "nullCatalogMeansCurrent" value= "true" />
  29.         </jdbcConnection>
  30.         <!--指定生成model的路径-->
  31.         <javaModelGenerator targetPackage= "com.macro.mall.tiny.mbg.model" targetProject= "mall-tiny-dynamic-sql\src\main\java"/>
  32.         <!--指定生成mapper接口的的路径-->
  33.         <javaClientGenerator  type= "XMLMAPPER" targetPackage= "com.macro.mall.tiny.mbg.mapper"
  34.                              targetProject= "mall-tiny-dynamic-sql\src\main\java"/>
  35.         <!--生成全部表tableName设为%-->
  36.         <table tableName= "ums_admin">
  37.             <generatedKey column= "id" sqlStatement= "MySql" identity= "true"/>
  38.         </table>
  39.         <table tableName= "ums_role">
  40.             <generatedKey column= "id" sqlStatement= "MySql" identity= "true"/>
  41.         </table>
  42.         <table tableName= "ums_admin_role_relation">
  43.             <generatedKey column= "id" sqlStatement= "MySql" identity= "true"/>
  44.         </table>
  45.     </context>
  46. </generatorConfiguration>
  • 与之前使用MBG有所不同,targetRuntime需要改为MyBatis3DynamicSql,用于配置生成mapper.xml路径的sqlMapGenerator标签也不需要配置了;

  • 之前使用MBG时自定义了实体类注解的生成,写了个类CommentGenerator继承DefaultCommentGenerator,在addFieldComment方法中将Swagger注解写入到了实体类的属性上;


   
  1. /**
  2.  * 自定义注释生成器
  3.  * Created by macro on 2018/4/26.
  4.  */
  5. public class CommentGenerator extends DefaultCommentGenerator {
  6.      /**
  7.      * 给字段添加注释
  8.      */
  9.     @Override
  10.     public void addFieldComment(Field field, IntrospectedTable introspectedTable,
  11.                                 IntrospectedColumn introspectedColumn) {
  12.         String remarks = introspectedColumn.getRemarks();
  13.          //根据参数和备注信息判断是否添加备注信息
  14.          if(addRemarkComments&&StringUtility.stringHasValue(remarks)){
  15.              //数据库中特殊字符需要转义
  16.              if(remarks.contains( "\"")){
  17.                 remarks = remarks.replace( "\"", "'");
  18.             }
  19.              //给model的字段添加swagger注解
  20.             field.addJavaDocLine( "@ApiModelProperty(value = \""+remarks+ "\")");
  21.         }
  22.     }
  23. }
  • 在使用Dynamic SQL的时候,这种方法已经无用,需要在addFieldAnnotation中将Swagger注解写入到了实体类的属性上;


   
  1. /**
  2.  * 自定义注释生成器
  3.  * Created by macro on 2018/4/26.
  4.  */
  5. public class CommentGenerator extends DefaultCommentGenerator {
  6.     @Override
  7.     public void addFieldAnnotation(Field field, IntrospectedTable introspectedTable, IntrospectedColumn introspectedColumn, Set<FullyQualifiedJavaType> imports) {
  8.          if (!addRemarkComments || CollUtil.isEmpty(imports))  return;
  9.         long count = imports.stream()
  10.                 .filter(item -> API_MODEL_PROPERTY_FULL_CLASS_NAME.equals(item.getFullyQualifiedName()))
  11.                 .count();
  12.          if (count <=  0L) {
  13.              return;
  14.         }
  15.         String remarks = introspectedColumn.getRemarks();
  16.          //根据参数和备注信息判断是否添加备注信息
  17.          if (StringUtility.stringHasValue(remarks)) {
  18.              //数据库中特殊字符需要转义
  19.              if (remarks.contains( "\"")) {
  20.                 remarks = remarks.replace( "\"""'");
  21.             }
  22.              //给model的字段添加swagger注解
  23.             field.addJavaDocLine( "@ApiModelProperty(value = \"" + remarks +  "\")");
  24.         }
  25.     }
  26. }
  • 一切准备就绪,执行Generator类的main方法,生成代码结构信息如下,可以发现已经不再生成mapper.xml文件和Example类,取而代之的是生成了DynamicSqlSupport类。

实现基本的CRUD操作

这里使用的是mall-tiny项目中权限管理功能相关表,具体可以参考《还在从零开始搭建项目?手撸了款快速开发脚手架!》

  • 查看下MBG生成的Mapper接口,比之前使用MBG时增加了很多方法,并且有了一些默认的方法实现,可见之前在mapper.xml中的实现都已经转移到Mapper接口中去了,单表CRUD直接调用对应方法即可;


   
  1. @Mapper
  2. public  interface UmsAdminMapper {
  3.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  4.     BasicColumn[] selectList = BasicColumn.columnList(id, username, password, icon, email, nickName, note, createTime, loginTime, status);
  5.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  6.     @SelectProvider( type=SqlProviderAdapter.class, method= "select")
  7.     long count(SelectStatementProvider selectStatement);
  8.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  9.     @DeleteProvider( type=SqlProviderAdapter.class, method= "delete")
  10.      int  delete(DeleteStatementProvider deleteStatement);
  11.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  12.     @InsertProvider( type=SqlProviderAdapter.class, method= "insert")
  13.     @SelectKey(statement= "SELECT LAST_INSERT_ID()", keyProperty= "record.id", before= false, resultType=Long.class)
  14.      int insert(InsertStatementProvider<UmsAdmin> insertStatement);
  15.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  16.     @SelectProvider( type=SqlProviderAdapter.class, method= "select")
  17.     @ResultMap( "UmsAdminResult")
  18.     Optional<UmsAdmin> selectOne(SelectStatementProvider selectStatement);
  19.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  20.     @SelectProvider( type=SqlProviderAdapter.class, method= "select")
  21.     @Results(id= "UmsAdminResult", value = {
  22.         @Result(column= "id", property= "id", jdbcType=JdbcType.BIGINT, id= true),
  23.         @Result(column= "username", property= "username", jdbcType=JdbcType.VARCHAR),
  24.         @Result(column= "password", property= "password", jdbcType=JdbcType.VARCHAR),
  25.         @Result(column= "icon", property= "icon", jdbcType=JdbcType.VARCHAR),
  26.         @Result(column= "email", property= "email", jdbcType=JdbcType.VARCHAR),
  27.         @Result(column= "nick_name", property= "nickName", jdbcType=JdbcType.VARCHAR),
  28.         @Result(column= "note", property= "note", jdbcType=JdbcType.VARCHAR),
  29.         @Result(column= "create_time", property= "createTime", jdbcType=JdbcType.TIMESTAMP),
  30.         @Result(column= "login_time", property= "loginTime", jdbcType=JdbcType.TIMESTAMP),
  31.         @Result(column= "status", property= "status", jdbcType=JdbcType.INTEGER)
  32.     })
  33.     List<UmsAdmin> selectMany(SelectStatementProvider selectStatement);
  34.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  35.     @UpdateProvider( type=SqlProviderAdapter.class, method= "update")
  36.      int update(UpdateStatementProvider updateStatement);
  37.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  38.      default long count(CountDSLCompleter completer) {
  39.          return MyBatis3Utils.countFrom(this::count, umsAdmin, completer);
  40.     }
  41.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  42.      default  int  delete(DeleteDSLCompleter completer) {
  43.          return MyBatis3Utils.deleteFrom(this:: delete, umsAdmin, completer);
  44.     }
  45.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  46.      default  int deleteByPrimaryKey(Long id_) {
  47.          return  delete(c -> 
  48.             c.where(id, isEqualTo(id_))
  49.         );
  50.     }
  51.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  52.      default  int insert(UmsAdmin record) {
  53.          return MyBatis3Utils.insert(this::insert, record, umsAdmin, c ->
  54.             c. map(username).toProperty( "username")
  55.             . map(password).toProperty( "password")
  56.             . map(icon).toProperty( "icon")
  57.             . map(email).toProperty( "email")
  58.             . map(nickName).toProperty( "nickName")
  59.             . map(note).toProperty( "note")
  60.             . map(createTime).toProperty( "createTime")
  61.             . map(loginTime).toProperty( "loginTime")
  62.             . map(status).toProperty( "status")
  63.         );
  64.     }
  65.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  66.      default  int insertSelective(UmsAdmin record) {
  67.          return MyBatis3Utils.insert(this::insert, record, umsAdmin, c ->
  68.             c. map(username).toPropertyWhenPresent( "username", record::getUsername)
  69.             . map(password).toPropertyWhenPresent( "password", record::getPassword)
  70.             . map(icon).toPropertyWhenPresent( "icon", record::getIcon)
  71.             . map(email).toPropertyWhenPresent( "email", record::getEmail)
  72.             . map(nickName).toPropertyWhenPresent( "nickName", record::getNickName)
  73.             . map(note).toPropertyWhenPresent( "note", record::getNote)
  74.             . map(createTime).toPropertyWhenPresent( "createTime", record::getCreateTime)
  75.             . map(loginTime).toPropertyWhenPresent( "loginTime", record::getLoginTime)
  76.             . map(status).toPropertyWhenPresent( "status", record::getStatus)
  77.         );
  78.     }
  79.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  80.      default Optional<UmsAdmin> selectOne(SelectDSLCompleter completer) {
  81.          return MyBatis3Utils.selectOne(this::selectOne, selectList, umsAdmin, completer);
  82.     }
  83.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  84.      default List<UmsAdmin>  select(SelectDSLCompleter completer) {
  85.          return MyBatis3Utils.selectList(this::selectMany, selectList, umsAdmin, completer);
  86.     }
  87.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  88.      default List<UmsAdmin> selectDistinct(SelectDSLCompleter completer) {
  89.          return MyBatis3Utils.selectDistinct(this::selectMany, selectList, umsAdmin, completer);
  90.     }
  91.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  92.      default Optional<UmsAdmin> selectByPrimaryKey(Long id_) {
  93.          return selectOne(c ->
  94.             c.where(id, isEqualTo(id_))
  95.         );
  96.     }
  97.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  98.      default  int update(UpdateDSLCompleter completer) {
  99.          return MyBatis3Utils.update(this::update, umsAdmin, completer);
  100.     }
  101.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  102.     static UpdateDSL<UpdateModel> updateAllColumns(UmsAdmin record, UpdateDSL<UpdateModel> dsl) {
  103.          return dsl.set(username).equalTo(record::getUsername)
  104.                 .set(password).equalTo(record::getPassword)
  105.                 .set(icon).equalTo(record::getIcon)
  106.                 .set(email).equalTo(record::getEmail)
  107.                 .set(nickName).equalTo(record::getNickName)
  108.                 .set(note).equalTo(record::getNote)
  109.                 .set(createTime).equalTo(record::getCreateTime)
  110.                 .set(loginTime).equalTo(record::getLoginTime)
  111.                 .set(status).equalTo(record::getStatus);
  112.     }
  113.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  114.     static UpdateDSL<UpdateModel> updateSelectiveColumns(UmsAdmin record, UpdateDSL<UpdateModel> dsl) {
  115.          return dsl.set(username).equalToWhenPresent(record::getUsername)
  116.                 .set(password).equalToWhenPresent(record::getPassword)
  117.                 .set(icon).equalToWhenPresent(record::getIcon)
  118.                 .set(email).equalToWhenPresent(record::getEmail)
  119.                 .set(nickName).equalToWhenPresent(record::getNickName)
  120.                 .set(note).equalToWhenPresent(record::getNote)
  121.                 .set(createTime).equalToWhenPresent(record::getCreateTime)
  122.                 .set(loginTime).equalToWhenPresent(record::getLoginTime)
  123.                 .set(status).equalToWhenPresent(record::getStatus);
  124.     }
  125.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  126.      default  int updateByPrimaryKey(UmsAdmin record) {
  127.          return update(c ->
  128.             c.set(username).equalTo(record::getUsername)
  129.             .set(password).equalTo(record::getPassword)
  130.             .set(icon).equalTo(record::getIcon)
  131.             .set(email).equalTo(record::getEmail)
  132.             .set(nickName).equalTo(record::getNickName)
  133.             .set(note).equalTo(record::getNote)
  134.             .set(createTime).equalTo(record::getCreateTime)
  135.             .set(loginTime).equalTo(record::getLoginTime)
  136.             .set(status).equalTo(record::getStatus)
  137.             .where(id, isEqualTo(record::getId))
  138.         );
  139.     }
  140.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  141.      default  int updateByPrimaryKeySelective(UmsAdmin record) {
  142.          return update(c ->
  143.             c.set(username).equalToWhenPresent(record::getUsername)
  144.             .set(password).equalToWhenPresent(record::getPassword)
  145.             .set(icon).equalToWhenPresent(record::getIcon)
  146.             .set(email).equalToWhenPresent(record::getEmail)
  147.             .set(nickName).equalToWhenPresent(record::getNickName)
  148.             .set(note).equalToWhenPresent(record::getNote)
  149.             .set(createTime).equalToWhenPresent(record::getCreateTime)
  150.             .set(loginTime).equalToWhenPresent(record::getLoginTime)
  151.             .set(status).equalToWhenPresent(record::getStatus)
  152.             .where(id, isEqualTo(record::getId))
  153.         );
  154.     }
  155. }
  • 生成代码中有一些DynamicSqlSupport类,比如UmsAdminDynamicSqlSupport,主要是把数据库表和字段抽象成了SqlTable和SqlColumn对象,估计是为了防止我们硬编码;


   
  1. public final class UmsAdminDynamicSqlSupport {
  2.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  3.     public static final UmsAdmin umsAdmin =  new UmsAdmin();
  4.     public static final SqlColumn<Long> id = umsAdmin.id;
  5.     public static final SqlColumn<String> username = umsAdmin.username;
  6.     public static final SqlColumn<String> password = umsAdmin.password;
  7.     public static final SqlColumn<String> icon = umsAdmin.icon;
  8.     public static final SqlColumn<String> email = umsAdmin.email;
  9.     public static final SqlColumn<String> nickName = umsAdmin.nickName;
  10.     public static final SqlColumn<String> note = umsAdmin.note;
  11.     public static final SqlColumn<Date> createTime = umsAdmin.createTime;
  12.     public static final SqlColumn<Date> loginTime = umsAdmin.loginTime;
  13.     public static final SqlColumn<Integer> status = umsAdmin.status;
  14.     @Generated( "org.mybatis.generator.api.MyBatisGenerator")
  15.     public static final class UmsAdmin extends SqlTable {
  16.         public final SqlColumn<Long> id = column( "id", JDBCType.BIGINT);
  17.         public final SqlColumn<String> username = column( "username", JDBCType.VARCHAR);
  18.         public final SqlColumn<String> password = column( "password", JDBCType.VARCHAR);
  19.         public final SqlColumn<String> icon = column( "icon", JDBCType.VARCHAR);
  20.         public final SqlColumn<String> email = column( "email", JDBCType.VARCHAR);
  21.         public final SqlColumn<String> nickName = column( "nick_name", JDBCType.VARCHAR);
  22.         public final SqlColumn<String> note = column( "note", JDBCType.VARCHAR);
  23.         public final SqlColumn<Date> createTime = column( "create_time", JDBCType.TIMESTAMP);
  24.         public final SqlColumn<Date> loginTime = column( "login_time", JDBCType.TIMESTAMP);
  25.         public final SqlColumn<Integer> status = column( "status", JDBCType.INTEGER);
  26.         public UmsAdmin() {
  27.             super( "ums_admin");
  28.         }
  29.     }
  30. }
  • 利用好MBG生成的代码即可完成单表的CRUD操作了,比如下面最常见的操作。


   
  1. /**
  2.  * 后台用户管理Service实现类
  3.  * Created by macro on 2020/12/8.
  4.  */
  5. @Service
  6. public class UmsAdminServiceImpl implements UmsAdminService {
  7.     @Autowired
  8.     private UmsAdminMapper adminMapper;
  9.     @Override
  10.     public void create(UmsAdmin entity) {
  11.         adminMapper.insert(entity);
  12.     }
  13.     @Override
  14.     public void update(UmsAdmin entity) {
  15.         adminMapper.updateByPrimaryKeySelective(entity);
  16.     }
  17.     @Override
  18.     public void  delete(Long id) {
  19.         adminMapper.deleteByPrimaryKey(id);
  20.     }
  21.     @Override
  22.     public UmsAdmin  select(Long id) {
  23.         Optional<UmsAdmin> optionalEntity = adminMapper.selectByPrimaryKey(id);
  24.          return optionalEntity.orElse(null);
  25.     }
  26.     @Override
  27.     public List<UmsAdmin> listAll(Integer pageNum, Integer pageSize) {
  28.         PageHelper.startPage(pageNum, pageSize);
  29.          return adminMapper. select(SelectDSLCompleter.allRows());
  30.     }
  31. }

进阶使用

想要用好Dynamic SQL,上面的基础操作是不够的,还需要一些进阶的使用技巧。

SqlBuilder

SqlBuilder是一个非常有用的类,使用它可以灵活地构建SQL语句的条件,一些常用的条件构建方法如下。

条件 例子 对应SQL
Between where(foo, isBetween(x).and(y)) where foo between ? and ?
Equals where(foo, isEqualTo(x)) where foo = ?
Greater Than where(foo, isGreaterThan(x)) where foo > ?
In where(foo, isIn(x, y)) where foo in (?,?)
Like where(foo, isLike(x)) where foo like ?
Not Equals where(foo, isNotEqualTo(x)) where foo <> ?
Null where(foo, isNull()) where foo is null
Present Equals where(foo, isEqualToWhenPresent(x)) where foo = ? (will render if x is non-null)

StatementProvider

回想一下之前我们在mapper.xml中定义select标签的方式,各个select标签相当于Statement。而这里的StatementProvider好比是Statement中参数和SQL语句的封装,方便以Java的方式创建Statement。

条件查询

使用SqlBuilder类构建StatementProvider,然后调用Mapper接口中的方法即可。

  • 这里以按用户名和状态查询后台用户并按创建时间降序排列为例,SQL实现如下;


   
  1. SELECT
  2.  id,
  3.  username,
  4.  PASSWORD,
  5.  icon,
  6.  email,
  7.  nick_name,
  8.  note,
  9.  create_time,
  10.  login_time,
  11. STATUS 
  12. FROM
  13.  ums_admin 
  14. WHERE
  15.  ( username =  'macro' AND STATUS IN (  01 ) ) 
  16. ORDER BY
  17.  create_time DESC;
  • 使用Dynamic SQL对应的Java代码实现如下,使用SqlBuilder的select方法可以指定查询列,使用from方法可以指定查询表,使用where方法可以构建查询条件,使用orderBy方法可以指定排序。


   
  1. /**
  2.  * 后台用户管理Service实现类
  3.  * Created by macro on 2020/12/8.
  4.  */
  5. @Service
  6. public class UmsAdminServiceImpl implements UmsAdminService {
  7.     @Override
  8.     public List<UmsAdmin> list(Integer pageNum, Integer pageSize, String username, List<Integer> statusList) {
  9.         PageHelper.startPage(pageNum, pageSize);
  10.         SelectStatementProvider selectStatement = SqlBuilder. select(UmsAdminMapper.selectList)
  11.                 .from(UmsAdminDynamicSqlSupport.umsAdmin)
  12.                 .where(UmsAdminDynamicSqlSupport.username, isEqualToWhenPresent(username))
  13.                 .and(UmsAdminDynamicSqlSupport.status, isIn(statusList))
  14.                 .orderBy(UmsAdminDynamicSqlSupport.createTime.descending())
  15.                 .build()
  16.                 .render(RenderingStrategies.MYBATIS3);
  17.          return adminMapper.selectMany(selectStatement);
  18.     }
  19. }

Lambda条件查询

使用Lambda表达式实现单表条件查询更加简单,实现上面的条件查询,对应Java代码实现如下。


   
  1. /**
  2.  * 后台用户管理Service实现类
  3.  * Created by macro on 2020/12/8.
  4.  */
  5. @Service
  6. public class UmsAdminServiceImpl implements UmsAdminService {
  7.     @Override
  8.     public List<UmsAdmin> lambdaList(Integer pageNum, Integer pageSize, String username, List<Integer> statusList) {
  9.         PageHelper.startPage(pageNum, pageSize);
  10.         List<UmsAdmin> list = adminMapper. select(c -> c.where(UmsAdminDynamicSqlSupport.username, isEqualToWhenPresent(username))
  11.                 .and(UmsAdminDynamicSqlSupport.status, isIn(statusList))
  12.                 .orderBy(UmsAdminDynamicSqlSupport.createTime.descending()));
  13.          return list;
  14.     }
  15. }

子查询

之前使用MBG需要在mapper.xml中手写SQL才能实现子查询,使用Dynamic SQL可以直接在Java代码中实现。

  • 这里以按角色ID查询后台用户为例,SQL实现如下;


   
  1. SELECT
  2.  * 
  3. FROM
  4.  ums_admin 
  5. WHERE
  6.  id IN ( SELECT admin_id FROM ums_admin_role_relation WHERE role_id =  1 )
  • 使用Dynamic SQL对应的Java代码实现如下,可以发现SqlBuilder的条件构造方法isIn中还可以嵌套SqlBuilder的查询。


   
  1. /**
  2.  * 后台用户管理Service实现类
  3.  * Created by macro on 2020/12/8.
  4.  */
  5. @Service
  6. public class UmsAdminServiceImpl implements UmsAdminService {
  7.     @Override
  8.     public List<UmsAdmin> subList(Long roleId) {
  9.         SelectStatementProvider selectStatement = SqlBuilder. select(UmsAdminMapper.selectList)
  10.                 .from(UmsAdminDynamicSqlSupport.umsAdmin)
  11.                 .where(UmsAdminDynamicSqlSupport.id, isIn(SqlBuilder. select(UmsAdminRoleRelationDynamicSqlSupport.adminId)
  12.                         .from(UmsAdminRoleRelationDynamicSqlSupport.umsAdminRoleRelation)
  13.                         .where(UmsAdminRoleRelationDynamicSqlSupport.roleId, isEqualTo(roleId))))
  14.                 .build()
  15.                 .render(RenderingStrategies.MYBATIS3);
  16.          return adminMapper.selectMany(selectStatement);
  17.     }
  18. }

Group和Join查询

涉及到多表查询,之前使用MBG的时候基本只能在mapper.xml中手写SQL实现,使用Dynamic SQL可以支持多表查询。

  • 这里以按角色统计后台用户数量为例,SQL实现如下;


   
  1. SELECT
  2.  ur.id AS roleId,
  3.  ur.NAME AS roleName,
  4.  count( ua.id ) AS count 
  5. FROM
  6.  ums_role ur
  7.  LEFT JOIN ums_admin_role_relation uarr ON ur.id = uarr.role_id
  8.  LEFT JOIN ums_admin ua ON uarr.admin_id = ua.id 
  9. GROUP BY
  10.  ur.id;
  • 先在Dao中添加一个groupList方法,然后使用@Results注解定义好resultMap;


   
  1. /**
  2.  * Created by macro on 2020/12/9.
  3.  */
  4. public  interface UmsAdminDao {
  5.     @SelectProvider( type = SqlProviderAdapter.class, method =  "select")
  6.     @Results(id =  "RoleStatResult", value = {
  7.             @Result(column =  "roleId", property =  "roleId", jdbcType = JdbcType.BIGINT, id =  true),
  8.             @Result(column =  "roleName", property =  "roleName", jdbcType = JdbcType.VARCHAR),
  9.             @Result(column =  "count", property =  "count", jdbcType = JdbcType.INTEGER)
  10.     })
  11.     List<RoleStatDto> groupList(SelectStatementProvider selectStatement);
  12. }
  • 然后在Service中调用groupList方法传入StatementProvider即可,对应的Java代码实现如下。


   
  1. /**
  2.  * 后台用户管理Service实现类
  3.  * Created by macro on 2020/12/8.
  4.  */
  5. @Service
  6. public class UmsAdminServiceImpl implements UmsAdminService {
  7.     @Override
  8.     public List<RoleStatDto> groupList() {
  9.         SelectStatementProvider selectStatement = SqlBuilder. select(UmsRoleDynamicSqlSupport.id.as( "roleId"), UmsRoleDynamicSqlSupport.name.as( "roleName"), count(UmsAdminDynamicSqlSupport.id).as( "count"))
  10.                 .from(UmsRoleDynamicSqlSupport.umsRole)
  11.                 .leftJoin(UmsAdminRoleRelationDynamicSqlSupport.umsAdminRoleRelation)
  12.                 .on(UmsRoleDynamicSqlSupport.id, equalTo(UmsAdminRoleRelationDynamicSqlSupport.roleId))
  13.                 .leftJoin(UmsAdminDynamicSqlSupport.umsAdmin)
  14.                 .on(UmsAdminRoleRelationDynamicSqlSupport.adminId, equalTo(UmsAdminDynamicSqlSupport.id))
  15.                 .groupBy(UmsRoleDynamicSqlSupport.id)
  16.                 .build()
  17.                 .render(RenderingStrategies.MYBATIS3);
  18.          return adminDao.groupList(selectStatement);
  19.     }
  20. }

条件删除

使用Dynamic SQL实现条件删除,直接调用Mapper接口中生成好的delete方法即可。

  • 这里以按用户名删除后台用户为例,SQL实现如下;


   
  1. DELETE 
  2. FROM
  3.  ums_admin 
  4. WHERE
  5.  username =  'andy';
  • 使用Dynamic SQL对应Java中的实现如下。


   
  1. /**
  2.  * 后台用户管理Service实现类
  3.  * Created by macro on 2020/12/8.
  4.  */
  5. @Service
  6. public class UmsAdminServiceImpl implements UmsAdminService {
  7.     @Override
  8.     public void deleteByUsername(String username) {
  9.         DeleteStatementProvider deleteStatement = SqlBuilder.deleteFrom(UmsAdminDynamicSqlSupport.umsAdmin)
  10.                 .where(UmsAdminDynamicSqlSupport.username, isEqualTo(username))
  11.                 .build()
  12.                 .render(RenderingStrategies.MYBATIS3);
  13.         adminMapper. delete(deleteStatement);
  14.     }
  15. }

条件修改

使用Dynamic SQL实现条件修改,直接调用Mapper接口中生成好的update方法即可。

  • 这里以按指定ID修改后台用户的状态为例,SQL实现如下;


   
  1. UPDATE ums_admin 
  2. SET STATUS =  1 
  3. WHERE
  4.  id IN (  12 );
  • 使用Dynamic SQL对应Java中的实现如下。


   
  1. /**
  2.  * 后台用户管理Service实现类
  3.  * Created by macro on 2020/12/8.
  4.  */
  5. @Service
  6. public class UmsAdminServiceImpl implements UmsAdminService {
  7.     @Override
  8.     public void updateByIds(List<Long> ids, Integer status) {
  9.         UpdateStatementProvider updateStatement = SqlBuilder.update(UmsAdminDynamicSqlSupport.umsAdmin)
  10.                 .set(UmsAdminDynamicSqlSupport.status).equalTo(status)
  11.                 .where(UmsAdminDynamicSqlSupport.id, isIn(ids))
  12.                 .build()
  13.                 .render(RenderingStrategies.MYBATIS3);
  14.         adminMapper.update(updateStatement);
  15.     }
  16. }

一对多查询

使用Dynamic SQL也可以实现一对多查询,只是由于Java注解无法实现循环引用,所以一对多的resultMap只能在mapper.xml来配置,这可能是唯一需要使用mapper.xml的地方。

  • 这里以按ID查询后台用户信息(包含对应角色列表)为例,SQL实现如下;


   
  1. SELECT
  2.  ua.*,
  3.  ur.id AS role_id,
  4.  ur.NAME AS role_name,
  5.  ur.description AS role_description,
  6.  ur.create_time AS role_create_time,
  7.  ur.STATUS AS role_status,
  8.  ur.sort AS role_sort 
  9. FROM
  10.  ums_admin ua
  11.  LEFT JOIN ums_admin_role_relation uarr ON ua.id = uarr.admin_id
  12.  LEFT JOIN ums_role ur ON uarr.role_id = ur.id 
  13. WHERE
  14.  ua.id =  1
  • 然后在Dao接口中添加selectWithRoleList方法,这里使用@ResultMap注解引用mapper.xml中定义的resultMap;


   
  1. /**
  2.  * Created by macro on 2020/12/9.
  3.  */
  4. public  interface UmsAdminDao {
  5.     @SelectProvider( type = SqlProviderAdapter.class, method =  "select")
  6.     @ResultMap( "AdminRoleResult")
  7.     AdminRoleDto selectWithRoleList(SelectStatementProvider selectStatement);
  8. }
  • 在mapper.xml中添加名称为AdminRoleResult的resultMap,这里有个小技巧,可以直接引用在Mapper接口中定义好的resultMap;


   
  1. <resultMap id= "AdminRoleResult"  type= "com.macro.mall.tiny.domain.AdminRoleDto"
  2.            extends= "com.macro.mall.tiny.mbg.mapper.UmsAdminMapper.UmsAdminResult">
  3.     <collection property= "roleList" resultMap= "com.macro.mall.tiny.mbg.mapper.UmsRoleMapper.UmsRoleResult" columnPrefix= "role_">
  4.     </collection>
  5. </resultMap>
  • 然后在Service实现类中调用即可,为了方便结果集映射给查询列取了别名。


   
  1. /**
  2.  * 后台用户管理Service实现类
  3.  * Created by macro on 2020/12/8.
  4.  */
  5. @Service
  6. public class UmsAdminServiceImpl implements UmsAdminService {   
  7.     @Override
  8.     public AdminRoleDto selectWithRoleList(Long id) {
  9.         List<BasicColumn> columnList =  new ArrayList<>(CollUtil.toList(UmsAdminMapper.selectList));
  10.         columnList.add(UmsRoleDynamicSqlSupport.id.as( "role_id"));
  11.         columnList.add(UmsRoleDynamicSqlSupport.name.as( "role_name"));
  12.         columnList.add(UmsRoleDynamicSqlSupport.description.as( "role_description"));
  13.         columnList.add(UmsRoleDynamicSqlSupport.createTime.as( "role_create_time"));
  14.         columnList.add(UmsRoleDynamicSqlSupport.status.as( "role_status"));
  15.         columnList.add(UmsRoleDynamicSqlSupport.sort.as( "role_sort"));
  16.         SelectStatementProvider selectStatement = SqlBuilder. select(columnList)
  17.                 .from(UmsAdminDynamicSqlSupport.umsAdmin)
  18.                 .leftJoin(UmsAdminRoleRelationDynamicSqlSupport.umsAdminRoleRelation)
  19.                 .on(UmsAdminDynamicSqlSupport.id, equalTo(UmsAdminRoleRelationDynamicSqlSupport.adminId))
  20.                 .leftJoin(UmsRoleDynamicSqlSupport.umsRole)
  21.                 .on(UmsAdminRoleRelationDynamicSqlSupport.roleId, equalTo(UmsRoleDynamicSqlSupport.id))
  22.                 .where(UmsAdminDynamicSqlSupport.id, isEqualTo(id))
  23.                 .build()
  24.                 .render(RenderingStrategies.MYBATIS3);
  25.          return adminDao.selectWithRoleList(selectStatement);
  26.     }
  27. }

总结

当我们使用MyBatis官方代码生成器MBG时,配置的targetRuntime决定了使用它的使用方式。Dynamic SQL更倾向于使用Java API来实现SQL操作,传统的方式更倾向于在mapper.xml中手写SQL来实现SQL操作。虽然MyBatis官方推荐使用Dynamic SQL,但选择那种方式全看个人习惯了!

参考资料

官方文档:https://mybatis.org/mybatis-dynamic-sql/docs/introduction.html

项目源码地址

https://github.com/macrozheng/mall-learning/tree/master/mall-tiny-dynamic-sql

推荐阅读


欢迎关注,点个在看


转载:https://blog.csdn.net/zhenghongcs/article/details/111878159
查看评论
* 以上用户言论只代表其个人观点,不代表本网站的观点或立场