1 jdbc.driver=com.mysql.jdbc.Driver
2 jdbc.url=jdbc:mysql://localhost:3306/csdn
3 jdbc.user=root
4 jdbc.password=123456
5 initsize=1
6 maxactive=1
7 maxwait=5000
8 maxidle=1
9 minidle=1

  1 package com.daliu.jdbc;
  2
  3 import java.io.InputStream;
  4 import java.sql.Connection;
  5 import java.sql.SQLException;
  6 import java.util.Properties;
  7
  8 import org.apache.commons.dbcp.BasicDataSource;
  9
 10 /**
 11  * 使用连接池技术管理数据库连接
 12  */
 13 public class DBUtil {
 14
 15     //数据库连接池
 16     private static BasicDataSource dbcp;
 17
 18     //为不同线程管理连接
 19     private static ThreadLocal<Connection> tl;
 20
 21     //通过配置文件来获取数据库参数
 22     static{
 23         try{
 24             Properties prop
 25                 = new Properties();
 26
 27             InputStream is
 28                 = DBUtil.class.getClassLoader()
 29                   .getResourceAsStream(
 30                           "com/daliu/jdbc/db.properties");
 31
 32             prop.load(is);
 33             is.close();
 34
 35             //一、初始化连接池
 36             dbcp = new BasicDataSource();
 37
 38
 39             //设置驱动 (Class.forName())
 40             dbcp.setDriverClassName(prop.getProperty("jdbc.driver"));
 41             //设置url
 42             dbcp.setUrl(prop.getProperty("jdbc.url"));
 43             //设置数据库用户名
 44             dbcp.setUsername(prop.getProperty("jdbc.user"));
 45             //设置数据库密码
 46             dbcp.setPassword(prop.getProperty("jdbc.password"));
 47             //初始连接数量
 48             dbcp.setInitialSize(
 49                     Integer.parseInt(
 50                             prop.getProperty("initsize")
 51                     )
 52             );
 53             //连接池允许的最大连接数
 54             dbcp.setMaxActive(
 55                     Integer.parseInt(
 56                             prop.getProperty("maxactive")
 57                     )
 58             );
 59             //设置最大等待时间
 60             dbcp.setMaxWait(
 61                     Integer.parseInt(
 62                             prop.getProperty("maxwait")
 63                     )
 64             );
 65             //设置最小空闲数
 66             dbcp.setMinIdle(
 67                     Integer.parseInt(
 68                             prop.getProperty("minidle")
 69                     )
 70             );
 71             //设置最大空闲数
 72             dbcp.setMaxIdle(
 73                     Integer.parseInt(
 74                             prop.getProperty("maxidle")
 75                     )
 76             );
 77             //初始化线程本地
 78             tl = new ThreadLocal<Connection>();
 79         }catch(Exception e){
 80             e.printStackTrace();
 81         }
 82     }
 83
 84     /**
 85      * 获取数据库连接
 86      * @return
 87      * @throws SQLException
 88      */
 89     public static Connection getConnection() throws SQLException{
 90         /*
 91          * 通过连接池获取一个空闲连接
 92          */
 93         Connection conn
 94                     = dbcp.getConnection();
 95         tl.set(conn);
 96         return conn;
 97     }
 98
 99
100     /**
101      * 关闭数据库连接
102      */
103     public static void closeConnection(){
104         try{
105             Connection conn = tl.get();
106             if(conn != null){
107                 /*
108                  * 通过连接池获取的Connection
109                  * 的close()方法实际上并没有将
110                  * 连接关闭，而是将该链接归还。
111                  */
112                 conn.close();
113                 tl.remove();
114             }
115         }catch(Exception e){
116             e.printStackTrace();
117         }
118     }
119
120     /**
121      * 测试是否连接成功
122      * @param args
123      * @throws SQLException
124      */
125     public static void main(String[] args) throws SQLException {
126         System.out.println(getConnection());
127     }
128 }