JSP JDBC

JSP JDBC
웹 어플리케이션 구동 시 JDBC 드라이버 로딩하기
JDBC에서 트랜잭션 처리
Connection Pool

JSP JDBC

데이터베이스나 JDBC에 대한 설명은 앞에서 이미 설명했기 때문에 넘어가고

이번에 공부할 jsp예제에서 사용할 데이터베이스는 mariaDB이기 때문에 mariaDB를 설치해줘야함

Download MariaDB

다운받은 파일 실행
mariaDB 10.5.11 다운로드
설치 위치 지정
C:\MariaDB 10.5\로 만듦
root 계정의 비밀번호를 입력
12345로 만들기
나머지 그냥 쭉 넘겨서 설치 완료!

참고페이지

JDBC MariaDB Connecter Driver

Java와 DB를 연동하기 위해서는 각 DBMS의 버전에 맞는 JRE 실행환경 라이브러리(커텍터 드라이버)를 Java프로젝트에 추가해야 함

▸ MSSQL, MySQL, Maria 등 각각 DB버전에 맞는 실행환경 드라이버를 추가해야 함

▸ mariadb-java-client/2.7.3.jar을 다운로드 받으면 됨

Download Maria Library

Add Library

라이브러리(드라이버)를 추가하는 방법

→ WEB-INF lib폴더에 .jar파일 끌어넣으면 자동으로 라이브러리가 추가됨

Navicat Connection

File → new Connection → mariaDB 으로 새로운 커넥션 생성

새로운 데이터베이스 생성

 create database 생성할_데이터베이스명

생성된 데이터베이스

JDBC Program Coding Style

JDBC Program Creation Steps에서도 설명한바와 같이 JDBC프로그램의 전형적인 실행순서는 다음과 같음

JDBC 드라이버 로딩
데이터베이스 커넥션 구하기
쿼리 실행을 위한 Statement 객체 생성
쿼리 실행
쿼리 실행결과 사용
Statement 종료
데이터베이스 커넥션 종료

예제

<%@page import="java.sql.DriverManager"%>
<%@page import="java.sql.Statement"%>
<%@page import="java.sql.ResultSet"%>
<%@page import="java.sql.Connection"%>
<%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%>
<!DOCTYPE html>
<html>
<head>
<body>
<h3>회원정보</h3>
<%
	//1. JDBC 드라이버 로딩
	Class.forName("org.mariadb.jdbc.Driver");

	Connection conn = null;
	Statement stmt = null;
	ResultSet rs = null;
	
	try {
		String drv = "jdbc:mariadb://localhost:3306/jspstudy";
		String usr = "root";
		String pwd = "12345";
		String sql = "select * from member";
		
		//2. 데이터베이스 커넥션 생성
		conn = DriverManager.getConnection(drv, usr, pwd);
		
		//3. Statement 생성
		stmt = conn.createStatement();
		//4. 쿼리 실행
		rs = stmt.executeQuery(sql);
		
		//5. 쿼리 실행결과 출력
		if(rs.next()) {
%> 
			<table>
				<tr>
					<td width="20%">아이디</td>
					<td><%= rs.getString("id") %></td>
				</tr>
				<tr>
					<td>비밀번호</td>
					<td><%= rs.getString("password") %></td>
				</tr>
				<tr>
					<td>이름</td>
					<td><%= rs.getString("name") %></td>
				</tr>
				<tr>
					<td>이메일</td>
					<td><%= rs.getString("email") %></td>
				</tr>
			</table>
<%		
		}
	} catch(Exception e) {
%>
		DB접속실패 : <%= e.getMessage() %>
<%
	} finally {
		try {
			// 6. 사용한 Statement 종료
			if(rs != null) rs.close();
			if(stmt != null) stmt.close();
			
			// 7. 커넥션 종료
			if(conn != null) conn.close();
		} catch (Exception e) {
			
		}	
	}
%>	
</body>
</html>

JDBC Driver for Communication with DBMS

DBMS와의 통신을 위한 JDBC 드라이버

▸ JDBC 드라이버는 DBMS와의 통신을 담당하는 자바 클래스

▸ DBMS마다 별도의 JDBC드라이버가 필요, 각 DBMS는 JDBC드라이버를 jar파일 형태로 제공함

▸ Class.forName() 메서드는 지정한 클래스 정보를 담고 있는 Class 인스턴스를 구해주는 기능만 제공

