6주차 미션 / 서버 4조 김재윤

.run/WebServerLauncher.run.xml

@@ -0,0 +1,10 @@
+<component name="ProjectRunConfigurationManager">
+  <configuration default="false" name="WebServerLauncher" type="Application" factoryName="Application" nameIsGenerated="true">
+    <option name="MAIN_CLASS_NAME" value="WebServerLauncher" />
+    <module name="java-webMVC.main" />
+    <option name="VM_PARAMETERS" value="-Dfile.encoding=UTF-8" />
+    <method v="2">
+      <option name="Make" enabled="true" />
+    </method>
+  </configuration>
+</component>

src/main/java/core/jdbc/JdbcTemplate.java

@@ -0,0 +1,86 @@
+package core.jdbc;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+
+public class JdbcTemplate<T> {
+
+    public void update(String sql, PreparedStatementSetter pstmtSetter) throws SQLException {
+        try (Connection conn = ConnectionManager.getConnection();
+             PreparedStatement pstmt = conn.prepareStatement(sql)) {
+            pstmtSetter.setParameters(pstmt);
+            pstmt.executeUpdate();
+        }
+    }
+
+    public <T> List<T> query(String sql, RowMapper<T> rowMapper) throws SQLException {
+        List<T> objects = new ArrayList<>();
+
+        try (Connection conn = ConnectionManager.getConnection();
+             PreparedStatement pstmt = conn.prepareStatement(sql);
+             ResultSet rs = pstmt.executeQuery();) {
+            while (rs.next()) {
+                T object = rowMapper.mapRow(rs);
+                objects.add(object);
+            }
+        }
+        return objects;
+    }
+
+    public T queryForObject(String sql, PreparedStatementSetter pstmtSetter, RowMapper<T> rowMapper) throws SQLException {
+        ResultSet rs = null;
+        T object = null;
+
+        try (Connection conn = ConnectionManager.getConnection();
+             PreparedStatement pstmt = conn.prepareStatement(sql);) {
+            pstmtSetter.setParameters(pstmt);
+            rs = pstmt.executeQuery();
+            if (rs.next()) {
+                object = rowMapper.mapRow(rs);
+            }
+        } finally {
+            if (rs != null)
+                rs.close();
+        }
+        return object;
+    }
+
+    public void update(String sql, PreparedStatementSetter pstmtSetter, KeyHolder keyHolder) throws SQLException {
+        ResultSet rs = null;
+        try (Connection conn = ConnectionManager.getConnection();
+             PreparedStatement pstmt = conn.prepareStatement(sql, PreparedStatement.RETURN_GENERATED_KEYS)) {
+            pstmtSetter.setParameters(pstmt);
+            pstmt.executeUpdate();
+            rs = pstmt.getGeneratedKeys();
+            if (rs.next()) {
+                keyHolder.setId((int) rs.getLong(1));
+            }
+        } finally {
+            if (rs != null)
+                rs.close();
+        }
+    }
+
+    public List<T> query(String sql, PreparedStatementSetter pstmtSetter, RowMapper<T> rowMapper) throws SQLException {
+        List<T> objects = new ArrayList<>();
+        ResultSet rs = null;
+
+        try (Connection conn = ConnectionManager.getConnection();
+             PreparedStatement pstmt = conn.prepareStatement(sql);) {
+            pstmtSetter.setParameters(pstmt);
+            rs = pstmt.executeQuery();
+            while (rs.next()) {
+                T object = rowMapper.mapRow(rs);
+                objects.add(object);
+            }
+        } finally {
+            if (rs != null)
+                rs.close();
+        }
+        return objects;
+    }
+}

src/main/java/core/jdbc/KeyHolder.java

@@ -0,0 +1,13 @@
+package core.jdbc;
+
+public class KeyHolder {
+    private int id;
+
+    public void setId(int id) {
+        this.id = id;
+    }
+
+    public int getId() {
+        return id;
+    }
+}

src/main/java/core/jdbc/PreparedStatementSetter.java

@@ -0,0 +1,9 @@
+package core.jdbc;
+
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+
+@FunctionalInterface
+public interface PreparedStatementSetter {
+    void setParameters(PreparedStatement ps) throws SQLException;
+}

src/main/java/core/jdbc/RowMapper.java

@@ -0,0 +1,11 @@
+package core.jdbc;
+
+import jwp.model.User;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+@FunctionalInterface
+public interface RowMapper<T> {
+    T mapRow(ResultSet rs) throws SQLException;
+}

src/main/java/core/mvc/AbstractController.java

@@ -0,0 +1,8 @@
+package core.mvc;
+
+import core.mvc.view.ModelAndView;
+
+public interface AbstractController extends Controller{
+    abstract ModelAndView jspView(String url);
+    abstract ModelAndView jsonView();
+}

src/main/java/core/mvc/Controller.java

@@ -0,0 +1,11 @@
+package core.mvc;
+
+import core.mvc.view.ModelAndView;
+import core.mvc.view.View;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+public interface Controller {
+    ModelAndView execute(HttpServletRequest req, HttpServletResponse resp) throws Exception;
+}

src/main/java/core/mvc/DispatcherServlet.java

