[JSP] 커넥션 풀

package jdbc;

import java.sql.DriverManager;
import java.util.Properties;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;

import org.apache.commons.dbcp2.BasicDataSource;
import org.apache.commons.dbcp2.BasicDataSourceFactory;
import org.apache.commons.dbcp2.ConnectionFactory;
import org.apache.commons.dbcp2.DriverManagerConnectionFactory;
import org.apache.commons.dbcp2.PoolableConnection;
import org.apache.commons.dbcp2.PoolableConnectionFactory;
import org.apache.commons.dbcp2.PoolingDriver;
import org.apache.commons.pool2.ObjectPool;
import org.apache.commons.pool2.impl.GenericObjectPool;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;

public class DBCPInit extends HttpServlet {

	@Override
	public void init() throws ServletException {
		loadJDBCDriver();
		initConnectionPool();
	}

	private void loadJDBCDriver() {
		try {
			Class.forName("com.mysql.jdbc.Driver");
		} catch (ClassNotFoundException ex) {
			throw new RuntimeException("fail to load JDBC Driver", ex);
		}
	}

	private void initConnectionPool() {
		try {
			String jdbcUrl = 
					"jdbc:mysql://localhost:3305/chap14?" + 
					"useUnicode=true&characterEncoding=utf8&serverTimezone=UTC";
			String username = "root";
			String pw = "1234";

			ConnectionFactory connFactory = 
					new DriverManagerConnectionFactory(jdbcUrl, username, pw);

			PoolableConnectionFactory poolableConnFactory = 
					new PoolableConnectionFactory(connFactory, null);
			poolableConnFactory.setValidationQuery("select 1");

			GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
			poolConfig.setTimeBetweenEvictionRunsMillis(1000L * 60L * 5L);
			poolConfig.setTestWhileIdle(true);
			poolConfig.setMinIdle(4);
			poolConfig.setMaxTotal(50);

			GenericObjectPool<PoolableConnection> connectionPool = 
					new GenericObjectPool<>(poolableConnFactory, poolConfig);
			poolableConnFactory.setPool(connectionPool);
			
			Class.forName("org.apache.commons.dbcp2.PoolingDriver");
			PoolingDriver driver = 
					(PoolingDriver) DriverManager.getDriver("jdbc:apache:commons:dbcp:");
			driver.registerPool("chap14", connectionPool);
		} catch (Exception e) {
			throw new RuntimeException(e);
		}
	}
}

요약

실제 커넥션을 생성할 ConnectionFactory를 생성한다.
커넥션 풀로 사용할 PoolableConnection을 생성하는 PoolableConnectionFactory를 생성한다.
커넥션 풀의 설정정보를 생성한다.
커넥션 풀을 사용할 JDBC 드라이버를 등록한다.

커넥션 풀 초기화 서블릿 설정

커넥션 풀을 초기화하기 위한 서블릿을 만들었으므로 이제 웹 어플리케이션을 구동할 때 이 서블릿을 실행하도록 설정할 차례이다. 앞서 DriverLoader와 동일하게 web.xml파일에 설정하면 된다.

   
    	<servlet>
		<servlet-name>DBCPInit</servlet-name>
		<servlet-class>jdbc.DBCPInit</servlet-class>
		<load-on-startup>1</load-on-startup>
	</servlet>

위와 같이 코드를 추가하면 웹 어플리케이션이 시작할 때 DBCPInit 서블릿 클래스가 자동으로 시작되고 init()메서드가 호출된다.

DBCP 관련 jar 파일과 JDBC 드라이버 jar 파일 설치하기
커넥션 풀 초기화 하기
커넥션 풀로 커넥션 사용하기

DBCP가 제공하는 PoolingDriver는 커넥션 풀을 위한 JDBC 드라이버이다.

PoolingDriver를 통해 커넥션 풀로 가져오려면 다음 형식의 JDBC URL을 사용하면 된다.

jdbc:apache:commonse:dbcp:풀이름

