학원 #75일차: Chain of Responsibility 패턴, Persistance 프레임워크 MyBatis

package com.eomcs.pms.filter;

import java.util.Map;
import com.eomcs.pms.handler.Request;

// 역할:
// - CommandFilter 구현체를 관리하고 실행시킨다.
// -
public class CommandFilterManager {
  Chain firstChain;
  Chain lastChain;

  public void add(CommandFilter filter) {
    Chain chain = new Chain(filter);
    if (lastChain == null) {
      firstChain = lastChain = chain;
      return;
    }
    lastChain.nextChain = chain;
    lastChain = chain;
  }

  public FilterChain getFilterChains() {
    return firstChain;
  }

  // 각각의 필터에게 준비하라고 요청한다.
  public void init(Map<String, Object> context) throws Exception {
    Chain chain = firstChain; // 첫번째 체인을 가져온다.
    while (chain != null) { // 그 체인이 있다면 
      chain.filter.init(context); // 그 체인의 필터에 대해 초기화시킨다.
      chain = chain.nextChain; // 그 체인의 다음 체인을 가져온다.
    } // 더이상 체인이 없다면 나간다.
  }

  //각각의 필터에게 마무리하라고 요청한다.
  public void destroy() {
    Chain chain = firstChain;
    while (chain != null) {
      chain.filter.destroy();
      chain = chain.nextChain;
    }
  }

  private static class Chain implements FilterChain {
    CommandFilter filter;
    Chain nextChain;

    public Chain(CommandFilter filter) {
      this.filter = filter;
    }

    // 커맨드 필터에게 위임 (다음 필터체인을 넘겨줌)
    @Override
    public void doFilter(Request request) throws Exception {
      filter.doFilter(request, nextChain);
    }
  }
}

public interface CommandFilter {
  default void init(Map<String,Object> context) throws Exception {
  }
  
  void doFilter(Request request, FilterChain next) throws Exception;
  
  default void destroy(){}
}

    
//........
	  // commandMap 객체를 context 맵에 보관한다.
    // => 필터나 커맨드 객체가 사용할 수 있기 때문이다.
    context.put("commandMap", commandMap);

    // 필터 관리자 준비
    CommandFilterManager filterManager = new CommandFilterManager();

    // 필터를 등록한다.
    filterManager.add(new LogCommandFilter());
    filterManager.add(new AuthCommandFilter());
    FilterManager.add(new DefaultCommandFilter());

    // 필터가 사용할 값을 context 맵에 담는다.
    File logFile = new File("command.log");
    context.put("logFile", logfile);

    // 필터들을 준비시킨다.
    filterManager.init(context);

    // 사용자가 입력한 명령을 처리할 필터 체인을 얻는다.
    FilterChain filterChain = filterManager.getFilterChains();

    loop:
      while (true) {
        String inputStr = Prompt.inputString("명령> ");

        if (inputStr.length() == 0) {
          continue;
        }

        commandStack.push(inputStr);
        commandQueue.offer(inputStr);

        switch (inputStr) {
          case "history": printCommandHistory(commandStack.iterator()); break;
          case "history2": printCommandHistory(commandQueue.iterator()); break;
          case "quit":
          case "exit":
            System.out.println("안녕!");
            break loop;
          default:
            // 커맨드나 필터가 사용할 객체를 준비한다.
            Request request = new Request(inputStr, context);

            // 필터들의 체인을 실행한다.
            if (filterChain != null) {
              filterChain.doFilter(request);
            }
        }
        System.out.println();
      }
    Prompt.close();

    // 필터들을 마무리시킨다.
    filterManager.destroy();

    notifyApplicationContextListenerOnServiceStopped();

public class BoardDaoImpl implements com.eomcs.pms.dao.BoardDao{

  Connection con;

  public BoardDaoImpl(Connection con) {
    this.con = con;
  }

  @Override
  public int insert(Board board) throws Exception {
    try (PreparedStatement stmt = con.prepareStatement(
        "insert into pms_board(title,content,writer) values(?,?,?)")) {

      stmt.setString(1, board.getTitle());
      stmt.setString(2, board.getContent());
      stmt.setInt(3, board.getWriter().getNo());
      return stmt.executeUpdate();
    }
  }
  
	//..
  
  @Override
  public List<Board> findAll() throws Exception {
    try (PreparedStatement stmt = con.prepareStatement(
        "select b.no, b.title, b.cdt, b.vw_cnt, m.no writer_no, m.name"
            + " from pms_board b inner join pms_member m on b.writer=m.no"
            + " order by b.no desc")) {

      try (ResultSet rs = stmt.executeQuery()) {

        ArrayList<Board> list = new ArrayList<>();

        while (rs.next()) {
          Board board = new Board();
          board.setNo(rs.getInt("no"));
          board.setTitle(rs.getString("title"));

          Member member = new Member();
          member.setNo(rs.getInt("writer_no"));
          member.setName(rs.getString("name"));
          board.setWriter(member);

          board.setRegisteredDate(rs.getDate("cdt"));
          board.setViewCount(rs.getInt("vw_cnt"));

          list.add(board);
        }
        return list;
      }
    }
  }
}

public class BoardDaoImpl implements com.eomcs.pms.dao.BoardDao{
	//....
  @Override
  public int insert(Board board) throws Exception {
    InputStream inputStream = Resources.getResourceAsStream("com/eomcs/pms/conf/mybatis-config.xml");
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputstream);
    // mybatis의 커밋 상태
    // - sqlSession.openSession(): 수동 커밋
    // - sqlSession.openSession(true): 오토 커밋
    try (SqlSession sqlSession = sqlSessionFactory.openSession(true)) {
      
      // => SqlSession 객체에 insert SQL문을 실행하라고 명령한다.
      return sqlSession.insert("Board.insert", board);
    }
  }

  //....
  @Override
  public List<Board> findAll() throws Exception {
    // mybatis 객체 준비
    
    // => mybatis 설정 파일을 읽어 들일 입력 스트림을 준비한다.
    InputStream inputStream = Resources.getResourceAsstream("com/eomcs/pms/conf/mybatis-config.xml");
    
    // => 입력 스트림에서 mybatis 설정 값을 읽어 SqlSessionFactory를 만든다.
    SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
    
    // => SqlSessionFactory에서 SqlSession 객체를 얻는다.
    //    SqlSession 객체는 SQL문을 실행하는 객체다.
    try (SqlSession sqlSession = sqlSessionFactory.openSession()) {
      // => SqlSession 객체에게 별도 파일에 분리한 SQL을 찾아 실행하라고 명령한다.
      return sqlSession.selectList("BoardDao.findAll");
    }
  }
}

class Board {
  Member writer;
}

class Member {
  int no;
  String name;
  Address addr;
  
}

class Address {
  String postNo;
  String baseAddr;
}


Address a = new Address();
Member m = new Member();
m.setAddr(a);
Board b = new Board();
b.setWriter(m);