[유용한 Database Connection Pool 관련 java 코드 1-연재] Database Connection java source WCDBConnection.java

앞으로 몇회간 연재를 하여 Java에서 database connection의 생성과
database connection pool
그리고 database connection pool의 관리를 하는 java class에 대해서 설명을 하고 소스코드를 연재하겠습니다.
그리고 SQL (select query, insert,delete,update query)의 실행하는 java class에 대해서도 설명을 하겠습니다.

JSP 혹은 Java 에서 database SQL을 실행할때 다음과 같이 3단계로 실행합니다.

- database connection을 생성
- SQL을 실행하고
- database connection을 release

그런데 위와같은 database connection의 생성과 release는 많은 시간이 걸립니다.
예를 들어 select sql을 100번 실행하면 select sql 실행 시간 보다 database connection을 생성하는
시간이 더 걸리게 됩니다.

이와 같이 SQL을 실행할때 마다 connection을 생성하는 방식은 매우 비효율 적인 방식입니다.
따라서 database connection을 미리 몇개 생성하고 이 connection을 사용하는 방식이
효과적입니다.
이 방식을 database connection pool 이라고 합니다.

또 다른 database connection pool의 필요성을 설명하겠습니다.
select sql을 실행하여 record를 database에서 읽어오면서
다른 table에 insert를 한다고 하겠습니다.
다음과 같은 프로그램이 있다고 하겠습니다.

아래의 프로그램은 java code를 가상 코드로 만든 sample code입니다.
select start;
while (true)
{
select fetch;
insert into another table;
}
select end;

select sql을 처리하면서 insert sql을 실행해야 합니다.
즉 하나의 database connection으로는 위의 프로그램을 실행 할 수가 없습니다.
따라서 2개의 connection이 필요합니다.
이와 같이 여러개의 connection을 관리할 필요가 있을때
하나의 database에 대하여 여러개의 connection을 관리하는 모듈이
database connection pool입니다.

database connection pool과 manager를 설명하기 위해서 다음과 같은 소스코드를 단계적으로 설명하겠습니다.

- WCDBConnection.java
- WCDBConnectionPool.java
- WCDBConnectionManager.java
- WCStmt.java

WCDBConnection.java 는 database Connection object를 저장하는 class입니다.
WCDBConnectionPool.java 는 하나의 database에서 여러개의 connection을 사용할 수 있도록 connection 들을 관리하는 pool입니다.
WCDBConnectionManager.java 는 database connection pool 여러개를 관리하는 class입니다.
WCStmt는 WCDBConnectionManager의 getConnection을 호출하여 Connection을 얻고 이를 사용하여 SQL을 처리하는 class 입니다.

즉 아래와 같은 구조입니다.

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

WCDBConnection class는 database connection 정보를 저장하는 Connection class와 기타 부가적인
정보를 저장하고 있습니다.
WCDBConnection member로는
Connection 정보
Connection의 상태 : free 상태인지, 사용중인지
실행중인 SQL 정보
처음 Connection이 맺어진 시간
ID

WCDBConnection의 부가적인 정보는 Connection을 보다 효과적으로 관리할 수 있습니다.
예를 들어 시스템이 죽었습니다. database가 동작하지 않는다고 하겠습니다.
개발자는 어디서 죽었는지 알수가 없습니다.
하지만 WCDBConnection에 저장된 실행중이 SQL 정보를 확인하면
현재 어떤 database에서 deadlock이 발생하여 어떤 SQL을 실행할때 시스템에 문제가 발생하는지를
빨리 알 수 있습니다.
실제로 필자는 이와 같은 실행중인 SQL monitor 기능을 사용하여 시스템의
문제점을 빨리 파악 할 수 있었습니다.
처음 connection이 맺어진 시간을 기록하는 이유는, connection을 맺고 시간이 지나면
지날 수록 connection이 broken 될 확율이 높아집니다.
예를 들어 MSSQL은 network이 broken되어도 Database Connection은 자동으로 recover됩니다.
하지만 Oracle은 recover가 되지 않습니다. 즉 일정한 시간이 지나면
Connection을 free하고 다시 Connection을 맺어주는게 효과적인 방법입니다.

