使用dbcp做为数据库连接池

时间:2020-12-01 04:34:45
在数据库应用中,数据库连接过程需要较长的时间。
而且,频繁的连接数据库会增加数据库系统的压力。
所以,最好在项目中使用数据库连接池来减少数据库连接的数量提高数据库访问效率。

DBCP是Apache的一个开源项目:
commons.dbcp
http://jakarta.apache.org/commons/dbcp/index.html

DBCP依赖Apache的另外2个开源项目
commons.collections

commons.pool

下载这些包并将这些包的路径添加到classpath中就可以使用dbcp做为项目中的数据库连接池使用了。

下面是一段示例代码,简单说说dbcp的使用方法:

使用dbcp做为数据库连接池import org.apache.commons.pool.ObjectPool;
使用dbcp做为数据库连接池
import org.apache.commons.pool.impl.GenericObjectPool;
使用dbcp做为数据库连接池
import org.apache.commons.dbcp.ConnectionFactory;
使用dbcp做为数据库连接池
import org.apache.commons.dbcp.PoolingDriver;
使用dbcp做为数据库连接池
import org.apache.commons.dbcp.PoolableConnectionFactory;
使用dbcp做为数据库连接池
import org.apache.commons.dbcp.DriverManagerConnectionFactory;
使用dbcp做为数据库连接池
使用dbcp做为数据库连接池使用dbcp做为数据库连接池
public class DaoUtil {
使用dbcp做为数据库连接池    
使用dbcp做为数据库连接池使用dbcp做为数据库连接池    
/**
使用dbcp做为数据库连接池     * 数据库连接池
使用dbcp做为数据库连接池     * 
@see http://jakarta.apache.org/commons/dbcp/index.html
使用dbcp做为数据库连接池     
*/

使用dbcp做为数据库连接池    
private static PoolingDriver driver = null;
使用dbcp做为数据库连接池    
使用dbcp做为数据库连接池   
使用dbcp做为数据库连接池使用dbcp做为数据库连接池    
/**
使用dbcp做为数据库连接池     * 设置一个数据库连接池
使用dbcp做为数据库连接池     * 
使用dbcp做为数据库连接池     * 
@param name 连接池的名称
使用dbcp做为数据库连接池     * 
@param url 数据源
使用dbcp做为数据库连接池     * 
@throws SQLException
使用dbcp做为数据库连接池     
*/

使用dbcp做为数据库连接池使用dbcp做为数据库连接池    
private static void setUpDriverPool(String name, String url) throws SQLException{
使用dbcp做为数据库连接池使用dbcp做为数据库连接池        
if ((driver == null|| driver.getPoolNames().length < 2{
使用dbcp做为数据库连接池使用dbcp做为数据库连接池            
try {
使用dbcp做为数据库连接池使用dbcp做为数据库连接池                
/**
使用dbcp做为数据库连接池                 * 首先创建一个对象池来保存数据库连接
使用dbcp做为数据库连接池                 * 
使用dbcp做为数据库连接池                 * 使用 commons.pool 的 GenericObjectPool对象
使用dbcp做为数据库连接池                 
*/

使用dbcp做为数据库连接池                ObjectPool connectionPool 
= new GenericObjectPool();
使用dbcp做为数据库连接池                
使用dbcp做为数据库连接池使用dbcp做为数据库连接池                
/**
使用dbcp做为数据库连接池                 * 创建一个 DriverManagerConnectionFactory对象
使用dbcp做为数据库连接池                 * 连接池将用它来获取一个连接
使用dbcp做为数据库连接池                 
*/

使用dbcp做为数据库连接池                ConnectionFactory connectionFactory 
= new DriverManagerConnectionFactory(url, null);
使用dbcp做为数据库连接池                
使用dbcp做为数据库连接池使用dbcp做为数据库连接池                
/**
使用dbcp做为数据库连接池                 * 创建一个PoolableConnectionFactory 对象。
使用dbcp做为数据库连接池                 
*/

使用dbcp做为数据库连接池                PoolableConnectionFactory poolableConnectionFactory 
= 
使用dbcp做为数据库连接池                    
new PoolableConnectionFactory(connectionFactory,connectionPool,null,null,false,true);
使用dbcp做为数据库连接池                
使用dbcp做为数据库连接池使用dbcp做为数据库连接池                
/**
使用dbcp做为数据库连接池                 * 注册PoolingDriver。
使用dbcp做为数据库连接池                 
*/

使用dbcp做为数据库连接池                Class.forName(
"org.apache.commons.dbcp.PoolingDriver");
使用dbcp做为数据库连接池                
使用dbcp做为数据库连接池                driver 
= (PoolingDriver) DriverManager.getDriver("jdbc:apache:commons:dbcp:");
使用dbcp做为数据库连接池                
使用dbcp做为数据库连接池                driver.registerPool(name,  connectionPool);
使用dbcp做为数据库连接池                
使用dbcp做为数据库连接池            }

使用dbcp做为数据库连接池使用dbcp做为数据库连接池            
catch (ClassNotFoundException e) {
使用dbcp做为数据库连接池                
throw new RuntimeException(e);
使用dbcp做为数据库连接池            }

使用dbcp做为数据库连接池        }

使用dbcp做为数据库连接池    }

使用dbcp做为数据库连接池    
使用dbcp做为数据库连接池使用dbcp做为数据库连接池    
/**
使用dbcp做为数据库连接池     * 关闭所有数据库连接池
使用dbcp做为数据库连接池     *
使用dbcp做为数据库连接池     
*/

使用dbcp做为数据库连接池使用dbcp做为数据库连接池    
public static void shutDownDriver() {
使用dbcp做为数据库连接池        
使用dbcp做为数据库连接池使用dbcp做为数据库连接池        
try {          
使用dbcp做为数据库连接池            PoolingDriver driver 
= (PoolingDriver)DriverManager.getDriver("jdbc:apache:commons:dbcp:");
使用dbcp做为数据库连接池使用dbcp做为数据库连接池            
for (int i = 0; i < poolNames.length; i++{
使用dbcp做为数据库连接池                driver.closePool(
"pool");
使用dbcp做为数据库连接池            }

使用dbcp做为数据库连接池        }

使用dbcp做为数据库连接池使用dbcp做为数据库连接池        
catch (SQLException sqle) {
使用dbcp做为数据库连接池            
throw new RuntimeException(sqle);
使用dbcp做为数据库连接池        }

使用dbcp做为数据库连接池    }

使用dbcp做为数据库连接池
使用dbcp做为数据库连接池使用dbcp做为数据库连接池    
/**
使用dbcp做为数据库连接池     * 取得一个数据库连接对象。
使用dbcp做为数据库连接池     * 
使用dbcp做为数据库连接池     * 因为可能使用两个不同的数据库,
使用dbcp做为数据库连接池     * 所以依据report的值来确定使用那个数据库。
使用dbcp做为数据库连接池     * 
使用dbcp做为数据库连接池     * 
@param report
使用dbcp做为数据库连接池     * 
@return
使用dbcp做为数据库连接池     
*/

使用dbcp做为数据库连接池使用dbcp做为数据库连接池    
public static Connection getConnection() {
使用dbcp做为数据库连接池        Connection con 
= null;
使用dbcp做为数据库连接池        
使用dbcp做为数据库连接池使用dbcp做为数据库连接池        
try {
使用dbcp做为数据库连接池            
//装载mysql的jdbc驱动
使用dbcp做为数据库连接池
            String driver = "com.mysql.jdbc.Driver";
使用dbcp做为数据库连接池            String url 
= "jdbc:mysql://server/db?user=root";
使用dbcp做为数据库连接池            String poolName 
= "pool";
使用dbcp做为数据库连接池            Class.forName(driver);
使用dbcp做为数据库连接池            setUpDriverPool(poolName, url);
使用dbcp做为数据库连接池
使用dbcp做为数据库连接池            con 
= DriverManager.getConnection("jdbc:apache:commons:dbcp:" + poolName);
使用dbcp做为数据库连接池            
return con;
使用dbcp做为数据库连接池        }

使用dbcp做为数据库连接池使用dbcp做为数据库连接池        
catch (ClassNotFoundException cnfe) {
使用dbcp做为数据库连接池            
throw new RuntimeException("无法装入数据库引擎") ;
使用dbcp做为数据库连接池        }
 
使用dbcp做为数据库连接池使用dbcp做为数据库连接池        
catch (SQLException sqle) {
使用dbcp做为数据库连接池            
throw new RuntimeException("无法打开数据库连接");
使用dbcp做为数据库连接池        }

使用dbcp做为数据库连接池    }

使用dbcp做为数据库连接池    
使用dbcp做为数据库连接池使用dbcp做为数据库连接池    
/**
使用dbcp做为数据库连接池     * 执行清理过程
使用dbcp做为数据库连接池     * 
使用dbcp做为数据库连接池     * <li>关闭数据库连接</li>
使用dbcp做为数据库连接池     * <li>关闭语句对象</li>
使用dbcp做为数据库连接池     * <li>关闭结果集</li>
使用dbcp做为数据库连接池     * 
使用dbcp做为数据库连接池     * 
@param con
使用dbcp做为数据库连接池     * 
@param s
使用dbcp做为数据库连接池     * 
@param rs
使用dbcp做为数据库连接池     
*/

使用dbcp做为数据库连接池使用dbcp做为数据库连接池    
public static void closeAll(Connection con, Statement s, ResultSet rs) {
使用dbcp做为数据库连接池使用dbcp做为数据库连接池        
try {
使用dbcp做为数据库连接池使用dbcp做为数据库连接池            
if (rs != null{
使用dbcp做为数据库连接池                rs.close();
使用dbcp做为数据库连接池                rs 
= null;
使用dbcp做为数据库连接池            }

使用dbcp做为数据库连接池            
使用dbcp做为数据库连接池使用dbcp做为数据库连接池            
if (s != null{
使用dbcp做为数据库连接池                s.close();
使用dbcp做为数据库连接池                s 
= null;
使用dbcp做为数据库连接池            }

使用dbcp做为数据库连接池            
使用dbcp做为数据库连接池使用dbcp做为数据库连接池            
if (con != null{
使用dbcp做为数据库连接池                con.close();
使用dbcp做为数据库连接池                con 
= null;
使用dbcp做为数据库连接池            }

使用dbcp做为数据库连接池        }
 
使用dbcp做为数据库连接池使用dbcp做为数据库连接池        
catch (SQLException sqle) {
使用dbcp做为数据库连接池            
//nothing to do, forget it;
使用dbcp做为数据库连接池
        }

使用dbcp做为数据库连接池    }

使用dbcp做为数据库连接池    
使用dbcp做为数据库连接池}