Mybatis plus

先查询再根据查询结果判断是否插入，并发情况下出现重复数据

解决：1、java代码中加同步代码块或加锁(保证查询、插入是一个原子性操作)

2、直接在数据库设置唯一键，java中无需先查询判断。捕获唯一键异常：org.springframework.dao.DuplicateKeyException e

基本使用步骤

Mybatis plus是mybatis的加强。

1、使用起来与mybatis差不多,但是更加方便，简单的crud操作都自动帮你生成了

2、默认使用了驼峰规则，需要自己建表，实体类名驼峰规则与表名匹配(xxAa=>xx_aa)，实体类属性名也驼峰与数据库字段名匹配。

3、无需使用mybatis Helper插件分页，结合条件构造器EntityWrapper调用selectPage()方法即可

4、自定义sql添加与mybatis一样，在mapper接口中直接添加即可@Select("select * from tb_employee where id=#{id}")。

@TableField(insertStrategy = FieldStrategy.NOT_NULL) //updateStrategy、whereStrategy。   旧版本是一个：strategy

IGNORED:  不管是不是null，都进行插入操作

NOT_NULL,也是默认策略，也就是不插入null的字段

NOT_EMPTY,  如果设置值为null，“”，不会插入数据库

@TableId(value = "competition_id", type = IdType.AUTO)   //设置主键字段。MR的selectById()、updateById()等方法的Id是和@TableId对应的。

type = IdType.AUTO设置主键生成规则(仅insert)。

IdType.AUTO指定类型为数据库自增策略,MR便不做任何处理(不会插入主键字段的值)。其他的还有UUID、ID_Worker、ID_WORKER_STR(这三个已过时)：MR便自动生成uuid、分布式全局唯一ID长整型、分布式全局唯一ID字符串型插入。

INSERT INTO competition ( name ) VALUES ( ? )

ASSIGN_ID（mr自动生成雪花算法插入）

ASSIGN_UUID（代替过时的UUID，MR自动生成uuid插入）

NONE (默认策略，无主键MR不处理，不会插入主键字段的值)

INSERT INTO competition ( name ) VALUES ( ? )

INPUT(自行输入，insert前如果自行set主键值(user.setId)，则会插入主键的值。)

INSERT INTO competition ( id,name ) VALUES ( ?,? )

new LambdaQueryWrapper<Competition>().eq(Competition::getCloseFlag,"0")//::仅在MR的LambdaQueryWrapper表示获取指定方法的属性名(且自动解驼峰close_flag) 。

1、使用mybatis plus只需将mybatis注解替换为mybatis-plus注解即可。

   <dependency>

        <groupId>com.baomidou</groupId>

        <artifactId>mybatis-plus-boot-starter</artifactId>

        <version>3.4.1</version>  <!--3.3.2-->

</dependency>

1. application.yml配置（MR默认自动开启驼峰）：

spring:
  datasource:
    #   连接池类
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.jdbc.Driver
    platform: mysql
    url: jdbc:mysql://10.101.1.66:32560/codem-oj-n?useUnicode=true&characterEncoding=utf-8
    username: root
    password: 123456
    druid:
      #2.连接池配置
      #初始化连接池的连接数量 大小，最小，最大
      initial-size: 5
      min-idle: 5
      max-active: 20
      #配置获取连接等待超时的时间
      max-wait: 60000
      #配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
      time-between-eviction-runs-millis: 60000
      # 配置一个连接在池中最小生存的时间，单位是毫秒
      min-evictable-idle-time-millis: 30000
      validation-query: SELECT 1 FROM DUAL
      test-while-idle: true
      test-on-borrow: true
      test-on-return: false
      # 是否缓存preparedStatement，也就是PSCache  官方建议MySQL下建议关闭   个人建议如果想用SQL防火墙 建议打开
      pool-prepared-statements: true
      max-pool-prepared-statement-per-connection-size: 20
      # 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
      filter:
        stat:
          merge-sql: true
          slow-sql-millis: 5000
      #3.基础监控配置
      web-stat-filter:
        enabled: true
        url-pattern: /*
# mybatis整合
mybatis-plus:
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl #开启sql日志
  global-config:
    db-config:
      id-type: auto
      logic-delete-field: delete_flag  # 全局逻辑删除的实体字段名
      logic-delete-value: 1 # 逻辑已删除值
      logic-not-delete-value: 0 # 逻辑未删除值
  mapper-locations: classpath:mapper/**/*.xml

