JAVA之DBCP(连接池)

青旅半醒 2022-05-22 11:55 270阅读 0赞

一：连接池技术

现在JDBC操作过程中，最浪费资源的步骤是创建数据库连接。但是在操作完成数据库之后又必须关闭数据库连接。

在使用JDBC时关闭数据库连接就是销毁数据库连接。

连接池：存放连接的一个容器。使用连接池容器可以实现对数据库连接对象的创建，维护和管理。

当我们再进行数据库操作时，可以从连接池获得一个数据库连接对象 ，进行与数据库之间的CRUD操作，操作完成之后释放数据库连接。可以有效的减少创建数据库连接对象的次数。

二：数据源对象

数据源对象是Java程序中连接池技术的实现类。  
在Java中使用数据源对象创建，维护和管理数据库连接对象。

现在使用第三方的连接池技术。

三：DBCP封装

在实际开发中，将数据库连接对象的获取进行单独的封装。

编写一个工具类。实现对数据库连接对象的操作

四：操作步骤

1 导入DBCP第三方连接池的jar文件

![70][]

2 编写一个连接池工作的参数文件  
    在src目录下创建一个资源文件。  
    driverClassName=com.mysql.jdbc.Driver  
    url=jdbc:mysql://127.0.0.1:3306/heda?useUnicode=true&characterEncoding=utf8  
    username=root  
    password=root  
    maxActive=50

maxIdle=20

maxWait=60000

3 读取资源文件的内容  
Properties properties = new Properties();  
InputStream inStream = DBUtil.class.getResourceAsStream("/mysql.properties");  
properties.load(inStream);  
4 创建数据源对象  
ds = BasicDataSourceFactory.createDataSource(properties);

##### DBCP部分代码： #####

public class DBUtil {
    	private static DataSource ds;
    	private static Connection conn;
    	static{
    		try {
    			Properties properties = new Properties();
    			InputStream inStream = DBUtil.class.getResourceAsStream("/mysql.properties");
    			properties.load(inStream);
    			ds = BasicDataSourceFactory.createDataSource(properties);
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    	/**
    	 * 获取数据库连接对象 
    	 * @return 数据库连接对象
    	 * @throws SQLException
    	 */
    	public static Connection getConn() throws SQLException {
    		if (conn == null || conn.isClosed()) {
    			conn = ds.getConnection();
    		}
    		return conn;
    	}
    	/**
    	 * 闭关数据库连接
    	 */
    	public static void closeConn() {
    		try {
    			if (conn != null && !conn.isClosed()) {
    				conn.close();
    			}
    		} catch (SQLException e) {
    			e.printStackTrace();
    		} finally {
    			conn = null;
    		}
    	}
    }

#####  完整代码： #####

1:JDBCTest.java

package edu.heda.test;
    
    import java.sql.Connection;
     
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    
    import edu.heda.util.DBUtil;
    
    public class JDBCTest {
    	 
    	public static void main(String[] args) {
    		try {
    			//第一步：使用dbcp创建数据库连接对象
    			Connection conn = DBUtil.getConn();
    			 
    			//第二部：数据库的curd操作
    			String sql = "select * from users";
    			// PreparedStatement对象是操作对象 ，负责向数据库发送SQL语句。
    			PreparedStatement pstat = conn.prepareStatement(sql);
    			// ResultSet是结果集对象 ，负责接收查询结果.BOF,EOF
    			ResultSet rs = pstat.executeQuery();
    			while (rs.next()) {
    				String userName = rs.getString("user_name");
    				String password = rs.getString("user_pass");
    				String userImg = rs.getString("user_img");
    				System.out.println(userName);
    				System.out.println(password);
    				System.out.println(userImg);
    				System.out.println("--------------");
    			}
    		} catch (SQLException e) {
    			e.printStackTrace();
    		} finally {
    			//第三步：使用dbcp关闭数据库链接对象
    			DBUtil.closeConn();
    		}
    
    	}
    
    }

2:DBUtil.java

package edu.heda.util;
    
     
    import java.io.InputStream;
     
    import java.sql.Connection;
    import java.sql.SQLException;
    import java.util.Properties;
    
    import javax.sql.DataSource;
    
    import org.apache.commons.dbcp.BasicDataSourceFactory;
    
    public class DBUtil {
    	private static DataSource ds;
    	private static Connection conn;
    	static{
    		try {
    			Properties properties = new Properties();
    			InputStream inStream = DBUtil.class.getResourceAsStream("/mysql.properties");
    			properties.load(inStream);
    			ds = BasicDataSourceFactory.createDataSource(properties);
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}	 
    	/**
    	 * 获取数据库连接对象 
    	 * @return 数据库连接对象
    	 * @throws SQLException
    	 */
    	public static Connection getConn() throws SQLException {
    		if (conn == null || conn.isClosed()) {
    			conn = ds.getConnection();
    		}
    		return conn;
    	}
    	/**
    	 * 闭关数据库连接
    	 */ 
    	public static void closeConn() {
    		try {
    			if (conn != null && !conn.isClosed()) {
    				conn.close();
    			}
    		} catch (SQLException e) {
    			e.printStackTrace();
    		} finally {
    			conn = null;
    		}
    	}
    }

3:mysqli.peoperties

driverClassName=com.mysql.jdbc.Driver
    url=jdbc:mysql://127.0.0.1:3306/dbcp?useUnicode=true&characterEncoding=utf8
    username=root
    password=root
    maxActive=50
    maxIdle=20
    maxWait=60000

[70]: /images/20220522/a8063ab9271541ffabd0c5f8dc88cdb5.png