Spring boot+JPA+Druid

Posted 二刀

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Spring boot+JPA+Druid相关的知识，希望对你有一定的参考价值。

pom.xml
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. 	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4. 	<modelVersion>4.0.0</modelVersion>
  6. 	<groupId>com.yginsight</groupId>
  7. 	<artifactId>pm_admin</artifactId>
  8. 	<version>0.0.1-SNAPSHOT</version>
  9. 	<packaging>jar</packaging>
  11. 	<name>pm_admin</name>
  12. 	<description>Power Manager Admin</description>
  14. 	<parent>
  15. 		<groupId>org.springframework.boot</groupId>
  16. 		<artifactId>spring-boot-starter-parent</artifactId>
  17. 		<version>1.5.2.RELEASE</version>
  18. 		<relativePath/> <!-- lookup parent from repository -->
  19. 	</parent>
  21. 	<properties>
  22. 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  23. 		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  24. 		<java.version>1.8</java.version>
  25. 	</properties>
  27. 	<dependencies>
  28. 		<dependency>
  29. 			<groupId>org.springframework.boot</groupId>
  30. 			<artifactId>spring-boot-starter-web</artifactId>
  31. 		</dependency>
  33. 		<dependency>
  34. 			<groupId>org.springframework.boot</groupId>
  35. 			<artifactId>spring-boot-starter-test</artifactId>
  36. 			<scope>test</scope>
  37. 		</dependency>
  38. 		<dependency>
  39. 			<groupId>com.alibaba</groupId>
  40. 			<artifactId>druid</artifactId>
  41. 			<version>1.0.26</version>
  42. 		</dependency>
  43. 		<dependency>
  44. 			<groupId>org.springframework.boot</groupId>
  45. 			<artifactId>spring-boot-configuration-processor</artifactId>
  46. 			<optional>true</optional>
  47. 		</dependency>
  48. 		<dependency>
  49. 			<groupId>org.springframework.boot</groupId>
  50. 			<artifactId>spring-boot-starter-data-jpa</artifactId>
  51. 		</dependency>
  52. 		<!-- postgresql连接 -->
  53. 		<dependency>
  54. 			<groupId>org.postgresql</groupId>
  55. 			<artifactId>postgresql</artifactId>
  56. 			<version>9.4-1201-jdbc41</version>
  57. 		</dependency>
  58. 		<!-- Springboot 热部署 -->
  59. 		<dependency>
  60. 			<groupId>org.springframework.boot</groupId>
  61. 			<artifactId>spring-boot-devtools</artifactId>
  62. 			<optional>true</optional>
  63. 		</dependency>
  65. 	</dependencies>
  67. 	<build>
  68. 		<plugins>
  69. 			<plugin>
  70. 				<groupId>org.springframework.boot</groupId>
  71. 				<artifactId>spring-boot-maven-plugin</artifactId>
  72. 			</plugin>
  73. 		</plugins>
  74. 	</build>
  77. </project>
application.properties
  2. # 数据库访问配置
  3. # 主数据源，默认的
  4. #spring.datasource.druid.type=com.alibaba.druid.pool.DruidDataSource
  5. spring.datasource.druid.driver-class-name=org.postgresql.Driver
  6. spring.datasource.druid.url=jdbc:postgresql://127.0.0.1/powermanager
  7. spring.datasource.druid.username=postgres
  8. spring.datasource.druid.password=root
  11. # 下面为连接池的补充设置，应用到上面所有数据源中
  12. # 初始化大小，最小，最大
  13. spring.datasource.druid.initial-size=5
  14. spring.datasource.druid.minIdle=5
  15. spring.datasource.druid.maxActive=20
  16. # 配置获取连接等待超时的时间
  17. spring.datasource.druid.maxWait=60000
  18. # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
  19. spring.datasource.druid.timeBetweenEvictionRunsMillis=60000
  20. # 配置一个连接在池中最小生存的时间，单位是毫秒
  21. spring.datasource.druid.minEvictableIdleTimeMillis=300000
  22. spring.datasource.druid.validationQuery=SELECT 1 FROM DUAL
  23. spring.datasource.druid.testWhileIdle=true
  24. spring.datasource.druid.testOnBorrow=false
  25. spring.datasource.druid.testOnReturn=false
  26. # 打开PSCache，并且指定每个连接上PSCache的大小
  27. spring.datasource.druid.poolPreparedStatements=true
  28. spring.datasource.druid.maxPoolPreparedStatementPerConnectionSize=20
  29. # 配置监控统计拦截的filters，去掉后监控界面sql无法统计，‘wall‘用于防火墙
  30. spring.datasource.druid.filters=stat,wall,log4j
  31. # 通过connectProperties属性来打开mergeSql功能；慢SQL记录
  32. spring.datasource.druid.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
  33. # 合并多个DruidDataSource的监控数据
  34. #spring.datasource.druid.useGlobalDataSourceStat=true

