반응형
개발자의 실수를 줄여주는 java.sql.Connection 만들기
흔히 close()를 하지 않아서 발생하는 자원 누수 현상을 줄여주는 Connection 클래스를 만들어본다.
JDBC API 사용시 흔히 하는 개발자의 실수
JDBC API를 사용하여 데이터베이스 프로그래밍을 할 때 가장 많이 사용되는 코드는 아마도 다음과 같은 형태일 것이다.
그런데 위와 같은 프로그래밍을 할 때 흔히 하는 실수가 close()를 제대로 해 주지 않는 것이다. 특히, 하나의 메소드에서 5-10개의 (PreparedStatement를 포함한)Statement와 ResultSet을 사용하는 경우에는 개발자의 실수로 같은 Statement를 두번 close() 하고 한두개의 Statement나 ResultSet은 닫지 않는 실수를 하곤 한다. 이처럼 close() 메소드를 알맞게 호출해주지 않을 경우에는 다음과 같은 문제가 발생한다.
Statement를 자동으로 닫아주는 MVConnection 클래스 구현
실제로 필자도 앞에서 언근했던 문제들 때문에 고생하는 사람들을 종종 봐 왔었으며, 그때마다 그 버그를 고치기 위해서 소스 코드를 일일이 찾아보는 노가다를 하는 개발자들을 보기도 했다. 그래서 만든 클래스가 있는데, 그 클래스의 이름을 MVConnection이라고 붙였다. 이름이야 여러분의 입맛에 맛게 수정하면 되는 것이므로, 여기서는 원리만 간단하게 설명하도록 하겠다.
먼저, MVConnection을 구현하기 전에 우리가 알고 있어야 하는 기본 사항이 있다. JDBC API를 유심히 읽어본 사람이라면 다음과 같은 내용을 본 적이 있을 것이다.
다음은 MVConnection 클래스의 핵심 코드이다.
위 코드를 보면 Statement를 저장하기 위한 List와 그 List에 저장된 Statement 객체를 모두 닫아주는 closeAll() 이라는 메소드가 정의되어 있다. 바로 이 List와 closeAll() 메소드가 이 MVConnection 클래스의 핵심이다. Statement를 생성해주는 메소드(createStatement, prepareCall, prepareStatement)를 보면 생성된 Statement를 statemetList에 추가해주는 것을 알 수 있다. 이렇게 저장된 Statement는 실제로 Connection을 닫을 때, 즉 Connection의 close() 메소드를 호출할 때 닫힌다. (코드를 보면 close() 메소드에서 closeAll() 메소드를 먼저 호출하고 있다.) 따라서, close() 메소드만 호출하면 그와 관련된 모든 Statement와 ResultSet은 자동으로 닫히게 된다.
위 코드에서 다른 메소드들은 모두 다음과 같이 간단하게 구현된다.
MVConnection은 java.sql.Connection을 implements 하기 때문에, 그 자체가 Connection으로 사용될 수 있다. 따라서 MVConnection을 사용한다고 해서 특별히 코드가 많이 변경되지는 않으며 다음과 같이 전체적으로 코드가 단순하게 바뀐다.
때에 따라서는 Connection을 close() 하지 않고 커넥션 풀에 되돌려 놔야 할 때가 있다. 그런 경우에는 다음과 같은 형태의 코드를 사용하면 된다.
즉, Connection을 닫지 않는 경우에는 위와 같이 커넥션 풀에 반환하기 전에 closeAll() 메소드 하나만을 호출해주면 된다. 그러면 Connection과 관련된 모든 Statement, ResultSet 등이 닫히게 된다.
결론
필자의 경우는 이 글에서 작성한 MVConnection을 실제 프로젝트에 응용하여 코드 작성의 편리함 뿐만 아니라 실수로 인해서 발생하는 시스템의 버그 문제를 어느 정도 해결할 수 있었다. 특히, Statement를 생성하거나 ResultSet을 생성할 때 발생하는 커서부족 문제를 획기적으로 줄일 수 있었다. 여러분도 이 클래스를 응용하여 보다 나은 방법으로 코딩의 실수 및 자원의 낭비를 줄일 수 있는 클래스를 작성해보기 바란다.
JDBC API 사용시 흔히 하는 개발자의 실수
JDBC API를 사용하여 데이터베이스 프로그래밍을 할 때 가장 많이 사용되는 코드는 아마도 다음과 같은 형태일 것이다.
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
try {
conn = DBPool.getConnection(); //
stmt = conn.createStatement();
rs = stmt.executeQuery(..);
...
} catch(SQLException ex) {
// 예외 처리
} finally {
if (rs != null) try { rs.close(); } catch(SQLException ex) {}
if (stmt != null) try { stmt.close(); } catch(SQLException ex) {}
if (conn != null) try { conn.close(); } catch(SQLException ex) {}
}
Statement stmt = null;
ResultSet rs = null;
try {
conn = DBPool.getConnection(); //
stmt = conn.createStatement();
rs = stmt.executeQuery(..);
...
} catch(SQLException ex) {
// 예외 처리
} finally {
if (rs != null) try { rs.close(); } catch(SQLException ex) {}
if (stmt != null) try { stmt.close(); } catch(SQLException ex) {}
if (conn != null) try { conn.close(); } catch(SQLException ex) {}
}
그런데 위와 같은 프로그래밍을 할 때 흔히 하는 실수가 close()를 제대로 해 주지 않는 것이다. 특히, 하나의 메소드에서 5-10개의 (PreparedStatement를 포함한)Statement와 ResultSet을 사용하는 경우에는 개발자의 실수로 같은 Statement를 두번 close() 하고 한두개의 Statement나 ResultSet은 닫지 않는 실수를 하곤 한다. 이처럼 close() 메소드를 알맞게 호출해주지 않을 경우에는 다음과 같은 문제가 발생한다.
- Statement를 닫지 않을 경우, 생성된 Statement의 개수가 증가하여 더 이상 Statement를 생성할 수 없게 된다.
- close() 하지 않으므로 불필요한 자원(네트워크 및 메모리)을 낭비하게 된다.
- 커넥션 풀을 사용하지 않는 상황에서 Connection을 닫지 않으면 결국엔 DBMS에 연결된 새로운 Connection을 생성할 수 없게 된다.
Statement를 자동으로 닫아주는 MVConnection 클래스 구현
실제로 필자도 앞에서 언근했던 문제들 때문에 고생하는 사람들을 종종 봐 왔었으며, 그때마다 그 버그를 고치기 위해서 소스 코드를 일일이 찾아보는 노가다를 하는 개발자들을 보기도 했다. 그래서 만든 클래스가 있는데, 그 클래스의 이름을 MVConnection이라고 붙였다. 이름이야 여러분의 입맛에 맛게 수정하면 되는 것이므로, 여기서는 원리만 간단하게 설명하도록 하겠다.
먼저, MVConnection을 구현하기 전에 우리가 알고 있어야 하는 기본 사항이 있다. JDBC API를 유심히 읽어본 사람이라면 다음과 같은 내용을 본 적이 있을 것이다.
- Statement를 close() 하면 Statement의 현재(즉, 가장 최근에 생성한) ResultSet도 close() 된다.
- ResultSet은 그 ResultSet을 생성한 Statement가 닫히거나, 또는 executeQuery 메소드를 실행하는 경우 close() 된다.
다음은 MVConnection 클래스의 핵심 코드이다.
public class MVConnection implements Connection {
private Connection conn; // 실제 커넥션
private java.util.List statementList; // statement를 저장
public MVConnection(Connection conn) {
this.conn = conn;
statementList = new java.util.ArrayList();
}
public void closeAll() {
for (int i = 0 ; i < statementList.size() ; i++) {
Statement stmt = (Statement)statementList.get(i);
try {
stmt.close();
} catch(SQLException ex) {}
}
}
public void close() throws SQLException {
this.closeAll(); conn.close();
}
public Statement createStatement() throws SQLException {
Statement stmt = conn.createStatement();
statementList.add(stmt);
return stmt;
}
public CallableStatement prepareCall(String sql) throws SQLException {
CallableStatement cstmt = conn.prepareCall(sql);
statementList.add(cstmt);
return cstmt;
}
public PreparedStatement prepareStatement(String sql) throws SQLException {
PreparedStatement pstmt = conn.prepareStatement(sql);
statementList.add(pstmt);
return pstmt;
}
...
}
private Connection conn; // 실제 커넥션
private java.util.List statementList; // statement를 저장
public MVConnection(Connection conn) {
this.conn = conn;
statementList = new java.util.ArrayList();
}
public void closeAll() {
for (int i = 0 ; i < statementList.size() ; i++) {
Statement stmt = (Statement)statementList.get(i);
try {
stmt.close();
} catch(SQLException ex) {}
}
}
public void close() throws SQLException {
this.closeAll(); conn.close();
}
public Statement createStatement() throws SQLException {
Statement stmt = conn.createStatement();
statementList.add(stmt);
return stmt;
}
public CallableStatement prepareCall(String sql) throws SQLException {
CallableStatement cstmt = conn.prepareCall(sql);
statementList.add(cstmt);
return cstmt;
}
public PreparedStatement prepareStatement(String sql) throws SQLException {
PreparedStatement pstmt = conn.prepareStatement(sql);
statementList.add(pstmt);
return pstmt;
}
...
}
위 코드를 보면 Statement를 저장하기 위한 List와 그 List에 저장된 Statement 객체를 모두 닫아주는 closeAll() 이라는 메소드가 정의되어 있다. 바로 이 List와 closeAll() 메소드가 이 MVConnection 클래스의 핵심이다. Statement를 생성해주는 메소드(createStatement, prepareCall, prepareStatement)를 보면 생성된 Statement를 statemetList에 추가해주는 것을 알 수 있다. 이렇게 저장된 Statement는 실제로 Connection을 닫을 때, 즉 Connection의 close() 메소드를 호출할 때 닫힌다. (코드를 보면 close() 메소드에서 closeAll() 메소드를 먼저 호출하고 있다.) 따라서, close() 메소드만 호출하면 그와 관련된 모든 Statement와 ResultSet은 자동으로 닫히게 된다.
위 코드에서 다른 메소드들은 모두 다음과 같이 간단하게 구현된다.
public boolean getAutoCommit() throws SQLException {
return conn.getAutoCommit();
}
return conn.getAutoCommit();
}
MVConnection은 java.sql.Connection을 implements 하기 때문에, 그 자체가 Connection으로 사용될 수 있다. 따라서 MVConnection을 사용한다고 해서 특별히 코드가 많이 변경되지는 않으며 다음과 같이 전체적으로 코드가 단순하게 바뀐다.
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
try {
// MV Connection 생성
conn = new MVConnection(DBPool.getConnection());
stmt = conn.createStatement();
rs = stmt.executeQuery(..);
...
} catch(SQLException ex) {
// 예외 처리
} finally {
// conn 만 close() 해준다.
if (conn != null) try { conn.close(); } catch(SQLException ex) {}
}
Statement stmt = null;
ResultSet rs = null;
try {
// MV Connection 생성
conn = new MVConnection(DBPool.getConnection());
stmt = conn.createStatement();
rs = stmt.executeQuery(..);
...
} catch(SQLException ex) {
// 예외 처리
} finally {
// conn 만 close() 해준다.
if (conn != null) try { conn.close(); } catch(SQLException ex) {}
}
때에 따라서는 Connection을 close() 하지 않고 커넥션 풀에 되돌려 놔야 할 때가 있다. 그런 경우에는 다음과 같은 형태의 코드를 사용하면 된다.
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
try {
// MV Connection 생성
conn = new MVConnection(DBPool.getConnection());
stmt = conn.createStatement();
rs = stmt.executeQuery(..);
...
} catch(SQLException ex) {
// 예외 처리
} finally {
if (conn != null) try {
((MVConnection)conn).closeAll();
DBPool.returnConnection(conn);
} catch(SQLException ex) {}
}
Statement stmt = null;
ResultSet rs = null;
try {
// MV Connection 생성
conn = new MVConnection(DBPool.getConnection());
stmt = conn.createStatement();
rs = stmt.executeQuery(..);
...
} catch(SQLException ex) {
// 예외 처리
} finally {
if (conn != null) try {
((MVConnection)conn).closeAll();
DBPool.returnConnection(conn);
} catch(SQLException ex) {}
}
즉, Connection을 닫지 않는 경우에는 위와 같이 커넥션 풀에 반환하기 전에 closeAll() 메소드 하나만을 호출해주면 된다. 그러면 Connection과 관련된 모든 Statement, ResultSet 등이 닫히게 된다.
결론
필자의 경우는 이 글에서 작성한 MVConnection을 실제 프로젝트에 응용하여 코드 작성의 편리함 뿐만 아니라 실수로 인해서 발생하는 시스템의 버그 문제를 어느 정도 해결할 수 있었다. 특히, Statement를 생성하거나 ResultSet을 생성할 때 발생하는 커서부족 문제를 획기적으로 줄일 수 있었다. 여러분도 이 클래스를 응용하여 보다 나은 방법으로 코딩의 실수 및 자원의 낭비를 줄일 수 있는 클래스를 작성해보기 바란다.
반응형
'Language > JAVA' 카테고리의 다른 글
| 간단한 포트 확인용 에코 프로그램 (0) | 2013.01.29 |
|---|---|
| Java 성능 모니터링에 대해 모르고 있던 5가지 사항, Part 1 (0) | 2012.05.02 |
| 엑셀 대용량 다운로드 가능하게 자바 만들기 (0) | 2012.04.05 |
| OOM(Out Of Memory) 없이 IBM Heapdump 파일 분석하기 (0) | 2012.02.15 |
| System.out.println()은 잊어라 log4sql이 온다. (0) | 2011.03.15 |
Abyssmedia.Quick.Batch.File.Compiler.v3.2.2.0.rar
도구를 선택합니다
도구를 선택한 상태로 수정 내용에 따라 아래와 같이 조작합니다.
그리기 도구를 사용합니다.
나 [다각형] 도구 등을 사용할 경우에는 정점을 클릭하여 선택해 갑니다.)
작업 버튼에서 [스탬프 팔레트 표시] 버튼을 클릭하여 [스탬프 팔레트]를 엽니다. 버튼이 표시되지 않을 경우에는 [도구] 메뉴 > [도구 모음 사용자 정의]에서 [스탬프 도구]에 체크한 후 [확인] 버튼을 누릅니다.