▸ JDBC드라이버에 해당하는 클래스들은 Class.forName() 메서드를 통해 로딩될 때 자동으로 JDBC 드라이버로 등록됨

JDBC 드라이버를 로딩하는 방법

try {
    Class.forName("JDBC 드라이버 클래스의 완전한 이름");
} catch (ClassNotFoundException ex){
    //지정한 클래스가 존재하지 않는 경우 에러가 발생함
}

주요 데이터베이스의 JDBC 드라이버에 해당하는 클래스

MySQL : com.mysql.jdbc.Driver
오라클 : oracle.jdbc.driver.OracleDriver
MS SQL 서버 : com.microsoft.sqlserver.jdbc.SQLServerDriver
MariaDB : org.mariadb.jdbc.Driver

예제 : MariaDB 드라이버를 로딩

try {
    Class.forName("org.mariadb.jdbc.Driver");
} catch (ClassNotFoundException ex){
    //지정한 클래스가 존재하지 않는 경우 에러가 발생함
    //에러 처리
}

JDBC URL for Database Identification

데이터베이스 식별을 위한 JDBC URL

▸ 데이터베이스를 구분할 때 URL과 비슷한 형식을 갖는 JDBC URL을 사용

syntax

jdbc:[DBMS]:[데이터베이스식별자]

MySQL
MySQL JDBC URL
jdbc:mysql://HOST[:PORT]/DBNAME[?param=value&param1=vale2&…]
▸ HOST : 서버의 호스트 주소
▸ DBNAME : 데이터베이스 이름
한글데이터를 올바르게 출력하기 위해 사용하는 추가 파라미터
```
  jdbc:[DBMS]://HOST[:PORT]/DBNAME?useUnicode=true&characterEncoding=utf8
```
MariaDB
MariaDB JDBC URL
jdbc:mariadb://HOST[:PORT]/DBNAME[?param=value&param1=vale2&…]
▸ HOST : 서버의 호스트 주소
▸ DBNAME : 데이터베이스 이름
```
  String drv = "jdbc:mariadb://localhost:3306/jspstudy";
```
Oracle
오라클은 Thin, OCI 두가지 드라이버가 있음
Oracle JDBC URL
jdbc:oracle:thin:@HOST:PORT:SID
▸ HOST : 서버의 호스트 주소
▸ PORT : 오라클이 설치된 포트번호
▸ SID : 사용할 데이터베이스의 SID
```
  jdbc:oracle:thin:@127.0.0.1:1521:ORCL
```

Database Connection

데이터베이스 커넥션

→ JDBC를 이용해서 데이터베이스를 사용하려면 데이터베이스와 연결된 커넥션을 구해야 함

java.sql.Connection 타입이 데이터베이스 커넥션을 나타내며, java.sql.DriverManager 클래스가 제공하는 getConnection() 메서드를 사용해서 커넥션을 구함

▸ 올바른 DB 사용자 계정과 암호를 사용 : DB와 연결된 Connection 객체를 리턴함

→ 이 객체를 사용해서 필요한 작업을 시작

▸ 올바르지 않은 DB 사용자 계정과 암호를 사용 : 객체를 생성하지 못하면 SQLException을 발생시켜서 getConnection()메소드를 사용할 때는 try-catch블럭을 이용해야 함

syntax

DriverManager.getConnection(String jdbcURL)
DriverManager.getConnection(String jdbcURL, String user, String password)

▸ jdbcURL : 데이터베이스에 연결할 때 사용할 JDBC URL

▸ user, password : 계정과 암호

Connection 객체를 다 사용한 뒤에는 close() 메소드를 호출해서 시스템 자원을 반납해야 함

→ 반납하지 않으면 시스템 자원이 불필요하게 소모되어 커넥션을 구할 수 없는 상황이 발생할 수도 있음

▸ 익셉션을 발생시킬 경우 conn에 Connection 객체가 할당되지 않으므로 null 인지의 여부를 판단 후에 close() 메소드를 호출

close()

try {
    String drv = "jdbc:mariadb://localhost:3306/jspstudy";
    String usr = "root";
    String pwd = "12345";
    String sql = "select * from member where id = '" + id + "'";
    conn = DriverManager.getConnection(drv, usr, pwd);
    ...
} catch(SQLException e) {
    //에러 발생
} finally {
    try { if(conn != null) conn.close(); } catch (SQLException e) {}	
}

Run Queries using Statements

Statement를 사용한 쿼리 실행

