DBCP 简单使用(属性文件)

下面直接通过 Java 代码使用 DBCP 数据库连接池连接到 MySQL 数据并获取一个数据库连接,通过该连接获取当前数据库的时间戳。

环境

JDK版本:1.8

MySQL版本:5.7.*

Maven 依赖

将下面依赖信息添加到 pom.xml 文件:

<!-- https://mvnrepository.com/artifact/org.apache.commons/commons-dbcp2 -->
<dependency>
   <groupId>org.apache.commons</groupId>
   <artifactId>commons-dbcp2</artifactId>
   <version>2.9.0</version>
</dependency>

<dependency>
   <groupId>commons-logging</groupId>
   <artifactId>commons-logging</artifactId>
   <version>1.2</version>
</dependency>

<!-- 数据库驱动依赖 -->
<dependency>
   <groupId>mysql</groupId>
   <artifactId>mysql-connector-java</artifactId>
   <version>5.1.38</version>
</dependency>

数据库配置

在项目的 resources 目录下创建 dbcp.properties 属性文件,该属性文件配置了数据库信息,内容如下:

# 基本的设置
driverClassName=com.mysql.jdbc.Driver
#url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8&useSSL=false
# 可以将附加参数通过 connectionProperties 属性指定
url=jdbc:mysql://localhost:3306/test
username=root
password=aaaaaa

# 初始化时连接池中connection数量
initialSize=10

# 最大连接数量
maxActive=50

# 最大的空闲连接数量
maxIdle=20

# 最小的空闲链接数量
minIdle=5

# 最大的等待时间,单位是毫秒
maxWait=60000

# 建立连接时的附加参数,如果指定的编码不一致数据库中会出现乱码
# 注意:多个参数之间使用分号(;)进行分割
connectionProperties=useUnicode=true;characterEncoding=utf8;useSSL=false

# 是否开启自动提交,跟事务的控制有关
defaultAutoCommit=true

# 指定由连接池所创建的连接的事务隔离级别(TransactionIsolation)
defaultTransactionIsolation=REPEATABLE_READ

Java 代码

下面代码通过 getResourceAsStream() 方法加载 dbcp.properties 属性文件,然后通过 BasicDataSourceFactory.createDataSource() 方法创建 BasicDataSource 数据源。代码如下:

package com.hxstrive.jdbc_pool.dbcp;

import org.apache.commons.dbcp2.BasicDataSource;
import org.apache.commons.dbcp2.BasicDataSourceFactory;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.Properties;

/**
* DBCP 简单使用,通过属性文件存储数据库信息
*
* @author hxstrive.com
*/
public class DbcpHello {

   public static void main(String args[]) throws Exception {
       Connection connection = null;
       PreparedStatement ps = null;
       ResultSet rs = null;
       BasicDataSource bs = null;

       try {
           // 加载属性文件
           InputStream in = DbcpHello.class.getClassLoader().getResourceAsStream("dbcp.properties");
           Properties pro = new Properties();
           pro.load(in);
           bs = BasicDataSourceFactory.createDataSource(pro);

           // 从连接池获取数据库连接
           connection = bs.getConnection();
           ps = connection.prepareStatement("select CURRENT_TIMESTAMP() as ct");
           rs = ps.executeQuery();
           if(rs.next()) {
               System.out.println(rs.getTimestamp("ct"));
           }
       } finally {
           // 释放资源
           if(null != rs) {
               rs.close();
           }

           if(null != ps) {
               ps.close();
           }

           if(null != connection) {
               connection.close();
           }

           if(null != bs) {
               bs.close();
           }
       }
   }

}

运行代码,输出如下:

2023-07-06 12:36:50.0
说说我的看法
全部评论(
没有评论
关于
本网站属于个人的非赢利性网站,转载的文章遵循原作者的版权声明,如果原文没有版权声明,请来信告知:hxstrive@outlook.com
公众号