MyBatis集成方式
- 注解版集成
- XML版本集成
XML版本为老式的配置集成方式，重度集成XML文件，SQL语句也是全部写在XML中的，我以前配SSM（Spring+SpringMVC+MyBatis）用的就是这种方式；注解版版本，相对来说比较简约，不需要XML配置，只需要使用注解和代码来操作数据，本文这里不作介绍（其实挺好学的，^_^）。
准备
启动MySQL服务
创建数据库spring_db
| 1
| CREATE DATABASE spring_db CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;
| | —- | —- |
创建user表
| 1
2
3
4
5
6
7
8
9
10
11
| create table user
(
uid int(11) unsigned auto_increment comment ‘主键Id’
primary key,
name varchar(255) null comment ‘名称’,
age int null comment ‘年龄’,
address varchar(255) null comment ‘地址’,
created_time datetime null comment ‘创建时间’,
updated_time datetime null comment ‘更新时间’
)
comment ‘用户表’ collate=utf8_general_ci;
| | —- | —- |
添加依赖
| 1
2
3
4
5
6
7
8
9
10
11
|
| | —- | —- |
配置数据库连接
设置application.properties文件，添加如下配置
| 1
2
3
4
| spring.datasource.url=jdbc:mysql://127.0.0.1:3306/spring_db?useUnicode=true&characterEncoding=UTF-8
spring.datasource.username=root
spring.datasource.password=2LCqvSOJ6m0Ut6ui
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
| | —- | —- |
- spring.datasource.url 数据库连接字符串
- spring.datasource.username 数据库用户名
- spring.datasource.password 数据库密码
- spring.datasource.driver-class-name 驱动类型（注意MySQL 8.0的值是com.mysql.cj.jdbc.Driver和之前不同）
设置 MapperScan 包路径
直接在启动文件SpringbootApplication.java的类上配置@MapperScan，这样就可以省去，单独给每个Mapper（就是我们这里的dao层）上标识@Mapper的麻烦。
| 1
2
3
4
5
6
7
8
| @SpringBootApplication
@MapperScan(“com.salamander.springbootdemo.dao”)
public class SpringbootdemoApplication {
public static void main(String[] args) {<br /> SpringApplication.run(SpringbootdemoApplication.class, args);<br /> }<br />}
| | —- | —- |
添加Entity和Dao层类
com.salamander.springbootdemo.entity下User类（使用了lombok的@Data注解）：
| 1
2
3
4
5
6
7
8
9
10
11
12
| @Data
public class User implements Serializable {
private Long id;
private String name;
private String address;
private int age;
private Date createdDatetime;<br />}
| | —- | —- |
com.salamander.springbootdemo.dao下UserDao接口：
| 1
2
3
4
5
| public interface UserDao {
User findByName(String name);
int insertUser(User user);
}
| | —- | —- |
XML方式MyBatis 集成
修改application.properties，添加配置
| 1
2
| mybatis.config-locations=classpath:mybatis/mybatis-config.xml
mybatis.mapper-locations=classpath:mybatis/mapper/*.xml
| | —- | —- |
- mybatis.config-locations 配置MyBatis基础属性
- mybatis.mapper-locations 配置Mapper XML文件
配置XML文件
本例创建两个xml文件，在resource/mybatis下的mybatis-config.xml（配置MyBatis基础属性）和在resource/mybatis/mapper下的UserMapper.xml（用户和数据交互的SQL语句）。
mybatis-config.xml
| 1
2
3
4
5
6
7
8
9
10
11
12
13
| <?xml version=”1.0” encoding=”UTF-8” ?>
<!DOCTYPE configuration PUBLIC “-//mybatis.org//DTD Config 3.0//EN” “http://mybatis.org/dtd/mybatis-3-config.dtd">
| | —- | —- |
UserMapper.xml
| 1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
| <?xml version=”1.0” encoding=”UTF-8” ?>
<!DOCTYPE mapper PUBLIC “-//mybatis.org//DTD Config 3.0//EN” “http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<select id="findByName" parameterType="java.lang.String" resultMap="userResultMap"><br /> select uid, name, age, address, created_time<br /> from user<br /> where name = #{name}<br /> </select><br /> <br /> <insert id="insertUser" parameterType="com.salamander.springbootdemo.entity.User"><br /> insert into user(name, age, address, created_time) VALUES (<br /> #{name}, #{age}, #{address}, #{createdDatetime}<br /> )<br /> </insert><br /></mapper>
| | —- | —- |
调用Dao类
HomeController.java类
| 1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
| @RestController
public class HomeController {
@Resource
private UserDao userDao;
@RequestMapping("/")<br /> public String index() {<br /> return "Hello World!";<br /> }
@RequestMapping("/user/{username}")<br /> @ResponseBody<br /> public User getUser(@PathVariable(name = "username") String name) {<br /> return userDao.findByName(name);<br /> }<br /> <br /> @RequestMapping("/user/add/{username}")<br /> @ResponseBody<br /> public String addUser(@PathVariable(name = "username") String name) {<br /> User user = new User();<br /> user.setName(name);<br /> user.setAge(20);<br /> user.setCreatedDatetime(new Date());<br /> userDao.insertUser(user);<br /> return "insert succesfully";<br /> }<br />}
| | —- | —- |
好了，访问链接http://localhost:8080/user/wang，就会输出wang这个用户的数据，而访问http://localhost:8080/user/add/zhao,会添加一条name为zhao的数据到数据库。
事务支持
在SpringBoot中开启事务非常简单，只需在业务层添加事务注解(@Transactional)即可快速开启事务。好的，让我们来尝试一下。
在上面的使用中，我们是直接把Dao类在控制层中使用的，但一般情况下，我们是在业务层中使用Dao类的。
在com.salamander.springbootdemo下新建Service的package，之后创建接口UserService：
| 1
2
3
4
5
| package com.salamander.springbootdemo.service;
public interface UserService {
void addUsers(String name) throws Exception;
}
| | —- | —- |
之后在impl的子package中添加实现类UserServiceImpl：
| 1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
package com.salamander.springbootdemo.service.impl;
import com.salamander.springbootdemo.dao.UserDao;
import com.salamander.springbootdemo.entity.User;
import com.salamander.springbootdemo.service.UserService;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.util.Date;
@Service
public class UserServiceImpl implements UserService {
@Resource
private UserDao userDao;
@Transactional<br /> @Override<br /> public void addUsers(String name) throws Exception {<br /> int num = 5;<br /> for (int i = 0; i < num; i++) {<br /> User user = getNewUser(name + (i + 1));<br /> userDao.insertUser(user);<br /> if (i == 3) {<br /> throw new Exception("发生内部错误了");<br /> }<br /> }<br /> }
private User getNewUser(String name) {<br /> User user = new User();<br /> user.setName(name);<br /> user.setAge(20);<br /> user.setCreatedDatetime(new Date());<br /> return user;<br /> }<br />}
| | —- | —- |
然后我们在HomeController中注入UserService，并添加路由
| 1
2
3
4
5
6
7
8
9
10
11
12
13
| @Resource
private UserService userService;
@RequestMapping(“/users/add/{username}”)
@ResponseBody
public String addUsers(@PathVariable(name = “username”) String name) {
try {
userService.addUsers(name);
return “batch insert succesfully”;
} catch (Exception e) {
return e.getMessage();
}
}
| | —- | —- |
可以看到，我们在addUsers方法上添加了@Transactional注解开启了事务，并在插入第4条数据后抛出了异常。好了，让我们访问链接http://localhost:8080/users/add/sun，我们发现数据库多出了四条name为sun的数据，**回滚并没有起效果**
这是一个常见的坑点，因为Spring的默认的事务规则是遇到运行异常（RuntimeException及其子类）和程序错误（Error）才会进行事务回滚，而Exception是基类就不行了，让我们看下Java的异常类层次图
如果想针对检测异常进行事务回滚，可以在@Transactional注解里使用
rollbackFor属性明确指定异常（或者你可以自己定义一个继承RuntimeException的类，然后抛出这个类）。
现在addUsers改成这样，就可以正常回滚了：
| 1
2
3
4
5
6
7
8
9
10
11
12
| @Transactional(rollbackFor = Exception.class) @Override public void addUsers(String name) throws Exception { int num = 5; for (int i = 0; i < num; i++) { User user = getNewUser(name + (i + 1)); userDao.insertUser(user); if (i == 3) { throw new Exception(“发生内部错误了”); } } } |
|---|
若有收获，就点个赞吧
0 人点赞
