spring boot3整合mybatis-plus

• 后端
  1. 添加依赖 
             
            com.baomidou
            mybatis-plus-boot-starter
            3.5.3.2
            
                
                    org.mybatis
                    mybatis-spring
                
            
        

        
        
            org.mybatis
            mybatis-spring
            3.0.3
        

        <!--
            mysql
            mysql-connector-java
            8.0.32
        -->

        
            com.mysql
            mysql-connector-j
        

        
            org.projectlombok
            lombok

  2. 配置属性信息

    spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    username: XXX
    password: XXX
    url: jdbc:mysql://localhost:3306/XXX?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC&serverTimezone=Asia/Shanghai

mybatis-plus:
  mapper-locations: classpath:/mapper/*.xml
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

  3. 编写业务逻辑测试代码

    package org.coding.java.controller;

import com.baomidou.mybatisplus.core.metadata.IPage;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import org.coding.java.api.CommonResult;
import org.coding.java.domain.user.UserDO;
import org.coding.java.query.PageQueryVO;
import org.coding.java.service.UserService;
import org.springframework.web.bind.annotation.*;

import java.util.List;

@Tag(name = "用户管理")
@RestController
@RequestMapping("api/v1/user")
public class UserController {
    @Resource
    private UserService userService;

    @PostMapping("/saveUser")
    @Operation(summary = "新增用户")
    public CommonResult saveUser(@RequestBody UserDO userDO) {
        return userService.saveUser(userDO);
    }

    @DeleteMapping("/deleteUser/{id}")
    @Operation(summary = "根据ID删除用户")
    public CommonResult deleteUser(@PathVariable("id") Long id) {
        return userService.deleteUserById(id);
    }

    @GetMapping("/selectList")
    @Operation(summary = "查询用户信息")
    public CommonResult<List> selectList() {
        return userService.selectList();
    }

    @PostMapping("/selectPage")
    @Operation(summary = "分页查询用户信息")
    public CommonResult<IPage> selectPage(@RequestBody PageQueryVO queryVO) {
        return userService.selectPage(queryVO);
    }

    @PutMapping("/updateUser")
    @Operation(summary = "更新用户信息")
    public CommonResult updateUser(@RequestBody UserDO userDO) {
        return userService.updateUser(userDO);
    }
}

    package org.coding.java.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import jakarta.annotation.Resource;
import org.coding.java.api.CommonResult;
import org.coding.java.api.ResponseMessage;
import org.coding.java.domain.user.UserDO;
import org.coding.java.mapper.UserMapper;
import org.coding.java.query.PageQueryVO;
import org.coding.java.service.UserService;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Collections;
import java.util.List;
import java.util.Objects;

@Service
@Transactional
public class UserServiceImpl implements UserService {

    @Resource
    private UserMapper userMapper;

    @Override
    public CommonResult saveUser(UserDO userDO) {
        return CommonResult.ok(ResponseMessage.MessageCode.SAVE_SUCCESS.code(), ResponseMessage.MessageCode.SAVE_SUCCESS.message(), userMapper.insert(userDO));
    }

    @Override
    public CommonResult deleteUserById(Long id) {
        int count = userMapper.deleteById(id);
        if (count > 0) {
            return CommonResult.ok(ResponseMessage.MessageCode.DELETE_SUCCESS.code(), ResponseMessage.MessageCode.DELETE_SUCCESS.message(), count);
        }
        return CommonResult.failed(ResponseMessage.MessageCode.DELETE_FAILED.code(), ResponseMessage.MessageCode.DELETE_FAILED.message(), count);
    }

    @Override
    public CommonResult<List> selectList() {
        if (getUserList().size() > 0) {
            return CommonResult.ok(ResponseMessage.MessageCode.SELECT_SUCCESS.code(), ResponseMessage.MessageCode.SELECT_SUCCESS.message(), getUserList());
        }
        return CommonResult.failed(ResponseMessage.MessageCode.SELECT_FAILED.code(), ResponseMessage.MessageCode.SELECT_FAILED.message(), Collections.emptyList());
    }

    @Override
    public CommonResult<IPage> selectPage(PageQueryVO queryVO) {
        IPage page = new Page(queryVO.getPageNo(), queryVO.getPageSize());
        IPage pageList = getUserPageList(queryVO, page);
        if (pageList.getRecords().size() > 0) {
            return CommonResult.ok(ResponseMessage.MessageCode.SELECT_SUCCESS.code(), ResponseMessage.MessageCode.SELECT_SUCCESS.message(), pageList);
        } else if (pageList.getRecords().size() == 0) {
            return CommonResult.failed(ResponseMessage.MessageCode.SELECT_NON_CONFORMANCE.code(), ResponseMessage.MessageCode.SELECT_NON_CONFORMANCE.message(), pageList);
        }
        return CommonResult.failed(ResponseMessage.MessageCode.SELECT_FAILED.code(), ResponseMessage.MessageCode.SELECT_FAILED.message(), pageList);
    }

    @Override
    public CommonResult updateUser(UserDO userDO) {
        int update = userMapper.updateById(userDO);
        if (update > 0) {
            return CommonResult.ok(ResponseMessage.MessageCode.UPDATE_SUCCESS.code(), ResponseMessage.MessageCode.UPDATE_SUCCESS.message(), update);
        }
        return CommonResult.failed(ResponseMessage.MessageCode.UPDATE_FAILED.code(), ResponseMessage.MessageCode.UPDATE_FAILED.message(), update);
    }

    private IPage getUserPageList(PageQueryVO queryVO, IPage page) {
        LambdaQueryWrapper wrapper = new LambdaQueryWrapper();
        wrapper.like(Objects.nonNull(queryVO.getName()), UserDO::getName, queryVO.getName());
        wrapper.eq(Objects.nonNull(queryVO.getPhone()), UserDO::getPhone, queryVO.getPhone()).or();
        wrapper.eq(Objects.nonNull(queryVO.getEmail()), UserDO::getEmail, queryVO.getEmail());
        return userMapper.selectPage(page, wrapper);
    }

    private List getUserList() {
        QueryWrapper wrapper = new QueryWrapper();
        wrapper.select("id", "name", "age", "email", "sex", "phone");
        return userMapper.selectList(wrapper);
    }
}

  4. 配置mybatis-plus分页插件

    package org.coding.java.config.mybatisplus;

import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.BlockAttackInnerInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.annotation.EnableTransactionManagement;

/**
 * @Description: mybatis常用配置
 */
