day12-SpringBoot数据库操作

SpringBoot数据库操作

1.JDBC+HikariDataSource

在SpringBoot 2.x项目中，默认使用Hikari连接池管理数据源。相比于传统的 C3P0 、DBCP、Tomcat jdbc 等连接池更加优秀。
当项目pom.xml引入spring-boot-starter-jdbc启动器依赖后，即可自动导入Hikari，该启动器不但依赖它，还会对其自动配置并创建数据源。我们以MySQL数据库为例，介绍如何使用Hikari。

数据源是啥？为什么要用？怎么用？

1.1应用实例

演示SpringBoot如何通过 JDBC+HikariDataSource 完成对Mysql操作。
（1）数据库和表

1. -- 创建数据库
2. DROP DATABASE IF EXISTS spring_boot;
3. CREATE DATABASE spring_boot;
4. USE spring_boot;
6. -- 创建表
7. CREATE TABLE furn(
8. `id` INT(11) PRIMARY KEY AUTO_INCREMENT, #id
9. `name` VARCHAR(64) NOT NULL, #家居名
10. `maker` VARCHAR(64) NOT NULL, #厂商
11. `price` DECIMAL(11,2) NOT NULL, #价格
12. `sales` INT(11) NOT NULL, #销量
13. `stock` INT(11) NOT NULL, #库存
14. `img_path` VARCHAR(256) NOT NULL #照片路径
15. );
17. -- 初始化家居数据
18. INSERT INTO furn(`id` , `name` , `maker` , `price` , `sales` , `stock` , `img_path`)
19. VALUES(NULL , '北欧风格小桌子' , '熊猫家居' , 180 , 666 , 7 , 'assets/images/product-image/6.jpg');
21. INSERT INTO furn(`id` , `name` , `maker` , `price` , `sales` , `stock` , `img_path`)
22. VALUES(NULL , '简约风格小椅子' , '熊猫家居' , 180 , 666 , 7 , 'assets/images/product-image/4.jpg');
24. INSERT INTO furn(`id` , `name` , `maker` , `price` , `sales` , `stock` , `img_path`)
25. VALUES(NULL , '典雅风格小台灯' , '蚂蚁家居' , 180 , 666 , 7 , 'assets/images/product-image/14.jpg');
27. INSERT INTO furn(`id` , `name` , `maker` , `price` , `sales` , `stock` , `img_path`)
28. VALUES(NULL , '温馨风格盆景架' , '蚂蚁家居' , 180 , 666 , 7 , 'assets/images/product-image/16.jpg');
30. SELECT * FROM furn;

复制代码

（2）进行数据库开发，首先要在pom.xml文件中引入spring-boot-starter-data-jdbc。SpringBoot不知道项目要操作Mysql还是Oracle，因此还需要导入数据库驱动，并指定对应版本。

1. <dependency>
2.     <groupId>org.springframework.boot</groupId>
3.     <artifactId>spring-boot-starter-data-jdbc</artifactId>
4. </dependency>
7. <dependency>
8.     <groupId>mysql</groupId>
9.     <artifactId>mysql-connector-java</artifactId>
10.     <version>5.1.49</version>
11. </dependency>

复制代码

（3）在application.yml配置操作数据源的信息

1. spring:
2.   datasource: #配置数据源
3.     #说明：如果没有配置useSSL=true，启动项目会报红警告，但不影响使用
4.     url: jdbc:mysql://localhost:3306/spring_boot?useSSL=true&useUnicode=true&characterEncoding=UTF-8
5.     username: root
6.     password: 123456
7.     driver-class-name: com.mysql.jdbc.Driver

复制代码

（4）创建Javabean--Furn.java

1. package com.li.thymeleaf.bean;
3. import lombok.AllArgsConstructor;
4. import lombok.Data;
5. import lombok.NoArgsConstructor;
7. import java.math.BigDecimal;
9. /**
10. * @author 李
11. * @version 1.0
12. */
13. @Data
14. @NoArgsConstructor
15. @AllArgsConstructor
16. public class Furn {
17.     private Integer id;
18.     private String name;
19.     private String maker;
20.     private BigDecimal price;
21.     private Integer sales;
22.     private Integer stock;
23.     private String imgPath;
24. }

复制代码

（5）测试类ApplicationTests.java

