程式師世界 >> 數據庫知識 >> Oracle數據庫 >> Oracle數據庫基礎 >> 利用Oracle自帶的連接緩沖類的一個例子

利用Oracle自帶的連接緩沖類的一個例子

編輯：Oracle數據庫基礎

import Java.sql.Connection;
import oracle.jdbc.pool.OracleConnectionCacheImpl; /**
* 連接池管理類
*/
public class DBPool {

/** 連接池 */
private static OracleConnectionCacheImpl pool = null;

/**
* 初始化連接池
*/
public static void init() {

try{
String user = "user"; //用戶名
String passWord = "pwd"; //密碼
String host = "127.0.0.1"; //Server地址
String port = "1521"; //端口
String sid = "Oracle92"; //SID
int max = 20; //最大連接數
int min = 5; //最小連接數

//拼連接字符串
String url = "jdbc:Oracle:thin:@" + host + ":" + port + ":" + sid;

//實例化連接池並設置參數
pool = new OracleConnectionCacheImpl();
pool.setURL(url);
pool.setPassword(passWord);
pool.setUser(user);
pool.setMaxLimit(max);
pool.setMinLimit(min);

/**
* 設置連接數超限時增加方式.
* DYNAMIC_SCHEME:是動態增加.用完如果超過上限則關掉.
* 還有兩個.1.直接返回Null .2.始終等待
*/
pool.setCacheScheme(OracleConnectionCacheImpl.DYNAMIC_SCHEME);

/**
* 如果你已經有個連接池了.
* 比如是OracleConnectionPoolDataSource ocpds;
* 可以直接設置.前面的設置就不用了.或者直接寫在構造器裡.
*/
//pool.setConnectionPoolDataSource(ocpds);

}catch(Exception ex) {
}

}

/**
* 終了處理.
* 比如在APP關掉前調用.
*/
public static void destory() {
if(pool != null) {
try {
pool.close();
pool = null;
}catch(Exception ex) {
}
}
}

/**
* 取連接.
* 和其他的連接一樣正常用.
* @return 連接
*/
public static Connection getConnection() {
try{
Connection conn = pool.getConnection();
return conn;
}catch(Exception e){
return null;
}
}

/**
* 調試
*/
public static void turnning() {
System.out.println("Active Conns:"+pool.getActiveSize());
System.out.println("Cached Conns:"+pool.getCacheSize());
}

}