▸ Connection 객체를 생성한 후에는 Connection 객체로부터 Statement를 생성하고 쿼리를 실행할 수 있음

▸ Statement는 Connection의 createStatement()메소드를 사용해서 생성함

syntax

Statement stmt = conn.createStatement();

Statement 객체는 쿼리를 실행할 수 있음. 쿼리를 실행하는 메소드

ResultSet executeQuery(String query) : SELECT 쿼리를 실행, 결과값을 java.sql.ResultSet 객체에 저장해서 리턴
int executeUpdate(String query) : INSERT, UPDATE, DELETE 쿼리를 실행, 변경한 레코드의 개수를 리턴

Process Single Quotes when Eecuting Queries using Statements

Statement를 이용한 쿼리 실행 시 작은따옴표 처리

▸ SQL 쿼리를 실행할 때 작은 따옴표가 들어가면 작은 따옴표 두 개를 사용하는 형태로 변경해야 함

▸ String 클래스의 replaceAll()메서드를 사용하면 문자열에 포함된 특정 문자나 단어를 손쉽게 변경할 수 있음

▸ 문자열에 포함되어 있는 작은 따옴표 한 개를 두개로 변경하고 싶다면 다음과 같이 String 클래스의 replaceAll() 메서드를 사용해야 함

예제

String value = "king's choice"

