게시판 - webstudy-board - controller,model

1. model

1) src - model.DataSource.java

package model; import javax.sql.DataSource; import org.apache.tomcat.dbcp.dbcp2.BasicDataSource; /* * javax.sql.DataSource Interface는 다양한 DBCP 구현체를 표준화 하는 인터페이스 * DataSource Interface 타입으로 DAO에서 사용하면 DBCP 구현체가 변경되도 별도 코드 수정 필요 없음 */ public class DataSourceManager { private static DataSourceManager instance=new DataSourceManager(); private DataSource dataSource; private DataSourceManager() { BasicDataSource dbcp=new BasicDataSource(); dbcp.setDriverClassName("org.mariadb.jdbc.Driver"); dbcp.setUrl("jdbc:mysql://localhost:3306/study_db"); dbcp.setUsername("study_user"); dbcp.setPassword("user"); //동시에 사용될 수 있는 커넥션 수 설정, 기본은 8 dbcp.setMaxTotal(20); dataSource=dbcp; } public static DataSourceManager getInstance() { return instance; } public DataSource getDataSource() { return dataSource; } }

2) src - model.ClientDTO

package model; public class ClientDTO { private String clientId; private String clientPassword; private String clientName; private String clientEmail; private String clientPhone; private String clientAddress; public ClientDTO(String clientId, String clientPassword, String clientName, String clientEmail, String clientPhone, String clientAddress) { super(); this.clientId = clientId; this.clientPassword = clientPassword; this.clientName = clientName; this.clientEmail = clientEmail; this.clientPhone = clientPhone; this.clientAddress = clientAddress; } public ClientDTO() { super(); } public String getClientId() { return clientId; } public void setClientId(String clientId) { this.clientId = clientId; } public String getClientPassword() { return clientPassword; } public void setClientPassword(String clientPassword) { this.clientPassword = clientPassword; } public String getClientName() { return clientName; } public void setClientName(String clientName) { this.clientName = clientName; } public String getClientEmail() { return clientEmail; } public void setClientEmail(String clientEmail) { this.clientEmail = clientEmail; } public String getClientPhone() { return clientPhone; } public void setClientPhone(String clientPhone) { this.clientPhone = clientPhone; } public String getClientAddress() { return clientAddress; } public void setClientAddress(String clientAddress) { this.clientAddress = clientAddress; } @Override public String toString() { return "ClientDTO [clientId=" + clientId + ", clientPassword=" + clientPassword + ", clientName=" + clientName + ", clientEmail=" + clientEmail + ", clientPhone=" + clientPhone + ", clientAddress=" + clientAddress + "]"; } }

3) src - model.ClientDAO

package model; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; public class ClientDAO { private static ClientDAO instance=new ClientDAO(); private ClientDAO() {} public static ClientDAO getInstance() { return instance; } public Connection getConnection() throws SQLException{ return DriverManager.getConnection("jdbc:mysql://localhost:3306/study_db","study_user","user"); } public void closeAll(PreparedStatement pstmt,Connection con) throws SQLException{ if(pstmt!=null) pstmt.close(); if(con!=null) con.close(); } public void closeAll(ResultSet rs,PreparedStatement pstmt,Connection con) throws SQLException{ if(rs!=null) rs.close(); closeAll(pstmt, con); } //메소드 추가 }

4)src - model.BoardDTO

package model; public class BoardDTO { private int boardNo; private String boardTitle; private String boardContent; private String clientId; private String boardDate; private int boardCount; public BoardDTO() { super(); } public BoardDTO(int boardNo, String boardTitle, String boardContent, String clientId, String boardDate, int boardCount) { super(); this.boardNo = boardNo; this.boardTitle = boardTitle; this.boardContent = boardContent; this.clientId = clientId; this.boardDate = boardDate; this.boardCount = boardCount; } public int getBoardNo() { return boardNo; } public void setBoardNo(int boardNo) { this.boardNo = boardNo; } public String getBoardTitle() { return boardTitle; } public void setBoardTitle(String boardTitle) { this.boardTitle = boardTitle; } public String getBoardContent() { return boardContent; } public void setBoardContent(String boardContent) { this.boardContent = boardContent; } public String getClientId() { return clientId; } public void setClientId(String clientId) { this.clientId = clientId; } public String getBoardDate() { return boardDate; } public void setBoardDate(String boardDate) { this.boardDate = boardDate; } public int getBoardCount() { return boardCount; } public void setBoardCount(int boardCount) { this.boardCount = boardCount; } @Override public String toString() { return "BoardDTO [boardNo=" + boardNo + ", boardTitle=" + boardTitle + ", boardContent=" + boardContent + ", clientId=" + clientId + ", boardDate=" + boardDate + ", boardCount=" + boardCount + "]"; } }

