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>

Java 代码

下面代码通过手动 new 一个 BasicDataSource 对象,然后使用 BasicDataSource 的 getConnection() 方法获取数据库连接。代码如下:

package com.hxstrive.jdbc_pool.dbcp;

import org.apache.commons.dbcp2.BasicDataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

/**
* 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 {
           // 创建数据源
           bs = new BasicDataSource();
           bs.setDriverClassName("com.mysql.jdbc.Driver");
           bs.setUrl("jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8&useSSL=false");
           bs.setUsername("root");
           bs.setPassword("aaaaaa");
           // 初始化时连接池中connection数量
           bs.setInitialSize(10);
           // 最小的空闲链接数量
           bs.setMinIdle(5);
           // 最大的空闲连接数量
           bs.setMaxIdle(20);
           // 最大的等待时间,单位是毫秒
           bs.setMaxWaitMillis(60000);
           // 是否开启自动提交,跟事务的控制有关
           bs.setDefaultAutoCommit(true);

           // 从连接池获取数据库连接
           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
公众号