1. 分页插件配置类（用于mybatis plus内置的selectPage分页查询方法）：

@Configuration
public class MybatisPlusConfig {
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {//public PaginationInterceptor paginationInterceptor(){return new PaginationInterceptor();}//3.3版本用此方法. 3.4已过时
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
        return interceptor;
    }
    @Bean
    public ConfigurationCustomizer configurationCustomizer() {
        //下个版本会移除。。但3.4版本为了避免缓存出现问题，即时过时也得使用得(该属性会在旧插件移除后一同移除)。
        return configuration -> configuration.setUseDeprecatedExecutor(false);
    }
}

4、实体类(根据数据库中创建的表设置的)

@Data@TableName(value = "tb_employee")//手动指定与数据库中对应的表名。MP有默认的表名对应规则:实体类名为：OwnUser，会对应到数据库中的own_user表public class Employee {//value与数据库主键列名一致，若实体类属性名与表主键列名一致可省略
@TableId(value = "id",type = IdType.AUTO) //IdType.AUTO指定类型为数据库自增策略,MR便不做任何处理。其他的还有UUID、ID_Worker、ID_WORKER_STRMR便自动生成uuid、分布式全局唯一ID长整型、分布式全局唯一ID字符串型。private Integer id;//若没有开启驼峰命名，或者表中列名不符合驼峰规则，可通过该注解指定数据库表中的列名，exist标明数据表中有没有对应列//@TableField(value = "last_name",exist = true)private String lastName;}

5、mapper接口：

//@Mapper 或者在主启动类使用MapperScan扫描public interface EmplopyeeDao extends BaseMapper<Employee> {@Select("SELECT AUTO_INCREMENT FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = 'employee' limit 1,2")
int getNextId(); //也可以在里面写自定义sql语句方法  }

6、调用mybatis plus(增删改查分页)：

@Resource    //不要用@Autowired 会出现警告
private EmplopyeeDao emplopyeeDao;public void testInsert(){Employee employee = new Employee();employee.setLastName("东方不败");emplopyeeDao.insert(employee);//mybatisplus会自动把当前插入对象在数据库中的id写回到该实体中System.out.println(employee.getId());}public void testUpdate(){Employee employee = new Employee();employee.setId(1);employee.setLastName("更新测试");//emplopyeeDao.updateById(employee);//根据id进行更新，没有传值的属性就不会更新emplopyeeDao.updateAllColumnById(employee);//根据id进行更新，没传值的属性就更新为null}public void testSelect(){Map<String,Object> columnMap = new HashMap<>();columnMap.put("last_name","东方不败");//写表中的列名columnMap.put("gender","1");List<Employee> employees         = emplopyeeDao.selectByMap(columnMap);//emplopyeeDao.select(new                 EntityWrapper<Employee>().gt("age",16)) 查询大于16的//删除类似：deleteByMap(columnMap);  emplopyeeDao.delete(new EntityWrapper<Employee>().eq("last_name","tom").eq("age",16)); //gt:大于 lt:小于
System.out.println(employees.size());}public void testPageSelect(){//分页查询List<Employee> employees = emplopyeeDao.selectPage(new Page<Employee>(1,3),new EntityWrapper<Employee>() // 注意：mybatis plus 3.0以上要用QueryWrapper<Employee>().between("age",18,50).eq("gender",0).eq("last_name","tom")
).getRecords();  //.getTotal() 获取总数}  

EntityWrapper构造复杂条件：

or的使用：

new EntityWrapper<Employee>().like("last_name", "老师")
//.or()    // SQL: (last_name LIKE ? OR email LIKE ? OR age LIKE ?)
.orNew()   // SQL: (last_name LIKE ?) OR (email LIKE ? OR age LIKE ?)
.like("email", "a").or().like("age", "1")
.and(wrapper->{wrapper.eq("age", "1")})

And的使用：

upRelationService.update(upRelation,new QueryWrapper<UPRelation>().eq("problem_uid",problem_uid)

.and(wrapper->{wrapper.eq("user_uid",user_uid);}) ) //where problem_uid=? And user_uid=?

