`
yuanyu5237
  • 浏览: 162800 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

一个简单的数据库连接池ConnectionPool

阅读更多
三个文件,ConnectionPool.java  ConnectionPoolTest.java  dbpool.properties
import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;
import java.util.Vector;

public class ConnectionPool {

	private Vector<Connection> pool;

	private String url;

	private String username;

	private String password;

	private String driverClassName;

	/**
	 * 连接池的大小,也就是连接池中有多少个数据库连接。
	 */
	private int poolSize = 1;

	private static ConnectionPool instance = null;

	/**
	 * 私有的构造方法,禁止外部创建本类的对象,要想获得本类的对象,通过<code>getIstance</code>方法。
	 * 使用了设计模式中的单子模式。
	 */
	private ConnectionPool() {
		init();
	}

	/**
	 * 连接池初始化方法,读取属性文件的内容 建立连接池中的初始连接
	 */
	private void init() {
		pool = new Vector<Connection>(poolSize);
		readConfig();
		addConnection();
	}

	/**
	 * 返回连接到连接池中
	 */
	public synchronized void release(Connection conn) {
		pool.add(conn);

	}

	/**
	 * 关闭连接池中的所有数据库连接
	 */
	public synchronized void closePool() {
		for (int i = 0; i < pool.size(); i++) {
			try {
				((Connection) pool.get(i)).close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			pool.remove(i);
		}
	}

	/**
	 * 返回当前连接池的一个对象
	 */
	public static ConnectionPool getInstance() {
		if (instance == null) {
			instance = new ConnectionPool();
		}
		return instance;
	}

	/**
	 * 返回连接池中的一个数据库连接
	 */
	public synchronized Connection getConnection() { 
		if (pool.size() > 0) {
			Connection conn = pool.get(0);
			pool.remove(conn);
			return conn;
		} else {
			return null;
		}
	}

	/**
	 * 在连接池中创建初始设置的的数据库连接
	 */
	private void addConnection() {
		Connection conn = null;
		for (int i = 0; i < poolSize; i++) {

			try {
				Class.forName(driverClassName);
				conn = java.sql.DriverManager.getConnection(url, username, password);
				pool.add(conn);

			} catch (ClassNotFoundException e) {
				e.printStackTrace();
			} catch (SQLException e) {
				e.printStackTrace();
			}

		}
	}

	/**
	 * 读取设置连接池的属性文件
	 */
	private void readConfig() {
		try {
			String path = System.getProperty("user.dir") + "\\dbpool.properties";
			FileInputStream is = new FileInputStream(path);
			Properties props = new Properties();
			props.load(is);
			this.driverClassName = props.getProperty("driverClassName");
			this.username = props.getProperty("username");
			this.password = props.getProperty("password");
			this.url = props.getProperty("url");
			this.poolSize = Integer.parseInt(props.getProperty("poolSize"));
		} catch (Exception e) {
			e.printStackTrace();
			System.err.println("读取属性文件出错. ");
		}
	}
}

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class ConnectionPoolTest {
	public static void main(String[] args) throws Exception {
		String sql = "select id,name,phone from guestbook";
		long start = System.currentTimeMillis();
		ConnectionPool pool = null;

		for (int i = 0; i < 100; i++) {
			pool = ConnectionPool.getInstance();
			Connection conn = pool.getConnection();
			Statement stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery(sql);
			while (rs.next()) {
			}
			rs.close();
			stmt.close();
			pool.release(conn);
		}
		pool.closePool();
		System.out.println("经过100次的循环调用,使用连接池花费的时间:"
				+ (System.currentTimeMillis() - start) + "ms\n");

		String hostName = "192.168.213.144";
		String driverClass = "oracle.jdbc.driver.OracleDriver";
		String url = "jdbc:oracle:thin:@" + hostName + ":1521:orcl";
		String user = "scott";
		String password = "tiger";
		start = System.currentTimeMillis();

		for (int i = 0; i < 100; i++) {
			Class.forName(driverClass);
			Connection conn = DriverManager.getConnection(url, user, password);
			Statement stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery(sql);
			while (rs.next()) {
			}
			rs.close();
			stmt.close();
			conn.close();
		}
		System.out.println("经过100次的循环调用,不使用连接池花费的时间:"
				+ (System.currentTimeMillis() - start) + "ms");
	}
}

driverClassName=oracle.jdbc.driver.OracleDriver
username=scott
password=tiger
url=jdbc:oracle:thin:@192.168.213.144:1521:orcl
poolSize=10

建表语句:
create table guestbook(id number(8) not null primary key,
name varchar(32) not null,
phone varchar(32) not null);

insert into guestbook(id,name,phone) values(1,'Alex','81456312');
分享到:
评论

相关推荐

    java数据库连接池connectionPool.zip

    java数据库连接池connectionPool.zip java数据库连接池connectionPool.zip java数据库连接池connectionPool.zip java数据库连接池connectionPool.zip java数据库连接池connectionPool.zip

    java数据库连接池connectionPool.jar

    总的来说,`connectionPool.jar`作为一个Java数据库连接池,简化了数据库连接的管理,提高了系统性能,是现代Java应用开发中不可或缺的一部分。正确理解和使用连接池,对于优化数据库操作、提高应用效率至关重要。

    ConnectionPool数据库连接池例子.doc

    数据库连接池ConnectionPool的实现和配置 数据库连接池(Database Connection Pool)是一种提高数据库访问效率的技术,通过重用已经创建的数据库连接来减少创建新连接的开销。下面是一个使用Java语言实现的数据库...

    C# 数据库连接池 database pool

    数据库连接池是数据库管理中的一个重要概念,特别是在使用像C#这样的编程语言进行应用程序开发时。在C#中,数据库连接池是一种高效的资源管理技术,它允许多个数据库操作共享一个数据库连接,而不是每次操作都创建新...

    ConnectionPool 数据库连接池

    本文将深入解析“ConnectionPool”(数据库连接池)的工作原理,常见实现及使用方法。 **一、数据库连接池的概念** 数据库连接池,简单来说,就是管理数据库连接的池化技术。它预先创建一定数量的数据库连接,当多...

    C#高效数据库连接池源码

    `ConnectionPool`可能是项目或类库的命名空间或类,包含实际的数据库连接池实现;`Demo`可能是一个示例应用程序,展示如何使用自定义的数据库连接池。 5. **连接池实现细节**: - **初始化**:在应用程序启动时,...

    Qt 多线程连接数据库——数据库连接池

    * 数据库连接池特点: * 获取连接时不需要了解连接的名字,连接池内部维护连接的名字 * 支持多线程,保证获取到的连接一定是没有被其他线程正在使用 * 按需创建连接,可以创建多个连接,可以控制连接的数量 * 连接...

    ConnectionPool 基于java实现数据库连接池

    数据库连接池是现代Java应用程序中不可或缺的部分,它有效地管理和复用数据库连接,提高了系统的性能和效率。本项目基于Java实现了这样一个连接池,旨在帮助开发者理解其工作原理,并能在实际项目中灵活运用。 在...

    Java jdbc数据库连接池总结

    数据库连接池(connection pool)的工作原理是为了解决资源的频繁分配、释放所造成的问题。数据库连接池的基本思想就是为数据库连接建立一个“缓冲池”。预先在缓冲池中放入一定数量的连接,当需要建立数据库连接时...

    常用jdbc数据库连接jar包,数据库连接池jar包

    数据库连接池在初始化时会创建一定数量的数据库连接并保存起来,当应用程序需要连接时,可以从池中获取一个已存在的连接,而不是每次都去新建,用完后也不立即关闭,而是归还给连接池。这样可以显著减少建立和释放...

    数据库连接池(database connection pool)是在 Java 中用于管理数据库连接的一种技术

    数据库连接池(database connection pool)是在 Java 中用于管理数据库连接的一种技术。它的主要目的是提高数据库连接的重用性和性能。在传统的数据库连接方式中,每次与数据库建立连接时都需要进行一系列的网络通信...

    数据库连接池的一个简单实现

    本篇文章将详细解析一个简单的Java实现数据库连接池的过程。 首先,我们要理解数据库连接池的基本原理。数据库连接池预先创建并维护一定数量的数据库连接,当应用程序需要访问数据库时,可以从池中获取一个已存在的...

    jsp连接数据库连接池代码示例

    数据库连接池是一种管理数据库连接的技术,它预先初始化一定数量的数据库连接并保存在内存中,当应用程序需要连接数据库时,可以从连接池中获取一个已存在的连接,用完后再归还,而不是每次都新建和关闭连接。...

    MySql数据库连接池C#代码(有注释含测试代码)

    本示例包含的代码文件`ConnectionPool.cs`、`TestConnectionPool.cs`和`PooledConnection.cs`提供了自定义数据库连接池的实现。 首先,我们来看`ConnectionPool.cs`。这个文件通常会包含一个类,比如`...

    一种简单JDBC数据库连接池的实现.rar_connection pool jdbc_site:www.pudn.com_数据库

    本文将详细讨论如何实现一个简单的JDBC(Java Database Connectivity)数据库连接池,以及相关的技术要点。 首先,我们需要了解JDBC的基本概念。JDBC是Java平台的标准API,用于与各种类型的数据库进行交互。通过...

    配置数据库连接池

    数据库连接池的基本思想是预先创建并维护一定数量的数据库连接,当应用需要与数据库通信时,可以快速地从连接池中获取一个已建立的连接,而不是每次都新建一个。用完后,连接会归还到池中,供其他请求使用,而不是...

    delphi实现数据库连接池

    数据库连接池(Database Connection Pool)是预先在内存中创建一定数量的数据库连接,当应用程序需要时,可以从池中获取一个已存在的连接,而不是每次都去创建新的。这种方式减少了创建和关闭连接的开销,提高了系统...

Global site tag (gtag.js) - Google Analytics