@@ -0,0 +1,33 @@
+package core.mvc;
+
+import core.mvc.view.ModelAndView;
+
+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(name = "dispatcher", urlPatterns = "/", loadOnStartup = 1)
+public class DispatcherServlet extends HttpServlet {
+    private RequestMapping requestMapping;
+    private static final String REDIRECT_PREFIX = "redirect:";
+
+    @Override
+    public void init() {
+        requestMapping = new RequestMapping();
+    }
+
+    @Override
+    protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException {
+        String url = req.getRequestURI();
+        Controller controller = requestMapping.getController(url);
+        try {
+            ModelAndView mav = controller.execute(req, resp);       //modelandview 사용으로 변경, execute()를 하면 view가 리턴 됨
+            mav.render(req, resp);                                  //modelandview.render() 사용
+        } catch (Exception e) {
+            System.out.println(e.getMessage());
+            throw new ServletException(e.getMessage());
+        }
+    }
+}

src/main/java/core/mvc/ForwardController.java

@@ -0,0 +1,34 @@
+package core.mvc;
+
+import core.mvc.view.JspView;
+import core.mvc.view.ModelAndView;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+public class ForwardController implements AbstractController {
+
+    private final String forwardUrl;
+
+    public ForwardController(String forwardUrl) {
+        this.forwardUrl = forwardUrl;
+        if (forwardUrl == null) {
+            throw new NullPointerException("forwardUrl is null");
+        }
+    }
+
+    @Override
+    public ModelAndView execute(HttpServletRequest req, HttpServletResponse resp) throws Exception {
+        return jspView(forwardUrl);
+    }
+
+    @Override
+    public ModelAndView jspView(String url) {
+        return new ModelAndView(new JspView(url));
+    }
+
+    @Override
+    public ModelAndView jsonView( ) {
+        return null;
+    }
+}

src/main/java/core/mvc/RequestMapping.java

@@ -0,0 +1,40 @@
+package core.mvc;
+
+import jwp.controller.*;
+import jwp.controller.qna.*;
+import jwp.controller.user.*;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class RequestMapping {
+
+    private static final Map<String, Controller> controllers = new HashMap<>();
+
+    static {
+        controllers.put("/", new HomeController());
+        controllers.put("/user/signup", new CreateUserController());
+        controllers.put("/user/list", new ListUserController());
+        controllers.put("/user/login", new LoginController());
+        controllers.put("/user/logout", new LogoutController());
+        controllers.put("/user/update", new UpdateUserController());
+        controllers.put("/user/updateForm", new UpdateUserFormController());
+
+        controllers.put("/user/form", new ForwardController("/user/form.jsp"));
+        controllers.put("/user/loginForm", new ForwardController("/user/login.jsp"));
+        controllers.put("/user/loginFailed", new ForwardController("/user/loginFailed.jsp"));
+
+        controllers.put("/qna/form", new CreateQuestionFormController());
+        controllers.put("/qna/updateForm", new UpdateQuestionFormController());
+        controllers.put("/qna/update", new UpdateQuestionController());
+        controllers.put("/qna/create", new CreateQuestionController());
+        controllers.put("/qna/show", new ShowQnaController());
+
+        controllers.put("/api/qna/addAnswer", new CreateAnswerController());
+    }
+
+
+    public Controller getController(String url) {
+        return controllers.get(url);
+    }
+}

src/main/java/core/mvc/view/JsonView.java

@@ -0,0 +1,31 @@
+package core.mvc.view;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.PrintWriter;
+import java.util.Enumeration;
+import java.util.HashMap;
+import java.util.Map;
+
+public class JsonView implements View{          //req에 있는 모든 파라미터를 map 자료구조에 저장, map 자료구조에 있는 모든 데이터들을 json형식으로 변환하여 사용자에게 응답
+    @Override
+    public void render(Map<String, Object> model, HttpServletRequest request, HttpServletResponse response) throws Exception {   //map 자료구조에 있는 모든 데이터들을 json형식으로 변환하여 사용자에게 http resp 응답
+        ObjectMapper objectMapper = new ObjectMapper();
+        response.setContentType("application/json;charset=utf-8");
+        PrintWriter out = response.getWriter();
+        out.print(objectMapper.writeValueAsString(model));          //model을 json으로 변환
+    }
+
+//    private static Map<String, Object> createModel(HttpServletRequest request) {                        //req에 있는 모든 파라미터를 map 자료구조에 저장후 리턴 (json으로 변환하기 위한 형식)
+//        Enumeration<String> names = request.getParameterNames();
+//        Map<String, Object> model = new HashMap<>();
+//        while (names.hasMoreElements()) {
+//            String name = names.nextElement();
+//            model.put(name, request.getParameter(name));
+//        }
+//        return model;
+//    }
+
+}

src/main/java/core/mvc/view/JspView.java

@@ -0,0 +1,32 @@
+package core.mvc.view;
+
+import javax.servlet.RequestDispatcher;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.util.Map;
+
+public class JspView implements View {
+
+    private final String viewName;      //url
+    private static final String REDIRECT_PREFIX = "redirect:";
+
+
+    public JspView(String viewName) {
+        this.viewName = viewName;
+    }
+
+    @Override
+    public void render(Map<String, Object> model, HttpServletRequest request, HttpServletResponse response) throws Exception {     //사용자에게 웹 페이지를 보여주는 함수
+        if (viewName.startsWith(REDIRECT_PREFIX)) {
+            response.sendRedirect(viewName.substring(REDIRECT_PREFIX.length()));
+            return;
+        }
+
+        for (Map.Entry<String, Object> entry : model.entrySet()) {
+            request.setAttribute(entry.getKey(), entry.getValue());
+        }
+
+        RequestDispatcher rd = request.getRequestDispatcher(viewName);
+        rd.forward(request, response);
+    }
+}