java application standalone org.apache.commons.dbcp.BasicDataSource

Tomcat에서도 쓰이고 있는 유명한 DB Connection Pool Library인 DBCP를 일반 StandAlone 형태의 Application에서쓸 일이 생겼다.



보통 WAS에 같이 사용되는지라 WAS에서의 세팅(JNDI를 사용)하는 예저는 많았으나 일반 Application 예제는 잘 보이지 않아서 DBCP 사이트의 Example 파일을 참고하여 테스트 해 본 다음에 사용했다.(첨부파일 참조)



예제 파일을 보면 크게 네 부분으로 나눠볼 수 있다.

DBCP를 설정하는 부분, 사용하는 부분, 종료하는 부분, 현재 사용현황을 보는 부분이다.

각 부분에 대해서 내가 사용한 소스는 다음과 같다.

(기본적으로 첨부한 소스를 참고로 하여 사용하였으므로 같이 참고하는게 좋을듯..)




1. DBCP 설정부분


private static void setupDriver() {

try {

/*

* 일반적인 Object Pool을 생성한다.

* MAX_ACTIVE : Active 가능한 최대 object 갯수(필요에 따라 정한다.)

* GenericKeyedObjectPool.WHEN_EXHAUSTED_BLOCK : Pool이 가득 차면 다음

* 이전 객체가 return 될 때까지 block 하고 기다린다.

* MAX_WAIT : Block 시 기다릴 최대 시간(ms, 필요에 따라 정한다.)

* MAX_IDLE : 최대한 유지할 idle object의 갯수. 지정된 이상 남으면 폐기한다.

* (필요에 따라 정한다.)

*/

connPool = new GenericObjectPool(null, MAX_ACTIVE,

GenericKeyedObjectPool.WHEN_EXHAUSTED_BLOCK,

MAX_WAIT, MAX_IDLE);

/*

* 연결할 DB의 URL, User명, Password를 세팅한다.

*/

ConnectionFactory connectionFactory =

new DriverManagerConnectionFactory(ServerConnector.getDatabaseUrl(),

ServerConnector.getMisUser(),

ServerConnector.getDatabasePassword());

/*

* ConnectionPool Factory를 생성한다.

* PoolableConnectionFactory(ConnectionFactory connFactory,

* ObjectPool pool, KeyedObjectPoolFactory stmtPoolFactory,

* String validationQuery, boolean defaultReadOnly, boolean defaultAutoCommit)

*/

new PoolableConnectionFactory(connectionFactory, connPool, null, null,

false, true);

/*

* Pool Driver를 로딩한다.(org.apache.commons.dbcp.PoolingDriver)

*/

Class.forName(POOLING_DRIVER);

/*

* DB Driver를 로딩한다.(oracle.jdbc.driver.OracleDriver)

*/

Class.forName(ORACLE_DRIVER);

/*

* Pooling Driver를 로딩한다.(jdbc:apache:commons:dbcp:)

*/

PoolingDriver driver = (PoolingDriver) DriverManager.getDriver(DRIVER_URL);

/*

* driver를 등록한다.(본인이 지정한 이름)

*/

driver.registerPool(POOL_NAME, connPool);

CommonLogger.getAllLogger().info("DB Connection setup completed.");

} catch (Throwable th) {

}

}


2. DBCP 사용하는 방법

연결된 Connection Pool을 사용할 때에는 일반적인 JDBC 프로그램과 같이 사용한다



public static Connection getConnection() {

try {

/*

* 각 변수가 의미하는 바는 1번 예제 참조

*/

return DriverManager.getConnection(DRIVER_URL + POOL_NAME);

} catch (Exception e) {

logger.error("Error getting Connection.", e);

return null;

}

}

참고로 사용하던 DBCP를 리턴할 경우에도 일반 JDBC 프로그래밍 하듯이 connection.close를 사용할 수 있다.




3. DBCP 사용 종료하는 부분

더이상 해당 Connection Pool을 사용하지 않을 때에는 다음과 같이 종료한다.



public static void shutdownDriver() throws Exception {

PoolingDriver driver = (PoolingDriver) DriverManager.getDriver(DRIVER_URL);

driver.closePool(POOL_NAME);

}






4. DBCP 사용현황을 출력하는 부분

1 번에서 생성한 connPool 객체를 이용한 사용량 체크

- 현재 Active 상태에 있는 Connection의 수 : connPool.getNumActive()

- 현재 놀고 있는(Idle) Connection의 수 : connPool.getNumIdle()

ManualPoolingDriverExample.java