前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Spring Boot(四)Mybatis-Pus

Spring Boot(四)Mybatis-Pus

作者头像
HcodeBlogger
发布2020-07-14 10:56:41
4610
发布2020-07-14 10:56:41
举报
文章被收录于专栏:Hcode网站Hcode网站

简介

  • Mybaitis Pus是什么? MyBatis 本来就是简化 JDBC 操作的!
  • 官网:https://mp.baomidou.com/ MyBatis Plus,简化 MyBatis !

Spring Boot集成使用

导入依赖

代码语言:javascript
复制
 <!-- 数据库驱动 -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <!-- lombok -->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <!-- mybatis-plus -->
        <!-- mybatis-plus 是自己开发,并非官方的! -->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.0.5</version>
        </dependency>

编写配置文件

代码语言:javascript
复制
# 设置开发环境
spring.profiles.active=dev


# 数据库连接配置
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.url=jdbc:mysql://localhost:3306/mybatis_plus?useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=GMT%2B8
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

# 配置日志
mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
# 配置逻辑删除
mybatis-plus.global-config.db-config.logic-delete-value=1
mybatis-plus.global-config.db-config.logic-not-delete-value=0

在Dao层编写Mapper接口

代码语言:javascript
复制
// 在对应的Mapper上面继承基本的类 BaseMapper
@Repository // 代表持久层
public interface UserMapper extends BaseMapper<User> {
    // 所有的CRUD操作都已经编写完成了
    // 你不需要像以前的配置一大堆文件了!
}

添加乐观锁,分页插件,逻辑删除组件的配置类

代码语言:javascript
复制
// 扫描我们的 mapper 文件夹
@MapperScan("com.kuang.mapper")
@EnableTransactionManagement
@Configuration // 配置类
public class MyBatisPlusConfig {

    // 注册乐观锁插件
    @Bean
    public OptimisticLockerInterceptor optimisticLockerInterceptor() {
        return new OptimisticLockerInterceptor();
    }

    // 分页插件
    @Bean
    public PaginationInterceptor paginationInterceptor() {
        return  new PaginationInterceptor();
    }

    // 逻辑删除组件!
    @Bean
    public ISqlInjector sqlInjector() {
        return new LogicSqlInjector();
    }


    /**
     * SQL执行效率插件  可以由此查看每个SQL语句的执行效率,可以进行SQL优化
     */
    @Bean
    @Profile({"dev","test"})// 设置 dev test 环境开启,保证我们的效率
    public PerformanceInterceptor performanceInterceptor() {
        PerformanceInterceptor performanceInterceptor = new PerformanceInterceptor();
        performanceInterceptor.setMaxTime(100); //ms 设置sql执行的最大时间,如果超过了则不执行
        performanceInterceptor.setFormat(true);
        return performanceInterceptor;
    }

}

添加自动填充时间的处理器类

代码语言:javascript
复制
@Slf4j
@Component // 一定不要忘记把处理器加到IOC容器中!
public class MyMetaObjectHandler implements MetaObjectHandler {
    // 插入时的填充策略
    @Override
    public void insertFill(MetaObject metaObject) {
        log.info("start insert fill.....");
        // setFieldValByName(String fieldName, Object fieldVal, MetaObject metaObject
        this.setFieldValByName("createTime",new Date(),metaObject);
        this.setFieldValByName("updateTime",new Date(),metaObject);
    }

    // 更新时的填充策略
    @Override
    public void updateFill(MetaObject metaObject) {
        log.info("start update fill.....");
        this.setFieldValByName("updateTime",new Date(),metaObject);
    }
}

对应POJO的实体类中应该对相应字段添加注解

代码语言:javascript
复制
    // 对应数据库中的主键 (uuid、自增id、雪花算法、redis、zookeeper!)
    @TableId(type = IdType.AUTO)
    private Long id;

    @Version //乐观锁Version注解
    private Integer version;

    @TableLogic //逻辑删除
    private Integer deleted;

    // 字段添加填充内容
    @TableField(fill = FieldFill.INSERT)
    private Date createTime;

    @TableField(fill = FieldFill.INSERT_UPDATE)
    private Date updateTime;

乐观锁

乐观锁实现方式:

  • 取出记录时,获取当前 version
  • 更新时,带上这个version
  • 执行更新时,set version = newVersion where version = oldVersion
  • 如果version不对,就更新失

具体操作

代码语言:javascript
复制
    @Autowired
    private UserMapper userMapper;
