• MyBatis-Plus详解

    MyBatis-Plus

    MyBatis-Plus 是一个 MyBatis 的增强工具，在 MyBatis 的基础上只做增强不做改变，为简化开发、提高效率而生。

    官网 MyBatis-Plus

    连接池： 传统开发中，每一次请求都要建立一次数据库连接。每一次数据库连接，使用完后都得断开。频繁的数据库连接操作势必占用很多的系统资源，响应速度必定下降。另外，在高并发时，系统资源被毫无顾及的分配出去，如连接过多，也可能导致内存泄漏，服务器崩溃。

    解决方案： 为数据库连接建立一个“缓冲池”（连接池）。预先在缓冲池中放入一定数量的连接，当需要建立数据库连接时，只需从“缓冲池”中取出一个，使用完毕再放回去。通过设定连接池最大连接数来防止系统无休止的数据库连接。

    工作流程： 当客户端请求服务器，服务器需要使用连接对象操作数据库的数据。这时，需要从连接池中申请一个连接对象。连接池会分配一个空闲连接给该客户。如果连接池中没有空闲连接，就看有没有到达最大连接数。如果没有到达最大连接数，就创建新连接分配给客户。如果已经到达最大连接，那么，请求用户会等待一段时间，在等待时间内，有连接对象被释放，则分配给等待用户。等待时间结束后，还没有连接被释放，则返回null。

    Mybatis --- 环境搭建

    1、导入相关依赖

    2.     org.springframework.boot
    3.     spring-boot-starter-parent
    4.     2.4.2
    5.     
    8.     
    9.         mysql
    10.         mysql-connector-java
    11.         5.1.48
    12.     
    13. ​
    14.     
    15.         org.springframework.boot
    16.         spring-boot-starter
    17.     
    18.     
    19.         org.springframework.boot
    20.         spring-boot-starter-test
    21.         test
    22.     
    23.     
    24.         com.baomidou
    25.         mybatis-plus-boot-starter
    26.         3.4.3
    27.     
    28.     
    29.         junit
    30.         junit
    31.         4.12
    32.         test
    33.     
    34.     
    35.         com.alibaba
    36.         druid
    37.         1.2.9
    38.     

    2、创建实体类

    1. //声明该实体类映射的表名
    2. @TableName("t_product")
    3. public class ProductBean {
    4.     //表示该列为主键列，value表示该列映射的列名
    5.     //type = IdType.AUTO 表示该列的值使用自动增长列生成
    6.     @TableId(value = "pk_productId",type = IdType.AUTO)
    7.     private Integer id;
    8.     
    9.     //指定当前属性映射的列名
    10.     @TableField("p_name")
    11.     private String name;
    12. ​
    13.     @TableField("p_createDate")
    14.     private LocalDate createDate;
    15. ​
    16.     @TableField("p_price")
    17.     private Integer price;
    18. }

    3、在 resources 目录下，创建 application.yml 配置文件

    1. spring:
    2.   datasource:
    3.     driver-class-name: com.mysql.jdbc.Driver  #定义配置驱动类
    4.     username: root #mysql登录用户名
    5.     password: 123 #mysql登录密码
    6.     url: jdbc:mysql://localhost:12345/shopDB?characterEncoding=utf8&allowMultiQueries=true 
    7.     type: com.alibaba.druid.pool.DruidDataSource #配置连接池
    8.     druid:
    9.       one:
    10.         max-active: 100 #最大连接数
    11.         min-idle: 20 #最小连接数
    12.         max-wait: 2000 #超时时间（ms）
    13. ​
    14. ​
    15. mybatis-plus:
    16.   configuration:
    17.     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl #配置日志
    18.   type-aliases-package: com.project.bean #实体类所在包，允许用实体类类名作为别名
    19.   mapper-locations: classpath:*/*Mapper.xml #链接 mapper文件

    4、创建业务接口

    1. public interface IProductService {
    2. ​
    3.     public void add(ProductBean productBean);
    4.     public void del(Integer id);
    5.     public void update(Integer id,Integer price);
    6.     public List findAll();
    7.     public ProductBean findById(Integer id);
    8.     public List findByItem(String name, 
    9. LocalDate startDate,LocalDate endDate);
    10. }

    5、创建 mapper 接口

    1. @Mapper
    2. public interface IProductMapper extends BaseMapper {
    3. }

    6、书写业务接口实现类

    1. @Service
    2. @Transactional//该类所有方法支持事务
    3. public class ProductServiceImpl implements IProductService {
    4.     @Autowired
    5.     private IProductMapper mapper;
    6.     @Override
    7.     public void add(ProductBean productBean) {
    8.         mapper.insert(productBean);//添加实体数据
    9.     }
    10. ​
    11.     @Override
    12.     public void del(Integer id) {
    13.         mapper.deleteById(id);//根据id删除实体数据
    14.     }
    15. ​
    16.     @Override
    17.     public void update(Integer id, Integer price) {
    18.         ProductBean productBean = new ProductBean();
    19.         productBean.setId(id);
    20.         productBean.setPrice(price);
    21.         mapper.updateById(productBean);//按id修改实体属性
    22.     }
    23. ​
    24.     @Override
    25.     public List findAll() {
    26.         return mapper.selectList(null);//查询所有
    27.     }
    28. ​
    29.     @Override
    30.     public ProductBean findById(Integer id) {
    31.         return mapper.selectById(id);//按id查询实体对象
    32.     }
    33. ​
    34.     @Override
    35.     public List findByItem(String name, 
    36. LocalDate startDate, LocalDate endDate) {
    37.         QueryWrapper qw = new QueryWrapper<>();//条件集合
    38.         if (name != null && name.length() != 0){
    39.             qw.like("p_name",name);//like 模糊查询
    40.         }
    41.         if (startDate != null){
    42.             qw.ge("p_creatDate",startDate);//ge 大于等于
    43.         }
    44.         if (endDate != null){
    45.             qw.le("p_createDate",endDate);//le 小于等于
    46.         }
    47.         return mapper.selectList(qw);//按条件查询
    48.     }
    49. }

    7、测试类

    1. @RunWith(SpringRunner.class)
    2. @SpringBootTest(classes = Main.class)//启动类类模板
    3. public class ProductTest {
    4.     @Autowired
    5.     private IProductService service;
    6. ​
    7.     @Test
    8.     public void test(){
    9. //        service.add(new ProductBean("999感冒灵", 
    10. LocalDate.parse("2022-06-06"),18));
    11.         System.out.println(service.findAll());
    12.     }
    13. }

    分页查询

    1、创建配置类，定义数据库 SQL 语句的方言。Mybatis-plus会根据配置的方言，产生分页的 SQL 语句

    1.  
    2. @Configuration
    3. public class MyBatisPlusConfig {
    4.     @Bean
    5.     public MybatisPlusInterceptor mybatisPlusInterceptor() {
    6.         MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
    7.         interceptor.addInnerInterceptor(
    8.                 new PaginationInnerInterceptor(DbType.MYSQL));
    9.         return interceptor;
    10.     }
    11. ​}

    2、定义业务接口方法

    1. /**
    2.  * 动态条件分页查询
    3.  * @param pageNO 页码
    4.  * @param name 姓名
    5.  * @param startDate 生产起始日期
    6.  * @param endDate 生成结束日期
    7.  * @return 分页对象
    8.  */
    9. public IPage findByItem(Integer pageNO, 
    10. String name, LocalDate startDate,LocalDate endDate);

    3、定义 mapper 接口

    1. @Mapper
    2. public interface IProductMapper extends BaseMapper {
    3. }

    4、书写业务方法

    1. @Override
    2. public IPage findByItem(Integer pageNO,
    3.  String name, LocalDate startDate, LocalDate endDate) {
    4.     QueryWrapper qw = new QueryWrapper<>();
    5.     if (name != null && name.length() != 0){
    6.         qw.like("p_name",name);
    7.     }
    8.     if (startDate != null){
    9.         qw.ge("p_createDate",startDate);
    10.     }
    11.     if (endDate != null){
    12.         qw.le("p_createDate",endDate);
    13.     }
    14.     return mapper.selectPage(new Page(pageNO,3),qw);
    15. }

    5、测试类

    1. @RunWith(SpringRunner.class)
    2. @SpringBootTest(classes = PlusMain.class)
    3. public class Test {
    4.     @Autowired
    5.     private IProductService service;
    6.     @org.junit.Test
    7.     public void test(){
    8. //        System.out.println(service.findAll());
    9.         IPage ip = service.findByItem(1,"",null,null);
    10.         System.out.println(ip.getRecords()//得到当前数据
    11.                 +"  "+ip.getTotal()//得到总记录数
    12.                 +"  "+ip.getPages()//总页数
    13.                 +"  "+ip.getCurrent()//得到页码
    14.                 +"  "+ip.getSize()//得到每页记录数
    15.                  );
    16.     }
    17. }

    Mybatis-plus 关联操作

    一对多：

    1、创建实体类

    1. /**
    2.  * 部门实体类
    3.  */
    4. @TableName("t_dept")
    5. public class DeptBean {
    6.     @TableId(value = "pk_deptId",type = IdType.AUTO)
    7.     private Integer id;
    8. ​
    9.     @TableField("d_name")
    10.     private String name;
    11. ​
    12.     @TableField(exist = false)//标识该属性没有对应的列
    13.     private Integer emNum;
    14. ​
    15.     @TableField(exist = false)//标识该属性没有对应的列
    16.     private List emList;
    17. }
    18. /**
    19.  * 员工实体类
    20.  */
    21. @TableName("t_employee")
    22. public class EmployeeBean {
    23.     @TableId(value = "pk_emId",type = IdType.AUTO)
    24.     private Integer id;
    25.     @TableField("e_name")
    26.     private String name;
    27.     @TableField("e_job")
    28.     private String job;
    29.     @TableField("e_birthday")
    30.     private LocalDate birthday;
    31.     @TableField("fk_deptId")
    32.     private Integer deptId;
    33.     @TableField(exist = false)
    34.     private DeptBean dept;
    35. }

    注意：如果一个属性没有对应的列，必须加上@TableField（exist = false）。否则，maybatis-plus会认为数据库表中有一个和该属性同名列。

    2、建立业务接口

    1. /**
    2. *部门业务接口
    3. */
    4. public interface IDeptService {
    5.     /**
    6.      * 查询所有部门，同时统计每个部门的人数
    7.      * @return 部门集合
    8.      */
    9.     public List findAll();
    10. ​
    11.     /**
    12.      * 级联添加，添加部门，同时添加该部门的员工集合
    13.      * @param dept 部门对象
    14.      * @param emList 新员工集合
    15.      */
    16.     public void add(DeptBean dept, List emList);
    17. ​
    18.     /**
    19.      * 删除部门，同时级联删除部门的员工
    20.      * @param id 部门ID
    21.      */
    22.     public void delCasede(Integer id);
    23. ​
    24.     /**
    25.      * 删除部门，同时将该部门员工外键设置为null
    26.      * @param id 部门ID
    27.      */
    28.     public void delSerNull(Integer id);
    29. ​
    30.     /**
    31.      * 按id查询部门，同时查询该部门中所有的员工
    32.      * @param id 部门id
    33.      * @return 部门对象
    34.      */
    35.     public DeptBean findById(Integer id);
    36. }
    37.  
    38.  
    39.  
    40. /**
    41.  * 员工业务接口
    42.  */
    43. public interface IEmployeeService {
    44.     /**
    45.      * 添加员工
    46.      * @param employee 员工对象
    47.      */
    48.     public void add(EmployeeBean employee);
    49. ​
    50.     /**
    51.      * 动态条件分页查询，同时查询每个员工所在部门的名称
    52.      * @param pageNO 页码
    53.      * @param deptName 部门名称
    54.      * @param name 员工姓名
    55.      * @return 分页对象
    56.      */
    57.     public IPage findByItem(Integer pageNO,
    58. String deptName,String name);
    59. ​
    60.     /**
    61.      * 按id查询员工，同时查询员工的部门信息
    62.      * @param id 员工编号
    63.      * @return 员工对象33
    64.      */
    65.     public EmployeeBean findById(Integer id);
    66. }

    3、建立 Mapper 接口

    1. /**
    2. *部门 mapper 接口
    3. */
    4. @Mapper
    5. public interface IDeptMapper extends BaseMapper {
    6.     @Select("SELECT d.*,COUNT(e.`pk_emId`) emNum FROM t_dept d LEFT JOIN
    7.  t_employee e ON d.`pk_deptId`=e.`fk_deptId`\n" +
    8.             "GROUP BY d.`pk_deptId`")
    9.     @ResultMap("deptMap")
    10.     public List findAll();
    11. ​
    12.     @Delete("delete from t_employee where fk_deptId=#{id};" +
    13.             "delete from t_dept where pk_deptId=#{id};")
    14.     public void delCasede(Integer id);
    15. ​
    16.     @Delete("update t_employee set fk_deptId=null where fk_deptId=#{id};" +
    17.             "delete from t_dept where pk_deptId=#{id};")
    18.     public void delSetNull(Integer id);
    19. }
    20. /**
    21. *员工 mapper 接口
    22. */
    23. @Mapper
    24. public interface IEmployeeMapper extends BaseMapper {
    25. ​
    26.     public void addMore(@Param("deptId") Integer deptId,
    27. @Param("emList") List emList);
    28. ​
    29.     public IPage findByItem(Page pageNO,
    30. @Param("deptName") String deptName,@Param("name") String name);
    31. ​
    32. }

    对于联表查询的结果集，动态条件查询、循环，都需要在 mapper 文件中完成。

    4、书写 mapper 文件

    IDeptMapper：

    1. "com.project.mapper.IDeptMapper">
    2.     "deptMap" type="DeptBean">
    3.         "id" column="pk_deptId">
    4.         "name" column="d_name">
    5.         "emNum" column="emNum">
    6.     

    IEmployeeMapper：

    1. "com.project.mapper.IEmployeeMapper">
    2.     "addMore">
    3.         insert into t_employee (e_name,e_job,e_birthday,fk_deptId)
    4.  values
    5.         "emList" item="em" separator=",">
    6.             (#{em.name},#{em.job},#{em.birthday},#{deptId})
    7.         
    8.     
    9. ​
    10.     "emMap" type="EmployeeBean">
    11.         "pk_emId" property="id">
    12.         "e_name" property="name">
    13.         "e_job" property="job">
    14.         "e_birthday" property="birthday">
    15.         "d_name" property="dept.name">
    16.     
    17. ​
    18.     

    5、书写业务方法

    1. /**
    2.  * 部门业务方法
    3.  */
    4. @Service
    5. @Transactional
    6. public class DeptServiceImpl implements IDeptService {
    7. ​
    8.     @Autowired
    9.     private IDeptMapper deptMapper;
    10.     @Autowired
    11.     private IEmployeeMapper employeeMapper;
    12. ​
    13.     @Override
    14.     public List findAll() {
    15.         return deptMapper.findAll();
    16.     }
    17. ​
    18.     @Override
    19.     public void add(DeptBean dept, List emList) {
    20.         deptMapper.insert(dept);
    21.         employeeMapper.addMore(dept.getId(),emList);
    22.     }
    23. ​
    24.     @Override
    25.     public void delCasede(Integer id) {
    26.         deptMapper.delCasede(id);
    27.     }
    28. ​
    29.     @Override
    30.     public void delSerNull(Integer id) {
    31.         deptMapper.delSetNull(id);
    32.     }
    33. ​
    34.     @Override
    35.     public DeptBean findById(Integer id) {
    36.         DeptBean dept = deptMapper.selectById(id);
    37.         QueryWrapper qw = new QueryWrapper<>();
    38.         qw.eq("fk_deptId",id);
    39.         dept.setEmList(employeeMapper.selectList(qw));
    40.         return dept;
    41.     }
    42. }
    43. /**
    44.  * 员工业务方法
    45.  */
    46. @Service
    47. @Transactional
    48. public class EmployeeServiceImpl implements IEmployeeService {
    49.     @Autowired
    50.     IEmployeeMapper employeeMapper;
    51.     @Autowired
    52.     IDeptMapper deptMapper;
    53.     @Override
    54.     public void add(EmployeeBean employee) {
    55.         employeeMapper.insert(employee);
    56.     }
    57. ​
    58.     @Override
    59.     public IPage findByItem(Integer pageNO, 
    60. String deptName, String name) {
    61.         return employeeMapper.findByItem(new Page(pageNO,3),deptName,name);
    62.     }
    63. ​
    64.     @Override
    65.     public EmployeeBean findById(Integer id) {
    66.         EmployeeBean em = employeeMapper.selectById(id);
    67.         em.setDept(deptMapper.selectById(em.getDeptId()));
    68.   ··      return em;
    69.     }
    70. }

    统计查询记录数

    1. QueryWrapper qw = new QueryWrapper<>();
    2. qw.eq("fk.classId",classId);
    3. Integer num = studentMapper.selectCount(qw);
  • 相关阅读:
    IDEA创建SparkSQL程序_大数据培训
    博途PLC S7-1200/1500 ModbusTcp通信SCL代码篇（轮询）
    Sentinel 分布式系统
    复合函数的结合律证明
    git常用的命令
    JUC并发编程：第二季
    vue源码分析-响应式系统(二)
    OceanBase 系统架构初探
    如何用idm下载迅雷文件 idm怎么安装到浏览器 idm怎么设置中文
    使用HTML制作静态网站作业——我的校园运动会(HTML+CSS)
  • 原文地址：https://blog.csdn.net/weixin_66564094/article/details/126696648