由于上述配置文件中，Spring.datasource.druid无法被识别，需要自行增加配置项
增加两个配置相关类
  1. package com.yginsight.druid;
  3. import com.alibaba.druid.pool.DruidDataSource;
  4. import com.alibaba.druid.support.http.StatViewServlet;
  5. import com.alibaba.druid.support.http.WebStatFilter;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
  8. import org.springframework.boot.context.properties.EnableConfigurationProperties;
  9. import org.springframework.boot.web.servlet.FilterRegistrationBean;
  10. import org.springframework.boot.web.servlet.ServletRegistrationBean;
  11. import org.springframework.context.annotation.Bean;
  12. import org.springframework.context.annotation.Configuration;
  14. import javax.sql.DataSource;
  15. import java.sql.SQLException;
  17. /**
  18.  * Created by dingshuo on 2017/4/13.
  19.  */
  20. @Configuration
  21. @EnableConfigurationProperties({DruidDataSourceProperties.class})
  22. public class DruidConfiguration {
  23.     @Autowired
  24.     private DruidDataSourceProperties properties;
  26.     @Bean
  27.     @ConditionalOnMissingBean
  28.     public DataSource druidDataSource() {
  29.         DruidDataSource druidDataSource = new DruidDataSource();
  30.         druidDataSource.setDriverClassName(properties.getDriverClassName());
  31.         druidDataSource.setUrl(properties.getUrl());
  32.         druidDataSource.setUsername(properties.getUsername());
  33.         druidDataSource.setPassword(properties.getPassword());
  34.         druidDataSource.setInitialSize(properties.getInitialSize());
  35.         druidDataSource.setMinIdle(properties.getMinIdle());
  36.         druidDataSource.setMaxActive(properties.getMaxActive());
  37.         druidDataSource.setMaxWait(properties.getMaxWait());
  38.         druidDataSource.setTimeBetweenEvictionRunsMillis(properties.getTimeBetweenEvictionRunsMillis());
  39.         druidDataSource.setMinEvictableIdleTimeMillis(properties.getMinEvictableIdleTimeMillis());
  40.         druidDataSource.setValidationQuery(properties.getValidationQuery());
  41.         druidDataSource.setTestWhileIdle(properties.isTestWhileIdle());
  42.         druidDataSource.setTestOnBorrow(properties.isTestOnBorrow());
  43.         druidDataSource.setTestOnReturn(properties.isTestOnReturn());
  44.         druidDataSource.setPoolPreparedStatements(properties.isPoolPreparedStatements());
  45.         druidDataSource.setMaxPoolPreparedStatementPerConnectionSize(properties.getMaxPoolPreparedStatementPerConnectionSize());
  46.         druidDataSource.setConnectionProperties(properties.getConnectionProperties());
  47.         try {
  48.             druidDataSource.setFilters(properties.getFilters());
  49.             druidDataSource.init();
  50.         } catch (SQLException e) {
  51.             e.printStackTrace();
  52.         }
  54.         return druidDataSource;
  55.     }
  57.     @Bean
  58.     @ConditionalOnMissingBean
  59.     public ServletRegistrationBean druidServlet() {
  61.         ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new StatViewServlet(), "/druid/*");
  63.         //添加初始化参数：initParams
  65.         //白名单：
  66.         //servletRegistrationBean.addInitParameter("allow","127.0.0.1");
  67.         //IP黑名单 (存在共同时，deny优先于allow) : 如果满足deny的话提示:Sorry, you are not permitted to view this page.
  68.         //servletRegistrationBean.addInitParameter("deny","192.168.1.73");
  69.         //登录查看信息的账号密码.
  70.         servletRegistrationBean.addInitParameter("loginUsername", "admin");
  71.         servletRegistrationBean.addInitParameter("loginPassword", "admin");
  72.         //是否能够重置数据.
  73.         servletRegistrationBean.addInitParameter("resetEnable", "true");
  74.         return servletRegistrationBean;
  76.     }
  78.     @Bean
  79.     @ConditionalOnMissingBean
  80.     public FilterRegistrationBean filterRegistrationBean() {
  81.         FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean();
  82.         filterRegistrationBean.setFilter(new WebStatFilter());
  83.         filterRegistrationBean.addUrlPatterns("/*");
  84.         filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");
  85.         return filterRegistrationBean;
  86.     }
  87. }
  1. package com.yginsight.druid;
  2. import org.springframework.boot.context.properties.ConfigurationProperties;
  3. /**
  4.  * Created by dingshuo on 2017/4/13.
  5.  */
  6. @ConfigurationProperties(prefix = "spring.datasource.druid")
  7. public class DruidDataSourceProperties {
  8.     private String driverClassName;
  9.     private String url;
  10.     private String username;
  11.     private String password;
  13.     private int initialSize;
  14.     private int minIdle;
  15.     private int maxActive;
  16.     private long maxWait;
  17.     private long timeBetweenEvictionRunsMillis;
  18.     private long minEvictableIdleTimeMillis;
  19.     private String validationQuery;
  20.     private boolean testWhileIdle;
  21.     private boolean testOnBorrow;
  22.     private boolean testOnReturn;
  23.     private boolean poolPreparedStatements;
  24.     private int maxPoolPreparedStatementPerConnectionSize;
  25.     private String filters;
  26.     private String connectionProperties;
  28.     public int getInitialSize() {
  29.         return initialSize;
  30.     }
  32.     public void setInitialSize(int initialSize) {
  33.         this.initialSize = initialSize;
  34.     }
  36.     public int getMinIdle() {
  37.         return minIdle;
  38.     }
  40.     public void setMinIdle(int minIdle) {
  41.         this.minIdle = minIdle;
  42.     }
  44.     public int getMaxActive() {
  45.         return maxActive;
  46.     }
  48.     public void setMaxActive(int maxActive) {
  49.         this.maxActive = maxActive;
  50.     }
  52.     public long getMaxWait() {
  53.         return maxWait;
  54.     }
  56.     public void setMaxWait(long maxWait) {
  57.         this.maxWait = maxWait;
  58.     }
  60.     public long getTimeBetweenEvictionRunsMillis() {
  61.         return timeBetweenEvictionRunsMillis;
  62.     }
  64.     public void setTimeBetweenEvictionRunsMillis(long timeBetweenEvictionRunsMillis) {
  65.         this.timeBetweenEvictionRunsMillis = timeBetweenEvictionRunsMillis;
  66.     }
  68.     public long getMinEvictableIdleTimeMillis() {
  69.         return minEvictableIdleTimeMillis;
  70.     }
  72.     public void setMinEvictableIdleTimeMillis(long minEvictableIdleTimeMillis) {
  73.         this.minEvictableIdleTimeMillis = minEvictableIdleTimeMillis;
  74.     }
  76.     public String getValidationQuery() {
  77.         return validationQuery;
  78.     }
  80.     public void setValidationQuery(String validationQuery) {
  81.         this.validationQuery = validationQuery;
  82.     }
  84.     public boolean isTestWhileIdle() {
  85.         return testWhileIdle;
  86.     }
  88.     public void setTestWhileIdle(boolean testWhileIdle) {
  89.         this.testWhileIdle = testWhileIdle;
  90.     }
  92.     public boolean isTestOnBorrow() {
  93.         return testOnBorrow;
  94.     }
  96.     public void setTestOnBorrow(boolean testOnBorrow) {
  97.         this.testOnBorrow = testOnBorrow;
  98.     }
  100.     public boolean isTestOnReturn() {
  101.         return testOnReturn;
  102.     }
  104.     public void setTestOnReturn(boolean testOnReturn) {
  105.         this.testOnReturn = testOnReturn;
  106.     }
  108.     public boolean isPoolPreparedStatements() {
  109.         return poolPreparedStatements;
  110.     }
  112.     public void setPoolPreparedStatements(boolean poolPreparedStatements) {
  113.         this.poolPreparedStatements = poolPreparedStatements;
  114.     }
  116.     public int getMaxPoolPreparedStatementPerConnectionSize() {
  117.         return maxPoolPreparedStatementPerConnectionSize;
  118.     }
  120.     public void setMaxPoolPreparedStatementPerConnectionSize(int maxPoolPreparedStatementPerConnectionSize) {
  121.         this.maxPoolPreparedStatementPerConnectionSize = maxPoolPreparedStatementPerConnectionSize;
  122.     }
  124.     public String getFilters() {
  125.         return filters;
  126.     }
  128.     public void setFilters(String filters) {
  129.         this.filters = filters;
  130.     }
  132.     public String getConnectionProperties() {
  133.         return connectionProperties;
  134.     }
  136.     public void setConnectionProperties(String connectionProperties) {
  137.         this.connectionProperties = connectionProperties;
  138.     }
  140.     public String getDriverClassName() {
  141.         return driverClassName;
  142.     }
  144.     public void setDriverClassName(String driverClassName) {
  145.         this.driverClassName = driverClassName;
  146.     }
  148.     public String getUrl() {
  149.         return url;
  150.     }
  152.     public void setUrl(String url) {
  153.         this.url = url;
  154.     }
  156.     public String getUsername() {
  157.         return username;
  158.     }
  160.     public void setUsername(String username) {
  161.         this.username = username;
  162.     }
  164.     public String getPassword() {
  165.         return password;
  166.     }
  168.     public void setPassword(String password) {
  169.         this.password = password;
  170.     }
  171. }




以上是关于Spring boot+JPA+Druid的主要内容，如果未能解决你的问题，请参考以下文章

Spring Boot + Jpa(Hibernate) 架构基本配置

带有分页和排序的 Spring Boot JPA 规范 API

06.深入浅出 Spring Boot - 数据访问之Druid

spring boot 集成Druid

Springboot整合druid

Spring Boot 集成 Druid 批量插入数据和效率监控配置