本文主要讲解如何在springboot下整合druid数据源。
本教程在Demo04基础上添加druid数据源配置信息
添加依赖
引入 druid
依赖:
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.10</version>
</dependency>
配置
在 application.yml
配置文件中添加 Druid 相关配置:
# DataSource Config
spring:
datasource:
########################## druid配置 ##########################
type: com.alibaba.druid.pool.DruidDataSource
# 初始化大小,最小,最大
initialSize: 5
minIdle: 5
maxActive: 20
# 配置获取连接等待超时的时间
maxWait: 60000
# 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒
timeBetweenEvictionRunsMillis: 60000
# 配置一个连接在池中最小生存的时间,单位是毫秒
minEvictableIdleTimeMillis: 300000
# 校验SQL,Oracle配置 validationQuery: SELECT 1 FROM DUAL,如果不配validationQuery项,则下面三项配置无用
validationQuery: SELECT 'x'
testWhileIdle: true
testOnBorrow: false
testOnReturn: false
# 打开PSCache,并且指定每个连接上PSCache的大小
poolPreparedStatements: true
maxPoolPreparedStatementPerConnectionSize: 20
# 配置监控统计拦截的filters,去掉后监控界面sql无法统计,'wall'用于防火墙
filters: stat,wall
# 通过connectProperties属性来打开mergeSql功能;慢SQL记录
connectionProperties:
druid.stat.mergeSql: true
druid.stat.slowSqlMillis: 5000
# 合并多个DruidDataSource的监控数据
useGlobalDataSourceStat: true
DruidConfig 配置
然后在项目中加入 DruidConfig 配置类
src/main/java/com/heardfate/springboot/demo/demo04/config/DruidConfig.java
package com.heardfate.springboot.demo.demo04.config;
import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.support.http.StatViewServlet;
import com.alibaba.druid.support.http.WebStatFilter;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.sql.DataSource;
/**
* @since: 2018/10/25
* @author: Mr.HeardFate
*/
@Configuration
public class DruidConfig {
/**
* 主要实现WEB监控的配置处理
* @return
*/
@Bean
public ServletRegistrationBean druidServlet() {
// 现在要进行druid监控的配置处理操作
ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new StatViewServlet(), "/druid/*");
// 白名单
//servletRegistrationBean.addInitParameter("allow", "127.0.0.1,192.168.1.159");
// 黑名单
// servletRegistrationBean.addInitParameter("deny", "192.168.1.200");
// 用户名
servletRegistrationBean.addInitParameter("loginUsername", "user");
// 密码
servletRegistrationBean.addInitParameter("loginPassword", "test");
// 是否可以重置数据源
servletRegistrationBean.addInitParameter("resetEnable", "false");
return servletRegistrationBean ;
}
@Bean
public FilterRegistrationBean filterRegistrationBean() {
FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean();
filterRegistrationBean.setFilter(new WebStatFilter());
// 所有请求进行监控处理
filterRegistrationBean.addUrlPatterns("/*");
filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.css,/druid/*");
return filterRegistrationBean;
}
@Bean
@ConfigurationProperties(prefix = "spring.datasource")
public DataSource druidDataSource() {
return new DruidDataSource();
}
}
UserController
接着添加 UserController 控制器
src/main/java/com/heardfate/springboot/demo/demo04/controller/UserController.java
package com.heardfate.springboot.demo.demo04.controller;
import com.heardfate.springboot.demo.demo04.entity.User;
import com.heardfate.springboot.demo.demo04.service.IUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
* 前端控制器
* @author Heardfate
* @since 2018-10-23
*/
@RestController
@RequestMapping("/demo04/user")
public class UserController {
@Autowired
private IUserService userService;
@RequestMapping(value = "/", method = RequestMethod.POST, produces = "application/json")
public Long saveUser(@RequestBody User user) {
System.out.println(user);
userService.save(user);
return user.getId();
}
@RequestMapping(value = "/{id}", method = RequestMethod.DELETE, produces = "application/json")
public Boolean deleteUser(@PathVariable Long id) {
return userService.removeById(id);
}
@RequestMapping(value = "/{id}", method = RequestMethod.PUT, produces = "application/json")
public User updateUser(@PathVariable Long id, @RequestBody User user) {
user.setId(id);
userService.updateById(user);
return userService.getById(id);
}
@RequestMapping(value = "/{id}", method = RequestMethod.GET, produces = "application/json")
public User getUser(@PathVariable Long id) {
User user = userService.getById(id);
return user;
}
@RequestMapping(value = "/", method = RequestMethod.GET, produces = "application/json")
public List getUserList() {
return userService.list(null);
}
}
Druid 后台
欢迎来到这里!
我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。
注册 关于