javakafka连接池_SpringBoot集成Druid数据库连接池1. 前⾔
通过本⽂，我们可以看到
Spring Boot 如何配置数据源
Spring Boot 如何集成Druid数据库连接池
如何打开并访问Druid数据库连接池的监控功能
Spring Boot 使⽤JdbcTemplate操作数据库
2. 配置l
org.springframework.boot
spring-boot-starter-parent
1.3.5.RELEASE
UTF-8
UTF-8
1.8
org.springframework.boot
spring-boot-starter-web
org.springframework.boot
spring-boot-starter-jdbc
com.alibaba
druid
1.0.20
org.postgresql
postgresql
runtime
3. 在application.properties中配置数据源
# 数据库访问配置，此处使⽤postgres为例。
# 主数据源，默认的
pe=com.alibaba.druid.pool.DruidDataSource
spring.datasource.driver-class-name=org.postgresql.Driver
spring.datasource.url=jdbc:postgresql://192.168.1.9/jianshudb
spring.datasource.username=postgres
spring.datasource.password=yourpassword
# 下⾯为连接池的补充设置，应⽤到上⾯所有数据源中
# 初始化⼤⼩，最⼩，最⼤
spring.datasource.initialSize=5
spring.datasource.minIdle=5
spring.datasource.maxActive=20
# 配置获取连接等待超时的时间
spring.datasource.maxWait=60000
# 配置间隔多久才进⾏⼀次检测，检测需要关闭的空闲连接，单位是毫秒
spring.datasource.timeBetweenEvictionRunsMillis=60000
# 配置⼀个连接在池中最⼩⽣存的时间，单位是毫秒
spring.datasource.minEvictableIdleTimeMillis=300000
# Oracle请使⽤select 1 from dual
spring.datasource.validationQuery=SELECT 'x'
stWhileIdle=true
stOnBorrow=false
stOnReturn=false
# 打开PSCache，并且指定每个连接上PSCache的⼤⼩
spring.datasource.poolPreparedStatements=true
spring.datasource.maxPoolPreparedStatementPerConnectionSize=20
# 配置监控统计拦截的filters，去掉后监控界⾯sql⽆法统计，'wall'⽤于防⽕墙
spring.datasource.filters=stat,wall,slf4j
# 通过connectProperties属性来打开mergeSql功能；慢SQL记录
#tionProperties=Sql=true;druid.stat.slowSqlMillis=5000
# 合并多个DruidDataSource的监控数据
#spring.datasource.useGlobalDataSourceStat=true
4. 打开Druid的监控统计功能
Druid的监控统计功能是通过filter-chain扩展实现，如果你要打开监控统计功能，需要配置StatFilter，相关代码如下。@Configuration
public class DruidConfiguration {
private static final Logger log = Logger(DruidConfiguration.class);
@Bean
public ServletRegistrationBean druidServlet() {
log.info("init Druid Servlet Configuration ");
ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(); servletRegistrationBean.setServlet(new StatViewServlet());
servletRegistrationBean.addUrlMappings("/druid/*");
Map initParameters = new HashMap();
initParameters.put("loginUsername", "admin");// ⽤户名
initParameters.put("loginPassword", "admin");// 密码
initParameters.put("resetEnable", "false");// 禁⽤HTML页⾯上的“Reset All”功能
initParameters.put("allow", ""); // IP⽩名单 (没有配置或者为空，则允许所有访问)
//initParameters.put("deny", "192.168.20.38");// IP⿊名单 (存在共同时，deny优先于allow) servletRegistrationBean.setInitParameters(initParameters);
return servletRegistrationBean;
}
@Bean
public FilterRegistrationBean filterRegistrationBean() {
FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean();
filterRegistrationBean.setFilter(new WebStatFilter());
filterRegistrationBean.addUrlPatterns("/*");
filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");
return filterRegistrationBean;
}
}
5. 使⽤JdbcTemplate操作数据库
假设数据库中有表t_user，其中id=1的user的username为ZhangSan。下⾯的例⼦演⽰了通过id查username的情况。@RestController
public class DemoController {
@Autowired
JdbcTemplate jdbcTemplate;
@RequestMapping(value = "/hello.do", method = RequestMethod.GET)
public String hello(@RequestParam(value = "id", required = true) Integer id) {
druid连接池配置详解String name = getNameById(id);
return (name == null) ? "Hello World" : ("Hello " + name);
}
public String getNameById(Integer id) {
String sql = "select username from t_user where id = ? ";
List list = jdbcTemplate.queryForList(sql, new Object[] {id}, String.class);
return list.isEmpty() ? null : (0);
}
}
结果输出：Hello, ZhangSan
以上就是本⽂的全部内容，希望对⼤家的学习有所帮助，也希望⼤家多多⽀持脚本之家。

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。