DBCP 数据连接池的配置和使用

字体大小: 中小 标准 ->行高大小: 标准

DBCP(DataBase connection pool),数据库连接池。是 apache 上的一个 java 连接池项目,也是 tomcat 使用的连接池组件。

单独使用dbcp需要3个包:common-dbcp.jar,common-pool.jar,common-collections.jar

由于建立数据库连接是一个非常耗时耗资源的行为,所以通过连接池预先同数据库建立一些连接,放在内存中,应用程序需要建立数据库连接时直接到连接池中申请一个就行,用

完后再放回去。


获取数据库连接的类:DbcpConnection.java

 

  1. import java.io.FileInputStream;  
  2. import java.io.FileNotFoundException;  
  3. import java.io.IOException;  
  4. import java.sql.Connection;  
  5. import java.sql.SQLException;  
  6. import java.util.Properties;  
  7.   
  8. import javax.sql.DataSource;  
  9. import org.apache.commons.dbcp.BasicDataSource;  
  10. public class DbcpConnection {  
  11.     private static DataSource dataSource;  
  12.     private static Connection connection;  
  13.       
  14.     public static void initDataSource(){  
  15.         FileInputStream is = null;  
  16.         Properties properties = new Properties();  
  17.           
  18.         String driverClassName = null;  
  19.         String url = null;  
  20.         String username = null;  
  21.         String password = null;  
  22.           
  23.         int initialSize = 0;  
  24.         int minIdle = 0;  
  25.         int maxIdle = 0;  
  26.         int maxWait = 0;  
  27.         int maxActive = 0;  
  28.           
  29.         try {  
  30.             String path = System.getProperty("user.dir")+"\\src\\com\\xiami\\db\\connection\\";  
  31.             is = new FileInputStream(path+"dbcp.properties");  
  32.             properties.load(is);  
  33.               
  34.             driverClassName = properties.getProperty("dbcp.driverClassName");  
  35.             url = properties.getProperty("dbcp.url");  
  36.             username = properties.getProperty("dbcp.username");  
  37.             password = properties.getProperty("dbcp.password");  
  38.             initialSize = Integer.parseInt((properties.getProperty("dbcp.initialSize").trim()));  
  39.             minIdle = Integer.parseInt((properties.getProperty("dbcp.minIdle")).trim());  
  40.             maxIdle = Integer.parseInt((properties.getProperty("dbcp.maxIdle")).trim());  
  41.             maxWait = Integer.parseInt((properties.getProperty("dbcp.maxWait")).trim());  
  42.             maxActive = Integer.parseInt((properties.getProperty("dbcp.maxActive")).trim());  
  43.               
  44.         } catch (FileNotFoundException e) {  
  45.             e.printStackTrace();  
  46.         } catch (IOException ioe){  
  47.             ioe.printStackTrace();  
  48.         }finally{  
  49.             try {  
  50.                 is.close();  
  51.             } catch (IOException e) {  
  52.                 // TODO Auto-generated catch block  
  53.                 e.printStackTrace();  
  54.             }  
  55.         }  
  56.         BasicDataSource bds = new BasicDataSource();  
  57.           
  58.         bds.setUrl(url);  
  59.         bds.setDriverClassName(driverClassName);  
  60.         bds.setUsername(username);  
  61.         bds.setPassword(password);  
  62.         bds.setInitialSize(initialSize);  
  63.         bds.setMaxActive(maxActive);  
  64.         bds.setMinIdle(minIdle);  
  65.         bds.setMaxIdle(maxIdle);  
  66.         bds.setMaxWait(maxWait);  
  67.           
  68.         dataSource = bds;  
  69.     }  
  70.       
  71.     public static Connection  getConnection() throws  SQLException {  
  72.         if (dataSource == null) {     
  73.             initDataSource();     
  74.         }     
  75.         Connection conn = null;     
  76.         if (dataSource != null) {     
  77.             conn = dataSource.getConnection();     
  78.         }     
  79.         return conn;     
  80.     }  
  81. }  


 

连接数据库信息的配置文件:dbcp.properties

 

  1. dbcp.driverClassName=com.ibm.db2.jcc.DB2Driver  
  2. dbcp.url=jdbc\:db2\://192.168.3.11\:50000/DBNAME  
  3. dbcp.username=db2admin  
  4. dbcp.password=password  
  5. dbcp.initialSize=30    
  6. dbcp.minIdle=10   
  7. dbcp.maxIdle=10    
  8. dbcp.maxWait=1000   
  9. dbcp.maxActive=30   


 

在Service层使用的时候:ZhiDianJieDu.java (业务逻辑处理的类)

 

  1. import java.sql.Connection;  
  2. import java.sql.PreparedStatement;  
  3. import java.sql.ResultSet;  
  4. import java.sql.SQLException;  
  5.   

此文章由 http://www.ositren.com 收集整理 ,地址为: http://www.ositren.com/htmls/70232.html