[Servelt] 데이터베이스 연동하기

2024. 8. 9. 19:53자바 웹 개발/서블릿 기초

클라이언트 <-> MemberServlet <-> MemberDAO <-> ㅡMemberVO <-> DB

 

DAO(Data Access Object)는 데이터를 전문적으로 처리하는 객체를 의미한다. 주로 VO를 단위로 처리한다. 

VO(Value Object) 테이블의 한 행을 자바 프록그램에서 하나의 객체가 된다. 데이터베이스에서 하나의 데이터를 엔티티라고 하는데 이를 처리하기 위해 테이블과 유사한 구조로 만든 객체를 VO라고 한다. 

 

 

1.클라이언트가 서블릿에게에 회원 정보를 요청한다. 

<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>회원 가입창</title>
<script type="text/javascript">
	function fn_sendMember(){
		var frmMember = document.frmMember;
		var id = frmMember.id.value;
		var pwd = frmMember.pwd.value;
		var name = frmMember.name.value;
		var email = frmMember.email.value;
		
		if(id.length == 0 || id == ""){
			alert("아이디는 필수입니다.");
		} else if (pwd.length == 0 || pwd == ""){
			alert("비밀번호는 필수입니다.");
		} else if (name.length == 0 || name == ""){
			alert("이름은 필수입니다.");
		} else if (email.length == 0 || email == ""){
			alert("이메일은 필수입니다.");
		} else {
			frmMember.method = "post";
			frmMember.action = "member"; //member로 매핑된 서블릿 호출
			frmMember.submit();
		}
	}
</script>
</head>
<body>
	<form name="frmMember">
		<table>
			<th>회원 가입창</th>
			<tr>
				<td>아이디</td>
				<td><input type="text" name="id"></td> //서블릿에 ID 전송
			</tr>
			<tr>
				<td>비밀번호</td>
				<td><input type="password" name="pwd"></td> //서블릿에 비밀번호 전송
			</tr>
			<tr>
				<td>이름</td>
				<td><input type="text" name="name"></td> //서블릿에 이름 전송
			</tr>
			<tr>
				<td>이메일</td>
				<td><input type="text" name="email"></td> //서블릿에 이메일 전송
			</tr>
		</table>
		
		<input type="button" value="가입하기" onclick="fn_sendMember()"> //함수 실행
		<input type="reset" value="다시 입력">
		<input type="hidden" name="command" value="addMember"/> //회원 가입 명령 전송
	</form>
</body>
</html>

 

 

2.MemberServlet은 요청을 받은 후 MemberDAO 객체를 생성하여 listMembers()메서드를 호출한다. 

@WebServlet("/member") //클라이언트 호출을 받음
public class MemberServlet extends HttpServlet {
  protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException{
	  doHandle(request, response);
  }
  
  protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException{
	  doHandle(request, response);
  }
	
  protected void doHandle(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
	request.setCharacterEncoding("utf-8");
    response.setContentType("text/html;charset=utf-8");
    MemberDAO dao = new MemberDAO();  //SQL문으로 조회할 MemberDAO 객체 생성
    PrintWriter out = response.getWriter();
    String command = request.getParameter("command");
    
    if(command != null && command.equals("addMember")) { //회원 추가 메서드
    String _id = request.getParameter("id");
    String _pwd = request.getParameter("pwd");
    String _name = request.getParameter("name");
    String _email = request.getParameter("email");
    MemberVO vo = new MemberVO();
    vo.setId(_id);
    vo.setPwd(_pwd);
    vo.setName(_name);
    vo.setEmail(_email);
    dao.addMember(vo);
    } else if (command != null && command.equals("delMember")){ //회원 삭제 메서드
    	String id = request.getParameter("id");
    	dao.delMember(id);
    }

    List<MemberVO> list = dao.listMembers(); // 회원 정보를 조회

    out.print("<html><body>");
    out.print("<table border=1><tr align='center' bgcolor='lightgreen'>");
    out.print("<td>아이디</td><td>비밀번호</td><td>이름</td><td>이메일</td><td>가입일</td><td>삭제</td></tr>");;

    for(int i = 0; i < list.size(); i++){ //조회한 회원 정보를 테이블로 출력
      MemberVO memberVO = list.get(i);
      String id = memberVO.getId();
      String pwd = memberVO.getPwd();
      String name = memberVO.getName();
      String email = memberVO.getEmail();
      Date joinDate = memberVO.getJoinDate();
      out.print("<tr><td>" + id + "</td><td>" + pwd + "</td><td>" + name + "</td><td>" + email + "</td><td>" + joinDate + "</td><td>" + "<a href='/pro5/member?command=delMember&id=" + id + "'>삭제</a></td></tr>");
    }
    out.print("</table></body></html>");
    out.print("<a href='/pro5/memberForm.html'>새 회원 등록하기</a>");
  }

 

3. listMembers()에서 다시 connDB() 메서드를 호출하여 데이터베이스와 연결후 SQL문을 실행하여 회원 정보를 조회한다. 

public class MemberDAO {
  private PreparedStatement pstmt;
  private Connection con;
  private DataSource dataFactory;