1. package com.li.thymeleaf;
3. import com.li.thymeleaf.bean.Furn;
4. import org.junit.jupiter.api.Test;
5. import org.springframework.boot.test.context.SpringBootTest;
6. import org.springframework.jdbc.core.BeanPropertyRowMapper;
7. import org.springframework.jdbc.core.JdbcTemplate;
9. import javax.annotation.Resource;
10. import java.util.List;
12. /**
13. * @author 李
14. * @version 1.0
15. * 演示如何在SpringBoot中开发测试类
16. */
17. @SpringBootTest
18. public class ApplicationTests {
19.     //这里使用spring的JDBCTemplate
20.     @Resource
21.     private JdbcTemplate jdbcTemplate;
23.     @Test
24.     public void contextLoads() {
25.         //使用RowMapper接口来对返回的数据进行封装(底层是反射->setter)
26.         BeanPropertyRowMapper<Furn> rowMapper =
27.                 new BeanPropertyRowMapper<>(Furn.class);
28.         List<Furn> furns = jdbcTemplate.query("select * from furn", rowMapper);
29.         for (Furn furn : furns) {
30.             System.out.println("furn=" + furn);
31.         }
32.         //查看底层使用的是什么数据源
33.         System.out.println(jdbcTemplate.getDataSource().getClass());
34.     }
35. }

复制代码

测试结果：

1. <dependency>
2. <groupId>org.springframework.boot</groupId>
3. <artifactId>spring-boot-starter-test</artifactId>
4. </dependency>

复制代码

2.整合Druid到SpringBoot

2.1Druid介绍

alibaba/druid: 为监控而生的数据库连接池 (github.com)
官方使用文档 · alibaba/druid Wiki (github.com)

Druid数据库连接池性能优秀，它除了提供性能卓越的数据池功能外，还继承了SQL监控，黑名单拦截等功能。强大的监控特性，通过Druid提供的监控功能，可以清楚知道连接池和SQL的工作情况，所以根据项目需要，我们也要掌握Druid和SpringBoot的整合。
整合Druid到SpringBoot的方式：

• 自定义方式
  
• 引入starter
  

2.2Druid基本使用

（1）修改pom.xml，引入druid依赖

1. <dependency>
2.     <groupId>com.alibaba</groupId>
3.     <artifactId>druid</artifactId>
4.     <version>1.1.17</version>
5. </dependency>

复制代码

（2）创建配置类 DruidDataSourceConfig.java，将DruidDataSource注入容器

1. package com.li.thymeleaf.config;
3. import com.alibaba.druid.pool.DruidDataSource;
4. import org.springframework.boot.context.properties.ConfigurationProperties;
5. import org.springframework.context.annotation.Bean;
6. import org.springframework.context.annotation.Configuration;
8. import javax.sql.DataSource;
10. /**
11. * @author 李
12. * @version 1.0
13. * 配置类
14. */
15. @Configuration
16. public class DruidDataSourceConfig {
17.     //注入DruidDataSource
18.    
19.     //通过@ConfigurationProperties指定读取application.yml文件的数据
20.     //我们就不需要调用DruidDataSource的setXxx方法来配置(不推荐)
21.     @ConfigurationProperties("spring.datasource")
22.     @Bean
23.     public DataSource dataSource() {
24.         return new DruidDataSource();
25.     }
26. }

复制代码

（3）测试类ApplicationTests.java（略，同上）
测试结果：
2.2.1一个问题

问题：为什么我们注入了自己的数据源，默认的HikariDataSource就失效了？
先来弄明白，默认的HikariDataSource 是如何配置的：
SpringBoot通过DataSourceAutoConfiguration.java来进行数据源的配置，在进行默认的配置之前，如果检测到容器中已经有DataSource Bean，就不会注入默认的HikariDataSource。
因此，如果你注入了自己的数据源，就不会注入默认的HikariDataSource。
DataSourceAutoConfiguration.java：
2.3Druid监控功能

2.3.1开启内置监控页

怎样使用Druid的内置监控页面：内置监控页面是一个Servlet，具体配置看这里
（1）在配置类中，启用druid的监控页功能：

在web项目中使用web.xml配置，若在SpringBoot中，有两种方法注入Servlet---注解和RegistrationBean，这里使用RegistrationBean

DruidDataSourceConfig.java：

1. package com.li.thymeleaf.config;
3. import com.alibaba.druid.pool.DruidDataSource;
4. import com.alibaba.druid.support.http.StatViewServlet;
5. import org.springframework.boot.context.properties.ConfigurationProperties;
6. import org.springframework.boot.web.servlet.ServletRegistrationBean;
7. import org.springframework.context.annotation.Bean;
8. import org.springframework.context.annotation.Configuration;
10. import javax.sql.DataSource;
12. /**
13. * @author 李
14. * @version 1.0
15. * 配置类
16. */
17. @Configuration
18. public class DruidDataSourceConfig {
19.     //注入DruidDataSource
20.     //通过@ConfigurationProperties指定读取yml文件的前缀的数据
21.     @ConfigurationProperties("spring.datasource")
22.     @Bean
23.     public DataSource dataSource() {
24.         return new DruidDataSource();
25.     }
27.     //配置Druid的监控页功能
28.     @Bean
29.     public ServletRegistrationBean statViewServlet() {
30.         //创建StatViewServlet
31.         ServletRegistrationBean<StatViewServlet> registrationBean
32.                 = new ServletRegistrationBean<>(new StatViewServlet(), "/druid/*");
33.         //设置初始化参数-用户名和密码-根据官方配置文件设置
34.         registrationBean.addInitParameter("loginUsername", "olien");
35.         registrationBean.addInitParameter("loginPassword", "123456");
36.         return registrationBean;
37.     }
38. }