LambdaQueryWrapper的使用：

new LambdaQueryWrapper<Competition>().eq(Competition::getCloseFlag,"0")//::仅在MR的LambdaQueryWrapper表示获取指定方法的属性名(且自动解驼峰close_flag和数据库字段匹配)  

通过实体类构造QueryWrapper查询器：

User user = new User(); user.setUsername("kaven");  user.setAge(22);

QueryWrapper<User> userQueryWrapper = new QueryWrapper<>(user); //查询username为kaven且age为22的(and)

       List<User> userList = userMapper.selectList(userQueryWrapper);

//注意：mybatis plus 3.0以上要用QueryWrapper<Employee>(),EntityWrapper已移除。

7、主启动类添加@MapperScan扫描或mapper接口上添加@Mapper注解。

@MapperScan(com.example.demo.mapper) //MapperScan扫描接口，包下所有接口编译后都会生成其实现类注入spring

注意MapperScan扫描至扫描mapper包即可，范围不要超出，否则可能会报错Field competitionService required a single bean, but 2 were found: CompetitionServiceImpl.class、ICompetitionService.class

MR自动生成器(generator)

执行下面代码，自动生成对应表的实体类，mapper接口、service、controller层文件。需要注意的是mysql中主键字段不能命名为id否则无法生成对于实体类属性。(可以是xxx_id)

自动生成的service中内置了调用mapper层的save、updateById、delete等方法的逻辑，可以直接this.save()等使用。

以com.example.demo为例，无需创建文件夹，会自动生成。

1、pom

    <dependency>

        <groupId>com.baomidou</groupId>

        <artifactId>mybatis-plus-generator</artifactId>

        <version>3.2.0</version>

    </dependency>

    <dependency>

        <groupId>com.baomidou</groupId>

        <artifactId>mybatis-plus-core</artifactId>

        <version>3.2.0</version>

    </dependency>

    <dependency>

        <groupId>org.springframework.boot</groupId>

        <artifactId>spring-boot-starter-freemarker</artifactId>

</dependency>

2、代码

public class CodeGeneratorNowProject {
    public static String ip = "localhost";
    public static String dbName = "liuyu";
    public static String port = "3306";
    public static String password = "123456";
    public static String parent = "cn.com.codem.oj";   //包配置中使用 生成到com.example.demo目录下
    public static String Author = "Liuyu";    //这是作者，写自己的名
    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.isNotBlank(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");//获取用户当前工程路径(根路径)
        System.out.println(projectPath);
        gc.setOutputDir(projectPath + "/"  + "/src/main/java");
        gc.setAuthor(Author);
        gc.setOpen(false);
        gc.setSwagger2(true); //实体属性 Swagger2 注解
        mpg.setGlobalConfig(gc);
        // 数据源配置
        DataSourceConfig dsc = new DataSourceConfig();
        dsc.setUrl("jdbc:mysql://" + ip + ":" + port + "/" + dbName + "?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai");
        // dsc.setSchemaName("public");
        dsc.setDriverName("com.mysql.jdbc.Driver");
        dsc.setUsername("root");
        dsc.setPassword(password);
        mpg.setDataSource(dsc);
        // 包配置
        PackageConfig pc = new PackageConfig();
        pc.setModuleName(scanner("模块名")); //demo  即项目中controller、service等上层目录的名称
        pc.setParent(parent);
        mpg.setPackageInfo(pc);
        // 自定义配置
        InjectionConfig cfg = new InjectionConfig() {
            @Override
            public void initMap() {
                // to do nothing
            }
        };
        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); //字段名生成策略 下划线转驼峰
        /*公共父类
        设置父类中字段: 如 id version deleted类似的字段几乎是每一张表都会有的字段，这样就可以设置一个共同的父类来保存这些字段
        设置父类，也就是某个类需要继承的类*/
        //strategy.setSuperEntityClass("你自己的父类实体,没有就不用设置!"); //自定义继承的Entity类全称，带包名
        //strategy.setSuperEntityColumns("id");        // 写于自定义基础的Entity类中的公共字段
        //strategy.setSuperControllerClass("你自己的父类控制器,没有就不用设置!"); //自定义继承的Controller类全称，带包名
        strategy.setEntityLombokModel(true); //使用lombok
        strategy.setRestControllerStyle(true); //生成restController
        strategy.setInclude(scanner("表名，多个英文逗号分割").split(","));
        strategy.setControllerMappingHyphenStyle(true); //controller映射地址url驼峰转连字符(中划线-)
        //strategy.setTablePrefix(pc.getModuleName() + "_");  //去除表前缀,表前缀不生成  demo_表名
        mpg.setStrategy(strategy);
        mpg.setTemplateEngine(new FreemarkerTemplateEngine());
        mpg.execute();
    }
}

