Mybatis-Plus处理Mysql Json类型字段
作者:mmseoamin日期:2023-12-21

文章目录

    • 概要
    • 整体实现流程
    • 技术细节
    • Mybatis Plus使用LambdaQueryChainWrapper查询

      概要

      Mysql 5.7.8开始支持Json对象和Json数组,但在Mysql 8版本中使用Json性能更佳。

      使用Json格式的好处:

      1. 无须预定义字段:字段可以无限拓展,避免了ALTER ADD COLUMN的操作,使用更加灵活。
      2. 处理稀疏字段:避免了稀疏字段的NULL值,避免冗余存储。
      3. 支持索引:相比于字符串格式的JSON,JSON类型支持索引做特定的查询优化。

      整体实现流程

      1. 查看Mysql版本
      SELECT VERSION();
      

      Mybatis-Plus处理Mysql Json类型字段,在这里插入图片描述,第1张

      2、创建mysql表

      CREATE TABLE `test` (
        `id` int(11) NOT NULL AUTO_INCREMENT,
        `text` json DEFAULT NULL,
        PRIMARY KEY (`id`)
      ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4;
      

      Mybatis-Plus处理Mysql Json类型字段,在这里插入图片描述,第2张

      3、定义实体类

      import com.baomidou.mybatisplus.annotation.IdType;
      import com.baomidou.mybatisplus.annotation.TableField;
      import com.baomidou.mybatisplus.annotation.TableId;
      import com.baomidou.mybatisplus.annotation.TableName;
      import com.baomidou.mybatisplus.extension.handlers.FastjsonTypeHandler;
      import lombok.Data;
      @Data
      //开启自动映射
      @TableName(value = "test",autoResultMap = true)
      public class Test {
          @TableId(type = IdType.AUTO)
          private Integer id;
      	//定义Json字段handler
          @TableField(typeHandler = FastjsonTypeHandler.class)
          private JsonNode text;
      }
      
      import lombok.Data;
      import java.io.Serializable;
      @Data
      public class JsonNode implements Serializable {
          private Integer id;
          private String name;
          private Integer age;
      }
      

      4、定义Mapper、Service、ServiceImpl

      import com.baomidou.mybatisplus.core.mapper.BaseMapper;
      import com.yiyou.base.entity.Test;
      public interface TestMapper extends BaseMapper {
      }
      
      import com.baomidou.mybatisplus.extension.service.IService;
      import com.yiyou.base.entity.Test;
      public interface TestService extends IService {
          boolean insert(Test test);
      }
      
      import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
      import com.yiyou.base.entity.Test;
      import com.yiyou.base.mapper.TestMapper;
      import com.yiyou.base.service.TestService;
      import org.springframework.stereotype.Service;
      @Service
      public class TestServiceImpl extends ServiceImpl implements TestService {
          @Override
         public boolean insert(Test test) {
              return this.saveOrUpdate(test);
          }
      }
      

      5、Controller层实现

      import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
      import com.yiyou.base.entity.Test;
      import com.yiyou.base.service.TestService;
      import com.yiyou.model.R;
      import io.swagger.annotations.Api;
      import io.swagger.annotations.ApiOperation;
      import lombok.extern.slf4j.Slf4j;
      import org.springframework.beans.factory.annotation.Autowired;
      import org.springframework.web.bind.annotation.*;
      import java.util.List;
      import java.util.Objects;
      @Slf4j
      @Api(tags = "test")
      @RestController
      @RequestMapping("/test")
      public class TestController {
          @Autowired
          private TestService testService;
          @ApiOperation("新增")
          @PostMapping("/save")
          public R save(@RequestBody Test test) {
              return R.ok(testService.insert(test));
          }
          @ApiOperation("根据Id获取对象")
          @GetMapping("/getById/{id}")
          public R getById(@PathVariable("id") Integer id) {
              return R.ok(testService.getById(id));
          }
          @ApiOperation("根据Id删除")
          @DeleteMapping("/deleteById/{id}")
          public R deleteById(@PathVariable("id") Integer id) {
              return R.ok(testService.removeById(id));
          }
          @ApiOperation("条件查询")
          @PostMapping("/findList")
          public R> findList(@RequestBody Test test) {
              LambdaQueryChainWrapper queryWrapper =  testService.lambdaQuery();
              queryWrapper
                      .eq(Objects.nonNull(test.getId()),Test::getId,test.getId())
      //                .apply(Objects.nonNull(test.getText()),"text -> '$.name' LIKE CONCAT('%',{0},'%')",test.getText().getName())
                      .apply(Objects.nonNull(test.getText()), "text -> '$.age' = {0}", test.getText().getAge());
      //                .like(Objects.nonNull(test.getText()),Test::getText,test.getText());
              return R.ok(queryWrapper.list());
          }
      

      技术细节

      • Json字段模糊查询
        SELECT * FROM TEST WHERE text -> '$[*].name' like '%测%'
        

        或 上面的"*"也可以使用下标

        SELECT * FROM TEST WHERE text -> '$[1].name' like '%测%'
        
        • Json字段精确查询

        • 使用箭头函数

          SELECT * FROM TEST WHERE text -> '$.name' = '测试'
          
          • 使用 JSON_CONTAINS
            SELECT * FROM TEST WHERE JSON_CONTAINS(text,JSON_OBJECT('name', '测试'))
            
            • 查询json中的name字段
              SELECT id, text -> '$[*].name' AS name FROM TEST;
              
              • 使用JSON_EXTRACT 函数,带双引号
                SELECT id, JSON_EXTRACT( text, '$[*].name' ) AS name FROM TEST;
                
                • 使用 JSON_UNQUOTE 函数,不带双引号
                  SELECT id, JSON_UNQUOTE(text, '$[*].name' ) AS name FROM TEST;
                  
                  • 查询Json字段中所有的值,用 “*”
                    SELECT id, text -> '$[*].*' AS name FROM TEST;
                    

                    Mybatis Plus使用LambdaQueryChainWrapper查询

                    提示:使用apply方法拼接sql片段,apply 是可以通过占位符的形式,传入多个参数。

                    例如:

                    LambdaQueryChainWrapper queryWrapper =  testService.lambdaQuery();
                            queryWrapper
                    .apply(Objects.nonNull(test.getText()),"text -> '$.name' LIKE CONCAT('%',{0},'%')",test.getText().getName())//模糊查询
                    .apply(Objects.nonNull(test.getText()), "text -> '$.age' = {0}", test.getText().getAge());//精确查询