5) src - mordel.BoardDAO

package model; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import javax.sql.DataSource; public class BoardDAO { private static BoardDAO instance=new BoardDAO(); private DataSource dataSource; private BoardDAO(){ dataSource=DataSourceManager.getInstance().getDataSource(); } public static BoardDAO getInstance() throws ClassNotFoundException{ return instance; } public void closeAll(PreparedStatement pstmt,Connection con) throws SQLException{ if(pstmt!=null) pstmt.close(); if(con!=null) con.close(); } public void closeAll(ResultSet rs,PreparedStatement pstmt,Connection con) throws SQLException{ closeAll(pstmt,con); if(rs!=null) rs.close(); } public Connection getConnection() throws SQLException{ return dataSource.getConnection(); } //여기서부터 코딩 }

 

※ DB connection 테스트

1) src - mordel.BoardDAO 에 checkDbconnect 추가

//DB Connection Test public void checkDbconnect()throws SQLException{ Connection con=null; PreparedStatement pstmt=null; ResultSet rs=null; ArrayList<ClientDTO> list=new ArrayList<ClientDTO>(); try { con=dataSource.getConnection(); String sql="select * from client"; pstmt=con.prepareStatement(sql); rs=pstmt.executeQuery(); while(rs.next()) { ClientDTO resultDTO=new ClientDTO(rs.getString(1),rs.getString(2),rs.getString(3),rs.getString(4),rs.getString(5),rs.getString(6)); list.add(resultDTO); } for(int i=0;i<list.size();i++) System.out.println(list.get(i)); }finally { closeAll(rs, pstmt, con); } }

2) src - test.TestDBConnection.java 

package test; import java.sql.SQLException; import model.BoardDAO; public class TestDBConnection { public static void main(String[] args) throws ClassNotFoundException, SQLException { BoardDAO.getInstance().checkDbconnect(); } }

 

 

[참고] Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/juli/logging/LogFactory 에러발생 시

- tomcat-juli.jar파일 다운로드(톰캣버전에 맞게) : https://mvnrepository.com/artifact/org.apache.tomcat/tomcat-juli

Maven Repository: org.apache.tomcat » tomcat-juli

- Java\jdk1.8.0_211\jre\lib\ext 안에 tomcat-juli.jar 파일을 넣는다.

 

2. controller

1) src - controller.DispatcherServelt.java

package controller; import java.io.IOException; import javax.servlet.ServletException; import javax.servlet.annotation.WebServlet; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; @WebServlet("/DispatcherServlet") public class DispatcherServlet extends HttpServlet { private static final long serialVersionUID = 1L; public DispatcherServlet() { super(); } protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { handleRequest(request, response); } protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { request.setCharacterEncoding("utf-8"); handleRequest(request, response); } private void handleRequest(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException{ try { String command=request.getParameter("command"); String url=HandlerMapping.getInstance().create(command).execute(request,response); if(url.trim().startsWith("redirect:")) response.sendRedirect(url.trim().substring(9)); else request.getRequestDispatcher(url).forward(request, response); } catch (Exception e) { e.printStackTrace(); response.sendRedirect("error.jsp"); } } }

2) src - controller.HandlerMapping.java

package controller; public class HandlerMapping { private static HandlerMapping instance=new HandlerMapping(); private HandlerMapping() {} public static HandlerMapping getInstance() { return instance; } public Controller create(String command) { Controller c=null; //메인 //회원관리 //게시판 return c; } }

3) src - controller.Controller.java(인터페이스)

package controller; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; public interface Controller { public String execute(HttpServletRequest request, HttpServletResponse response) throws Exception; }