MR逻辑删除配置：

1、Yml中配置：

mybatis-plus:

  global-config:

    db-config:

      logic-delete-field: close_flag  # 全局逻辑删除的实体字段名，可以不要此字段

      logic-delete-value: 1 # 逻辑已删除值

      logic-not-delete-value: 0 # 逻辑未删除值

2、实体类中也要添加此字段(closeFlag)

@TableLogic //标识逻辑删除字段,实体类中没有此注解便不会附带逻辑删除功能

private Integer closeFlag;

3、编写代码

使用mp自带方法删除和查找都会附带逻辑删除功能(与@TableLogic有关,没有此注解则不会附带逻辑删除。逻辑删除的字段与@TableLogic注解的实体对象有关)

删除时：competitionMapper.deleteById(2);//UPDATE competition SET close_flag=1 WHERE id=? AND close_flag=0

查询时：competitionMapper.selectList(new QueryWrapper<Competition>().eq("uid","1")) //SELECT * FROM competition WHERE close_flag=0 AND (uid = ?)

逻辑删除是为了方便数据恢复和保护数据本身价值等等的一种方案，但实际就是删除。如果你需要再查出来就不应使用逻辑删除，而是以一个状态去表示。若确需查找删除数据，如老板需要查看历史所有数据的统计汇总信息，请单独手写sql。

Druid配置开启连接池监控界面

1、Application.yml中添加配置
spring:
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://10.101.1.66:32560/codem-oj-n?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
    username: root
    password: 123456
    druid: # druid 配置
      #2.连接池配置    初始化连接池的连接数量 大小，最小，最大
      initial-size: 5
      min-idle: 5
      max-active: 20
      max-wait: 60000#配置获取连接等待超时的时间
      time-between-eviction-runs-millis: 60000 #配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
      min-evictable-idle-time-millis: 30000  # 配置一个连接在池中最小生存的时间，单位是毫秒
      validation-query: SELECT 1 FROM DUAL
      test-while-idle: true
      test-on-borrow: true
      test-on-return: false
      # 是否缓存preparedStatement，也就是PSCache  官方建议MySQL下建议关闭   个人建议如果想用SQL防火墙 建议打开
      pool-prepared-statements: true
      max-pool-prepared-statement-per-connection-size: 20
    # 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
    filter:
      stat:
      merge-sql: true
      slow-sql-millis: 5000
      #3.基础监控配置
      web-stat-filter:
        enabled: true
        url-pattern: /*

1. 添加配置类

@Configuration
public class DruidConfigDemo {
    /**
     * 配置监控服务器
     * @return 返回监控注册的servlet对象
     */
   @Bean
    public ServletRegistrationBean statViewServletDemo() {
        ServletRegistrationBean srb = new ServletRegistrationBean(new StatViewServlet(), "/competition/druid/*");
        // 添加IP白名单
        srb.addInitParameter("allow", "127.0.0.1");//localhost
        // 添加IP黑名单，当白名单和黑名单重复时，黑名单优先级更高
        //srb.addInitParameter("deny", "192.168.25.123");
        // 添加控制台管理用户
        srb.addInitParameter("loginUsername", "admin");
        srb.addInitParameter("loginPassword", "123456");
        // 是否能够重置数据
        srb.addInitParameter("resetEnable", "false");
        return srb;
    }
}

3、访问网址：http://localhost:8080/competition/druid/login.html

报错：Error attempting to get column 'create_time' from result set.  Cause: java.sql.SQLFeatureNotSupportedException

; null; nested exception is java.sql.SQLFeatureNotSupportedException。

原因：问题原因自动生成的实体类变量是JDK8的LocalDate、LocalTime、LocalDateTime日期类型，druid数据源尚不支持。改为String即可