[유용한 Database Connection Pool 관련 java 코드 4-연재] 개발자가 정의하는 Database Connection Pool

지금까지 database connection pool의 구조에 대해서 설명하였습니다.
여러개의 database를 동시에 연결하기 위한 구조로
connection manager에서는 connection pool을 관리하고
connection pool에서는 connection들을 관리하는 구조였습니다.

WDDBConnectionManager
-> WCDBConnectionPool : database AAA
    -> WCDBConnection -> Connection
    -> WCDBConnection -> Connection
-> WCDBConnectionPool : database BBB
    -> WCDBConnection -> Connection
    -> WCDBConnection -> Connection

개발자가 원하는 database connection pool을 사용는 경우 어떻게 해야 하는지 설명하겠습니다.
위의 database connection pool 기법은 WAS(Web Application Server)에 상관없이 사용이 가능합니다.
그러나 어떤 시스템의 경우 WAS에서 제공하는 database connection pool을 꼭 사용하기를 원하는 경우도 있을 것입니다.
필자가 격은 경우는 고객의 Web Server에 Jeus WAS가 설치되어 있고 꼭 Jeus Database Connection Pool을
쓰고 싶다는 이유였습니다.

WCDBConnectionManager에 소속되면서 connection을 생성하고 release하는 connection pool을
사용자가 개발한 code는 아래와 같습니다.
WCDBConnectionPool로 부터 상속받아야 합니다. 그래야 WCDBConnectionManager 여기서 관리가
가능합니다.
아래의 소스코드는 성능이 매우 느립니다. 말이 connection pool이지
connection을 요청할때 마다 connection pool을 생성하고 release하면 바로 free하는 방식입니다.
하지만 개발자의 이해를 돕기 위해서 일부러 아래와 같이 코딩을 하였습니다.

-- user defined connection pool 소스 시작
package wdl;

import java.io.*;
import java.sql.*;
import java.util.*;
import java.util.Date;

public class UserDefinedConnectionPool extends WCDBConnectionPool
{
  public UserDefinedConnectionPool()
  {
   super();
  }

  public synchronized WCDBConnection getConnection()
  {
   Connection oConn = null;
   WCDBConnection oDBConn = null;
   try
   {
    String sUrl = "jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8";
    String sUser = "root";
    String sPassword = "";
    oConn = DriverManager.getConnection(sUrl, sUser, sPassword);
    oDBConn = new WCDBConnection(this);
    oDBConn.setConnection(oConn);
   }
   catch (SQLException e)
   {
    return null;
   }
   return oDBConn;
  }

  public synchronized void freeConnection(WCDBConnection oDBConn)
  {
   oDBConn.close();
   Connection oConn = oDBConn.getConnection();
   oDBConn.setConnection(null);
  }

  public synchronized Driver registerDriver(String sDriverName)
  {
   try
   {
    String sDriverName2 = "org.gjt.mm.mysql.Driver";
    Driver oDriver = (Driver)Class.forName(sDriverName2).newInstance();
    DriverManager.registerDriver(oDriver);
    return oDriver;
   }
   catch (Exception ex)
   {
   }
   return null;
  }
}
-- user defined connection pool 소스 끝

위의 소스를 사용하면 자동으로 아래와 같은 connection pool 구조가 됩니다.

WDDBConnectionManager
-> UserDefinedConnectionPool : database AAA
    -> WCDBConnection -> Connection
    -> WCDBConnection -> Connection
-> UserDefinedConnectionPool : database BBB
    -> WCDBConnection -> Connection
    -> WCDBConnection -> Connection

아래의 sample code는 user define connection pool을 호출하는 JSP code입니다.

-- user defined connection pool 호출 JSP Code 시작

<%@ page language="java" import="wdl.*,wdl.board.*,wdl.board.*,java.util.*,java.sql.*,java.lang.*,
java.io.*,java.io.File " contentType="text/html; charset=EUC-KR"%>
<%
WCProperties rRcd = new WCProperties();
String sDsn = "UserDefinedConnectionPool";
rRcd.setValue("UserDefinedConnectionPool.dsn","UserDefinedConnectionPool");
rRcd.setValue("UserDefinedConnectionPool.databasetype","oracle");
rRcd.setValue("UserDefinedConnectionPool.connectionPoolClassName","wdl.UserDefinedConnectionPool");
WCDBConnectionManager.getInstance().removePool(sDsn);
WCDBConnectionManager.getInstance().createPool(sDsn,rRcd);

