1. Python技术站首页
  2. 其他
  3. Java

SpringBoot整合Druid数据源的方法实现

• Java
yizhihongxing

SpringBoot整合Druid数据源的方法实现，可以分为以下几个步骤：

步骤一：添加Druid和jdbc依赖

在pom.xml文件中，添加以下两个依赖

<!--Druid数据库连接池-->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.1.21</version>
</dependency>

<!--jdbc驱动-->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>5.1.41</version>
</dependency>

步骤二：配置Druid数据源

在application.properties/yml文件中添加以下配置项

spring.datasource.url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource

#Druid配置
#监控地址
spring.datasource.druid.stat-view-servlet.allow=true
spring.datasource.druid.stat-view-servlet.url-pattern=/druid/*
#用户名和密码
spring.datasource.druid.stat-view-servlet.login-username=admin
spring.datasource.druid.stat-view-servlet.login-password=admin
#IP白名单（没有配置或者为空，则允许所有访问）
spring.datasource.druid.stat-view-servlet.reset-enable=false
spring.datasource.druid.stat-view-servlet.allow=127.0.0.1
#IP黑名单（存在共同时，deny优先于allow）
spring.datasource.druid.stat-view-servlet.deny=192.168.1.73

步骤三：创建数据库连接池

在代码中，通过注解@Configuration创建数据源对象，并注入到spring容器中

@Configuration
public class DruidDBConfig {
    @Value("${spring.datasource.url}")
    private String dbUrl;

    @Value("${spring.datasource.username}")
    private String username;

    @Value("${spring.datasource.password}")
    private String password;

    @Value("${spring.datasource.driver-class-name}")
    private String driverClassName;

    @Bean
    public DataSource dataSource() {
        DruidDataSource datasource = new DruidDataSource();
        datasource.setUrl(this.dbUrl);
        datasource.setUsername(username);
        datasource.setPassword(password);
        datasource.setDriverClassName(driverClassName);

        //configuration
        datasource.setInitialSize(10);
        datasource.setMinIdle(10);
        datasource.setMaxActive(50);
        datasource.setMaxWait(60000);
        datasource.setTimeBetweenEvictionRunsMillis(60000);
        datasource.setValidationQuery("SELECT 1 FROM DUAL");
        datasource.setTestWhileIdle(true);
        datasource.setTestOnBorrow(false);
        datasource.setTestOnReturn(false);
        datasource.setPoolPreparedStatements(true);
        datasource.setMaxPoolPreparedStatementPerConnectionSize(50);
        try {
            datasource.setFilters("stat,wall,slf4j");
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return datasource;
    }
}

步骤四：测试连接

在代码中，创建一个测试Controller，测试是否能成功连接。

@RestController
public class HelloController {
    @Autowired
    private DataSource dataSource;

    @RequestMapping("/hello")
    String index() {
        try {
            Connection connection = dataSource.getConnection();
            return "Hello Spring Boot and Druid!" + connection.getMetaData().getDatabaseProductName();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return "Hello Spring Boot and Druid!";
    }
}

测试连接，访问url：http://localhost:8080/hello

如果连接成功，则会显示以下内容：

Hello Spring Boot and Druid!MySQL

示例一：

以下是一个完整的SpringBoot整合Druid数据源实现的示例，供参考：

pom.xml文件

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-jdbc</artifactId>
    </dependency>
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid</artifactId>
        <version>1.1.21</version>
    </dependency>
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>5.1.41</version>
    </dependency>
</dependencies>

application.yml文件

spring:
  datasource:
    url: jdbc:mysql://localhost:3306/springboot?useUnicode=true&characterEncoding=utf-8
    username: root
    password: 123456
    driver-class-name: com.mysql.jdbc.Driver
    type: com.alibaba.druid.pool.DruidDataSource

# Druid配置
spring.datasource.druid.initialSize=5
spring.datasource.druid.minIdle=5
spring.datasource.druid.maxActive=20
spring.datasource.druid.maxWait=60000
spring.datasource.druid.timeBetweenEvictionRunsMillis=60000
spring.datasource.druid.minEvictableIdleTimeMillis=30000
spring.datasource.druid.validationQuery=SELECT 1 FROM DUAL
spring.datasource.druid.testWhileIdle=true
spring.datasource.druid.testOnBorrow=false
spring.datasource.druid.testOnReturn=false
spring.datasource.druid.poolPreparedStatements=true
spring.datasource.druid.maxPoolPreparedStatementPerConnectionSize=20
spring.datasource.druid.filters=stat,wall

spring.mvc.view.prefix=/templates/
spring.mvc.view.suffix=.html

连接测试Controller

@RestController
public class HelloController {

    @Autowired
    private DataSource dataSource;

    @RequestMapping("/hello")
    public String index() throws SQLException {
        Connection connection = dataSource.getConnection();
        DatabaseMetaData metaData = connection.getMetaData();
        String productName = metaData.getDatabaseProductName();
        String productVersion = metaData.getDatabaseProductVersion();
        return "Hello Spring Boot and Druid!数据库类型: "+productName+",版本: "+productVersion;
    }
}

此示例中，当请求url：http://localhost:8080/hello时，会返回以下内容：

Hello Spring Boot and Druid!数据库类型: MySQL,版本: 5.6.39

示例二：

以下是一个完整的SpringBoot整合Druid数据源实现的示例，供参考：

pom.xml文件中添加以下依赖

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
        <version>2.2.4.RELEASE</version>
    </dependency>
    <!-- 集成 druid -->
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid-spring-boot-starter</artifactId>
        <version>1.1.21</version>
    </dependency>
    <dependency><!-- mysql驱动 -->
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>5.1.44</version>
    </dependency>

</dependencies>

application.yml文件

spring.datasource.username=root
spring.datasource.password=root
spring.datasource.url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimeZone=Asia/Shanghai

spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource

# Druid监控页面
spring.datasource.druid.stat.enable=true
# Druid连接池监控
spring.datasource.druid.filters=stat,wall,log4j2
spring.datasource.druid.stat-view-servlet.login-username=admin
spring.datasource.druid.stat-view-servlet.login-password=admin
server.servlet.context-path=/druid

Druid数据源配置类

@Configuration
public class DataSourceConfig {

    @Bean
    @Primary
    @ConfigurationProperties("spring.datasource")
    public DataSource druidDataSource(){
        DruidDataSource druidDataSource = new DruidDataSource();
        return druidDataSource;
    }

    @Bean
    public ServletRegistrationBean statViewServlet(){
        ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new StatViewServlet(), "/druid/*");
        servletRegistrationBean.addInitParameter("loginUsername", "admin");
        servletRegistrationBean.addInitParameter("loginPassword", "admin");
        servletRegistrationBean.addInitParameter("resetEnable","false");
        return servletRegistrationBean;
    }

    @Bean
    public FilterRegistrationBean webStatFilter(){
        FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean(new WebStatFilter());
        filterRegistrationBean.addUrlPatterns("/*");//添加过滤规则
        filterRegistrationBean.addInitParameter("exclusions","*.jpg,*.png,*.gif,*.ico,/druid/*");//过滤掉静态资源请求和Druid的请求
        return filterRegistrationBean;
    }

}

测试Controller

@RestController
@RequestMapping("/druid")
public class TestController {

    private static final String[] USER_NAMES = {"user1", "user2", "user3", "user4"};

    private static final String[] AGES = {"22", "23", "24", "25", "26", "27", "28"};

    @Autowired
    private DataSource dataSource;

    private Random random = new Random(System.currentTimeMillis());

    @RequestMapping("/insertUser")
    public String index() {
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        int row = 0;
        String sql = "INSERT INTO user(name, age) VALUES (?, ?)";
        try {
            connection = dataSource.getConnection();
            preparedStatement = connection.prepareStatement(sql);
            preparedStatement.setString(1, USER_NAMES[random.nextInt(USER_NAMES.length)]);
            preparedStatement.setInt(2, Integer.valueOf(AGES[random.nextInt(AGES.length)]));
            row = preparedStatement.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return "成功插入[" + row + "]条用户数据";
    }


}

此示例中，当请求url：http://localhost:8080/druid/insertUser时，会返回以下内容：

成功插入[1]条用户数据

并且，访问http://localhost:8080/druid，可以进入Druid监控页面，查看连接池的状态和信息。

本站文章如无特殊说明，均为本站原创，如若转载，请注明出处：SpringBoot整合Druid数据源的方法实现 - Python技术站

赞 (0)
0 0 打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023年5月20日
下一篇 2023年5月20日

相关文章

  • mybatis使用foreach遍历list集合或者array数组方式

    下面我将详细讲解使用MyBatis的foreach遍历list集合或者array数组的方法。 1. foreach遍历list集合 1.1 准备工作 首先，我们需要在mapper接口中定义一个方法，参数为List类型，如下所示： public interface UserMapper { List<User> getUsersByIds(List…

    Java 2023年5月26日
    00

  • SpringMVC使用注解配置方式

    以下是关于“SpringMVC使用注解配置方式”的完整攻略，其中包含两个示例。 SpringMVC使用注解配置方式 SpringMVC是一个基于MVC模式的Web框架，它可以帮助我们快速开发Web应用程序。本文将介绍SpringMVC使用注解配置方式，并提供两个示例。 配置DispatcherServlet DispatcherServlet是SpringM…

    Java 2023年5月16日
    00

  • Jtable和JTree的写法示例代码

    我将为您提供关于JTable和JTree的写法示例代码的攻略。 JTable的写法示例代码 基本示例 下面是一个简单的JTable示例代码，它展示了如何创建一个带有表头和数据的JTable： // 创建表头和数据 String[] columnNames = {"Name", "Age", "Gender&q…

    Java 2023年6月15日
    00

  • IDEA Spring Boot 自动化构建+部署的实现

    下面我将详细讲解“IDEA Spring Boot 自动化构建+部署的实现”的完整攻略。 一、前置条件 下载并安装JDK1.8及以上版本； 下载并安装IntelliJ IDEA； 配置Maven。 二、创建Spring Boot项目 打开IntelliJ IDEA，点击”Create New Project”，然后选择Spring Initializr； 在…

    Java 2023年5月19日
    00

  • SpringBoot JPA懒加载失效的解决方案(亲测有效)

    下面我将详细讲解“SpringBoot JPA懒加载失效的解决方案(亲测有效)”的完整攻略。 1. 问题描述 在使用SpringBoot框架中，我们常常会使用JPA来进行数据持久化操作，而在使用JPA的过程中，我们可能会遇到懒加载失效的问题。具体来说，就是当我们使用懒加载的注解（如@OneToMany）来关联查询两个实体类时，有时候却发现第二个实体类并没有进…

    Java 2023年5月20日
    00

  • Mybatis-Plus实体类注解方法与mapper层和service层的CRUD方法

    Mybatis-Plus是一个基于Mybatis的ORM框架，提供了很多便捷的操作数据库的方法，其中实体类注解方法常用于简化CRUD操作。下面将详细讲解Mybatis-Plus实体类注解方法与mapper层和service层的CRUD方法的完整攻略。 1. 实体类注解方法 Mybatis-Plus实体类注解方法主要是使用注解来简化常规的数据库操作，包括字段映…

    Java 2023年5月20日
    00

  • java实现将ftp和http的文件直接传送到hdfs

    讲解“Java实现将FTP和HTTP的文件直接传送到HDFS”的完整攻略，步骤如下： 1.导入必要的依赖项 对于将FTP和HTTP文件传送到HDFS，我们需要使用一些必要的Java包和库。其中，Java对于FTP协议的支持已经包括在Java自带的JDK中了。而对于HTTP协议的支持，我们可以通过引入Apache HttpClient的库来实现。对于HDFS的…

    Java 2023年5月19日
    00

  • 使用maven插件对java工程进行打包过程解析

    使用 Maven 插件可以非常方便地对 Java 工程进行打包。下面是使用 maven-assembly-plugin 对 Java 工程进行打包的攻略： 1. 添加 Maven 插件 在 pom.xml 文件中添加 maven-assembly-plugin 插件的依赖： <build> <plugins> <plugin&g…

    Java 2023年5月20日
    00
合作推广
合作推广
分享本页
返回顶部