풀 이름은 PoolingDriver에 커넥션 풀을 등록할 때 지정한다. 예를 들어, 앞서 DBCPInit 클래스를 보면 다음과 같은 코드가 있다.

Class.forName("org.apache.commons.dbcp2.PoolingDriver");
			PoolingDriver driver = 
					(PoolingDriver) DriverManager.getDriver("jdbc:apache:commons:dbcp:");
			driver.registerPool("chap14", connectionPool);

이 코드를 보면 커넥션 풀을 등록할 때, 풀의 이름으로 "chap14"를 사용했다. 따라서, 위 커넥션 풀로부터 커넥션을 구하려면 다음과 같은 JDBC URL을 사용하면 된다.

Connection conn = null;
....

try {
String jdbcUrl="jdbc:apache:commons:dbcp:chap14";
//커넥션 풀에서 커넥션을 구함
conn = DriverManager.getConnection(jdbcUrl);
...
}finally {

...
//커넥션을 풀에 반환함

if(conn != null) try {conn.close();} catch (SQLException ex){}
}

이 코드를 보면 DBCP API 기반의 커넥션 풀을 사용한다고 해서 특별히 코다가 달라지는 부분이 없다는 것을 알 수 있다. 일반 경우와 마찬가지로 DriverManager.getConnection() 메서드를 사용해서 커넥션을 구해오고, 커넥션을 사용하면 close()메서드로 사용한 커넥션을 닫는다.

커넥션 풀에서 구한 Connection의 close()메서드를 호출하면 DB와의 연결을 끊지 않고 해당 커넥션을 풀에 반환한다.

실제로 커넥션 풀을 사용하는 완전한 예제이다

앞에서 작성했던 viewMemberUsingPool.jsp를 커넥션 풀을 사용하도록 변경한 것이다.

<%@ page contentType = "text/html; charset=utf-8" %>
<%@ page import = "java.sql.DriverManager" %>
<%@ page import = "java.sql.Connection" %>
<%@ page import = "java.sql.Statement" %>
<%@ page import = "java.sql.ResultSet" %>
<%@ page import = "java.sql.SQLException" %>
<html>
<head><title>회원 목록</title></head>
<body>

MEMBER 테이블의 내용
<table width="100%" border="1">
<tr>
	<td>이름</td><td>아이디</td><td>이메일</td>
</tr>
<%
	
	Connection conn = null;
	Statement stmt = null;
	ResultSet rs = null;
	
	try {
		String jdbcDriver = "jdbc:apache:commons:dbcp:chap14";
		String query = "select * from member order by MEMBERID";
		conn = DriverManager.getConnection(jdbcDriver);
		stmt = conn.createStatement();
		rs = stmt.executeQuery(query);
		while(rs.next()) {
%>
<tr>
	<td><%= rs.getString("NAME") %></td>
	<td><%= rs.getString("MEMBERID") %></td>
	<td><%= rs.getString("EMAIL") %></td>
</tr>
<%
		}
	} 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) {}
	}
%>
</table>

</body>
</html>

'개발' 카테고리의 다른 글

[JSP] 방명록 구현 (0)	2020.07.27
[JSP] 웹 어플리케이션의 일반적인 구성 (0)	2020.07.27
[JSP] 데이터 삽입 / 조회 /정렬 / 집합 / 수정 / 삭제 / 조인 (0)	2020.07.26
[JSP] SQL 기초 - 테이블 생성, 주요 타입 (0)	2020.07.26
[JSP] SQL 데이터 베이스 프로그래밍 기초 (0)	2020.07.26

현재글[JSP] 커넥션 풀

Handy Smurf

log4jdbclog4jdbc.log4j2.properties, boardmappertests, 최범균, ojdbc8, spring update, Insert, boardmapper.xml, spring insert, spring delete, 기초부터 중급까지, boardmapper, test, spring read, jsp, boardvo, JDBC, root-context, orai18n, mapper, Spring,

Today :
Yesterday :

Handy Smurf