- 一、简介
- 二、maven依赖
- 三、配置文件
- 3.1、启动类
- 3.2、mybatis.xml
- 3.3、application.yml
- 3.4、数据库数据准备
- 四、具体使用
- 4.1、包装类
- 4.2、mapper接口
- 4.3、映射文件
- 五、测试
- 5.1、接口
- 5.2、实现类
- 5.3、测试类
- 5.4、运行结果
- 5.4.1、查询所有员工
- 5.4.2、查询单个员工
- 5.4.3、添加员工
- 5.4.4、修改员工
- 5.4.5、删除员工
- 结语
MyBatis也挺流行的,我们也用SpringBoot整合MyBatis做一个简单的增删查改,作为MyBatis的入门教程,让大家有个简单的了解。
二、maven依赖三、配置文件 3.1、启动类4.0.0 org.springframework.boot spring-boot-starter-parent 2.5.2 com.alian mybatis 0.0.1-SNAPSHOT mybatis Spring Boot整合mybatis 1.8 org.springframework.boot spring-boot-starter-web 2.5.2 org.springframework.boot spring-boot-starter-data-jpa 2.5.2 org.mybatis.spring.boot mybatis-spring-boot-starter 2.1.4 com.alibaba druid-spring-boot-starter 1.2.6 mysql mysql-connector-java 8.0.26 runtime org.projectlombok lombok 1.18.20 org.springframework.boot spring-boot-test 2.5.2 org.springframework spring-test 5.3.8 junit junit ${junit.version} org.springframework.boot spring-boot-maven-plugin
package com.alian.mybatis;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@MapperScan("com.alian.mybatis.mapper")
@SpringBootApplication
public class MybatisApplication {
public static void main(String[] args) {
SpringApplication.run(MybatisApplication.class, args);
}
}
我们需要在启动类上加上注解@MapperScan(“com.alian.mybatis.mapper”)
3.2、mybatis.xml此文件我放到resource/config目录下了,提醒一下,如果是希望输出mybatis里sql相关的日志信息,可以在settings配置:
3.3、application.yml
server:
port: 8081
servlet:
context-path: /mybatis
spring:
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
type: com.alibaba.druid.pool.DruidDataSource
username: test
password: Test!@34
url: jdbc:mysql://192.168.0.139:3306/test?characterEncoding=utf8&useUnicode=true&useSSL=false&zeroDateTimeBehavior=convertToNull&autoReconnect=true&allowMultiQueries=true&failOverReadonly=false&connectTimeout=6000&maxReconnects=5
initialSize: 5
minIdle: 5
maxActive: 20
mybatis:
config-location: classpath:config/mybatis.xml
mapper-locations: classpath:mapper/*.xml
type-aliases-package: com.alian.mybatis.dto
这里我使用的是druid作为连接池,里面有三项MyBatis配置,我们也简单介绍下
- config-location:也就是指定mybatis配置文件的地址,也就是上面我们resource/config/目录下mybatis.xml
- mapper-locations:也就是我们mapper对应的xml的路径,这里使用通配符表示classpath:mapper目录下所有的xml文件
- type-aliases-package:一般是用于mybatis结果返回的自定义pojo
CREATE TABLE `tb_inf_employee` (
`id` varchar(10) NOT NULL DEFAULT '' COMMENT '主键',
`emp_name` varchar(20) NOT NULL DEFAULT '' COMMENT '姓名',
`age` int(2) NOT NULL DEFAULT '0' COMMENT '年龄',
`salary` double(8,2) NOT NULL DEFAULT '0.00' COMMENT '工资',
`department` varchar(20) NOT NULL DEFAULT '' COMMENT '部门',
`hire_date` date NOT NULL DEFAULT '1970-07-01' COMMENT '入职时间',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
INSERT INTO `tb_inf_employee` (`id`, `emp_name`, `age`, `salary`, `department`, `hire_date`) VALUES
('BAT10001','梁南生',32,32000.00,'研发部','2020-05-20'),
('BAT10002','唐鹏',31,25000.00,'研发部','2015-03-01'),
('BAT10003','王林',30,22000.00,'研发部','2015-08-01'),
('BAT10004','罗考聪',35,7000.00,'测试部','2016-11-20'),
('BAT10005','包雅馨',25,7000.00,'财务部','2018-07-01'),
('BAT10006','朱健儿',26,8000.00,'人事部','2019-01-01');
四、具体使用
4.1、包装类
EmployeeDto.java
package com.alian.mybatis.dto;
import lombok.Data;
import java.io.Serializable;
import java.time.LocalDate;
@Data
public class EmployeeDto implements Serializable {
private static final long serialVersionUID = 1L;
private String id;
private String name;
private int age;
private double salary;
private String department;
private LocalDate hireDate;
}
4.2、mapper接口
EmployeeMapper.java
package com.alian.mybatis.mapper;
import com.alian.mybatis.dto.EmployeeDto;
import org.apache.ibatis.annotations.Param;
import java.util.List;
public interface EmployeeMapper {
List findAll();
EmployeeDto getById(@Param("id") String id);
int addEmployee(EmployeeDto employeeDto);
int updateById(@Param("emp") EmployeeDto employeeDto);
int deleteById(@Param("id") String id);
}
这里需要提到一个注解是@Param,就相当于给参数弄了一个别名,举个例子,如果你Mapper接口定义的是:
EmployeeDto getById(@Param("empId") String id);
那么对应的xml配置就是
这里使用是 #{empId} 而不是 #{id} ,另外还举一个例子,针对对象别名的:
int updateById(@Param("emp") EmployeeDto employeeDto);
那么对应的xml配置就是
update tb_inf_employee set emp_name=#{emp.name}, age=#{emp.age},salary=#{emp.salary}, department=#{emp.department},hire_date=#{emp.hireDate} where id=#{emp.id}
这里如果你不使用 #{emp.属性} 是会报错的,如果你没有加@Param,那么你直接引用pojo里的属性即可,更多的知识,可以参考下面映射文件里的注释。
4.3、映射文件EmployeeMapper.xml
这里需要注意的几点:
- namespace的值要配置成mapper接口的全路径
- select,insert,update,delete标签里的id对应接口里方法名称
- resultMap 里property是pojo的属性,column是数据库表列名,也可以是表列名的别名,也就是查询时时as后面的名称
- resultType映射结果的时候,查询的字段需要和pojo的属性一样,如果不一致,查询时可以使用as来映射成一样
- 配置了mybatis.type-aliases-package,parameterType类型是pojo,那么就可以省略全路径,直接写pojo
- 为了防止sql注入,建议都是用#{},而不是${}
IEmployeeService.java
package com.alian.mybatis.service;
import com.alian.mybatis.dto.EmployeeDto;
import java.util.List;
public interface IEmployeeService {
List findAll();
EmployeeDto getById(String id);
int addEmployee(EmployeeDto employeeDto);
int updateById(EmployeeDto employeeDto);
int deleteById(String id);
}
5.2、实现类
EmployeeService.java
package com.alian.mybatis.service.impl;
import com.alian.mybatis.dto.EmployeeDto;
import com.alian.mybatis.mapper.EmployeeMapper;
import com.alian.mybatis.service.IEmployeeService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
@Slf4j
@Service
public class EmployeeService implements IEmployeeService{
@Autowired
private EmployeeMapper employeeMapper;
@Override
public List findAll() {
return employeeMapper.findAll();
}
@Override
public EmployeeDto getById(String id) {
return employeeMapper.getById(id);
}
@Override
public int addEmployee(EmployeeDto employeeDto) {
return employeeMapper.addEmployee(employeeDto);
}
@Override
public int updateById(EmployeeDto employeeDto) {
return employeeMapper.updateById(employeeDto);
}
@Override
public int deleteById(String id) {
return employeeMapper.deleteById(id);
}
}
5.3、测试类
TestMybatisService.java
package com.alian.mybatis.service;
import com.alian.mybatis.dto.EmployeeDto;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import java.time.LocalDate;
import java.util.List;
@Slf4j
@RunWith(SpringRunner.class)
@SpringBootTest
public class TestMybatisService {
@Autowired
private IEmployeeService employeeService;
@Test
public void findAll() {
List employeeDtoList = employeeService.findAll();
log.info("查询所有的结果:{}", employeeDtoList.toString());
}
@Test
public void getById() {
String id = "BAT10001";
EmployeeDto employeeDto = employeeService.getById(id);
log.info("根据id查询员工结果:{}", employeeDto);
}
@Test
public void add() {
EmployeeDto employeeDto = new EmployeeDto();
employeeDto.setId("BAT10007");
employeeDto.setName("昊天");
employeeDto.setAge(25);
employeeDto.setDepartment("测试部");
employeeDto.setSalary(12000);
employeeDto.setHireDate(LocalDate.of(2020, 5, 20));
int result = employeeService.addEmployee(employeeDto);
log.info("添加的结果:{}", result);
}
@Test
public void update() {
String id = "BAT10007";
EmployeeDto employeeDto = employeeService.getById(id);
if (employeeDto == null) {
log.error("员工信息不存在");
return;
}
employeeDto.setSalary(20000);
employeeDto.setAge(25);
int result = employeeService.updateById(employeeDto);
log.info("修改的结果:{}", result);
}
@Test
public void delete() {
String id = "BAT10007";
EmployeeDto employeeDto = employeeService.getById(id);
if (employeeDto == null) {
log.error("员工信息不存在:{}", id);
return;
}
int result = employeeService.deleteById(id);
log.info("删除的结果:{}", result);
}
}
5.4、运行结果
5.4.1、查询所有员工
==> Preparing: select id, emp_name, age, salary, department, hire_date from tb_inf_employee ==> Parameters: <== Columns: id, emp_name, age, salary, department, hire_date <== Row: BAT10001, 梁南生, 32, 32000.0, 研发部, 2020-05-20 <== Row: BAT10002, 唐鹏, 31, 25000.0, 研发部, 2015-03-01 <== Row: BAT10003, 王林, 30, 22000.0, 研发部, 2015-08-01 <== Row: BAT10004, 罗考聪, 35, 7000.0, 测试部, 2016-11-20 <== Row: BAT10005, 包雅馨, 25, 7000.0, 财务部, 2018-07-01 <== Row: BAT10006, 朱健儿, 26, 8000.0, 人事部, 2019-01-01 <== Total: 6 Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@7e77678c] 2021-11-03 15:25:53 223 [main] INFO findAll 28:查询所有的结果:[EmployeeDto(id=BAT10001, name=梁南生, age=32, salary=32000.0, department=研发部, hireDate=2020-05-20), EmployeeDto(id=BAT10002, name=唐鹏, age=31, salary=25000.0, department=研发部, hireDate=2015-03-01), EmployeeDto(id=BAT10003, name=王林, age=30, salary=22000.0, department=研发部, hireDate=2015-08-01), EmployeeDto(id=BAT10004, name=罗考聪, age=35, salary=7000.0, department=测试部, hireDate=2016-11-20), EmployeeDto(id=BAT10005, name=包雅馨, age=25, salary=7000.0, department=财务部, hireDate=2018-07-01), EmployeeDto(id=BAT10006, name=朱健儿, age=26, salary=8000.0, department=人事部, hireDate=2019-01-01)]5.4.2、查询单个员工
==> Preparing: SELECt e.id, e.emp_name as name, e.age, e.salary, e.department, e.hire_date as hireDate FROM tb_inf_employee e WHERe e.id= ? ==> Parameters: BAT10001(String) <== Columns: id, name, age, salary, department, hireDate <== Row: BAT10001, 梁南生, 32, 32000.0, 研发部, 2020-05-20 <== Total: 1 Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@4cd7d5e1] 2021-11-03 15:26:47 709 [main] INFO getById 40:根据id查询员工结果:EmployeeDto(id=BAT10001, name=梁南生, age=32, salary=32000.0, department=研发部, hireDate=2020-05-20)5.4.3、添加员工
==> Preparing: insert into tb_inf_employee(id,emp_name,age,salary,department,hire_date) values(?,?,?,?,?,?) ==> Parameters: BAT10007(String), 昊天(String), 25(Integer), 12000.0(Double), 测试部(String), 2020-05-20(LocalDate) <== Updates: 1 Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@5103eea2] 2021-11-03 15:27:35 313 [main] INFO add 56:添加的结果:15.4.4、修改员工
==> Preparing: SELECT e.id, e.emp_name as name, e.age, e.salary, e.department, e.hire_date as hireDate FROM tb_inf_employee e WHERe e.id= ? ==> Parameters: BAT10007(String) <== Columns: id, name, age, salary, department, hireDate <== Row: BAT10007, 昊天, 25, 12000.0, 测试部, 2020-05-20 <== Total: 1 Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@4cd7d5e1] Creating a new SqlSession SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@211a9647] was not registered for synchronization because synchronization is not active JDBC Connection [com.mysql.cj.jdbc.ConnectionImpl@28f878a0] will not be managed by Spring ==> Preparing: update tb_inf_employee set emp_name=?, age=?,salary=?,department=?,hire_date=? where id=? ==> Parameters: 昊天(String), 25(Integer), 20000.0(Double), 测试部(String), 2020-05-20(LocalDate), BAT10007(String) <== Updates: 1 Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@211a9647] 2021-11-03 15:29:34 380 [main] INFO update 73:修改的结果:15.4.5、删除员工
==> Preparing: SELECT e.id, e.emp_name as name, e.age, e.salary, e.department, e.hire_date as hireDate FROM tb_inf_employee e WHERe e.id= ? ==> Parameters: BAT10007(String) <== Columns: id, name, age, salary, department, hireDate <== Row: BAT10007, 昊天, 25, 20000.0, 测试部, 2020-05-20 <== Total: 1 Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@762405bf] Creating a new SqlSession SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@17884d] was not registered for synchronization because synchronization is not active JDBC Connection [com.mysql.cj.jdbc.ConnectionImpl@4d0753c9] will not be managed by Spring ==> Preparing: delete from tb_inf_employee where id=? ==> Parameters: BAT10007(String) <== Updates: 1 Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@17884d] 2021-11-03 15:30:44 463 [main] INFO delete 88:删除的结果:1结语
好了,非常简单的整合MyBatis,及其简单的增删查改就完成了,当然MyBatis远不止这些,后续有时间,我会发布相关博文。



