Java的JDBC数据库连接池实现方法
Java程序员都很羡慕Windows ADO ，只需要new Connection 就可以直接从数据库连接池中返回Connection。并且 ADO Connection 是线程安全的，多个线程可以共用一个Connection，所以ASP程序一般都把getConnection 放在 Global.asa 文件中，在 IIS 启动时建立数据库连接。ADO 的Connection 和Result 都有很好的缓冲，并且很容易使用。

其实我们可以自己写一个JDBC数据库连接池。

写JDBC connection pool 的注意事项有：

1. 有一个简单的函数从连接池中得到一个 Connection。

2. close 函数必须将connection 放回 数据库连接池。

3. 当数据库连接池中没有空闲的connection，数据库连接池必须能够自动增加connection 个数。

4. 当数据库连接池中的connection 个数在某一个特别的时间变得很大，但是以后很长时间只用其中一小部分，应该可以自动将多余的connection 关闭掉。

5. 如果可能，应该提供debug 信息报告没有关闭的new Connection 。

如果要new Connection 就可以直接从数据库连接池中返回Connection， 可以这样写( Mediator pattern ) (以下代码中使用了中文全角空格)：

public class EasyConnection implements java.sql.Connection{ 
private Connection m_delegate = null; 
public EasyConnection(){ 
m_delegate = getConnectionFromPool(); 
} 
　public void close(){ 
putConnectionBackToPool(m_delegate); 
} 
public PreparedStatement prepareStatement(String sql) throws SQLException{ 
m_delegate.prepareStatement(sql); 
} 
//...... other method 
}
看来并不难。不过不建议这种写法，因为应该尽量避免使用Java Interface, 关于Java Interface 的缺点我另外再写文章讨论。大家关注的是Connection Pool 的实现方法。下面给出一种实现方法。

import java.sql.*; 
import java.lang.reflect.*; 
import java.util.*; 
import java.io.*; 

public class SimpleConnetionPool { 
private static LinkedList m_notUsedConnection = new LinkedList(); 
private static HashSet m_usedUsedConnection = new HashSet(); 
private static String m_url = ""; 
private static String m_user = ""; 
private static String m_password = ""; 
static final boolean DEBUG = true; 
static private long m_lastClearClosedConnection = System.currentTimeMillis(); 
public static long CHECK_CLOSED_CONNECTION_TIME = 4 * 60 * 60 * 1000; //4 hours 

static { 
initDriver(); 
} 

private SimpleConnetionPool() { 
} 

private static void initDriver() { 
Driver driver = null; 
//load mysql driver 
try { 
driver = (Driver) Class.forName("com.mysql.jdbc.Driver").newInstance(); 
installDriver(driver); 
} catch (Exception e) { 
} 

//load postgresql driver 
try { 
driver = (Driver) Class.forName("org.postgresql.Driver").newInstance(); 
installDriver(driver); 
} catch (Exception e) { 
} 
} 

public static void installDriver(Driver driver) { 
try { 
DriverManager.registerDriver(driver); 
} catch (Exception e) { 
e.printStackTrace(); 
} 
} 


public static synchronized Connection getConnection() { 
clearClosedConnection(); 
while (m_notUsedConnection.size() > 0) { 
try { 
ConnectionWrapper wrapper = (ConnectionWrapper) m_notUsedConnection.removeFirst(); 
if (wrapper.connection.isClosed()) { 
continue; 
} 
m_usedUsedConnection.add(wrapper); 
if (DEBUG) { 
wrapper.debugInfo = new Throwable("Connection initial statement"); 
} 
return wrapper.connection; 
} catch (Exception e) { 
} 
} 
int newCount = getIncreasingConnectionCount(); 
LinkedList list = new LinkedList(); 
ConnectionWrapper wrapper = null; 
for (int i = 0; i < newCount; i++) { 
wrapper = getNewConnection(); 
if (wrapper != null) { 
list.add(wrapper); 
} 
} 
if (list.size() == 0