当前位置：首页 > news >正文

MyBatis-Plus详解

news 2025/6/6 12:51:12

MyBatis-Plus

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

官网 MyBatis-Plus

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

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

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

Mybatis --- 环境搭建

1、导入相关依赖

<parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.4.2</version><relativePath/>
</parent>
<dependencies><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.48</version></dependency>
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.4.3</version></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version><scope>test</scope></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid</artifactId><version>1.2.9</version></dependency>
</dependencies>

2、创建实体类

//声明该实体类映射的表名
@TableName("t_product")
public class ProductBean {//表示该列为主键列，value表示该列映射的列名//type = IdType.AUTO 表示该列的值使用自动增长列生成@TableId(value = "pk_productId",type = IdType.AUTO)private Integer id;//指定当前属性映射的列名@TableField("p_name")private String name;
@TableField("p_createDate")private LocalDate createDate;
@TableField("p_price")private Integer price;
}

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

spring:datasource:driver-class-name: com.mysql.jdbc.Driver  #定义配置驱动类username: root #mysql登录用户名password: 123 #mysql登录密码url: jdbc:mysql://localhost:12345/shopDB?characterEncoding=utf8&allowMultiQueries=true type: com.alibaba.druid.pool.DruidDataSource #配置连接池druid:one:max-active: 100 #最大连接数min-idle: 20 #最小连接数max-wait: 2000 #超时时间（ms）


mybatis-plus:configuration:log-impl: org.apache.ibatis.logging.stdout.StdOutImpl #配置日志type-aliases-package: com.project.bean #实体类所在包，允许用实体类类名作为别名mapper-locations: classpath:*/*Mapper.xml #链接 mapper文件

4、创建业务接口

public interface IProductService {
public void add(ProductBean productBean);public void del(Integer id);public void update(Integer id,Integer price);public List<ProductBean> findAll();public ProductBean findById(Integer id);public List<ProductBean> findByItem(String name, 
LocalDate startDate,LocalDate endDate);
}

5、创建 mapper 接口

@Mapper
public interface IProductMapper extends BaseMapper<ProductBean> {
}

6、书写业务接口实现类

