開發的時候常常會需要對資料庫進行一些操作，比如說常見的增刪改查之類的，當資料量小的時候，可以直接進行操作，但是當資料量增多的時候，每一次連接以及釋放資料庫都會耗費一定的時間，這個時候，可以採用資料庫連接池來保持資料庫的鏈接，減少連接資料庫對程式帶來的開銷，並且可以減少資料庫的壓力，那麼資料庫連結池是一個什麼樣的東西呢？顧名思義，它是一個池子，池子裡放的是對數據庫的鏈接，打個比方魚塘，就是養魚的池子，想要吃魚可以直接去撈，不用自己去親自的買魚苗等，數據庫連接池就是放的對於數據庫的鏈接，統一的把所有的鏈接都給建立好了，用的時候就可以直接的從裡面去取，用完了之後放回池子裡就可以，既然用這個東西，那麼我們也沒必要完全自己去寫程式碼實現，有些開源的可以直接用，常見的有三種開源的連接池，c3p0，dbcp，proxool這三種，對於c3p0、proxool這兩種沒用過，只是簡單的用過dbcp的池子，在此講下如何使用dbcp資料庫連接池，以及使用的時候遇到的一些坑
圖1、使用連接池之前
圖2 使用連線池之後
如上圖1所示，在使用連線池之前，需要每次都對資料庫建立鏈接，並且需要隨時進行釋放，在資料量大的情況下，需要很大的連接資料庫的開銷，並且頻繁的對資料庫進行訪問以及釋放，也會對資料庫造成很大的壓力，圖2為使用資料庫連接池之後，將所有的鏈接放在池子裡，不進行釋放，當用的時候直接從池子裡去取，用完之後放回池子裡，池子保持對數據庫的長鏈接，連結斷開會進行自動重連，如果連接不夠那麼對應後來的用戶就需要進行等待
包含tomcat-dbcp.jar即可，剩下的都是一些基礎包
dbname.Driver=com.mysql.jdbc.Driver dbname.Url=jdbc:mysql://<your ip>/<your dbname>?useUnicode=true&characterEncoding=UTF-8 &autoReconnect=true&failOverReadOnly=false&maxReconnects=10&autoReconnectForPools=true&zeroDateTimeBehavior=convertToNull&connectTimeout=3000 dbname.Username=<your username> dbname.Password=<your password> dbname.InitialSize=15 dbname.MinIdle=10 dbname.MaxIdle=20 dbname.MaxWait=5000 dbname.MaxActive=20 dbname.validationQuery=select 1
其中這些配置只需要放在
其中driver，url，username，password為常見的資料庫連接的配置
##
InitialSize为初始化建立的连接数
minidle为数据库连接池中保持的最少的空闲的链接数
maxidle数据库连接池中保持的最大的连接数
maxwait等待数据库连接池分配连接的最长时间，超出之后报错
maxactivite最大的活动链接数，如果是多线程可以设置为超出多线程个数个链接数
<pre name="code" class="java">validationQuery测试是否连接是有效的sql语句
public abstract class DB {
private static HashMap<String, DataSource> dsTable = new HashMap<String, DataSource>();//此处记得用static
private BasicDataSource ds;
private PreparedStatement stmt = null;
private DataSource getDataSource(String n) {
if (dsTable.containsKey(n)) {
return dsTable.get(n);//如果不同的数据库，多个连接池
} else {
synchronized (dsTable) {
ds = new BasicDataSource();
ds.setDriverClassName(DBConfig.getString("db", n.concat(".Driver")));//将<yourname>.properties的值读进来
ds.setUrl(DBConfig.getString("db", n.concat(".Url")));
ds.setUsername(DBConfig.getString("db", n.concat(".Username")));
ds.setPassword(DBConfig.getString("db", n.concat(".Password")));
ds.setInitialSize(DBConfig.getInteger("db", n.concat(".InitialSize")));
ds.setMinIdle(DBConfig.getInteger("db", n.concat(".MinIdle")));
ds.setMaxIdle(DBConfig.getInteger("db", n.concat(".MaxIdle")));
ds.setMaxWait(DBConfig.getInteger("db", n.concat(".MaxWait")));
ds.setMaxActive(DBConfig.getInteger("db", n.concat(".MaxActive")));
ds.setValidationQuery(DBConfig.getString("db", n.concat(".validationQuery")));
dsTable.put(n, ds);
return ds;
}
}
}
protected Connection conn;
public boolean open() throws SQLException {
BasicDataSource bds=(BasicDataSource)this.getDataSource(this.getConnectionName());
System.out.println("connection_number:"+bds.getNumActive()+"dsTable:"+dsTable);
this.conn = this.getDataSource(this.getConnectionName()).getConnection();
return true;
}
public void close() throws SQLException {
if (this.conn != null)
this.conn.close();
}
protected abstract String getConnectionName();//此函数可以根据自己的需求，将数据库的名字传进来即可
public void prepareStatement(String sql) throws SQLException {
this.stmt = this.conn.prepareStatement(sql);
}
public void setObject(int index, Object value, int type) throws SQLException {
this.stmt.setObject(index, value, type);
}
public void setObject(int index, Object value) throws SQLException {
this.stmt.setObject(index, value);
}
public int execute() throws SQLException {
return this.stmt.executeUpdate();
}
}
ps aux|grep <your java name>
netstat -apn|grep <your processid>
#
