`

可供参考的【数据库连接池(DBCP)】

 
阅读更多

 

package com.spring.test;

import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Enumeration;
import java.util.Vector;

public class ConnectionPool {

	private String jdbcDriver = ""; // 数据库驱动
	private String dbUrl = ""; // 数据URL
	private String dbUsername = ""; // 数据库用户名
	private String dbPassword = ""; // 数据库用户密码
	private String testTable = ""; // 测试连接是否可用的测试表名,默认没有测试表
	private int initialConnections = 10; // 连接池的初始大小
	private int incrementalConnections = 5;// 连接池自动增加的大小
	private int maxConnections = 50; // 连接池最大的大小
	private Vector<PooledConnection> connections = null; // 存放连接池中数据库连接的向量,初始时为 null,它存放的对象为 PooledConnection 型

	/**
	 * 构造函数
	 * @param jdbcDriver String JDBC 驱动类串
	 * @param dbUrl String 数据库 URL
	 * @param dbUsername String 连接数据库用户名
	 * @param dbPassword String 连接数据库用户的密码
	 */
	public ConnectionPool(String jdbcDriver, String dbUrl, String dbUsername, String dbPassword) {
		this.jdbcDriver = jdbcDriver;
		this.dbUrl = dbUrl;
		this.dbUsername = dbUsername;
		this.dbPassword = dbPassword;
	}
	
	//----------------Set/Get Method Start--------------------------------
	/**
	 * @return 返回连接池的初始大小
	 */
	public int getInitialConnections() {
		return this.initialConnections;
	}

	/**
	 * 设置连接池的初始大小 
	 * @param 用于设置初始连接池中连接的数量
	 */
	public void setInitialConnections(int initialConnections) {
		this.initialConnections = initialConnections;
	}

	/**
	 * 返回连接池自动增加的大小  
	 * @return 连接池自动增加的大小
	 */
	public int getIncrementalConnections() {
		return this.incrementalConnections;
	}

	/**
	 * 设置连接池自动增加的大小
	 * @param 连接池自动增加的大小
	 */
	public void setIncrementalConnections(int incrementalConnections) {
		this.incrementalConnections = incrementalConnections;
	}

	/**
	 * 返回连接池中最大的可用连接数量
	 * @return 连接池中最大的可用连接数量
	 */
	public int getMaxConnections() {
		return this.maxConnections;
	}

	/**
	 * 设置连接池中最大可用的连接数量
	 * @param 设置连接池中最大可用的连接数量值
	 */
	public void setMaxConnections(int maxConnections) {
		this.maxConnections = maxConnections;
	}

	/**
	 * 获取测试数据库表的名字
	 * @return 测试数据库表的名字
	 */
	public String getTestTable() {
		return this.testTable;
	}

	/**
	 * 设置测试表的名字
	 * @param testTable String 测试表的名字
	 */
	public void setTestTable(String testTable) {
		this.testTable = testTable;
	}
	
	//-----------------Set/Get Method Start---------------------------------
	/**
	 * 创建一个数据库连接池,连接池中的可用连接的数量采用类成员
	 * initialConnections 中设置的值
	 */
	public synchronized void createPool() throws Exception {
		// 确保连接池没有创建
		// 如果连接池己经创建了,保存连接的向量 connections 不会为空
		if (connections != null) {
			return; // 如果己经创建,则返回
		}
		// 实例化 JDBC Driver 中指定的驱动类实例
		Driver driver = (Driver) (Class.forName(this.jdbcDriver).newInstance());
		DriverManager.registerDriver(driver); // 注册 JDBC 驱动程序
		// 创建保存连接的向量 , 初始时有 0 个元素
		connections = new Vector();
		// 根据 initialConnections 中设置的值,创建连接。
		createConnections(this.initialConnections);
		System.out.println("数据库连接池创建成功! ");
	}

	/**
	 * 创建由 numConnections 指定数目的数据库连接,并把这些连接放入 connections 向量中
	 * @param numConnections 要创建的数据库连接的数目
	 */
	@SuppressWarnings("unchecked")
	private void createConnections(int numConnections) throws SQLException {
		// 循环创建指定数目的数据库连接
		for (int x = 0; x < numConnections; x++) {
			// 是否连接池中的数据库连接的数量己经达到最大?最大值由类成员 maxConnections
			// 指出,如果 maxConnections 为 0 或负数,表示连接数量没有限制。
			// 如果连接数己经达到最大,即退出。
			if (this.maxConnections > 0 && this.connections.size() >= this.maxConnections) {
				break;
			}
			// 增加一个连接到连接池中(向量 connections 中)
			try {
				connections.addElement(new PooledConnection(newConnection()));
			} catch (SQLException e) {
				System.out.println(" 创建数据库连接失败! " + e.getMessage());
				throw new SQLException();
			}
			System.out.println(" 数据库连接己创建 ......");
		}
	}

	/**
	 * 创建一个新的数据库连接并返回它
	 * @return 返回一个新创建的数据库连接
	 */
	private Connection newConnection() throws SQLException {
		// 创建一个数据库连接
		Connection conn = DriverManager.getConnection(dbUrl, dbUsername, dbPassword);
		// 如果这是第一次创建数据库连接,即检查数据库,获得此数据库允许支持的
		// 最大客户连接数目
		// connections.size()==0 表示目前没有连接己被创建
		if (connections.size() == 0) {
			DatabaseMetaData metaData = conn.getMetaData();
			int driverMaxConnections = metaData.getMaxConnections();
			// 数据库返回的 driverMaxConnections 若为 0 ,表示此数据库没有最大
			// 连接限制,或数据库的最大连接限制不知道
			// driverMaxConnections 为返回的一个整数,表示此数据库允许客户连接的数目
			// 如果连接池中设置的最大连接数量大于数据库允许的连接数目 , 则置连接池的最大
			// 连接数目为数据库允许的最大数目
			if (driverMaxConnections > 0 && this.maxConnections > driverMaxConnections) {
				this.maxConnections = driverMaxConnections;
			}
		}
		return conn; // 返回创建的新的数据库连接
	}

	/**
	 * 通过调用 getFreeConnection() 函数返回一个可用的数据库连接 ,
	 * 如果当前没有可用的数据库连接,并且更多的数据库连接不能创
	 * 建(如连接池大小的限制),此函数等待一会再尝试获取。
	 * @return 返回一个可用的数据库连接对象
	 */
	public synchronized Connection getConnection() throws SQLException {
		// 确保连接池己被创建
		if (connections == null) {
			return null; // 连接池还没创建,则返回 null
		}
		Connection conn = getFreeConnection(); // 获得一个可用的数据库连接
		// 如果目前没有可以使用的连接,即所有的连接都在使用中
		while (conn == null) {
			// 等一会再试
			wait(250);
			conn = getFreeConnection(); // 重新再试,直到获得可用的连接,如果
			// getFreeConnection() 返回的为 null
			// 则表明创建一批连接后也不可获得可用连接
		}
		return conn;// 返回获得的可用的连接
	}

	/**
	 * 本函数从连接池向量 connections 中返回一个可用的的数据库连接,如果
	 * 当前没有可用的数据库连接,本函数则根据 incrementalConnections 设置
	 * 的值创建几个数据库连接,并放入连接池中。
	 * 如果创建后,所有的连接仍都在使用中,则返回 null
	 * @return 返回一个可用的数据库连接
	 */
	private Connection getFreeConnection() throws SQLException {
		// 从连接池中获得一个可用的数据库连接
		Connection conn = findFreeConnection();
		if (conn == null) {
			// 如果目前连接池中没有可用的连接
			// 创建一些连接
			createConnections(incrementalConnections);
			// 重新从池中查找是否有可用连接
			conn = findFreeConnection();
			if (conn == null) {
				// 如果创建连接后仍获得不到可用的连接,则返回 null
				return null;
			}
		}
		return conn;
	}

	/**
	 * 查找连接池中所有的连接,查找一个可用的数据库连接,
	 * 如果没有可用的连接,返回 null
	 * @return 返回一个可用的数据库连接
	 */
	private Connection findFreeConnection() throws SQLException {
		Connection conn = null;
		PooledConnection pConn = null;
		// 获得连接池向量中所有的对象
		Enumeration enumerate = connections.elements();
		// 遍历所有的对象,看是否有可用的连接
		while (enumerate.hasMoreElements()) {
			pConn = (PooledConnection) enumerate.nextElement();
			/**
			if (!pConn.isBusy()) {
				// 如果此对象不忙,则获得它的数据库连接并把它设为忙
				conn = pConn.getConnection();
				pConn.setBusy(true);
				// 测试此连接是否可用
				if (!testConnection(conn)) {
					// 如果此连接不可再用了,则创建一个新的连接,
					// 并替换此不可用的连接对象,如果创建失败,返回 null
					try {
						conn = newConnection();
					} catch (SQLException e) {
						System.out.println("创建数据库连接失败! " + e.getMessage());
						return null;
					}
					pConn.setConnection(conn);
				}
				break; // 己经找到一个可用的连接,退出
			}
			*/
			conn = pConn.getConnection();
			if(!pConn.isBusy()&& testConnection(conn)){//有效数据库连接
				pConn.setBusy(true);
				break;
			}
		}
		return conn;// 返回找到的可用连接
	}

	/**
	 * 测试一个连接是否可用,如果不可用,关掉它并返回 false
	 * 否则可用返回 true
	 * @param conn 需要测试的数据库连接
	 * @return 返回 true 表示此连接可用, false 表示不可用
	 */
	private boolean testConnection(Connection conn) {
		try {
			// 判断测试表是否存在
			if (testTable.equals("")) {
				// 如果测试表为空,试着使用此连接的 setAutoCommit() 方法
				// 来判断连接否可用(此方法只在部分数据库可用,如果不可用 ,
				// 抛出异常)。注意:使用测试表的方法更可靠
				conn.setAutoCommit(true);
			} else {// 有测试表的时候使用测试表测试
				// check if this connection is valid
				Statement stmt = conn.createStatement();
				stmt.execute("select count(*) from " + testTable);
			}
		} catch (SQLException e) {
			// 上面抛出异常,此连接己不可用,关闭它,并返回 false;
			closeConnection(conn);
			return false;
		}
		// 连接可用,返回 true
		return true;
	}

	/**
	 * 此函数返回一个数据库连接到连接池中,并把此连接置为空闲。
	 * 所有使用连接池获得的数据库连接均应在不使用此连接时返回它。
	 * @param 需返回到连接池中的连接对象
	 */
	public void returnConnection(Connection conn) {
		// 确保连接池存在,如果连接没有创建(不存在),直接返回
		if (connections == null) {
			System.out.println(" 连接池不存在,无法返回此连接到连接池中 !");
			return;
		}
		PooledConnection pConn = null;
		Enumeration enumerate = connections.elements();
		// 遍历连接池中的所有连接,找到这个要返回的连接对象
		while (enumerate.hasMoreElements()) {
			pConn = (PooledConnection) enumerate.nextElement();
			// 先找到连接池中的要返回的连接对象
			if (conn == pConn.getConnection()) {
				// 找到了,设置此连接为空闲状态
				pConn.setBusy(false);
				break;
			}
		}
	}

	/**
	 * 刷新连接池中所有的连接对象
	 */
	public synchronized void refreshConnections() throws SQLException {
		// 确保连接池己创新存在
		if (connections == null) {
			System.out.println(" 连接池不存在,无法刷新 !");
			return;
		}
		PooledConnection pConn = null;
		Enumeration enumerate = connections.elements();
		while (enumerate.hasMoreElements()) {
			// 获得一个连接对象
			pConn = (PooledConnection) enumerate.nextElement();
			// 如果对象忙则等 5 秒 ,5 秒后直接刷新
			if (pConn.isBusy()) {
				wait(5000); // 等 5 秒
			}
			// 关闭此连接,用一个新的连接代替它。
			closeConnection(pConn.getConnection());
			pConn.setConnection(newConnection());
			pConn.setBusy(false);
		}
	}

	/**
	 * 关闭连接池中所有的连接,并清空连接池。
	 */
	public synchronized void closeConnectionPool() throws SQLException {
		// 确保连接池存在,如果不存在,返回
		if (connections == null) {
			System.out.println(" 连接池不存在,无法关闭 !");
			return;
		}
		PooledConnection pConn = null;
		Enumeration enumerate = connections.elements();
		while (enumerate.hasMoreElements()) {
			pConn = (PooledConnection) enumerate.nextElement();
			// 如果忙,等 5 秒
			if (pConn.isBusy()) {
				wait(5000); // 等 5 秒
			}
			// 5 秒后直接关闭它
			closeConnection(pConn.getConnection());
			// 从连接池向量中删除它
			connections.removeElement(pConn);
		}
		// 置连接池为空
		connections = null;
	}

	/**
	 * 关闭一个数据库连接
	 * @param 需要关闭的数据库连接
	 */
	private void closeConnection(Connection conn) {
		try {
			conn.close();
		} catch (SQLException e) {
			System.out.println(" 关闭数据库连接出错: " + e.getMessage());
		}
	}

	/**
	 * 使程序等待给定的毫秒数
	 * @param 给定的毫秒数
	 */
	private void wait(int mSeconds) {
		try {
			Thread.sleep(mSeconds);
		} catch (InterruptedException e) {
		}
	}

	//-------------------内部类(POJO)-----------------------------
	/**
	 * 内部使用的用于保存连接池中连接对象的类
	 * 此类中有两个成员,一个是数据库的连接,另一个是指示此连接是否正在使用的标志。
	 */
	class PooledConnection {
		Connection connection = null;// 数据库连接
		boolean busy = false; // 此连接是否正在使用的标志,默认没有正在使用
		// 构造函数,根据一个 Connection 构造一个 PooledConnection 对象
		public PooledConnection(Connection connection) {
			this.connection = connection;
		}
		// 返回此对象中的连接
		public Connection getConnection() {
			return connection;
		}
		// 设置此对象的连接
		public void setConnection(Connection connection) {
			this.connection = connection;
		}
		// 获得对象连接是否忙
		public boolean isBusy() {
			return busy;
		}
		// 设置对象的连接正在忙
		public void setBusy(boolean busy) {
			this.busy = busy;
		}
	}
	
}
分享到:
评论

相关推荐

    JAVA数据库连接池

    总的来说,数据库连接池是Java开发中不可或缺的一部分,它通过有效地管理和复用数据库连接,提高了系统的运行效率和资源利用率。了解和掌握C3P0和DBCP的使用方法,能够帮助开发者更好地优化数据库操作,提升应用性能...

    数据库连接池相关 jar 包

    在给定的标题和描述中,我们聚焦于两个关键的库——`commons-dbcp.jar`和`commons-pool.jar`,它们是Apache Commons项目的一部分,用于实现数据库连接池功能。 `commons-dbcp`(Database Connection Pool)是Apache...

    补充 数据库连接池.ppt

    总结来说,数据库连接池是现代数据库驱动的Web应用程序中不可或缺的一部分,它通过有效的管理数据库连接,提高了系统的效率和稳定性,同时也降低了资源消耗和潜在的系统风险。开发者可以根据项目需求选择合适的连接...

    各种数据库连接池

    标题中提到的"各种数据库连接池",包括了c3p、DBCP和Proxool,这些都是Java环境下常见的数据库连接池实现: 1. **C3P0**:这是一个开源的JDBC连接池,它实现了数据源和JNDI绑定,支持JDBC3规范和JDBC2的标准扩展。...

    数据库连接池代码实现

    接下来,我们将以Java为例,简要介绍如何使用开源库如C3P0、HikariCP或Apache DBCP来实现数据库连接池。 1. **C3P0** 是一个开源的JDBC连接池,提供了数据库连接的自动获取、释放和管理功能。在使用C3P0时,我们...

    数据库连接池的应用与研究

    数据库连接池是现代软件开发中不可或缺的一个重要组件,它的主要作用是提高数据库访问效率,减少系统资源消耗。本文将深入探讨数据库连接池的应用与研究,包括其原理、优点、常见实现以及如何在实际项目中有效地利用...

    Java数据库连接池的原理与应用.pdf

    在Java开发领域,数据库连接池(Database Connection Pool,简称DBCP)是一种提高数据库访问性能、降低资源消耗的重要技术。它通过预先建立一定数量的数据库连接,存储在一个“池”中,当应用程序需要进行数据库操作...

    数据库连接池所需jar包

    数据库连接池是现代Java应用程序中不可或缺的部分,它有效地管理和优化了数据库资源的使用。在Java中,连接池通过复用已存在的数据库连接来减少创建和销毁连接的开销,从而提高系统性能。本文将深入探讨数据库连接池...

    java 数据库 连接池驱动.rar

    - DBCP (Apache BasicDataSource):Apache的一个开源项目,基于Jakarta Pool实现,它是Tomcat默认的数据库连接池。 - HikariCP:高性能的连接池,设计目标是提供最小的延迟和最大吞吐量,被认为是目前最快的Java...

    tomcat数据库连接池的使用

    此外,随着技术的发展,还有其他更先进的数据库连接池组件可供选择,如HikariCP,它以其高性能和低延迟而受到广泛欢迎。 总结来说,Tomcat数据库连接池的使用涉及添加依赖、配置数据源、上下文配置以及代码中的使用...

    简单建立数据库连接池及JDK自带日志使用(真正)

    数据库连接池是现代Web应用程序中不可或缺的部分,它有效地管理和复用数据库连接,提高了系统的性能和资源利用率。在Java中,我们可以使用多种库来创建数据库连接池,如C3P0、DBCP、HikariCP等。本示例将重点讨论...

    DBCP连接池的jar包

    DBCP(Database Connection Pool)是Apache组织提供的一种开源数据库连接池实现,全称为"Jakarta DBCP"。它基于Java编写,旨在提高数据库访问效率,通过复用已存在的数据库连接,减少创建和销毁数据库连接时的开销,...

    基于数据库连接池的D A O模式在J 2 E E应用系统中的实现

    数据库连接池可以通过多种方式进行实现,包括但不限于手动构建连接池或使用现有的开源框架(如C3P0、DBCP等)。无论采用哪种方式,其核心都是为了达到以下目标: - 预先创建一定数量的数据库连接。 - 当应用程序...

    适合各种数据库的数据库连接池

    在Java编程语言中,常见的数据库连接池实现有Apache的DBCP、C3P0,以及HikariCP等。这些连接池都提供了丰富的配置选项,如最小连接数、最大连接数、超时时间等,以便根据实际应用的负载情况进行调整。 DBConnection...

    连接池dbcp

    总的来说,Apache Commons DBCP是Java开发中实现数据库连接池的一个可靠选择,尤其适合于对性能要求不那么高但又希望利用连接池技术来提升效率的应用场景。然而,对于高并发和性能敏感的应用,可能需要考虑更先进的...

    一个Demo小例子让你了解数据库连接池实现的4种方式

    数据库连接池是现代Java应用程序中不可或缺的组件,它在提高数据库访问效率、节省系统资源方面起着关键作用。本文将通过一个Demo小例子详细介绍四种常见的数据库连接池实现方式:C3P0、DBCP、HikariCP以及Druid。 ...

    数据库连接池的工作原理

    数据库连接池是现代应用程序开发中不可或缺的一个组件,它在提高系统性能、节省资源以及优化数据库操作方面发挥着关键作用。数据库连接池的工作原理涉及到多个层面,包括连接的创建与复用、连接池的管理以及性能优化...

    开源数据库连接池

    在这个压缩包“开源数据库连接池”中,我们找到了几个主流的Java数据库连接池实现,包括c3p0、DBCP等,以及与JDBC事务控制相关的PPT资料。以下将详细介绍这些内容。 首先,c3p0是一个开源的JDBC连接池,由Miquel ...

    数据库连接池所需要用到的三个jar包

    本话题将聚焦于"数据库连接池所需要用到的三个jar包"——`commons-collections-3.1.jar`、`commons-dbcp-1.2.2.jar`和`commons-pool.jar`,它们在数据库连接池实现中的作用以及如何使用。 首先,`commons-...

    数据库连接池

    在Java开发中,常见的数据库连接池实现有Apache的DBCP、C3P0,以及HikariCP等。这些连接池库提供了一套完善的API和配置选项,使得开发者能够根据实际需求调整连接池的大小、超时时间、空闲检查频率等参数。 1. DBCP...

Global site tag (gtag.js) - Google Analytics