复制代码

（2）启动项目，浏览器中访问http://项目ip:项目端口/项目名称/druid/index.html，输入配置的用户名和密码，即可访问到内置的监控页面：
2.3.2SQL监控

配置_StatFilter · alibaba/druid Wiki (github.com)
除了文档中的配置方式，也可在配置类中直接对数据源进行设置。
修改DruidDataSourceConfig.java：
启用SQL监控功能之后，在监控页中可以查看到所有对数据库发出的SQL语句：
2.3.3-Web关联监控

Web关联监控配置
Spring关联监控配置
修改DruidDataSourceConfig.java：注入webStatFilter

1. //配置WebStatFilter，用于采集web-jdbc关联的监控数据
2. @Bean
3. public FilterRegistrationBean webStatFilter() {
4.     //创建过滤器webStatFilter
5.     WebStatFilter webStatFilter = new WebStatFilter();
6.     FilterRegistrationBean<WebStatFilter> filterRegistrationBean =
7.             new FilterRegistrationBean<>(webStatFilter);
8.     //设置webStatFilter的监控url
9.     filterRegistrationBean.setUrlPatterns(Arrays.asList("/*"));
10.     //根据官方文档设置webStatFilter排除的url
11.     filterRegistrationBean.addInitParameter("exclusions",
12.             "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");
13.     return filterRegistrationBean;
14. }

复制代码

启用URI监控功能之后，在监控页中可以查看到所有的Web应用情况和URI请求情况：
2.3.4SQL防火墙

Druid提供了WallFilter，它是基于SQL语义分析来实现防御SQL注入攻击的。具体配置看这里
修改DruidDataSourceConfig.java：
启用SQL防火墙之后，在监控页中可以查看到所有的SQL情况：
2.3.5Session监控

注意：这里的Session不包括Druid后台监控系统产生的Session

Druid的Session监控不需要配置，在开启了内置监控功能后就可以使用了。
2.4Druid-Starter

整合Druid到SpringBoot的方式有两种：自定义方式和引入starter。
2.3中的所有例子中我们使用的是自己引入druid+配置类方式整合druid和监控。此外，还可以引入Druid Srping Boot Starter，让程序员在SpringBoot项目中更加轻松集成Druid和监控。

演示使用Druid-Starter（演示之前，删除之前所有的自定义方式操作）

（1）pom.xml引入druid-spring-boot-starter

1. <dependency>
2.     <groupId>com.alibaba</groupId>
3.     <artifactId>druid-spring-boot-starter</artifactId>
4.     <version>1.1.17</version>
5. </dependency>

复制代码

（2）在application.yml文件中配置druid和监控功能

1. spring:
2.   datasource: #配置数据源
3.     #如果没有配置useSSL=true，启动项目会报红警告，但不影响使用
4.     url: jdbc:mysql://localhost:3306/spring_boot?useSSL=true&useUnicode=true&characterEncoding=UTF-8
5.     username: root
6.     password: 123456
7.     driver-class-name: com.mysql.jdbc.Driver
8.     #配置druid和监控功能
9.     druid:
10.       stat-view-servlet: #(1)开启监控页
11.         enabled: true
12.         login-username: jack
13.         login-password: 1234
14.         reset-enable: false
15.       web-stat-filter: #(2)启用web监控功能
16.         enabled: true
17.         url-pattern: /*
18.         exclusions: "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*"
19.       filter:
20.         stat: #(3)启用sql监控功能
21.           slow-sql-millis: 1000 #单位ms
22.           log-slow-sql: true #启用慢查询的sql日志
23.           enabled: true
24.         wall: #(4)启用sql防火墙功能
25.           enabled: true
26.           config:
27.             drop-table-allow: false #是否允许进行删除表的操作
28.             select-all-column-allow: false #是否允许查询所有字段的操作

复制代码

3.练习

将异常处理、注入Servlet、Filter、Listener，Tomcat切换，数据库操作（HikariDataSource&DruidDataSource）相关代码和案例写一遍

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！