String sSql = "select * from tb_board";
WCDBConnection oDBConn = WCDBConnectionManager.getInstance().getConnection("UserDefinedConnectionPool");
Connection oConn = oDBConn.getConnection();
Vector vRet = executeQuery(oConn,sSql,sDsn);
WCDBConnectionManager.getInstance().freeConnection(sDsn,oDBConn);
if (vRet != null)
{
  int nSize = vRet.size();
  for (int i=0;i<nSize;i++)
  {
   Properties oProp = (Properties)vRet.elementAt(i);
   Enumeration oEnum = oProp.propertyNames();
   while (oEnum.hasMoreElements())
   {
    String sProp = (String)oEnum.nextElement();
    String sValue = oProp.getProperty(sProp);
    %>
    <%=sProp%> = <%=sValue%><br>
    <%
   }
  }
}
%>
<%!
public Vector executeQuery(Connection oConn,String sSql, String sDsn)
{
  PreparedStatement ps = null;
  ResultSet rs = null;
  try
  {
   Vector vRet = new Vector();
   int nValue;
   String sProp, strValue, strType;
   ps = oConn.prepareStatement(sSql);
   if (ps == null)
   {
    return null;
   }
   ps.setFetchSize(0);
   ps.setMaxRows(0);
   rs = ps.executeQuery();
   if (rs == null)
   {
    ps.close();
    return null;
   }
   ResultSetMetaData meta = rs.getMetaData();
   if (meta == null)
   {
    if (rs != null)
     rs.close();
    ps.close();
   }
   int nCount = 0;
   while (rs.next())
   {
    Properties oProp = new Properties();
    nCount = meta.getColumnCount();
    for (int i=1;i <= nCount;i++)
    {
     sProp = WCString.toLower(meta.getColumnName(i));
     strValue = WCString.nullCheck(rs.getString(i),"");
     oProp.setProperty(sProp,strValue);
    }
    WCVector.addElement(vRet,oProp);
    nCount ++;
   }
   rs.close();
   ps.close();
   return vRet;
  }
  catch(Exception e)
  {
   try
   {
    if (rs != null)
     rs.close();
    ps.close();
   }
   catch(SQLException sql)
   {
   }
  }
  return null;
}
%>
-- user defined connection pool 호출 JSP Code 끝

WCDBConnectionManager에서 하는 일은 간단합니다.
단순히 WCDBConnectionPool class의 object를 생성하고 저장하는 역할을 합니다.

sample code의 이해를 돕기 위해서
select query를 실행하는
public Vector executeQuery(Connection oConn,String sSql, String sDsn) 함수를 만들었습니다.

JSP 코드에서 보듯이 WCDBConnectionManager에서
WCDBConnectionManager.getInstance().createPool(sDsn,rRcd);을 호출하여 user defined connection pool을 생성합니다.
rRcd는 WCProperties로서 우선 Properties와 동일한 기능을 한다고 생각하십시요.
(추후 차차 WCProperties에 대해서 설명하겠습니다.)
rRcd.setValue("UserDefinedConnectionPool.connectionPoolClassName","wdl.UserDefinedConnectionPool");
connection pool의 class name을 이렇게 등록하면 WCDBConnectionPool로 부터 상속받은
UserDefinedConnectionPool object가 만들어 집니다.

아래의 코드는 WCDBConnectionManager에서 WCDBConnectionPool class의 object를 생성하는 함수입니다.
(아래의 소스코드는 WCDBConnectionManager.java의 일부분을 발췌한것입니다.)

사용자가 전달한 class 이름을 사용하여 object를 생성할 수도 있고
사용자가 정의하지 않았다면 default로 "wdl.WCDBConnectionPool"를 사용하여 Pool을 생성합니다.

WCDBConnectionPool oPool = (WCDBConnectionPool)Class.forName(sClassName).newInstance();

-- WCDBConnectionManager.java 소스 일부분 시작
public WCDBConnectionPool createPoolObject(String sName,String sConnectionPoolClassName)
{
try
{
  String sClassName = "wdl.WCDBConnectionPool";
  if (!WCString.isEmpty(sConnectionPoolClassName))
  {
   sClassName = sConnectionPoolClassName;
  }
  WCProperties rEnv = WCEnv.getInstance().getProperties();
  if (WCString.parseBoolean(rEnv.getStrValue("wdl.init.verbose")) == true)
  {
   WCLog.getInstance().printLog("WCDBConnectionManager.java createPool : dsn="+sName+",connection pool name="+sClassName+"");
  }
  WCDBConnectionPool oPool = (WCDBConnectionPool)Class.forName(sClassName).newInstance();
  oPool.setName(sName);
  return oPool;
}
catch (Exception ex)
{
  WCLog.getInstance().printLog("exception at WCDBConnectionManager.createPool "+ex.toString());
}
return null;
}
-- WCDBConnectionManager.java 소스 일부분 끝

아래의 4개의 source code를 첨부합니다. 모두 제가 test를 한 sample입니다.

WCDBConnection.java
WCDBConnectionPool.java
WCDBConnectionManager.java
UserDefinedConnectionPool.java
user_defined_database_connection_pool.jsp

아래의 소스가 완벽히 돌기 위해서는 WCProperties,WCVector,WCLog,WCSystem 등의 source코드가 필요합니다.
이러한 소스코드도 모두 차차 글을 올리며 설명하겠습니다.
미리 보시려면 Web Development Library(www.webdevlib.net)에서 download 받아 사용하실 수 있습니다.

출처 : 고급 웹 UI 개발 라이브러리 Web Development Library 소스공개 : http://www.webdevlib.net