@Service
@Transactional//该类所有方法支持事务
public class ProductServiceImpl implements IProductService {@Autowiredprivate IProductMapper mapper;@Overridepublic void add(ProductBean productBean) {mapper.insert(productBean);//添加实体数据}
@Overridepublic void del(Integer id) {mapper.deleteById(id);//根据id删除实体数据}
@Overridepublic void update(Integer id, Integer price) {ProductBean productBean = new ProductBean();productBean.setId(id);productBean.setPrice(price);mapper.updateById(productBean);//按id修改实体属性}
@Overridepublic List<ProductBean> findAll() {return mapper.selectList(null);//查询所有}
@Overridepublic ProductBean findById(Integer id) {return mapper.selectById(id);//按id查询实体对象}
@Overridepublic List<ProductBean> findByItem(String name, 
LocalDate startDate, LocalDate endDate) {QueryWrapper<ProductBean> qw = new QueryWrapper<>();//条件集合if (name != null && name.length() != 0){qw.like("p_name",name);//like 模糊查询}if (startDate != null){qw.ge("p_creatDate",startDate);//ge 大于等于}if (endDate != null){qw.le("p_createDate",endDate);//le 小于等于}return mapper.selectList(qw);//按条件查询}
}

7、测试类

@RunWith(SpringRunner.class)
@SpringBootTest(classes = Main.class)//启动类类模板
public class ProductTest {@Autowiredprivate IProductService service;
@Testpublic void test(){
//        service.add(new ProductBean("999感冒灵", 
LocalDate.parse("2022-06-06"),18));System.out.println(service.findAll());}
}

分页查询

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


@Configuration
public class MyBatisPlusConfig {@Beanpublic MybatisPlusInterceptor mybatisPlusInterceptor() {MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));return interceptor;}
}

2、定义业务接口方法

/*** 动态条件分页查询* @param pageNO 页码* @param name 姓名* @param startDate 生产起始日期* @param endDate 生成结束日期* @return 分页对象*/
public IPage<ProductBean> findByItem(Integer pageNO, 
String name, LocalDate startDate,LocalDate endDate);

3、定义 mapper 接口

@Mapper
public interface IProductMapper extends BaseMapper<ProductBean> {
}

4、书写业务方法

@Override
public IPage<ProductBean> findByItem(Integer pageNO,String name, LocalDate startDate, LocalDate endDate) {QueryWrapper<ProductBean> qw = new QueryWrapper<>();if (name != null && name.length() != 0){qw.like("p_name",name);}if (startDate != null){qw.ge("p_createDate",startDate);}if (endDate != null){qw.le("p_createDate",endDate);}return mapper.selectPage(new Page(pageNO,3),qw);
}

5、测试类

@RunWith(SpringRunner.class)
@SpringBootTest(classes = PlusMain.class)
public class Test {@Autowiredprivate IProductService service;@org.junit.Testpublic void test(){
//        System.out.println(service.findAll());IPage ip = service.findByItem(1,"",null,null);System.out.println(ip.getRecords()//得到当前数据+"  "+ip.getTotal()//得到总记录数+"  "+ip.getPages()//总页数+"  "+ip.getCurrent()//得到页码+"  "+ip.getSize()//得到每页记录数);}
}

Mybatis-plus 关联操作

一对多：

1、创建实体类

/*** 部门实体类*/
@TableName("t_dept")
public class DeptBean {@TableId(value = "pk_deptId",type = IdType.AUTO)private Integer id;
@TableField("d_name")private String name;
@TableField(exist = false)//标识该属性没有对应的列private Integer emNum;
@TableField(exist = false)//标识该属性没有对应的列private List<EmployeeBean> emList;
}
/*** 员工实体类*/
@TableName("t_employee")
public class EmployeeBean {@TableId(value = "pk_emId",type = IdType.AUTO)private Integer id;@TableField("e_name")private String name;@TableField("e_job")private String job;@TableField("e_birthday")private LocalDate birthday;@TableField("fk_deptId")private Integer deptId;@TableField(exist = false)private DeptBean dept;
}

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

2、建立业务接口

/**
*部门业务接口
*/
public interface IDeptService {/*** 查询所有部门，同时统计每个部门的人数* @return 部门集合*/public List<DeptBean> findAll();
/*** 级联添加，添加部门，同时添加该部门的员工集合* @param dept 部门对象* @param emList 新员工集合*/public void add(DeptBean dept, List<EmployeeBean> emList);
/*** 删除部门，同时级联删除部门的员工* @param id 部门ID*/public void delCasede(Integer id);
/*** 删除部门，同时将该部门员工外键设置为null* @param id 部门ID*/public void delSerNull(Integer id);
/*** 按id查询部门，同时查询该部门中所有的员工* @param id 部门id* @return 部门对象*/public DeptBean findById(Integer id);
}/*** 员工业务接口*/
public interface IEmployeeService {/*** 添加员工* @param employee 员工对象*/public void add(EmployeeBean employee);
/*** 动态条件分页查询，同时查询每个员工所在部门的名称* @param pageNO 页码* @param deptName 部门名称* @param name 员工姓名* @return 分页对象*/public IPage<EmployeeBean> findByItem(Integer pageNO,
String deptName,String name);
/*** 按id查询员工，同时查询员工的部门信息* @param id 员工编号* @return 员工对象33*/public EmployeeBean findById(Integer id);
}

3、建立 Mapper 接口

/**
*部门 mapper 接口
*/
@Mapper
public interface IDeptMapper extends BaseMapper<DeptBean> {@Select("SELECT d.*,COUNT(e.`pk_emId`) emNum FROM t_dept d LEFT JOINt_employee e ON d.`pk_deptId`=e.`fk_deptId`\n" +"GROUP BY d.`pk_deptId`")@ResultMap("deptMap")public List<DeptBean> findAll();
@Delete("delete from t_employee where fk_deptId=#{id};" +"delete from t_dept where pk_deptId=#{id};")public void delCasede(Integer id);
@Delete("update t_employee set fk_deptId=null where fk_deptId=#{id};" +"delete from t_dept where pk_deptId=#{id};")public void delSetNull(Integer id);
}
/**
*员工 mapper 接口
*/
@Mapper
public interface IEmployeeMapper extends BaseMapper<EmployeeBean> {
public void addMore(@Param("deptId") Integer deptId,
@Param("emList") List<EmployeeBean> emList);
public IPage<EmployeeBean> findByItem(Page pageNO,
@Param("deptName") String deptName,@Param("name") String name);

}

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

4、书写 mapper 文件

IDeptMapper：

<mapper namespace="com.project.mapper.IDeptMapper"><resultMap id="deptMap" type="DeptBean"><id property="id" column="pk_deptId"></id><result property="name" column="d_name"></result><result property="emNum" column="emNum"></result></resultMap>
</mapper>

IEmployeeMapper：

<mapper namespace="com.project.mapper.IEmployeeMapper"><insert id="addMore">insert into t_employee (e_name,e_job,e_birthday,fk_deptId)values<foreach collection="emList" item="em" separator=",">(#{em.name},#{em.job},#{em.birthday},#{deptId})</foreach></insert>
<resultMap id="emMap" type="EmployeeBean"><id column="pk_emId" property="id"></id><result column="e_name" property="name"></result><result column="e_job" property="job"></result><result column="e_birthday" property="birthday"></result><result column="d_name" property="dept.name"></result></resultMap>
<select id="findByItem" resultMap="emMap">select e.*,d.d_name from t_dept d,t_employee e whered.pk_deptId=e.fk_deptId<if test="deptName != null and deptName != '' ">and d_name like "%"#{deptName}"%"</if><if test="name != null and name != '' ">and e_name like "%"#{name}"%"</if></select>
</mapper>

5、书写业务方法

/*** 部门业务方法*/
@Service
@Transactional
public class DeptServiceImpl implements IDeptService {
@Autowiredprivate IDeptMapper deptMapper;@Autowiredprivate IEmployeeMapper employeeMapper;
@Overridepublic List<DeptBean> findAll() {return deptMapper.findAll();}
@Overridepublic void add(DeptBean dept, List<EmployeeBean> emList) {deptMapper.insert(dept);employeeMapper.addMore(dept.getId(),emList);}
@Overridepublic void delCasede(Integer id) {deptMapper.delCasede(id);}
@Overridepublic void delSerNull(Integer id) {deptMapper.delSetNull(id);}
@Overridepublic DeptBean findById(Integer id) {DeptBean dept = deptMapper.selectById(id);QueryWrapper<EmployeeBean> qw = new QueryWrapper<>();qw.eq("fk_deptId",id);dept.setEmList(employeeMapper.selectList(qw));return dept;}
}
/*** 员工业务方法*/
@Service
@Transactional
public class EmployeeServiceImpl implements IEmployeeService {@AutowiredIEmployeeMapper employeeMapper;@AutowiredIDeptMapper deptMapper;@Overridepublic void add(EmployeeBean employee) {employeeMapper.insert(employee);}
@Overridepublic IPage<EmployeeBean> findByItem(Integer pageNO, 
String deptName, String name) {return employeeMapper.findByItem(new Page(pageNO,3),deptName,name);}
@Overridepublic EmployeeBean findById(Integer id) {EmployeeBean em = employeeMapper.selectById(id);em.setDept(deptMapper.selectById(em.getDeptId()));··      return em;}
}

统计查询记录数

QueryWrapper<StudentBean> qw = new QueryWrapper<>();
qw.eq("fk.classId",classId);
Integer num = studentMapper.selectCount(qw);

查看全文

http://www.xdnf.cn/news/846649.html

Kali 2023年最新版下载安装最全流程功能介绍（内附安装包）

全站最全Tampermonkey 油猴插件指南，不看后悔一辈子

Mysql的安装和配置教程（超详细图文）从零基础入门到精通，看完这一篇就够了

SQL cast()函数

select简单使用

Unity移动应用如何在Bugly上查看崩溃堆栈

【Python】【进阶篇】四、Python爬虫的URL编码/解码

Three.js学习1：threejs简介及文档本地部署

vscode使用git上传提交代码、比较代码（git基本操作）

【雕爷学编程】Arduino智慧农业之精确控制温度、湿度和光照

Git的下载、安装与使用(Windows)

flex布局

前端插件swiper基础使用详解含部分常用API

SSH服务

swagger接口测试工具介绍及使用

00_简单常识介绍——NOIP/NOI/IOI（信息学奥林匹克竞赛）

zabbix监控

Apache Doris新手指南：10分钟内搭建数据分析引擎！_doris priority_netwoks(3)

什么是LLM？看这一篇就够了！

Ping命令详解（使用Ping这命令来测试网络连通）

Token验证流程、代码示例、优缺点和安全策略，一文告诉你。

jQuery看这一篇就够啦，jQuery基础大全，可用于快速回顾知识，面试首选

Https连接过程详解

Linux - 安装 Jenkins(详细教程)

MyBatis-Plus

Mybatis --- 环境搭建

分页查询

Mybatis-plus 关联操作

统计查询记录数

相关文章：