Mybatis-Plus的使用


Mybatis-Plus的使用

  1. 在SpringBoot中导依赖(只需要导入Mybatis-plus就好,不需要再额外导入Mybatis)

    
        com.baomidou
        mybatis-plus-boot-starter
        3.4.2
    
    
  2. 代码生成器依赖

    
    
        com.baomidou
        mybatis-plus-generator
        3.4.2
    
    
    
    
        org.freemarker
        freemarker
        2.3.31
    
    
    
  3. 代码生成器示例

    // 演示例子,执行 main 方法控制台输入模块表名回车自动生成对应项目目录中
    // 在控制台输入 m_user   m_blog
    public class CodeGenerator {
    
        /**
         * 

    * 读取控制台内容 *

    */ public static String scanner(String tip) { Scanner scanner = new Scanner(System.in); StringBuilder help = new StringBuilder(); help.append("请输入" + tip + ":"); System.out.println(help.toString()); if (scanner.hasNext()) { String ipt = scanner.next(); if (StringUtils.isNotEmpty(ipt)) { return ipt; } } throw new MybatisPlusException("请输入正确的" + tip + "!"); } public static void main(String[] args) { // 代码生成器 AutoGenerator mpg = new AutoGenerator(); // 全局配置 GlobalConfig gc = new GlobalConfig(); String projectPath = System.getProperty("user.dir"); gc.setOutputDir(projectPath + "/src/main/java"); // gc.setOutputDir("D:\\test"); gc.setAuthor("陈天祥"); gc.setOpen(false); // gc.setSwagger2(true); 实体属性 Swagger2 注解 gc.setServiceName("%sService"); mpg.setGlobalConfig(gc); // 数据源配置 DataSourceConfig dsc = new DataSourceConfig(); dsc.setUrl("jdbc:mysql://localhost:3306/自己连接的数据库?useUnicode=true&useSSL=false&characterEncoding=utf8&serverTimezone=UTC"); // dsc.setSchemaName("public"); dsc.setDriverName("com.mysql.cj.jdbc.Driver"); dsc.setUsername("root"); dsc.setPassword("密码"); mpg.setDataSource(dsc); // 包配置 PackageConfig pc = new PackageConfig(); pc.setModuleName(null); pc.setParent("com.chen.vueblog"); mpg.setPackageInfo(pc); // 自定义配置 InjectionConfig cfg = new InjectionConfig() { @Override public void initMap() { // to do nothing } }; // 如果模板引擎是 freemarker String templatePath = "/templates/mapper.xml.ftl"; // 如果模板引擎是 velocity // String templatePath = "/templates/mapper.xml.vm"; // 自定义输出配置 List focList = new ArrayList<>(); // 自定义配置会被优先输出 focList.add(new FileOutConfig(templatePath) { @Override public String outputFile(TableInfo tableInfo) { // 自定义输出文件名 , 如果你 Entity 设置了前后缀、此处注意 xml 的名称会跟着发生变化!! return projectPath + "/src/main/resources/mapper/" + "/" + tableInfo.getEntityName() + "Mapper" + StringPool.DOT_XML; } }); cfg.setFileOutConfigList(focList); mpg.setCfg(cfg); // 配置模板 TemplateConfig templateConfig = new TemplateConfig(); templateConfig.setXml(null); mpg.setTemplate(templateConfig); // 策略配置 StrategyConfig strategy = new StrategyConfig(); strategy.setNaming(NamingStrategy.underline_to_camel); strategy.setColumnNaming(NamingStrategy.underline_to_camel); strategy.setEntityLombokModel(true); strategy.setRestControllerStyle(true); strategy.setInclude(scanner("表名,多个英文逗号分割").split(",")); strategy.setControllerMappingHyphenStyle(true); strategy.setTablePrefix("m_"); mpg.setStrategy(strategy); mpg.setTemplateEngine(new FreemarkerTemplateEngine()); mpg.execute(); } }

    运行后,数据想要创建模板的表名,系统自动创建

  4. 分页插件

    //Spring boot方式
    @Configuration
    @MapperScan("com.baomidou.cloud.service.*.mapper*")
    public class MybatisPlusConfig {
    
        // 旧版
        @Bean
        public PaginationInterceptor paginationInterceptor() {
            PaginationInterceptor paginationInterceptor = new PaginationInterceptor();
            // 设置请求的页面大于最大页后操作, true调回到首页,false 继续请求  默认false
            // paginationInterceptor.setOverflow(false);
            // 设置最大单页限制数量,默认 500 条,-1 不受限制
            // paginationInterceptor.setLimit(500);
            // 开启 count 的 join 优化,只针对部分 left join
            paginationInterceptor.setCountSqlParser(new JsqlParserCountOptimize(true));
            return paginationInterceptor;
        }
    }
    
  5. Mybatis-Plus Service CRUD的接口 使用

    ps:当传入是个wapper时候,可以用 new xxxWrapper 包装一下xxx为想使用那种行为,,例如 查询Query,Update,在下面分页时候使用到了该方法

    save

    // 插入一条记录(选择字段,策略插入)
    boolean save(T entity);
    // 插入(批量)
    boolean saveBatch(Collection entityList);
    // 插入(批量)
    boolean saveBatch(Collection entityList, int batchSize);
    
    参数说明
    类型 参数名 描述
    T entity 实体对象
    Collection entityList 实体对象集合
    int batchSize 插入批次数量

    SaveOrUpdata

    // TableId 注解存在更新记录,否插入一条记录
    boolean saveOrUpdate(T entity);
    // 根据updateWrapper尝试更新,否继续执行saveOrUpdate(T)方法
    boolean saveOrUpdate(T entity, Wrapper updateWrapper);
    // 批量修改插入
    boolean saveOrUpdateBatch(Collection entityList);
    // 批量修改插入
    boolean saveOrUpdateBatch(Collection entityList, int batchSize);
    
    参数说明
    类型 参数名 描述
    T entity 实体对象
    Wrapper updateWrapper 实体对象封装操作类 UpdateWrapper
    Collection entityList 实体对象集合
    int batchSize 插入批次数量

    Remove

    // 根据 entity 条件,删除记录
    boolean remove(Wrapper queryWrapper);
    // 根据 ID 删除
    boolean removeById(Serializable id);
    // 根据 columnMap 条件,删除记录
    boolean removeByMap(Map columnMap);
    // 删除(根据ID 批量删除)
    boolean removeByIds(Collection<? extends Serializable> idList);
    
    参数说明
    类型 参数名 描述
    Wrapper queryWrapper 实体包装类 QueryWrapper
    Serializable id 主键ID
    Map columnMap 表字段 map 对象
    Collection<? extends Serializable> idList 主键ID列表

    Update

    // 根据 UpdateWrapper 条件,更新记录 需要设置sqlset
    boolean update(Wrapper updateWrapper);
    // 根据 whereEntity 条件,更新记录
    boolean update(T entity, Wrapper updateWrapper);
    // 根据 ID 选择修改
    boolean updateById(T entity);
    // 根据ID 批量更新
    boolean updateBatchById(Collection entityList);
    // 根据ID 批量更新
    boolean updateBatchById(Collection entityList, int batchSize);
    
    参数说明
    类型 参数名 描述
    Wrapper updateWrapper 实体对象封装操作类 UpdateWrapper
    T entity 实体对象
    Collection entityList 实体对象集合
    int batchSize 更新批次数量

    Get

    // 根据 ID 查询
    T getById(Serializable id);
    // 根据 Wrapper,查询一条记录。结果集,如果是多个会抛出异常,随机取一条加上限制条件 wrapper.last("LIMIT 1")
    T getOne(Wrapper queryWrapper);
    // 根据 Wrapper,查询一条记录
    T getOne(Wrapper queryWrapper, boolean throwEx);
    // 根据 Wrapper,查询一条记录
    Map getMap(Wrapper queryWrapper);
    // 根据 Wrapper,查询一条记录
     V getObj(Wrapper queryWrapper, Function<? super Object, V> mapper);
    
    参数说明
    类型 参数名 描述
    Serializable id 主键ID
    Wrapper queryWrapper 实体对象封装操作类 QueryWrapper
    boolean throwEx 有多个 result 是否抛出异常
    T entity 实体对象
    Function<? super Object, V> mapper 转换函数

    List

    // 查询所有
    List list();
    // 查询列表
    List list(Wrapper queryWrapper);
    // 查询(根据ID 批量查询)
    Collection listByIds(Collection<? extends Serializable> idList);
    // 查询(根据 columnMap 条件)
    Collection listByMap(Map columnMap);
    // 查询所有列表
    List> listMaps();
    // 查询列表
    List> listMaps(Wrapper queryWrapper);
    // 查询全部记录
    List listObjs();
    // 查询全部记录
     List listObjs(Function<? super Object, V> mapper);
    // 根据 Wrapper 条件,查询全部记录
    List listObjs(Wrapper queryWrapper);
    // 根据 Wrapper 条件,查询全部记录
     List listObjs(Wrapper queryWrapper, Function<? super Object, V> mapper);
    
    
    参数说明
    类型 参数名 描述
    Wrapper queryWrapper 实体对象封装操作类 QueryWrapper
    Collection<? extends Serializable> idList 主键ID列表
    Map<?String, Object> columnMap 表字段 map 对象
    Function<? super Object, V> mapper 转换函数

    Page

    // 无条件分页查询
    IPage page(IPage page);
    // 条件分页查询
    IPage page(IPage page, Wrapper queryWrapper);
    // 无条件分页查询
    IPage> pageMaps(IPage page);
    // 条件分页查询
    IPage> pageMaps(IPage page, Wrapper queryWrapper);
    

    示例: 查询所有blogs为例

    @GetMapping("/blogs")
        public Result list(@RequestParam(defaultValue = "1") Integer currentPage) {
            // 分页,按照created倒序
            Page page = new Page(currentPage, 5);
            IPage pageData = blogService.page(page, new QueryWrapper().orderByDesc("created"));
            return Result.succ(pageData);
        }
    
    参数说明
    类型 参数名 描述
    IPage page 翻页对象
    Wrapper queryWrapper 实体对象封装操作类 QueryWrapper
  6. MapperCRUD接口

    insert

    // 插入一条记录
    int insert(T entity);
    
    参数说明
    类型 参数名 描述
    T entity 实体对象

    Delete

    // 根据 entity 条件,删除记录
    int delete(@Param(Constants.WRAPPER) Wrapper wrapper);
    // 删除(根据ID 批量删除)
    int deleteBatchIds(@Param(Constants.COLLECTION) Collection<? extends Serializable> idList);
    // 根据 ID 删除
    int deleteById(Serializable id);
    // 根据 columnMap 条件,删除记录
    int deleteByMap(@Param(Constants.COLUMN_MAP) Map columnMap);
    
    参数说明
    类型 参数名 描述
    Wrapper wrapper 实体对象封装操作类(可以为 null)
    Collection<? extends Serializable> idList 主键ID列表(不能为 null 以及 empty)
    Serializable id 主键ID
    Map columnMap 表字段 map 对象

    Update

    // 根据 whereEntity 条件,更新记录
    int update(@Param(Constants.ENTITY) T entity, @Param(Constants.WRAPPER) Wrapper updateWrapper);
    // 根据 ID 修改
    int updateById(@Param(Constants.ENTITY) T entity);
    
    参数说明
    类型 参数名 描述
    T entity 实体对象 (set 条件值,可为 null)
    Wrapper updateWrapper 实体对象封装操作类(可以为 null,里面的 entity 用于生成 where 语句)

    Select

    // 根据 ID 查询
    T selectById(Serializable id);
    // 根据 entity 条件,查询一条记录
    T selectOne(@Param(Constants.WRAPPER) Wrapper queryWrapper);
    
    // 查询(根据ID 批量查询)
    List selectBatchIds(@Param(Constants.COLLECTION) Collection<? extends Serializable> idList);
    // 根据 entity 条件,查询全部记录
    List selectList(@Param(Constants.WRAPPER) Wrapper queryWrapper);
    // 查询(根据 columnMap 条件)
    List selectByMap(@Param(Constants.COLUMN_MAP) Map columnMap);
    // 根据 Wrapper 条件,查询全部记录
    List> selectMaps(@Param(Constants.WRAPPER) Wrapper queryWrapper);
    // 根据 Wrapper 条件,查询全部记录。注意: 只返回第一个字段的值
    List selectObjs(@Param(Constants.WRAPPER) Wrapper queryWrapper);
    
    // 根据 entity 条件,查询全部记录(并翻页)
    IPage selectPage(IPage page, @Param(Constants.WRAPPER) Wrapper queryWrapper);
    // 根据 Wrapper 条件,查询全部记录(并翻页)
    IPage> selectMapsPage(IPage page, @Param(Constants.WRAPPER) Wrapper queryWrapper);
    // 根据 Wrapper 条件,查询总记录数
    Integer selectCount(@Param(Constants.WRAPPER) Wrapper queryWrapper);
    
    
    参数说明
    类型 参数名 描述
    Serializable id 主键ID
    Wrapper queryWrapper 实体对象封装操作类(可以为 null)
    Collection<? extends Serializable> idList 主键ID列表(不能为 null 以及 empty)
    Map columnMap 表字段 map 对象
    IPage page 分页查询条件(可以为 RowBounds.DEFAULT)

    到此,Mybatis-Plus总结告一段落,足够开发中用的了!


    下面是Mybatis如何在SpringBoot项目中 自定义SQL

    Mybatis-Plus通过注解自定义SQL语句

    其实Mybatis-Plus在Mybatis的基础上封装了CRUD,故保留着原来的功能!

    和以前的Mybatis使用相同

    示例:

    1. 在UserMapper定义SQL语句

      public interface UserMapper extends BaseMapper {
      
          // 自定义sql语句查询(查询数据库中其他表)
          @Select(" select *  from sys_user")
          public List findAllUser();
      }
      
    2. 在UserService接口中写入方法

      public interface UserService extends IService {
          public List findAllUser();
      }
      
    3. 在UserService.java中实现方法

      @Service
      public class UserServiceImpl extends ServiceImpl implements UserService {
      
          @Autowired
          private UserMapper userMapper;
      
          // 调用自己的sql语句查询
          @Override
          public List findAllUser() {
              return userMapper.findAllUser();
          }
      }
      
    4. 在UserController中调用

      @RestController
      @RequestMapping("/user")
      public class UserController {
      
          @Autowired
          UserService userService;
      
          @GetMapping("/index")
          public User index(){
              return userService.getById(1L);
          }
      
          @PostMapping("/save")
          public Result save(@Validated @RequestBody User user) {
              return Result.succ(user);
          }
      
          // 自定义sql语句查询其他表数据
          @GetMapping("/all")
          public List findAllUser(){
              return userService.findAllUser();
          }
      }
      

      这样就可以实现自定义SQL语句了

      还可以通过相应的注解写入复杂的SQL语句