写了个通用连接池，c3p0，用来连接多个数据库，大家看看有没有问题
要实现的功能，就是读取jdbc.properties，获取数据库连接。只要在jdbc.properties配置了url，username，password三项就可以调用DBPool实现数据库连接，是连接池的。
import java.beans.PropertyVetoException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Map;
import java.util.Properties;
import java.util.concurrent.ConcurrentHashMap;
import org.apache.log4j.Logger;
import com.mchange.v2.c3p0.ComboPooledDataSource;
public class DBPool {
private static Logger log = Logger.getLogger(DBPool.class);
private static DBPool dbPool = new DBPool();
private static Map<String, ComboPooledDataSource> dataSources = new ConcurrentHashMap<String, ComboPooledDataSource>();
private DBPool() {
}
public final static DBPool getInstance() {
return dbPool;
}
public final Connection getConnection(String connName) {
try {
Connection conn = getDataSource(connName).getConnection();
return conn;
} catch (SQLException e) {
log.error("can't get the connection :" + e);
throw new RuntimeException("unable to connect to the database ", e);
}
}
private ComboPooledDataSource getDataSource(String connName) {
ComboPooledDataSource dataSource = dataSources.get(connName);
if (dataSource != null) {
return dataSource;
}
try {
InputStream is = DBPool.class.getResourceAsStream("/jdbc.properties");
Properties p = new Properties();
p.load(is);
String dbUrl = p.getProperty(connName + ".url");
String dbUser = p.getProperty(connName + ".username");
String dbPwd = p.getProperty(connName + ".password");
String driver = p.getProperty("driver");
dataSource = new ComboPooledDataSource();
dataSource.setUser(dbUser);
dataSource.setPassword(dbPwd);
dataSource.setJdbcUrl(dbUrl);
dataSource.setDriverClass(driver);
dataSource.setInitialPoolSize(2);
dataSource.setMinPoolSize(1);
dataSource.setMaxPoolSize(10);
dataSource.setMaxStatements(50);
dataSource.setMaxIdleTime(60);
dataSource.setAcquireIncrement(5);
is.close();
} catch (PropertyVetoException e) {
log.error("jdbc.properties error ", e);
} catch (Exception e) {
log.error("datasource generate error ", e);
}
dataSources.put(connName, dataSource);
return dataSource;
}
public final void close(Statement pstmt, ResultSet rs, Connection conn) {
try {
if (pstmt != null)
pstmt.close();
if (rs != null)
rs.close();
if (conn != null)
conn.close();
} catch (SQLException e) {
log.error("close conn error ", e);
}
}
}
写了一个测试代码，执行正确
public class Test {
public static void main(String[] args) {
Connection conn = DBPool.getInstance().getConnection("erpt");
PreparedStatement pstmt = null;
ResultSet rs = null;
try{
pstmt= conn.prepareStatement("select * from daily_aop limit 5;");
rs = pstmt.executeQuery();
while (rs.next()) {
System.out.println(rs.getInt(1));
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
DBPool.getInstance().close(pstmt, rs, conn);
}
}
}
数据库连接 java c3p0 --------------------编程问答--------------------
你这写的是链接池？
--------------------编程问答--------------------
准确的说不是连接池实现，是连接池的使用，哈哈。
主要功能就是可以调用多个数据库连接池。只要配置文件里写一下就可以在代码里调用了。 --------------------编程问答--------------------
木有认真看，还以为你是自己实现了一个连接池。。你这close是把连接用完以后关闭了么，不是还给连接池？ --------------------编程问答--------------------
c3p0连接池，要直接关掉的。
http://bbs.csdn.net/topics/390458524?page=1#post-394497078
--------------------编程问答-------------------- 额，你这里调用的close应该是放回连接池并不是关闭物理连接的，之前我没想对 --------------------编程问答-------------------- 直接配置多数据源就可以了
--------------------编程问答--------------------
除
--------------------编程问答--------------------
虽然使用了 ConcurrentHashMap 但并未处理 ComboPooledDataSource dataSource = dataSources.get(connName);
if (dataSource != null) {
return dataSource;
}
这块代码的同步问题，如果竞争激烈的话，很可能会造成连接泄漏。 --------------------编程问答-------------------- 另外，对于异常处理非常不好，比如：
} catch (PropertyVetoException e) {
log.error("jdbc.properties error ", e);
} catch (Exception e) {
log.error("datasource generate error ", e);
}
dataSources.put(connName, dataSource);
return dataSource;
直接把异常吃了，如果 dataSource 没有初始化成功，也将 put 到 dataSources 中，并返回给调用者一个 null 值的 dataSource。 --------------------编程问答--------------------
谢谢火龙果！
那么这个异常怎么处理比较好呢？throw 一个运行是异常吗？
--------------------编程问答--------------------
这里不会吧，ConcurrentHashMap只是读取数据，put的时候可能会有点问题，
put的时候加个锁就行了
synchronized (dataSources) {
dataSources.put(connName, dataSource);
}怎么配置？ --------------------编程问答-------------------- MARK 正想把部分业务处理使用另外一个库去执行。 --------------------编程问答-------------------- 我看不出你这个关闭是放回连接池中你的conn是sql包中的connection所以你直接关掉了。 --------------------编程问答-------------------- 我看不出你这个关闭是放回连接池中，你的conn是sql包中的connection所以你直接关掉了。 --------------------编程问答--------------------
看这个火龙果大大的回复：http://bbs.csdn.net/topics/330195313
c3p0是要关闭的。其他的连接池不了解
补充：Java , Java EE