查询操作
代码语言:javascript
复制
 @Test
    public void testSelectById(){
        User user = userMapper.selectById(1L);
        System.out.println(user);
    }

    // 测试批量查询!
    @Test
    public void testSelectByBatchId(){
        List<User> users = userMapper.selectBatchIds(Arrays.asList(1, 2, 3));
        users.forEach(System.out::println);
    }

    // 按条件查询之一使用map操作
    @Test
    public void testSelectByBatchIds(){
        HashMap<String, Object> map = new HashMap<>();
        // 自定义要查询
        map.put("name","hcode");
        map.put("age",1);

        List<User> users = userMapper.selectByMap(map);
        users.forEach(System.out::println);
    }
分页查询
代码语言:javascript
复制
  // 测试分页查询
    @Test
    public void testPage(){
        //  参数一:当前页
        //  参数二:页面大小
        //  使用了分页插件之后,所有的分页操作也变得简单的!
        Page<User> page = new Page<>(2,5);
        userMapper.selectPage(page,null);

        page.getRecords().forEach(System.out::println);
        System.out.println(page.getTotal()); //总分页数

    }
删除操作

如果已经配置了逻辑删除,那么实际上的删除操作就是将字段deleted变成1,其实实际并未删除该数据,但是相应的在更新查询操作中也会自动带上deleted=0的才能操作,这些逻辑删除可以防止数据误删,以后可以一键删除delete=1的数据

代码语言:javascript
复制
 // 测试删除
    @Test
    public void testDeleteById(){
        userMapper.deleteById(1L);
    }

    // 通过id批量删除
    @Test
    public void testDeleteBatchId(){
        userMapper.deleteBatchIds(Arrays.asList(1L,2L));
    }

    // 通过map删除
    @Test
    public void testDeleteMap(){
        HashMap<String, Object> map = new HashMap<>();
        map.put("name","hcode"); //会自动拼接 where name = hcode
        userMapper.deleteByMap(map);
    }
插入操作
代码语言:javascript
复制
   // 测试插入
    @Test
    public void testInsert(){
        User user = new User();
        user.setName("hcode");
        user.setAge(3);
        user.setEmail("372347736@qq.com");

        int result = userMapper.insert(user); // 帮我们自动生成id
        System.out.println(result); // 受影响的行数
        System.out.println(user); // 发现,id会自动回填
    }
更新操作
代码语言:javascript
复制
 // 测试更新
    @Test
    public void testUpdate(){
        User user = new User();
        // 通过条件自动拼接动态sql
        user.setId(1L);
        user.setName("Himit_ZH是个大帅哥");
        user.setAge(22);
        // 注意:updateById 但是参数是一个 对象!
        int i = userMapper.updateById(user);
        System.out.println(i);
    }

条件构造器(处理多条件复杂SQL)

wrapper是链式编程~

条件查询
代码语言:javascript
复制
// 查询name不为空的用户,并且邮箱不为空的用户,年龄大于等于12
        QueryWrapper<User> wrapper = new QueryWrapper<>();
        wrapper
                .isNotNull("name")
                .isNotNull("email")
                .ge("age",12);
        userMapper.selectList(wrapper).forEach(System.out::println); 
区间查询
代码语言:javascript
复制
  // 查询年龄在 20 ~ 30 岁之间的用户
        QueryWrapper<User> wrapper = new QueryWrapper<>();
        wrapper.between("age",20,30); // 区间
        Integer count = userMapper.selectCount(wrapper);// 查询结果数
        System.out.println(count);
模糊查询
代码语言:javascript
复制
        QueryWrapper<User> wrapper = new QueryWrapper<>();
        // likeRight 表示 t%
        // likeLeft 表示 %t
        // notLike 表示不包含 e
        wrapper
                .notLike("name","e")
                .likeRight("email","t");

        List<Map<String, Object>> maps = userMapper.selectMaps(wrapper);
        maps.forEach(System.out::println);
子查询
代码语言:javascript
复制
        // 大概等同于查询id小于3的用户信息,可以多表查询。
        QueryWrapper<User> wrapper = new QueryWrapper<>();
        // id 在子查询中查出来
        wrapper.inSql("id","select id from user where id<3");
        List<Object> objects = userMapper.selectObjs(wrapper);
        objects.forEach(System.out::println);
排序查询
代码语言:javascript
复制
        QueryWrapper<User> wrapper = new QueryWrapper<>();
        // 通过id进行升序
        wrapper.orderByAsc("id"); //里面是可变长参数,可以多字段排序
        // 降序
        wrapper.orderByDesc("id");
        List<User> users = userMapper.selectList(wrapper);
        users.forEach(System.out::println);