@Configuration
@EnableTransactionManagement
@MapperScan("org.coding.java.mapper")
public class MybatisPlusConfig {

    /**
     * 实现分页配置
     * @return
     */
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        PaginationInnerInterceptor paginationInnerInterceptor = new PaginationInnerInterceptor();
        paginationInnerInterceptor.setDbType(DbType.MYSQL);
        interceptor.addInnerInterceptor(paginationInnerInterceptor);
        return interceptor;
    }

}

  5. 配置mybatis-plus之属性自动填充

    package org.coding.java.config.mybatisplus;

import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;
import org.apache.ibatis.reflection.MetaObject;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;

/**
 * @Description: mybatis自动填充功能
 */
@Component
public class MyMetaObjectHandler implements MetaObjectHandler {

    @Override
    public void insertFill(MetaObject metaObject) {
        this.strictInsertFill(metaObject, "createTime", LocalDateTime.class, LocalDateTime.now());
        this.strictUpdateFill(metaObject, "updateTime",  LocalDateTime.class, LocalDateTime.now());
    }

    @Override
    public void updateFill(MetaObject metaObject) {
        this.strictUpdateFill(metaObject, "updateTime",  LocalDateTime.class, LocalDateTime.now());
    }
}

  6. 如图所示spring boot3整合mybatis-plusspring boot3整合mybatis-plus

        二、SpringBoot3整合mybatis

1、添加依赖

            org.springframework.boot
            spring-boot-starter-web
        

        
            mysql
            mysql-connector-java
            8.0.32
        

        
            com.github.xiaoymin
            knife4j-openapi3-jakarta-spring-boot-starter
            4.3.0
        

        
            org.coding
            boot-cmmon
            0.0.1-SNAPSHOT
        

        
            org.mybatis
            mybatis
            3.5.13
        

        
            com.github.pagehelper
            pagehelper-spring-boot-starter
            1.4.6
        

        
        
            org.mybatis
            mybatis-spring
            3.0.3

2、配置属性

server:
  port: 18082

spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    username: XXX
    password: XXX
    url: jdbc:mysql://localhost:3306/XXX?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC&serverTimezone=Asia/Shanghai


