#93 Java Connection Pool

 2019.09.26

 

 

ConnectionPool.zip

1.76MB

 

 

 

 context.xml

<?xml version="1.0" encoding="UTF-8"?>
<context> 
 
    <!-- 
    
    Resource를 등록하여 웹에서 JNDI로 호출할 이름과 정보를 설정
    각 db의 Driver jar 필요
    mariadb : org.mariadb.jdbc.Driver // jdbc:mariadb
    mysql : org.gjt.mm.mysql.Driver // jdbc:mysql
    
    -->
 
    <Resource 
      name="jdbc/connCall" 
      auth="Container" 
      type="javax.sql.DataSource"
    factory="org.apache.tomcat.dbcp.dbcp2.BasicDataSourceFactory"
    driverClassName="com.mysql.jdbc.Driver"
    url="jdbc:mysql://localhost:3306/db명?"
    username="db아이디" 
    password="db비밀번호" 
    maxActive="100" 
    maxIdle="30" 
    maxWait="10000"
    removeAbandoned="true" 
    removeAbandonedTimeout="60"/> 
 
      <!-- 
    1. name : JNDI로 호출될 이름을 설정
    2. auth : DBCP를 관리할 관리자 (Container or Application)
    3. type : 해당 resource의 return type 
    4. factory : dbcp를 유용하는 관리 클래스
    5. driverClassName : JDBC를 이용하기 위한 드라이버 클래스
    6. url : DB의 접속 URL
    7. username : DB의 계정 명
    8. password : 계정에 대한 비밀번호
    9. maxActive : 최대 접속 허용 개수
    10. maxIdle : DB Pool에 여분으로 남겨질 최대 Connection 개수
    11. maxWait : DB 연결이 반환되는 Timeout의 최대 시간 (-1은 무한 대기)
    12. removeAbandoned : Connection이 잘못 관리되어 버려진 연결을 찾아 재활용할 것인지의 여부 설정
    13. removeAbandonedTimeout : 버려진 연결로 인식할 기본 시간 설정
    (초 단위로 해당 시간이 지나면 버려진 연결로 인식한다.)
    -->          
 
</context>

 

 

 server.xml

<Context docBase="connectionPool" path="/connectionPool" reloadable="true" source="org.eclipse.jst.jee.server:connectionPool"/>

 

 

 ConnectionLoad.java

package kr.or.ksmart;
 
import java.io.IOException;
import java.io.PrintWriter;
 
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;
 
 
@WebServlet("/")
public class ConnectionLoad extends HttpServlet {
    private static final long serialVersionUID = 1L;
    
    public ConnectionLoad() {
        super();        
    }
 
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        String connectionInfo = "";
        String getConnectionInfo = "";
        try{            
            Context context = new InitialContext(); // 프로젝트가 돌아가는 정보
            DataSource dataSource = (DataSource)context.lookup("java:comp/env/jdbc/connCall");
            connectionInfo = dataSource.toString();
            getConnectionInfo = dataSource.getConnection().toString();
        }catch(Exception e){
            e.printStackTrace();
        }
        
        PrintWriter out = response.getWriter();
        out.write("Served at: " + request.getContextPath()+"<br>");
        out.write("dataSource info : " + connectionInfo+"<br>");
        out.write("connection info : " +getConnectionInfo);
        out.close();
        out.flush();
    }
    
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        doGet(request, response);
    }
 
}