SpringData

官网

数据库相关的启动器

对于数据访问层，无论是 SQL(关系型数据库) 还是 NOSQL(非关系型数据库)，Spring Boot 底层都是采用 Spring Data 的方式进行统一处理。

Spring Boot 底层都是采用 Spring Data 的方式进行统一处理各种数据库，Spring Data 也是 Spring 中与 Spring Boot、Spring Cloud 等齐名的知名项目。

1. 整合JDBC

1.1. 步骤

1. 导入MySQL驱动和jdbc启动器。

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

2. yml配置文件。

   spring:
     datasource:
       username: root
       password: root
       url: jdbc:mysql://localhost:3306/test?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8
       driver-class-name: com.mysql.cj.jdbc.Driver
   

3. 使用。

   // 注入数据源
   @Autowired
   DataSource dataSource;
   
   dataSource.getClass();
   dataSource.getConnection();
   

在SpringBoot中，默认的数据源为com.zaxxer.hikari.HikariDataSource.

// DataSourceAutoConfiguration
@Import(
    {Hikari.class, Tomcat.class, Dbcp2.class, Generic.class, DataSourceJmxConfiguration.class}
)
protected static class PooledDataSourceConfiguration {
    protected PooledDataSourceConfiguration() {
    }
}

Hikari速度快，Druid提供可视化的监控功能。

可以用spring.datasource.type指定数据源的类型。

1.2. 使用JDBCTemplate

有了数据源并连接数据库后，可以用原生的JDBC语句来操作数据库。即使不使用第三方的数据库操作框架，如Mybatis，Spring本身也提供了原生JDBC的轻量级封装，即JDBCTemplate，将操作的CRUD方法都封装起来。在使用的时候，只需要将JDBCTemplate注入即可使用。

JdbcTemplate主要提供以下几类方法：

• execute方法：可以用于执行任何SQL语句，一般用于执行DDL语句；
• update方法及batchUpdate方法：update方法用于执行新增、修改、删除等语句；batchUpdate方法用于执行批处理相关语句；
• query方法及queryForXXX方法：用于执行查询相关语句；
• call方法：用于执行存储过程、函数相关语句。

String sql = "select * from user";
List<Map<String, Object>> maps = jdbcTemplate.queryForList(sql);

String sql = "insert into test.user(id, name, pwd) values(7,'小明','123456')";
jdbcTemplate.update(sql);

String sql = "update test.user set name  = ?,pwd = ? where id = " + id;
//封装
Object[] objects = new Object[2];
objects[0] = "小明2";
objects[1] = "123123";
jdbcTemplate.update(sql,objects);

String sql = "delete from test.user where id = ?";
jdbcTemplate.update(sql,id)

2. 集成Druid

Duird是阿里巴巴开源平台上的一个数据库连接池的实现。优点是增加了日志监控的功能，可以很好的监控数据库连接池的连接和SQL的执行情况。

druid-spring-boot-starter

com.alibaba.druid.pool.DruidDataSource 基本配置参数如下：

2.1. 步骤

1. 导入依赖。

   <!-- https://mvnrepository.com/artifact/com.alibaba/druid-spring-boot-starter -->
   <dependency>
       <groupId>com.alibaba</groupId>
       <artifactId>druid-spring-boot-starter</artifactId>
       <version>1.2.11</version>
   </dependency>
   <!-- https://mvnrepository.com/artifact/log4j/log4j -->
   <dependency>
       <groupId>log4j</groupId>
       <artifactId>log4j</artifactId>
       <version>1.2.17</version>
   </dependency>
   

2. 配置yml。

   spring:
     datasource:
       username: root
       password: root
       url: jdbc:mysql://localhost:3306/springboot?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8
       driver-class-name: com.mysql.cj.jdbc.Driver
       type: com.alibaba.druid.pool.DruidDataSource
   
       # SpringBoot默认不注入下列属性，需要进行绑定
       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: stat,wall,log4j
       maxPoolPreparedStatementPerConnectionSize: 20
       useGlobalDataSourceStat: true
       connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=500
   

3. 通过Java Config绑定yml文件。

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

4. 之后注入DataSource就可以查看是否生效了。

2.2. Druid监控

@Bean
public ServletRegistrationBean statViewServlet() {
    ServletRegistrationBean bean = new ServletRegistrationBean(new StatViewServlet(), "/druid/*");

    // 这些参数可以在 com.alibaba.druid.support.http.StatViewServlet的父类 com.alibaba.druid.support.http.ResourceServlet 中找到
    Map<String, String> initParams = new HashMap<>();
    initParams.put("loginUsername", "root"); //后台管理界面的登录账号
    initParams.put("loginPassword", "admin"); //后台管理界面的登录密码

    //后台允许谁可以访问
    //initParams.put("allow", "localhost")：表示只有本机可以访问
    //initParams.put("allow", "")：为空或者为null时，表示允许所有访问
    initParams.put("allow", "");
    //deny：Druid 后台拒绝谁访问
    //initParams.put("hacker", "192.168.1.2");表示禁止此ip访问

    //设置初始化参数
    bean.setInitParameters(initParams);
    return bean;
}

随后访问http://<IP>:<PORT>/druid/即可进入监控页面。

配置web监控的filter过滤器。

//WebStatFilter：用于配置Web和Druid数据源之间的管理关联监控统计
@Bean
public FilterRegistrationBean webStatFilter() {
    FilterRegistrationBean bean = new FilterRegistrationBean();
    bean.setFilter(new WebStatFilter());

    //exclusions：设置哪些请求进行过滤排除掉，从而不进行统计
    Map<String, String> initParams = new HashMap<>();
    initParams.put("exclusions", "*.js,*.css,/druid/*,/jdbc/*");
    bean.setInitParameters(initParams);

    //"/*" 表示过滤所有请求
    bean.setUrlPatterns(Arrays.asList("/*"));
    return bean;
}