String replaced = value.replaceAll("'", """);

매번 치환 처리를 하는게 귀찮고 놓치기 쉽기 때문에 PreparedStatement를 사용함

Read values from ResultSet

ResultSet에서 값 읽어오기

▸ Statement의 executeQuery()는 select쿼리의 결과를 ResultSet에 담아서 리턴

▸ 따라서 ResultSet이 제공하는 메서드를 사용해서 결과값을 읽어올 수 있음

next() : select 결과의 존재 여부를 확인할 수 있음

ResultSet클래스의 주요 데이터 읽기 메서드

메서드	리턴 타입	설명
getString(String name) getString(int index)	String	지정한 칼럼 값을 String으로 읽어옴
getCharacterStream(String name) getCharacterStream(int index)	java.io.Reader	지정한 칼럼 값을 스트림 형태로 읽어옴. Long VARCHAR타입을 읽어올 때 사용
getInt(String name) getInt(int index)	int	지정한 칼럼 값을 int 타입으로 읽어옴
getLong(String name) getLong(int index)	long	지정한 칼럼 값을 long 타입으로 읽어옴
getDouble(String name) getDouble(int index)	double	지정한 칼럼 값을 double 타입으로 읽어옴
getFloat(String name) getFloat(int index)	float	지정한 칼럼 값을 float 타입으로 읽어옴
getTimestamp(String name) getTimestamp(int index)	java.sql.Timestamp	지정한 칼럼 값을 Timestamp 타입으로 읽어옴
getDate(String name) getDate(int index)	java.sql.Date	지정한 칼럼 값을 Date 타입으로 읽어옴
getTime(String name) getTime(int index)	java.sql.Time	지정한 칼럼 값을 Time 타입으로 읽어옴

Read LONG VARCHAR type value from ResultSet

ResultSet에서 LONG VARCHAR 타입 값 읽어오기

getCharacterStream()메서드를 사용해서 읽어오는 게 원칙이지만 다수의 JDBC 드라이버는 getString()메서드로 읽어올 수 있게 지원하고 있음

따라서 아래 코드를 사용하지 않아도 되지만 원칙으로 아래 코드를 알아두기!

LONG VARCHAR타입을 포함하는 테이블 생성

 create table MEMBER_HISTORY(
     MEMBERID VARCHAR(10) NOT NULL PRIMARY KEY,
     HISTORY LONG VARCHAR
 )

HISTORY 칼럼 부분에 길이가 긴 문자열을 값으로 입력

concat은 그냥 알아보기 좋게 하려고 사용함

 insert into MEMBER_HISTORY values ( 'madvirus',
     concat(
        '2015 스프링4 프로그래밍 입문<br>',
        '2014 Spring4.0 프로그래밍<br>',
        '2013 객체지향과 디자인 패턴<br>',
        '2012 JSP 2.2 웹프로그래밍<br>',
     )

 )

LONG VARCHAR타입의 값을 읽어오는 코드

 String data = null // 스트림으로 읽어온 데이터를 저장할 변수
 java.io.Reader reader = null // LONG VARCHAR 데이터를 읽어올 스트림

 try{
     //1. ResultSet의 getCharacterstream()으로 Reader 구함
     reader = rs.getCharacterStream("FIELD") //스트림 읽어옴

     if(reader!= null){
         //2. 스트림에서 읽어온 데이터를 저장할 버퍼를 생성
         StringBuilder buff = new StringBuilder();
         char[] ch = new char[512];
         int len = -1;

         //3. 스트림에서 데이터를 읽어와 버퍼에 저장
         while((len = reader.read(ch)) != -1) {
             buff.append(ch, 0, len);
         }

         //4. 버퍼에 저장한 내용을 String으로 변환
         data =  buff.toString();
     } catch(IOException e){
         //5. IO관련 처리 도중 문제가 있으면 IOException이 발생
         //익셉션 발생 
     } finally{
         if(reader!=null) try{ reader.close() } catch (IOException){}
     }
 }

 ...

Run queries using PreparedStatement

PreparedStatement를 사용한 쿼리 실행

▸ Statement와 동일한 기능을 제공함

▸ 차이점 : PreparedStatement은 SQL 쿼리의 틀을 미리 생성해 놓고 값을 나중에 지정함

Connection.prepareStatment() 메서드를 사용해 PreparedStatement 생성

 PreparedStatement pstmt = null;
 ...
    
 pstmt = conn.prepareStatement("insert into MEMBER values(?,?,?)");

PreparedStatement의 set 메서드를 사용해 필요한 값 지정
인덱스는 1, 이후 물음표의 인덱스는 나오는 순서대로 인덱스값이 1씩 증가
```
 pstmt.setString(1, "aaa"); //첫번째 물음표 값 지정
 pstmt.setString(2, "bbb"); //두번째 물음표 값 지정
```

PreparedStatement클래스가 제공하는 set메서드

메서드	설명
setString(int index, String x)	지정한 인덱스의 파라미터 값을 x로 지정
setCharacterStream(int index, Reader reader, int length)	지정한 인덱스의 파라미터 값을 LONG VARCHAR타입의 값으로 지정한다
setInt(int index, String x)	지정한 인덱스의 파라미터 값을 int의 값 x로 지정한다
setLong(int index, String x)	지정한 인덱스의 파라미터 값을 long의 값 x로 지정한다
setDouble(int index, String x)	지정한 인덱스의 파라미터 값을 의 double값 x로 지정한다
setFloat(int index, String x)	지정한 인덱스의 파라미터 값을 의 float값 x로 지정한다
setTimestamp(int index, String x)	지정한 인덱스의 값을 SQL TIMESTAMP 타입을 나타내는 java.sql.Timestamp 타입으로 지정한다
setDate(int index, String x)	지정한 인덱스의 값을 SQL DATE타입을 나타내는 java.sql.Date 타입으로 지정한다
setTime(int index, String x)	지정한 인덱스의 값을 SQL TIME타입을 나타내는 java.sql.Time 타입으로 지정한다

PreparedStatement의 executeQuery() 나 executeUpdate()를 사용해 쿼리를 실행
PreparedStatement를 생성할 때 실행할 쿼리를 지정하기 때문에 이 메서드는 쿼리를 인자로 입력받지 않음
- ResultSet executeQuery(String query) : SELECT 쿼리를 실행, 결과값을 java.sql.ResultSet 객체에 저장해서 리턴
- int executeUpdate(String query) : INSERT, UPDATE, DELETE 쿼리를 실행, 변경한 레코드의 개수를 리턴
finally 블록에서 사용한 PreparedStatement를 닫음(close() 실행)

Specifying the value of LONG VARCHAR type in PreparedStatement

PreparedStatement에서 LONG VARCHAR 타입 값 지정하기

▸ setCharacterStream(int index, Reader reader, int length) 메서드를 사용해서 지정함

▸ reader로부터 length 글자 수만큼 데이터를 읽어와 저장

▸ reader에는 두가지가 있음

String 타입의 값을 저장하고 싶을 때

 PreparedStatement pstmt = null;

 try{
     String value = "..." //Long VARCHAR에 넣을 값
     pstmt = conn.preparedStatement(...);
     java.io.StringReader reader = new java.io.StringReader(value);
     pstmt.setCharacterStream(1, reader, value.length());
     ...
 }catch (SQLException ex){
     ...
 }finally{
     ...
     if(pstmt != null) try{ pstmt.close(); } catch(SQLException e){}
 }

텍스트 파일로부터 데이터를 읽어와 저장하고 싶을 때

 PreparedStatement pstmt = null;
 FileReader reader = null;

 try{
     pstmt = conn.preparedStatement(...);
     reader = java.io.FileReader(파일경로);
     pstmt.setCharacterStream(1, reader);
     ...
 } catch(SQLException ex){
 } finally {
     if(pstmt != null) try{ pstmt.close(); } catch(SQLException e){}
     if(reader != null) try{ pstmt.close(); } catch(SQLException e){}
 }

Why use PreparedStatement Queries?

값 변환을 자동으로 하기 위해
간결한 코드를 위해

검색 조건과 같이 값을 지정해야 하는 쿼리를 실행 할 때는 PreparedStatement를 선호함

웹 어플리케이션 구동 시 JDBC 드라이버 로딩하기

JDBC 드라이버는 한 번만 로딩하면 이후로 계속해서 사용할 수 있기 때문에 JSP를 실행할 때 마다 JDBC 드라이버를 로딩할 필요가 없음

드라이버를 로딩하기 가장 좋은 시점은 웹 어플리케이션이 시작할 때임

즉, 톰텟과 같은 웹 컨테이너가 시작될 때 자동으로 JDBC 드라이버를 로딩하도록 지정하면 JSP 페이지에서 매번 JDBC 드라이버를 로딩할 필요가 없음

웹 어플리케이션이 시작될 때 자동으로 JDBC 드라이버를 로딩하도록 만들려면 서블릿 클래스를 사용하면 됨

예제 : MySQLDriverLoader

package com.lec.web.jdbc;

import java.sql.DriverManager;

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

// HttpServlet 클래스를 상속
public class MySQLDriverLoader extends HttpServlet {

    //서블릿을 초기화할 때 호출되는 init()메서드를 구현
	private void init(ServletConfig config) throws ServletException {
		try {
            //MySQL JDBC 드라이버를 로딩
			Class.forName("org.mariadb.jdbc.Driver");
		} catch (Exception e) {
			throw new ServletException(e);	
		}
	}

HttpServlet은 서블릿을 위한 상위 클래스임

서블릿은 init() 메서드를 제공하고 있고, 이 메서드는 서블릿을 초기화할 떄 최초에 한 번 실행됨

톰캣과 같은 컨테이너는 서블릿을 사용하기 전에 초기화를 수행하므로 init() 메서드에서 JDBC 드라이버를 로딩하도록 구현하면 컨테이너를 실행할 때 JDBC 드라이버를 로딩할 수 있음

웹 어플리케이션이 시작될 때 자동으로 MySQLDriverLoader를 실행하도록 설정해야 함

web.xml파일을 만들어서 servlet태그를 추가하면 됨

예제 : web.xml

//MySQLDriverLoader 서블릿클래스에 대한 설정 추가
<servlet>
     <servlet-name>MySQLDriverLoader</servlet-name>                        //java파일 이름
     <servlet-class>com.lec.web.jdbc.MySQLDriverLoader</servlet-class>     //클래스 풀 이름
     <load-on-startup>1</load-on-startup>                                  //웹 어플리케이션이 시작될 때, 서블릿 클래스를 자동으로 로딩하도록 설정
</servlet>

★ 결론적으로 web.xml파일에 servlet태그를 추가하면 웹 어플리케이션 구동시 자동으로 MySQLDriverLoader 서블릿 클래스의 init()메서드가 실행됨

→ 따라서 웹 어플리케이션을 시작할 때 JDBC 드라이버를 로딩한게 됨

JDBC에서 트랜잭션 처리

두 개 이상의 쿼리를 모두 성공적으로 실행해야 데이터가 정상적으로 처리되는 경우 DBMS는 트랜잭션을 이용해서 두 개 이상의 쿼리를 마치 한 개의 쿼리처럼 처리할 수 있게 함

트랜젝션은 시작과 종료를 가지고 있음. 시작되면 이후 실행되는 쿼리 결과는 DBMS에 곧바로 반영되지 않고 임시로 보관됨

이후 트랜잭션을 커밋(Commit)하면 임시 보관한 모든 쿼리 결과를 실제 데이터에 반영함

커밋 하기전에 에러가 발생하면 임시로 보관한 모든 쿼리 결과를 실제 데이터에 반영하지 않고 취소하는데, 이걸 Rollback이라고 함

즉, 트랜잭션이 시작되면 트랜잭션 범위 내에 있는 모든 쿼리 결과가 DB에 반영되거나 또는 반영되지 않게 됨

트랜잭션을 구현하는 방법

JDBC의 오토 커밋 모드를 false로 지정하는 방법 : 단일 데이터베이스에 접근하는 경우 (아래 예제)
JTA(Java Transaction API)를 이용하는 방법 : 두개 이상의 데이터베이스를 트랜잭션으로 처리하려면 JTA를 이용

try{
     conn = DriverManager.getConnection(...);
     //트랜잭션 시작
     conn.setAutoCommit(false)
     ...
     //쿼리 실행
     ...
     //트랜잭션 커밋
     conn.comit() 
} catch (SQLException e) {
    if(conn!=null) {
        //트랜잭션 롤벡
        conn.rollback()
    }
}

Connection Pool

What is Connection Pool?

데이터베이스와 연결된 커넥션을 미리 만들어서 풀 속에 저장해두고 있다가 필요할 때 커넥션을 풀에서 가져다 쓰고 다시 풀에 반환하는 기법

풀 속에 데이터베이스와 연결된 커넥션을 미리 생성

커넥션을 새로 생성하는게 아니라 풀 속에 미리 생성된 커넥션을 가져다 쓰고 사용이 끝나면 커넥션을 풀에 반환

풀에 반환된 커넥션은 다음에 다시 사용됨

Features of Connection Pool

풀 속에 미리 커넥션이 생섣외어 있기 때문에 커넥션을 생성하는데 드는 연결 시간을 줄일 수 있음

커넥션을 계속해서 재사용하기 때문에 생성되는 커넥션 수가 일정하게 유지됨

한번에 생성할 수 있는 커넥션 수를 제어하기 때문에 동시 접속자수가 몰려도 웹 어플리케이션이 쉽게 다운되지 않음

전체적인 웹 어플리케이션의 성능과 처리량이 향상되므로 많은 웹 어플리케이션이 커넥션 풀을 기본으로 사용

다양한 커넥션 풀 라이브러리가 존재하는데 오픈 소스 프로젝트인 DBCP API를 많이 사용함

Using Connection Pool with DBCP

DBCP를 이용해서 커넥션 풀 사용하기

필요한 jar 파일 복사하기
- Commons DBCP API 관련 jar파일
  Apache Commons DBCP » 2.8.0
- Commons DBCP API가 사용하는 Commons Pool API의 Jar파일
  Apache Commons Pool » 2.9.0
- 로그 기록에 사용하는 Commons Logging API관련 jar파일
  Apache Commons Logging
위 세개 파일을 WEB-INF/lib 디렉토리에 복사

커넥션 풀 초기화하는 서블릿 클래스

DBCPInit

 package com.lec.web.jdbc;

 import java.sql.DriverManager;

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

 import org.apache.commons.dbcp2.ConnectionFactory;
 import org.apache.commons.dbcp2.DriverConnectionFactory;
 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.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() {
         String driverClass = getInitParameter("jdbcdriver");	

         try {
             //커넥션풀이 내부에서 사용할 JDBC드라이버 로딩
             Class.forName(driverClass);
         } catch (ClassNotFoundException e) {
             throw new RuntimeException("JDBC 드라이버 로딩 실패!!");		
         }
     }

     private void initConnectionPool() {

         String url =  getInitParameter("url");
         String usr =  getInitParameter("user");
         String pwd =  getInitParameter("pass");

         // A. Connection Pool 생성
         // 1. 커넥션풀이 새로운 커넥션을 생성할 떄 사용하는 커넥션팩토리를 생성
         ConnectionFactory connFactory = new DriverManagerConnectionFactory(url, usr, pwd);

         // 2. PoolableConnection을 생성하는 객체생성. DBCP는 커넥션풀에 커넥션을 보관할 떄 PoolableConnection을 사용
         // 이 클래스는 내부적으로 커넥션을 보관하고 있으며 커넥션풀을 관리하는데 필요한 기능을 제공
         // 예를 들어서 connection을 close하면 커넥션을 완전히 종료하지 않고 커넥션풀에 connection을 반환
         PoolableConnectionFactory poolFactory = new PoolableConnectionFactory(connFactory, null);

         // 3. 커넥션이 유효한지여부를 검사하기 위한 SQL을 지정
         poolFactory.setValidationQuery("select 1"); // 커넥션유효성을 검사 : mariadb or mysql;
         // poolFactory.setValidationQuery("select * from dual"); // oracle

         // B. 커넥션플의 설정정보
         // 1. 설정정보를 관리할 객체를 생성
         GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();		
         // 2. 커넥션의 검사주기
         poolConfig.setTimeBetweenEvictionRunsMillis(1000l * 60l * 5l); // 사용가능한 검사주기
         // 3. 풀에 보관중인 커넥션유효여부를 검사할지 안할지 여부설정
         poolConfig.setTestWhileIdle(true);
         // 4. 커넥션의 최소 갯수
         poolConfig.setMinIdle(4);
         // 5. 커넥션의 최대 갯수
         poolConfig.setMaxIdle(50);

         // C. 커넥션풀을 생성
         // 1. PoolableConnection을 생성할 떄 사용할 커넥션팩토리와 설정정보를 이용해서 커넥션풀을 생성
         GenericObjectPool<PoolableConnection> connPool = new GenericObjectPool<>(poolFactory, poolConfig);
         // 2. 생성한 커넥션풀을 연결
         poolFactory.setPool(connPool);

         // D. 커넥션풀을 제공할 JDBC드라이버 등록
         try {
             Class.forName("org.apache.commons.dbcp2.PoolingDriver");
             PoolingDriver driver = (PoolingDriver) DriverManager.getDriver("jdbc:apache:commons:dbcp:");
             String poolName = getInitParameter("poolName");
             driver.registerPool(poolName, connPool);
         } catch (Exception e) {
             throw new RuntimeException();
         }	
     }
 }

커넥션 풀 초기화 서블릿 설정
이 코드를 추가하면 웹 어플리케이션이 시작할 때 DBCPInit 서블릿 클래스가 자동으로 시작되고 init()메소드가 호출됨
```
 <servlet>
     <servlet-name>DBCPInit</servlet-name>
     <servlet-class>jdbc.DBCPInit</servlet-class>
     <load-on-startup>1</load-on-startup>
 </servlet>
```
커넥션 풀로부터 커넥션 사용하기

Connection Pool Properties Description

GenericObjectPoolConfig 클래스의 커넥션 개수와 대기 관련 설정 메서드

메서드	설명	기본값
setMaxTotal(int)	풀이 관리하는 커넥션의 최대 개수를 설정. 음수면 제한 X	8
setMaxIdle(int)	커넥션풀이 보관할 수 있는 최대 유휴 개수를 지정. 음수면 제한 X	8
setMinldle(int)	커넥션풀이 유지할 최소 유휴 커넥션 개수를 지정. 이 값이 maxIdle보다 크면 maxIdle을 minIdle값으로 사용	0
setBlockWhenExhausted(boolean)	풀이 관리하는 커넥션이 모두 사용중인 상태에서 커넥션을 요청할 떄 풀에 커넥션이 반환될 때 까지 대기할지 여부를 지정. ture: 대기 / false: NoSuchElementException 발생	true
setMaxWaitMillis(long)	bolckWhenExhausted가 true일 때, 최대 대기 시간을 설정. 음수면 풀에서 커넥션을 구할 수 있을 때 까지 대기. 단위는 밀리초	-1L

커넥션 풀은 사용되지 않은 유휴 커넥션을 제거하는 기능을 제공함

이 기능을 사용하면 주기적으로 커넥션을 검사하기 때문에 DBMS에서 연결을 끊기 전에 먼저 커넥션을 풀에서 제거할 수 있음

GenericObjectPoolConfig 클래스의 유휴 커넥션 제거 및 검사 관련 설정 메서드

메서드	설명	기본값
setTimeBetweenEvictionRunsMillis(long)	풀에 있는 유휴 커넥션 검사 주기를 설정. 양수가 아니면 검사하지 않음, 단위는 밀리초	-1L
setNumTestsPerEvictionRun(int)	각 주기 때마다 검사할 커넥션의 개수를 설정. 음수면 유휴 커넥션 개수를 검사 개수의 절대값으로 나눈 값을 사용	3
setMinEvictableIdleTimeMillies(long)	풀에 머물 수 있는 최소 유휴시간. 이 시간을 초과한 커넥션이 제거대상, 단위는 밀리초	1800000L(30분)
setTestWhileIdle(boolean)	ture면 유휴 커넥션이 유효한지 검사	false
setTestOnBorrow(boolean)	true면 커넥션 풀에서 커넥션을 가져올 때 유효한지 검사	false
setTestOnReturn(boolean)	true면 커넥션 풀을 반환할 때 유효한지 검사	false

커넥션 풀에 있는 커넥션 중 오랜 시간동안 사용되지 않는 커넥션은 DBMS와 연결이 끊길 가능성이 높음

연결이 끊긴 커넥션을 사용하면 프로그램 실행 도중 오류가 발생하기 때문에 주기적으로 커넥션 풀에 있는 커넥션을 검사해서 사전에 제거해 주는게 좋음

DBCP는 다음의 두가지 기준으로 풀에 있는 커넥션을 검사함

커넥션이 최소 유휴 시간보다 오래 풀에 있는 경우(minEvictableIdleTimeMillis)
커넥션이 유효한지 여부 확인(testWhileIdle)
true면 PoolableConnectionFactory의 커넥션 검사 기능을 사용

두 속성은 기본적으로 검사 주기가 양수일 때 적용됨

→ 양수가 아니면 유휴 커넥션 제거 처리 자체를 하지 않기 때문에 검사 주기 값을 설정해야 유효 커넥션을 제거함

PoolableConnectionFactory클래스의 커넥션 검사 기능과 관련된 설정 메서드

메서드	설명	기본값
setMaxConnLifeTimeMillis(long)	커넥션의 최대 사용 시간을 설정. 단위는 밀리초	-1L
setValidationQuery(String)	커넥션을 검사할 때 사용할 쿼리를 설정

GerenicObjectPoolConfig 클래스에서 설정하는 풀의 속성

maxTotal : 사이트의 최대 커넥션 사용량을 기준으로 지정. 이 값이 불필요하게 커질 경우 커넥션 개수가 비대하게 늘어나 DBMS가 수용할 수 있는 수준을 넘어서면 오히려 전체 성능에 좋지 않은 영향을 끼칠 수 있음
minIdle : 사용되지 않는 커넥션의 최소 개수를 0으로 지저하면 풀에 저장된 커넥션 개수가 0이 될 수 있음. 이 경우 커넥션이 필요할 때 다시 커넥션을 생성하게 됨. 따라서 커넥션의 최소 개수는 시스템 사용이 가장 적은 시간을 기준으로 설정
timeBetweenEvctionRunsMillis : 이 값을 설정해서 주기적으로 유휴 커넥션을 풀에서 제거해야 함. 커넥션의 동시 사용량은 보통 새벽에 최저이고 낮 시간대에 최대에 이름. 이 두시간대에 필요한 커넥션 개수의 차이는 수십에서 수백개. 이때 최대 상태에 접어들었다가 최소 상태로 가게되면 풀에서 사용되지 않는 커넥션의 개수가 점차 증가. 따라서 DB와의 연결이 끊기기 전에 유휴 커넥션을 미리 풀에서 제거해주는게 좋음. 보통 10분에서 30분 단위로 검사하는게 좋음
testWhileIdle : 유휴 커넥션을 검사할 떄 유효하지 않은 커넥션도 검사해서 연결이 끊긴 커넥션을 사전에 제거하는게 좋음
maxWaitMillis : 커넥션 풀에 커넥션이 없으면 일정 시간 대기 후 익셉션을 발생시키는게 좋음. 커넥션을 대기하느라 수십 초 이상 대기하면 사용자는 응답이 없으므로 브라우저의 새로고침을 누르거나 DB를 사용하는 다른 페이지로 이동해서 다시 풀에서 가져오기 위해 대기하게 됨. 사용자가 아무 응답없이 대기하는 것 보다 1초 미만의 길지 않은 시간 안에 커넥션을 구하지 못하면 익셉션을 발생시켜서 알맞은 안내 화면을 보여주는게 더 좋음

GuestBook

JSP JDBC

Table of contents

JSP JDBC

Download MariaDB

JDBC MariaDB Connecter Driver

Add Library

Navicat Connection

JDBC Program Coding Style

JDBC Driver for Communication with DBMS

JDBC URL for Database Identification

Database Connection

Run Queries using Statements

Process Single Quotes when Eecuting Queries using Statements

Read values from ResultSet

Read LONG VARCHAR type value from ResultSet

Run queries using PreparedStatement

Specifying the value of LONG VARCHAR type in PreparedStatement

Why use PreparedStatement Queries?

웹 어플리케이션 구동 시 JDBC 드라이버 로딩하기

JDBC에서 트랜잭션 처리

Connection Pool

What is Connection Pool?

Features of Connection Pool

Using Connection Pool with DBCP

Connection Pool Properties Description

Table of contents