tk.mybatis如何扩展自己的通用mapper
tk.mybatis扩展自己的通用mapper
目的:tk.mybatis 提供的通用mapper,虽然使用方便,不过在有些sql还是不能满足我们的需要的,而且我们希望对于deleted语句进行管控(因为通用mapper提供的都是物理删除,有时我们对一些敏感数据只能进行逻辑删除),因此我们将基于原有的通用mapper进行自己的扩展
1 jar引入
<!-- 非springboot --> <dependency> <groupId>tk.mybatis</groupId> <artifactId>mapper</artifactId> <version>3.4.0</version> </dependency>
非springboot项目引这个包
<!-- springboot --> <dependency> <groupId>tk.mybatis</groupId> <artifactId>mapper-spring-boot-starter</artifactId> <version>2.0.2</version> </dependency>
springboot项目直接引这个包,本次我们将基于springboot进行开发,这里注意jar包版本,过低的版本将会出现问题,下面会介绍
2 编写配置类
package com.example.configuration; import com.example.common.mapper.commonMapper.CommonMapper; import org.mybatis.spring.boot.autoconfigure.MybatisAutoConfiguration; import org.springframework.boot.autoconfigure.AutoConfigureAfter; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import tk.mybatis.spring.mapper.MapperScannerConfigurer; import java.util.Properties; @Configuration @AutoConfigureAfter(MybatisAutoConfiguration.class) public class MyBatisConfiguration { @Bean public MapperScannerConfigurer mapperScannerConfigurer() { MapperScannerConfigurer mapperScannerConfigurer = new MapperScannerConfigurer(); mapperScannerConfigurer.setSqlSessionFactoryBeanName("sqlSessionFactory"); mapperScannerConfigurer.setBasePackage("com.example.dao.mapper"); Properties properties = new Properties(); properties.setProperty("mappers", CommonMapper.class.getName()); properties.setProperty("notEmpty", "false"); properties.setProperty("identity", "MYSQL"); properties.setProperty("order","BEFORE"); mapperScannerConfigurer.setProperties(properties); return mapperScannerConfigurer; } }
这里要注意两点:
1>CommonMapper这个是我们自己定义的通用mapper,它放置一个单独的包下面。也就是说这个包下面只有这个一个mapper,否则我们在实用泛型时会出现类型转换的问题。(我在这里纠结了好久)
2>这里我们配置了自定义mapper的扫描路径。注意springboot项目一定要注意jar包版本,版本过低的话,在配置类中的定义是没有用的。还是扫描不到,我之前使用的版本1.2.3就会出现这个问题,更换更高的版本就可以解决了。
3 常规方法接口整合到自己的自定义Mapper接口上
因为我们使用的是mysql数据库,所以在使用通用功能的时候就选择性引入一些经常使用的方法,下面是自己定义的常用mapper类的整合(这里会抛弃一些不常用的类或不是mysql的方法类)。这些基类不要放在 BasePackage的路径下,这个路径下的mapper都是要指定明确的泛型类型的。
1 > 提供查询功能Mapper:
package com.example.common.mapper.basics; import tk.mybatis.mapper.common.Marker; import tk.mybatis.mapper.common.base.select.*; import tk.mybatis.mapper.common.condition.SelectByConditionMapper; import tk.mybatis.mapper.common.condition.SelectCountByConditionMapper; import tk.mybatis.mapper.common.example.SelectByExampleMapper; import tk.mybatis.mapper.common.ids.SelectByIdsMapper; /** * @desc 基础查询功能mapper * */ public interface SelectMapper<T> extends Marker, SelectOneMapper<T>, tk.mybatis.mapper.common.base.select.SelectMapper<T>, SelectAllMapper<T>, SelectCountMapper<T>, SelectByPrimaryKeyMapper<T>, ExistsWithPrimaryKeyMapper<T>, SelectByIdsMapper<T>, SelectByConditionMapper<T>, SelectCountByConditionMapper<T>, SelectByExampleMapper<T> { }
2>提供新增功能mapper
package com.example.common.mapper.basics; import tk.mybatis.mapper.common.Marker; import tk.mybatis.mapper.common.MySqlMapper; import tk.mybatis.mapper.common.base.insert.InsertSelectiveMapper; /** * @desc 基础插入功能mapper */ public interface InsertMapper<T> extends Marker, tk.mybatis.mapper.common.base.insert.InsertMapper<T>, InsertSelectiveMapper<T>, MySqlMapper<T>{ }
3>提供更新功能mapper
package com.example.common.mapper.basics; import tk.mybatis.mapper.common.Marker; import tk.mybatis.mapper.common.base.update.UpdateByPrimaryKeyMapper; import tk.mybatis.mapper.common.base.update.UpdateByPrimaryKeySelectiveMapper; import tk.mybatis.mapper.common.condition.UpdateByConditionMapper; import tk.mybatis.mapper.common.condition.UpdateByConditionSelectiveMapper; import tk.mybatis.mapper.common.example.UpdateByExampleSelectiveMapper; /** * @desc 基础更新功能mapper * */ public interface UpdateMapper<T> extends Marker, UpdateByPrimaryKeyMapper<T>, UpdateByPrimaryKeySelectiveMapper<T>, UpdateByConditionMapper<T>, UpdateByConditionSelectiveMapper<T>, UpdateByExampleSelectiveMapper<T> { }
4>提供删除功能mapper
package com.example.common.mapper.basics; import com.example.common.mapper.defined.DeleteShamByIdsMapper; import tk.mybatis.mapper.common.Marker; import tk.mybatis.mapper.common.base.delete.DeleteByPrimaryKeyMapper; import tk.mybatis.mapper.common.condition.DeleteByConditionMapper; import tk.mybatis.mapper.common.ids.DeleteByIdsMapper; /** * @desc 基础删除功能mapper * */ public interface DeleteMapper<T> extends Marker, tk.mybatis.mapper.common.base.delete.DeleteMapper<T>, DeleteByPrimaryKeyMapper<T>, DeleteByConditionMapper<T>, DeleteByIdsMapper<T>{ }
5>提供增删改查的基类 CommonMapper
package com.example.common.mapper.commonMapper; import com.example.common.mapper.basics.DeleteMapper; import com.example.common.mapper.basics.InsertMapper; import com.example.common.mapper.basics.SelectMapper; import com.example.common.mapper.basics.UpdateMapper; /** * @param <T> * @desc 基础增删改查功能mapper */ public interface CommonMapper<T> extends DeleteMapper<T>, InsertMapper<T>, SelectMapper<T>, UpdateMapper<T> { }
6>实体对象
package com.example.dao.entity; import lombok.Data; import javax.persistence.Id; import javax.persistence.Table; import java.io.Serializable; @Table(name="user") @Data public class User implements Serializable { @Id private Integer id; private String trueName; private String userName; private Integer isDeleted; }
7>让自定义mapper继承CommenMapper,就可以使用这些语句了
package com.example.dao.mapper; import com.example.common.mapper.commonMapper.CommonMapper; import com.example.dao.entity.User; public interface UserMapper extends CommonMapper<User> { }
接下来我们会对 CommonMapper中提供删除方法的DeleteMapper进行增强,来给他添加逻辑删除的语句
1>我们自定义的Provider需要去继承 MapperTemplate并覆写构造方法
这个是源码中的批量删除
// // Source code recreated from a .class file by IntelliJ IDEA // (powered by Fernflower decompiler) // package tk.mybatis.mapper.provider; import java.util.Set; import org.apache.ibatis.mapping.MappedStatement; import tk.mybatis.mapper.MapperException; import tk.mybatis.mapper.entity.EntityColumn; import tk.mybatis.mapper.mapperhelper.EntityHelper; import tk.mybatis.mapper.mapperhelper.MapperHelper; import tk.mybatis.mapper.mapperhelper.MapperTemplate; import tk.mybatis.mapper.mapperhelper.SqlHelper; public class IdsProvider extends MapperTemplate { public IdsProvider(Class<?> mapperClass, MapperHelper mapperHelper) { super(mapperClass, mapperHelper); } public String deleteByIds(MappedStatement ms) { Class<?> entityClass = this.getEntityClass(ms); StringBuilder sql = new StringBuilder(); sql.append(SqlHelper.deleteFromTable(entityClass, this.tableName(entityClass))); Set<EntityColumn> columnList = EntityHelper.getPKColumns(entityClass); if (columnList.size() == 1) { EntityColumn column = (EntityColumn)columnList.iterator().next(); sql.append(" where "); sql.append(column.getColumn()); sql.append(" in (${_parameter})"); return sql.toString(); } else { throw new MapperException("继承 deleteByIds 方法的实体类[" + entityClass.getCanonicalName() + "]中必须只有一个带有 @Id 注解的字段"); } } public String selectByIds(MappedStatement ms) { Class<?> entityClass = this.getEntityClass(ms); this.setResultType(ms, entityClass); StringBuilder sql = new StringBuilder(); sql.append(SqlHelper.selectAllColumns(entityClass)); sql.append(SqlHelper.fromTable(entityClass, this.tableName(entityClass))); Set<EntityColumn> columnList = EntityHelper.getPKColumns(entityClass); if (columnList.size() == 1) { EntityColumn column = (EntityColumn)columnList.iterator().next(); sql.append(" where "); sql.append(column.getColumn()); sql.append(" in (${_parameter})"); return sql.toString(); } else { throw new MapperException("继承 selectByIds 方法的实体类[" + entityClass.getCanonicalName() + "]中必须只有一个带有 @Id 注解的字段"); } } }
接下来我们对IdsProvider 进行扩展使他支持批量逻辑删除
1>创建IdsProvider的子类
package com.example.common.mapper.defined; import org.apache.ibatis.mapping.MappedStatement; import tk.mybatis.mapper.MapperException; import tk.mybatis.mapper.entity.EntityColumn; import tk.mybatis.mapper.mapperhelper.EntityHelper; import tk.mybatis.mapper.mapperhelper.MapperHelper; import tk.mybatis.mapper.mapperhelper.SqlHelper; import tk.mybatis.mapper.provider.IdsProvider; import java.util.Set; public class IdsProviderDefined extends IdsProvider { public IdsProviderDefined(Class<?> mapperClass, MapperHelper mapperHelper) { super(mapperClass, mapperHelper); } public String deleteShamByIds(MappedStatement ms) { Class<?> entityClass = this.getEntityClass(ms); StringBuilder sql = new StringBuilder(); sql.append(SqlHelper.updateTable(entityClass, this.tableName(entityClass))); sql.append("<set> is_deleted='1' </set>"); Set<EntityColumn> columnList = EntityHelper.getPKColumns(entityClass); if (columnList.size() == 1) { EntityColumn column = (EntityColumn)columnList.iterator().next(); sql.append(" where "); sql.append(column.getColumn()); sql.append(" in (${_parameter})"); return sql.toString(); } else { throw new MapperException("继承 deleteByIds 方法的实体类[" + entityClass.getCanonicalName() + "]中必须只有一个带有 @Id 注解的字段"); } } }
deleteShamByIds就是我们门批量逻辑删除的方法,这个方法其实就是再拼装sql,tk中提供了很多帮助我们拼装sql,和参数的类(SqlHelper,EntityHelper),我们可以使用
2>创建DeleteShamByIdsMapper接口
package com.example.common.mapper.defined; import org.apache.ibatis.annotations.DeleteProvider; public interface DeleteShamByIdsMapper<T> { @DeleteProvider( type = IdsProviderDefined.class, method = "dynamicSQL" ) int deleteShamByIds(String var1); //这里的抽象方法的名称必须和IdsProviderDefined 中的方法一致 }
3>在DeleteMapper中继承我们自定义的逻辑删除接口DeleteShamByIdsMapper
package com.example.common.mapper.basics; import com.example.common.mapper.defined.DeleteShamByIdsMapper; import tk.mybatis.mapper.common.Marker; import tk.mybatis.mapper.common.base.delete.DeleteByPrimaryKeyMapper; import tk.mybatis.mapper.common.condition.DeleteByConditionMapper; import tk.mybatis.mapper.common.ids.DeleteByIdsMapper; /** * @desc 基础删除功能mapper * */ public interface DeleteMapper<T> extends Marker, tk.mybatis.mapper.common.base.delete.DeleteMapper<T>, DeleteByPrimaryKeyMapper<T>, DeleteByConditionMapper<T>, DeleteByIdsMapper<T>, DeleteShamByIdsMapper<T>{ }
到这里我们自定义的批量逻辑删除就定义好了,我们可以通过这种方式扩展通用mapper。
TK mybatis插件通用mapper与oracle的几个坑
最近公司有几个项目的数据库用的oracle,有段时间没用,然后果断就掉坑里面了,记录几个比较有代表性的。
1:关于oracle的批量数据插入,我用TK通用mapper的insertList方法自动拼接出来的sql是这样的
insert into table(column1,column2)values (value1,value2), (value3,value4)。。。
咋一看没啥问题啊,然后就一直报 sql未正确结束,出于对自己sql的过于自信,导致一直都在思考是否是参数问题,浪费了好几个小时,后来把sql拼好直接丢到数据库跑了跑才发现,这种sql确实是不能在oracle跑的,oracle批量插入的语法应该是:
INSERT ALL INTO A(field_1,field_2) VALUES (value_1,value_2) INTO A(field_1,field_2) VALUES (value_3,value_4) INTO A(field_1,field_2) VALUES (value_5,value_6)
粗略的瞅了下TK的代码,貌似确实没有校验数据库驱动就直接开始拼sql了
public String insertList(MappedStatement ms) { Class<?> entityClass = this.getEntityClass(ms); StringBuilder sql = new StringBuilder(); sql.append(SqlHelper.insertIntoTable(entityClass, this.tableName(entityClass))); sql.append(SqlHelper.insertColumns(entityClass, true, false, false)); sql.append(" VALUES "); sql.append("<foreach collection=\"list\" item=\"record\" separator=\",\" >"); sql.append("<trim prefix=\"(\" suffix=\")\" suffixOverrides=\",\">"); Set<EntityColumn> columnList = EntityHelper.getColumns(entityClass); Iterator var5 = columnList.iterator(); while(var5.hasNext()) { EntityColumn column = (EntityColumn)var5.next(); if (!column.isId() && column.isInsertable()) { sql.append(column.getColumnHolder("record") + ","); } } sql.append("</trim>"); sql.append("</foreach>"); return sql.toString(); }
不过我觉得这种插件肯定是有兼容方案的,并且使用了这个插件跟使用源生mybatis并不冲突,所以实际对开发并没有影响,算是复习一下oracle的基础并提醒下自己,程序员还是老老实实先run起来,自以为是的经验有时候也很坑的。
2:关于oracle的比较符号(<> =)和null
先复习一下
一般数据库查询某某字段为空或者不为空的时候都是用is null或者is not null
如果查询条件使用=null或者<>null是查不出来数据的
但是赋值却可以用=null如
update BUS_PLATFORM.bus_trans set return_code = null where return_msg= 'tac验证通过';
这个是可以执行成功的,不过这个都是表外的值操作,那么当表内的数据有null时,又有啥坑呢,比如
select * from table1 where name <>'zhansan'
查询表中name字段不为zhangsan的数据,当表中有name为null的数据时,这些数据也是查不出来的.比如表中有100条数据,一条数据的name值为zhangsan ,九条数据的name值为null,那么这条sql只能查出90条数据,所以如果确切的需求要查询name值不为zhangsan的数据且包括name值为null的数据,sql应该为
select * from table1 where name <>'zhansan' or name is null
3:这个是mybatis的一个规范,基本是凑数的,不过也坑过我
先上内容:mybatis插入null值时需要指定该值的类型(jdbctype),不然会报错。
因为不指定类型的话mybatis会自己去适配匹配的数据库字段类型,null适配不了。搞不定就报错,很稳。不过一般使用xml配置sql的话一般都不会有这个问题,写的时候顺手都会写上。这个也是我使用TK的时候暴露出来的问题,在使用insert方法的时候有null就挂了,不过TK有个insertSelective方法做插入的时候会自动过滤掉空值。
以上为个人经验,希望能给大家一个参考,也希望大家多多支持我们。