7.SpringBoot2 数据访问#

温馨提示

转载请标注来源哦~~

本文介绍 SpringBoot2 数据访问方式，你将学习到如何集成 MyBatis 与 MyBatisPlus 进行数据库操作。文章内容来自站主大学时期的学习笔记。

数据存储方式有很多，例如 MySQL、Oracle、MongoDB、Redis 等等，这里我们以 MySQL 为例进行介绍。

7.1 SQL#

1.整合MyBatis操作#

前面用的JdbcTemplate是spring boot官方的，我们用MyBatis

整合第三方技术：找starter（场景启动器）+写配置yml。

SpringBoot官方的Starter：spring-boot-starter-*

第三方的： *-spring-boot-starter

druid和mybatis关系

1.1引入依赖#

1
<dependency>
2
    <groupId>org.mybatis.spring.boot</groupId>
3
    <artifactId>mybatis-spring-boot-starter</artifactId>
4
    <version>2.1.4</version>
5
</dependency>

MyBatis 的使用方式有三种，分别是：配置模式、注解模式、混合模式，下面分别进行介绍。

1.2配置模式(法1)#

全局配置文件
SqlSessionFactory: 自动配置好了
SqlSession：自动配置了 SqlSessionTemplate 组合了SqlSession
@Import(AutoConfiguredMapperScannerRegistrar.class）；
Mapper：只要我们写的操作MyBatis的接口标注了 @Mapper注解就会被自动扫描进来

上图：controller调service，service调mapper。

yml

1
# 配置Mybatis规则
2
mybatis:
3
  config-location: classpath:mybatis/mybatis-config.xml # 全局配置文件位置
4
  mapper-locations: classpath:mybatis/mapper/*.xml # sql映射文件位置

AccountMapper接口

1
@Mapper
2
public interface AccountMapper {
3

4
    public Accout getAccount(Long id);
5
}

映射文件

1
<?xml version="1.0" encoding="UTF-8" ?>
2
<!DOCTYPE mapper
3
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
4
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
5

6
<mapper namespace="com.atguigu.admin.mapper.AccountMapper">
7
<!--    public Accout getAccount(Long id);-->
8
    <select id="getAccount" resultType="com.atguigu.admin.bean.Accout">
9
        select * from account where id=#{}
10
    </select>
11
</mapper>

Mybatis全局配置文件

1
<?xml version="1.0" encoding="UTF-8" ?>
2
<!DOCTYPE configuration
3
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
4
        "http://mybatis.org/dtd/mybatis-3-config.dtd">
5
<configuration>
6
    <settings>
7
<!--        配置驼峰命名（数据库属性如果用的是下划线，bean用的是驼峰，则会映射失败）【我的数据库可无】-->
8
        <setting name="mapUnderscoreToCamelCase" value="true"/>
9
    </settings>
10
</configuration>

测试：

1
@Autowired
2
AccountService accountService;
3

4
@GetMapping("/getAccount")
5
public Accout getAccountById(@RequestParam("id") Long id){
6
    return accountService.getAccountById(id);
7
}

改进：

配置 private Configuration configuration; mybatis.configuration下面的所有，就是相当于改mybatis全局配置文件中的值：

1
# 配置mybatis规则
2
mybatis:
3
  mapper-locations: classpath:mybatis/mapper/*.xml
4
  configuration: # 指定Mybatis全局配置文件中相关配置项
5
    map-underscore-to-camel-case: true

可以不写全局配置文件，所有全局配置文件的配置都放在configuration配置项中即可，但是要把config-location注释掉（全局配置文件只能有一个）。

配置小结：

导入mybatis官方starter
编写mapper接口。标准@Mapper注解
编写sql映射文件并绑定mapper接口
在application.yaml中指定Mapper配置文件的位置，以及指定全局配置文件的信息（建议；配置在mybatis.configuration）

1.3注解模式(法2)#

公司还是xml用的多一点，便于维护。主要是因为注解只适合小型的sql语句，而公司里的语句都非常长，用xml配置会更清晰

Mapper接口

SQL语句直接用注解写，无需xml映射文件

1
@Mapper
2
public interface CityMapper {
3

4
    @Select("select * from city where id=#{id}")
5
    public City getCityById(Long id);
6
}

Service

1
@Service
2
public class CityService {
3

4
    @Autowired
5
    CityMapper cityMapper;
6

7
    public City getCityById(Long id){
8
        return cityMapper.getCityById(id);
9
    }
10
}

Controller

1
@Autowired
2
CityService cityService;
3
@ResponseBody
4
@GetMapping("/getCity")
5
public City getCityById(@RequestParam("id") Long id){
6
    return cityService.getCityById(id);
7
}

1.4混合模式#

Mapper接口

1
@Mapper
2
public interface CityMapper {
3

4
    @Select("select * from city where id=#{id}")
5
    public City getCityById(Long id);
6

7
    public void insertCity(City city);
8
}

xml映射文件

1
<mapper namespace="com.atguigu.admin.mapper.CityMapper">
2
    <!--   public void insertCity(City city);-->
3
    <insert id="insertCity">
4
        insert into city(`name`,`state`,`country`)
5
        values(#{name},#{state},#{country})
6
    </insert>
7
</mapper>

Service

1
@Service
2
public class CityService {
3

4
    @Autowired
5
    CityMapper cityMapper;
6

7
    public City getCityById(Long id){
8
        return cityMapper.getCityById(id);
9
    }
10

11
    public void insertCity(City city){
12
        cityMapper.insertCity(city);
13
    }
14
}

Controller

1
@ResponseBody
2
@PostMapping("/insertCity")
3
public City getCityById(City city){
4
    cityService.insertCity(city);
5
    return city;
6
}

测试（用postman发post请求）：

失败

自动将自增主键的值放入传入的对象：

1
<mapper namespace="com.atguigu.admin.mapper.CityMapper">
2
    <!--   public void insertCity(City city);-->
3
    <insert id="insertCity" useGeneratedKeys="true" keyProperty="id">
4
        insert into city(`name`,`state`,`country`)
5
        values(#{name},#{state},#{country})
6
    </insert>
7
</mapper>

#相当于? $相当于直接拼接。所以$ 会有SQL注入问题。

如果上面的也要写成注解：Mapper接口

1
@Insert("insert into city(`name`,`state`,`country`) values(#{name},#{state},#{country})")
2
@Options(useGeneratedKeys = true,keyProperty = "id")
3
public void insertCity(City city);

小结最佳实战：

引入mybatis-starter
配置application.yaml中，指定mapper-location位置即可
编写Mapper接口并标注@Mapper注解
简单方法直接注解方式
复杂方法编写mapper.xml进行绑定映射
@MapperScan(“com.atguigu.admin.mapper”) 简化，其他的接口就可以不用标注@Mapper注解

2.整合 MyBatis-Plus 完成CRUD#

2.1什么是MyBatis-Plus#

MyBatis-Plus（简称 MP）是一个 MyBatis 的增强工具，在 MyBatis 的基础上只做增强不做改变，为简化开发、提高效率而生。基本的增删改查帮你写好了。

mybatis plus 官网

建议安装 MybatisX 插件

2.2整合MyBatis-Plus#

1.引入依赖#

1
<dependency>
2
    <groupId>com.baomidou</groupId>
3
    <artifactId>mybatis-plus-boot-starter</artifactId>
4
    <version>3.4.1</version>
5
</dependency>

这个里面引入了好多东西，下面这个就不要了，注释掉

1
<dependency>
2
    <groupId>org.mybatis.spring.boot</groupId>
3
    <artifactId>mybatis-spring-boot-starter</artifactId>
4
    <version>2.1.4</version>
5
</dependency>

2.使用#

(1)准备对象

1
@Data
2
@TableName("user")
3
public class User {
4
    //所有属性都应该在数据库中有，此注解表示属性不在表中
5
    @TableField(exist = false)
6
    private String userName;
7
    @TableField(exist = false)
8
    private String password;
9

10
    //以下是数据库字段
11
    private Long id;
12
    private String name;
13
    private Integer age;
14
    private String email;
15
}

@TableField(exist = false) 此注解表示属性不在表中
@TableName(“user”)表示表名，当修改表名时用

(2)Mapper接口继承BaseMapper<T>（Dao就是Mapper）

1
@Mapper
2
public interface UserMapper extends BaseMapper<User> {
3
}

(3)测试类

1
@Test
2
void testUserMapper(){
3
    User user = userMapper.selectById("1");
4
    log.info("用户信息：{}",user);
5
}

3.CRUD功能#

CRUD是做计算处理时的增加(Create)、读取查询(Retrieve)、更新(Update)和删除(Delete)几个单词的首字母简写。

(1)User对象

1
@Data
2
@TableName("user")
3
public class User {
4
    //所有属性都应该在数据库中有，此注解表示属性不在表中
5
    @TableField(exist = false)
6
    private String userName;
7
    @TableField(exist = false)
8
    private String password;
9

10
    //以下是数据库字段
11
    private Long id;
12
    private String name;
13
    private Integer age;
14
    private String email;
15
}

(2)Mapper

1
@Mapper
2
public interface UserMapper extends BaseMapper<User> {
3
}

(3)Service接口继承IService<T>

1
public interface UserService extends IService<User> {
2
}

(4)ServiceImpl实现类继承ServiceImpl<T>

1
@Service
2
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
3
}

(5)Controller使用

1
@GetMapping("/dynamic_table")
2
public String dynamic_table(@RequestParam(value = "pn",defaultValue = "1") Integer pn,
3
                                Model model){
4

5
    //从数据库查出user表数据展示
6
//    List<User> list = userService.list(); //查询所有
7
//    model.addAttribute("users",list);
8

9
    //分页查询数据
10
    Page<User> userPage = new Page<>(pn, 2);
11
    Page<User> page = userService.page(userPage, null);
12
//    long current = page.getCurrent(); //当前页
13
//    long pages = page.getPages(); //总共多少页
14
//    long total = page.getTotal(); //总共几条记录
15
//    List<User> records = page.getRecords();
16

17
    model.addAttribute("page",page);
18
    return "table/dynamic_table";
19
}
20

21
// 删除功能
22
@GetMapping("/user/delete/{id}")
23
public String deleteUser(@PathVariable("id") Long id,
24
                         @RequestParam(value = "pn",defaultValue = "1") Integer pn,
25
                         RedirectAttributes redirectAttributes){
26

27
    userService.removeById(id);
28
    redirectAttributes.addAttribute("pn",pn); //重定向参数
29
    return "redirect:/dynamic_table";
30
}

(6)分页器配置类

1
@Configuration
2
public class MybatisConfig {
3

4
    @Bean
5
    public MybatisPlusInterceptor mybatisPlusInterceptor(){
6
        MybatisPlusInterceptor mybatisPlusInterceptor = new MybatisPlusInterceptor();
7

8
        //分页拦截器
9
        PaginationInnerInterceptor innerInterceptor = new PaginationInnerInterceptor();
10
        innerInterceptor.setOverflow(true); //最后一页时true跳回到首页，false继续请求
11
        innerInterceptor.setMaxLimit(50L); //每页最大数量 -1 不受限制
12
        mybatisPlusInterceptor.addInnerInterceptor(innerInterceptor);
13
        return mybatisPlusInterceptor;
14
    }
15
}

(7)模板示例

1
<tr class="gradeX" th:each="user,stat: ${page.records}">
2
    <td th:text="${stat.count}"></td>
3
    <td th:text="${user.id}"></td>
4
    <td>[[${user.name}]]</td>
5
    <td th:text="${user.age}">Win 95+</td>
6
    <td th:text="${user.email}">4</td>
7
    <td>
8
        <a th:href="@{/user/delete/{id}(id=${user.id},pn=${users.current})}"
9
           class="btn btn-danger btn-sm" type="button">删除</a>
10
    </td>
11
</tr>

1
<div class="dataTables_info" id="dynamic-table_info">
2
    当前第[[${page.current}]]页 总计 [[${page.pages}]]页 共[[${page.total}]]条记录
3
</div>

1
<ul>
2
    <li class="prev disabled"><a href="#">← 前一页</a></li>
3
    <li th:class="${num == page.current?'active':''}"
4
        th:each="num:${#numbers.sequence(1,page.pages)}">
5
        <a th:href="@{/dynamic_table(pn=${num})}">[[${num}]]</a>
6
    </li>
7
    <li class="next disabled"><a href="#">下一页 → </a></li>
8
</ul>

展示

音乐

音乐

7.SpringBoot2 数据访问#

7.1 SQL#

1.整合MyBatis操作#

1.1引入依赖#

1.2配置模式(法1)#

1.3注解模式(法2)#

1.4混合模式#

2.整合 MyBatis-Plus 完成CRUD#

2.1什么是MyBatis-Plus#

2.2整合MyBatis-Plus#

1.引入依赖#

2.使用#

3.CRUD功能#

支持与分享