  public MemberDAO() {
	  try {
		  Context ctx = new InitialContext();
		  Context envContext = (Context) ctx.lookup("java:/comp/env");
		  dataFactory = (DataSource) envContext.lookup("jdbc/oracle");
		  
	  } catch(Exception e) {
		  e.printStackTrace();
	  }
  }

  public List<MemberVO> listMembers(){
    List<MemberVO> list = new ArrayList<MemberVO>();
    try{
      con = dataFactory.getConnection(); //데이터 베이스 연결
      String query = "select * from t_member"; //select 쿼리문 생성
      System.out.println("PrepareStatement: " + query);
      pstmt = con.prepareStatement(query);
      ResultSet rs = pstmt.executeQuery();
      while(rs.next()){
        String id = rs.getString("id"); //회원 정보 불러오기
        String pwd = rs.getString("pwd");
        String name = rs.getString("name");
        String email = rs.getString("email");
        Date joinDate = rs.getDate("joinDate");
        MemberVO vo = new MemberVO(); //VO 객체 생성
        vo.setId(id); //객체에 정보 입력
        vo.setPwd(pwd);
        vo.setName(name);
        vo.setEmail(email);
        vo.setJoinDate(joinDate);
        list.add(vo);
      }
      rs.close();
      pstmt.close();
      con.close();
    } catch(Exception e){
      e.printStackTrace();
    }
    return list; //리스트 반환
  }
  
  public void addMember(MemberVO memberVO) {
	  System.out.println("여기서 실행");
	  try {
		  con = dataFactory.getConnection(); //데이터 베이스 연결
		  String id = memberVO.getId();
		  String pwd = memberVO.getPwd();
		  String name = memberVO.getName();
		  String email = memberVO.getEmail();
		  
		  String query = "insert into t_member"; //insert문 생성
		  query += " (id, pwd, name, email)";
		  query += " values(?,?,?,?)";
		  System.out.println("prepareStatement: " + query);
		  pstmt = con.prepareStatement(query); 
		  
		  pstmt.setString(1,  id);
		  pstmt.setString(2,  pwd);
		  pstmt.setString(3,  name);
		  pstmt.setString(4,  email);
		  pstmt.executeUpdate();
		  pstmt.close();
	  } catch(Exception e) {
		  e.printStackTrace();
	  }
  }
  
  public void delMember(String id) {
	  try {
		  con = dataFactory.getConnection();
		  
		  String query = "delete from t_member" + " where id=?"; //delete문 생성
		  System.out.println("prepareStatement: " + query);
		  pstmt = con.prepareStatement(query);
		  pstmt.setString(1,  id); //?에 전달된 id를 인자로 넣기
		  pstmt.executeUpdate(); //실행
		  pstmt.close();
	  } catch (Exception e) {
		  e.printStackTrace();
	  }
  }
}

 

4. 조회된 회원 정보를 MemberVO속성에 설정한 후 다시 ArrayList에 저장한다. 

public class MemberVO {
	  private String id;
	  private String pwd;
	  private String name;
	  private String email;
	  private Date joinDate;
	  
	  public String getId() {
		return id;
	}
	  public void setId(String id) {
		this.id = id;
	}
	  public String getPwd() {
		return pwd;
	}
	  public void setPwd(String pwd) {
		this.pwd = pwd;
	}
	  public String getName() {
		return name;
	}
	  public void setName(String name) {
		this.name = name;
	}
	  public String getEmail() {
		return email;
	}
		public void setEmail(String email) {
		this.email = email;
	}
		public Date getJoinDate() {
		return joinDate;
	}
		public void setJoinDate(Date joinDate) {
		this.joinDate = joinDate;
	}
	
	}

 

5. ArrayList를 다시 메서드를 호출한 MemberServlet으로 반환한 후 ArrayList의 MemberVo를 차례대로 가져와 회원 정보를 HTML 태그의 문자열로 만든다. 

 

6. 만들어진 HTML 태그를 웹 브라우저로 전송한다.