SpringBoot源码学习之路（十三、数据访问（JDBC、DataSource））

朱雀 2022-05-19 10:37 187阅读 0赞

# SpringBoot的数据访问 #

\#\#一、JDBC的使用

<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-jdbc</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>mysql</groupId>
    			<artifactId>mysql-connector-java</artifactId>
    			<scope>runtime</scope>
    		</dependency>

spring:
      datasource:
        username: root
        password: 123456
        url: jdbc:mysql://127.0.0.1:3306/jdbc
        driver-class-name: com.mysql.jdbc.Driver

**效果：**  
当没有在配置中指定数据源。默认是用org.apache.tomcat.jdbc.pool.DataSource作为数据源；数据源的相关配置都在`DataSourceProperties.class`里面；

**SpringBoot对数据访问的自动配置分析：**  
自动配置依赖jar下的：`org.springframework.boot.autoconfigure.jdbc包`

\*\*1、\*\*参考`DataSourceConfiguration.class`，根据配置创建数据源，默认使用Tomcat连接池；可以使用`spring.datasource.type`指定自定义的数据源类型；

\*\*2、\*\*SpringBoot默认还可以支持下列数据源：

DataSource   、   HikariDataSource      、BasicDataSource、

\*\*3、\*\*自定义配置数据源的源码分析：

/** * Generic DataSource configuration. */
    @ConditionalOnMissingBean(DataSource.class)
    @ConditionalOnProperty(name = "spring.datasource.type")
    static class Generic { 
    
       @Bean
       public DataSource dataSource(DataSourceProperties properties) { 
           //使用DataSourceBuilder创建数据源，利用反射创建响应type的数据源，并且绑定相关属性
          return properties.initializeDataSourceBuilder().build();
       }
    
    }

**4**、**DataSourceInitializer（ApplicationListener的实现类，所以其本质是监听器）**；

作用：

1）、`runSchemaScripts()`;运行建表语句；

2）、`runDataScripts()`;运行插入数据的sql语句；

默认只需要将文件命名为(默认规则)：`schema.sql`，`schema-all.sql`,应用在启动的时候就会去执行sql脚本。  
如果你的sql脚本不是按照上面命名，，然而又想让应用启动时能执行，可以用如下方式指定`schema`,其是数组，既可以一次指定多个文件,需要如下配置：

schema:
          - classpath:department.sql

![这里写图片描述][70]

\*\*Tip:\*\*如果不需要执行的时候需要移除sql文件，否则每次重启都会重新创建表格。

\*\*5、\*\*操作数据库：因为SpringBoot已经自动配置了JdbcTemplate，所以直接从容器中就可以拿出使用了  
实例如下:

@Controller
    public class HelloController { 
    
        @Autowired
        JdbcTemplate jdbcTemplate;
    
        @ResponseBody
        @GetMapping("/query")
        public Map<String,Object> map(){ 
            List<Map<String, Object>> list = jdbcTemplate.queryForList("select * FROM department");
            return list.get(0);
        }
    }

--------------------

## 二、整合Druid数据源 ##

**1、依赖：**

<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>druid</artifactId>
    			<version>1.1.8</version>
    		</dependency>

**2、配置文件：**

spring:
      datasource:
        username: root
        password: 123456
        url: jdbc:mysql://127.0.0.1:3306/jdbc
        driver-class-name: com.mysql.jdbc.Driver
        type: com.alibaba.druid.pool.DruidDataSource
    
        initialSize: 5
        minIdle: 5
        maxActive: 20
        maxWait: 60000
        timeBetweenEvictionRunsMillis: 60000
        minEvictableIdleTimeMillis: 300000
        validationQuery: SELECT 1 FROM DUAL
        testWhileIdle: true
        testOnBorrow: false
        testOnReturn: false
        poolPreparedStatements: true
    #   配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
        filters: stat,wall,log4j
        maxPoolPreparedStatementPerConnectionSize: 20
        useGlobalDataSourceStat: true
        connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=500

**3、导入druid数据源配置。**  
默认情况如果只在配置文件中配置druid连接池的各种属性【initialSize、minIdle、maxActive等】，是无法生效的，  
因为自动配置类【Properties】内并没有那些属性，所以必须自己在容器中添加数据源,让druid的配置生效。

@Configuration
    public class DruidConfig { 
    
        @ConfigurationProperties(prefix = "spring.datasource")
        @Bean
        public DataSource druid(){ 
           return  new DruidDataSource();
        }
    
    }

**4、配置Druid的监控(分两步：①、配置一个管理后台的Servlet；②、配置一个web监控的filter。)**

application.yml

#   配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
            filters: stat,wall,log4j

DruidConfig .java

@Configuration
    public class DruidConfig { 
    
        //配置Druid的监控
        //1、配置一个管理后台的Servlet
        @Bean
        public ServletRegistrationBean statViewServlet(){ 
            ServletRegistrationBean bean = new ServletRegistrationBean(new StatViewServlet(), "/druid/*");
            Map<String,String> initParams = new HashMap<>();
    
            initParams.put("loginUsername","admin");
            initParams.put("loginPassword","123456");
            initParams.put("allow","");//默认就是允许所有访问
            initParams.put("deny","192.168.15.21");
    
            bean.setInitParameters(initParams);
            return bean;
        }
    
        //2、配置一个web监控的filter
        @Bean
        public FilterRegistrationBean webStatFilter(){ 
            FilterRegistrationBean bean = new FilterRegistrationBean(new WebStatFilter());
           
    
            Map<String,String> initParams = new HashMap<>();
            //配置拦截的路径
            initParams.put("exclusions","*.js,*.css,/druid/*");
            bean.setInitParameters(initParams);
            bean.setUrlPatterns(Arrays.asList("/*"));
            return  bean;
        }
    }

配置完只要请求`/druid`，使用指定的用户名密码即可使用。

具体项目参考：【Git\\repository\\SpringBoot\\prooject\\com.atguigu\\spring-boot-06-data-jdbc】

[70]: /images/20220519/f870ac1919684c83aeceb1f6322efd75.png