mybatis:
  mapper-locations: classpath:/mapper/*.xml
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

pagehelper:
  helper-dialect: mysql # 指定数据库类型
  reasonable: true
  params: count=countSql
  support-methods-arguments: true

# springdoc-openapi项目配置
springdoc:
  swagger-ui:
    path: /swagger-ui.html
    tags-sorter: alpha
    operations-sorter: alpha
  api-docs:
    path: /v3/api-docs
  group-configs:
    - group: 'mybatis'
      paths-to-match: '/**'
      packages-to-scan: org.coding.java.controller

# knife4j的增强配置，不需要增强可以不配
knife4j:
  enable: true
  setting:
    language: zh_cn
logging:
  level:
    org.coding.java.mapper: debug

3、编写测试代码

package org.coding.java.service.impl;

import com.github.pagehelper.IPage;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import jakarta.annotation.Resource;
import org.coding.java.api.CommonResult;
import org.coding.java.api.ResponseMessage;
import org.coding.java.domain.user.UserDO;
import org.coding.java.mapper.UserMapper;
import org.coding.java.query.QueryPageVO;
import org.coding.java.service.UserService;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

@Service
@Transactional
public class UserServiceImpl implements UserService {

    @Resource
    private UserMapper userMapper;

    @Override
    public CommonResult saveUser(UserDO userDO) {
        return CommonResult.ok(ResponseMessage.MessageCode.SAVE_SUCCESS.code(), ResponseMessage.MessageCode.SAVE_SUCCESS.message(), userMapper.saveUser(userDO));
    }

    @Override
    public CommonResult<List> selectList() {
        List list = userMapper.selectList();
        if (list.size() > 0) {
            return CommonResult.ok(ResponseMessage.MessageCode.SELECT_SUCCESS.code(), ResponseMessage.MessageCode.SELECT_SUCCESS.message(), list);
        }
        return CommonResult.ok(ResponseMessage.MessageCode.SELECT_FAILED.code(), ResponseMessage.MessageCode.SELECT_FAILED.message(), list);
    }

    @Override
    public CommonResult deleteUserById(Long id) {
        Integer count = userMapper.deleteUserById(id);
        if (count > 0) {
            return CommonResult.ok(ResponseMessage.MessageCode.DELETE_SUCCESS.code(), ResponseMessage.MessageCode.DELETE_SUCCESS.message(), count);
        }
        return CommonResult.ok(ResponseMessage.MessageCode.DELETE_FAILED.code(), ResponseMessage.MessageCode.DELETE_FAILED.message(), count);
    }

    @Override
    public CommonResult updateUser(UserDO userDO) {
        Integer count = userMapper.updateUser(userDO);
        if (count > 0) {
            return CommonResult.ok(ResponseMessage.MessageCode.UPDATE_SUCCESS.code(), ResponseMessage.MessageCode.UPDATE_SUCCESS.message(), count);
        }
        return CommonResult.ok(ResponseMessage.MessageCode.UPDATE_FAILED.code(), ResponseMessage.MessageCode.UPDATE_FAILED.message(), count);
    }

    @Override
    public CommonResult selectPage(QueryPageVO pageVO) {
        PageHelper.startPage(pageVO.getPageNo(), pageVO.getPageSize());
        List list = userMapper.selectPage(pageVO);
        PageInfo pageInfo = new PageInfo(list);
        if (pageInfo.getTotal() > 0) {
            return CommonResult.ok(ResponseMessage.MessageCode.SELECT_SUCCESS.code(), ResponseMessage.MessageCode.SELECT_SUCCESS.message(), pageInfo);
        }
        return CommonResult.ok(ResponseMessage.MessageCode.SELECT_FAILED.code(), ResponseMessage.MessageCode.SELECT_FAILED.message(), pageInfo);
    }
}

package org.coding.java.controller;

import com.github.pagehelper.IPage;
import com.github.pagehelper.PageInfo;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import org.coding.java.api.CommonResult;
import org.coding.java.domain.user.UserDO;
import org.coding.java.query.QueryPageVO;
import org.coding.java.service.UserService;
import org.springframework.web.bind.annotation.*;

import java.util.List;

@Tag(name = "用户管理")
@RestController
@RequestMapping("/api/v1/user")
public class UserController {

    @Resource
    private UserService userService;

    @PostMapping("/saveUser")
    @Operation(summary = "新增用户")
    public CommonResult saveUser(@RequestBody UserDO userDO) {
        return userService.saveUser(userDO);
    }

    @GetMapping("/selectList")
    @Operation(summary = "查询用户【不分页】")
    public CommonResult<List> selectList() {
        return userService.selectList();
    }

    @PostMapping("/selectPage")
    @Operation(summary = "查询用户【分页】")
    public CommonResult selectPage(@RequestBody QueryPageVO pageVO) {
        return userService.selectPage(pageVO);
    }

    @DeleteMapping("/deleteUserById/{id}")
    @Operation(summary = "删除用户【根据ID】")
    public CommonResult deleteUserById(@PathVariable("id") Long id) {
        return userService.deleteUserById(id);
    }

    @PutMapping("/updateUser")
    @Operation(summary = "编辑用户【根据ID】")
    public CommonResult updateUser(@RequestBody UserDO userDO) {
        return userService.updateUser(userDO);
    }

}

4、XML文件



    
        insert into user(name,age,phone,sex,email) value(#{name},#{age},#{phone},#{sex},#{email})
    

    
        select id, name, age, phone, sex, email from user;
    

    
        delete from user where id = #{id}
    

    
        update user
        
            
                name = #{name},
            
            
                age = #{age},
            
            
                phone = #{phone},
            
            
                sex = #{sex},
            
            
                email = #{email},
            
            update_time = now()
        
        where id = #{id}
    

    
        select id, name, age, phone, sex, email from user where
        
            
                name like '%' #{item.name} '%'
            
            
                and phone = #{item.phone}
            
        
        order by create_time desc

5、测试数据是否能走通

spring boot3整合mybatis-plus

spring boot3整合mybatis-plus

spring boot3整合mybatis-plus

本文来自网络，不代表协通编程立场，如若转载，请注明出处：https://net2asp.com/2af0fcfc5f.html

赞 (0)
« 上一篇 1天前
下一篇 » 1天前

相关推荐