이번에는 WCDBConnection.java 소스를 아래와 같이 제공합니다.
아래의 소스가 완벽히 실행하기 위해서는 WCProperties,WCVector,WCLog,WCSystem 등의 source코드가 필요합니다.
이러한 java source는 Web Development Library(www.webdevlib.net)에서 download 받아 사용하실 수 있습니다.
물론 www.webdevlib.net에서 소스코드를 받지 않고, 아래의 소스 코드를 수정하여 사용하실 수도 있습니다.
의도적으로 소스코드의 일부만 글로 쓰는 것은 아닙니다. 모든 소스에 대한 설명은 차차 하겠습니다.
이번 글에서는 WCDBConnection에 대해서만 설명하겠습니다. 다음기회에 WCProperties에 대해서도 설명을 하겠습니다.

다음번 글에는 WCDBConnectionPool class의 소스와 설명을 올리겠습니다.

- 소스코드 WCDBConnection.java

package wdl;
import java.io.*;
import java.sql.*;
import java.util.*;
import java.util.Date;
public class WCDBConnection extends Object
{
  public WCDBConnectionPool m_oPool = null;
  public String m_sSql = "";
  public Connection m_oConn = null;
  public int m_nID = 0;
  public boolean m_bFree = true;
  public long m_nConnTime = 0;
  public WCDBConnection()
  {
   m_oPool = null;
   m_sSql = null;
   m_oConn = null;
   m_nID = 0;
   m_bFree = true;
  }
  public void setFree(boolean bFree)
  {
   m_bFree = bFree;
  }
  public boolean getFree()
  {
   return isFree();
  }
  public boolean isFree()
  {
   return m_bFree;
  }
  public void setID(int nID)
  {
   m_nID = nID;
  }
  public int getID()
  {
   return m_nID;
  }
  public String getName()
  {
   if (m_oPool == null)
    return null;
   String sName = m_oPool.getName();
   return sName;
  }
  public WCDBConnection(WCDBConnectionPool oPool)
  {
   m_oPool = oPool;
  }
  public WCDBConnection(WCDBConnectionPool oPool,Connection oConn,String sSql)
  {
   m_oPool = oPool;
   m_sSql = new String(sSql);
   m_oConn = oConn;
  }
  public void setConnectionPool(WCDBConnectionPool oPool)
  {
   m_oPool = oPool;
  }
  public void setSql(String sSql)
  {
   m_sSql = sSql;
  }
  public void setConnection(Connection oConn)
  {
   m_nConnTime = new Date().getTime();
   m_oConn = oConn;
  }
  public boolean isTimeout(long nTimeout)
  {
   long nCurTime = new Date().getTime();
   long nDiff = nCurTime - m_nConnTime;
   if (nDiff >= nTimeout && nTimeout > 0)
   {
    return true;
   }
   return false;
  }
  public WCDBConnectionPool getConnectionPool()
  {
   return m_oPool;
  }
  public Connection getConnection()
  {
   return m_oConn;
  }
  public String getSql()
  {
   return m_sSql;
  }
  public void close()
  {
   try
   {
    m_oConn.close();
    m_oConn = null;
   }
   catch (SQLException ex)
   {
    WCLog.getInstance().printLog("exception at WCDBConnectionManager.close "+ex.toString());
   }
  }
  public PreparedStatement prepareStatement(String sSql)
  {
   try
   {
    PreparedStatement ps = m_oConn.prepareStatement(sSql);
    return ps;
   }
   catch (Exception ex)
   {
    WCLog.getInstance().printLog("exception at WCDBConnectionManager.prepareStatement "+ex.toString());
   }
   return null;
  }
}

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