代码自动生成器(超好用,偷懒神器啊!!!)

  • dao、pojo、service、controller可以全部自动生成,而且代码非常规范!
  • AutoGenerator 是 MyBatis-Plus 的代码生成器,通过 AutoGenerator 可以快速生成 Entity、 Mapper、Mapper XML、Service、Controller 等各个模块的代码,极大的提升了开发效率
代码语言:javascript
复制
public class HcodeAutoCode {


    public static void main(String[] args) {
        // 需要构建一个 代码自动生成器 对象
        AutoGenerator mpg = new AutoGenerator();
        // 配置策略
        // 1、全局配置
        GlobalConfig gc = new GlobalConfig();
        String projectPath = System.getProperty("user.dir");

        gc.setOutputDir(projectPath + "/src/main/java"); //设置生成路径
        gc.setAuthor("Himit_ZH");
        gc.setOpen(false); //一般false,就是打开一下文件夹而已
        gc.setFileOverride(false); // 是否覆盖
        gc.setServiceName("%sService"); // 去Service的I前缀
        gc.setIdType(IdType.ID_WORKER); //设置主键策略
        gc.setDateType(DateType.ONLY_DATE);
        gc.setSwagger2(true);
        mpg.setGlobalConfig(gc);
        //2、设置数据源
        DataSourceConfig dsc = new DataSourceConfig();
        dsc.setUrl("jdbc:mysql://localhost:3306/test?useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai");
        dsc.setDriverName("com.mysql.cj.jdbc.Driver");
        dsc.setUsername("root");
        dsc.setPassword("123456");
        dsc.setDbType(DbType.MYSQL);
        mpg.setDataSource(dsc);
        //3、包的配置
        PackageConfig pc = new PackageConfig();
        pc.setModuleName("blog");  //最后会在/src/main/java/blog 开始创建对应层的文件夹
        pc.setParent("top.hcode");
        pc.setEntity("entity"); //生成实体类pojo
        pc.setMapper("mapper"); //生成mapper dao层
        pc.setService("service"); //生成service
        pc.setController("controller"); //生成controller层
        mpg.setPackageInfo(pc);
        //4、策略配置
        StrategyConfig strategy = new StrategyConfig();
        // 设置要映射的表名 会自动生成pojo和mapper
        strategy.setInclude("表名1", "表名2");
        strategy.setNaming(NamingStrategy.underline_to_camel); //设置命名格式
        strategy.setColumnNaming(NamingStrategy.underline_to_camel);
        strategy.setEntityLombokModel(true); // 自动lombok;

        strategy.setLogicDeleteFieldName("deleted"); //配置逻辑删除的字段名

        // 自动填充配置 自动填充创建时间和更新时间
        TableFill gmtCreate = new TableFill("gmt_create", FieldFill.INSERT);
        TableFill gmtModified = new TableFill("gmt_modified", FieldFill.INSERT_UPDATE);

        ArrayList<TableFill> tableFills = new ArrayList<>();
        tableFills.add(gmtCreate);
        tableFills.add(gmtModified);
        strategy.setTableFillList(tableFills);

        // 乐观锁
        strategy.setVersionFieldName("version"); //添加乐观锁对应字段名

        //增加控制层的路径
        strategy.setRestControllerStyle(true);
        strategy.setControllerMappingHyphenStyle(true);
        // localhost:8080/hello_id_2
        mpg.setStrategy(strategy);
        mpg.execute(); //执行
    }
}
本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2020年6月26日 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • Spring Boot集成使用
    • 导入依赖
      • 编写配置文件
        • 在Dao层编写Mapper接口
          • 添加乐观锁,分页插件,逻辑删除组件的配置类
            • 添加自动填充时间的处理器类
              • 对应POJO的实体类中应该对相应字段添加注解
                • 乐观锁
                  • 具体操作
                    • 查询操作
                    • 分页查询
                    • 删除操作
                    • 插入操作
                    • 更新操作
                  • 条件构造器(处理多条件复杂SQL)
                    • 条件查询
                    • 区间查询
                    • 模糊查询
                    • 子查询
                    • 排序查询
                  • 代码自动生成器(超好用,偷懒神器啊!!!)
                  相关产品与服务
                  容器服务
                  腾讯云容器服务(Tencent Kubernetes Engine, TKE)基于原生 kubernetes 提供以容器为核心的、高度可扩展的高性能容器管理服务,覆盖 Serverless、边缘计算、分布式云等多种业务部署场景,业内首创单个集群兼容多种计算节点的容器资源管理模式。同时产品作为云原生 Finops 领先布道者,主导开源项目Crane,全面助力客户实现资源优化、成本控制。
                  领券
                  问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档