태터데스크 관리자

도움말
닫기
적용하기   첫페이지 만들기

태터데스크 메시지

저장하였습니다.

이번에는 글목록을 출력하는 코드를 작성해보도록 하겠다. 일단 모델은 지난 번과 같이 POJO를 사용하여 최대한 단순무식(?)하게 구현을 할 것이다. 데이터맵핑과 관련한 프레임워크를 사용해 볼 계획이지만 일단은 스트러츠 1.x에 최대한 집중하여 작성할 것이므로 다른 프레임워크를 섞어서 코드를 복잡하게 할 생각은 없다.^^;

모델

	private static final String _LIST = ""
		+ "SELECT no, title, writer, wtime FROM bboard ORDER BY no DESC "
		+ "LIMIT ?, ?";
	
	private static final int _ROWSPERPAGE = 10;

	/**
	 * 게시판 글목록 가져오기
	 * @param pageNo 페이지 번호
	 * @return ArrayList<BasicBoardDataBean> 글목록
	 * @throws SQLException
	 */
	public List<BasicBoardDataBean> list(int pageNo) throws SQLException {
		ArrayList<BasicBoardDataBean> rows =
			new ArrayList<BasicBoardDataBean>();
		int startRowNo = (pageNo - 1) * _ROWSPERPAGE + 1;
		int endRowNo = pageNo * _ROWSPERPAGE;
		
		Connection conn = null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		
		conn = _getConnection();
		
		try {
			pstmt = conn.prepareStatement(_LIST);
			pstmt.setInt(1, startRowNo);
			pstmt.setInt(2, endRowNo);
			
			
			rs = pstmt.executeQuery();
			
			while (rs.next()) {
				BasicBoardDataBean row = new BasicBoardDataBean();
				row.setNo(rs.getLong(1));
				row.setTitle(rs.getString(2));
				row.setWriter(rs.getString(3));
				row.setWtime(rs.getTimestamp(4));
				
				rows.add(row);
			}
		} finally {
			try {
				pstmt.close();
			} catch (SQLException e) {
				throw e;
			}

			try {
				conn.close();
			} catch (SQLException e) {
				throw e;
			}
			
			pstmt = null;
			conn = null;
		}
		
		return rows;
	}

출력을 위한 폼이므로 ActionForm은 일단 작성하지 않았다. 스트러츠는 JSTL을 확장한 다양한 taglib를 제공한다. 우선 페이지 네비게이션과 디자인은 빼고 기본적인 로직만 담도록 하겠다.

폼(listForm.jsp)

<%@ page language="java" contentType="text/html; charset=UTF-8"
    pageEncoding="UTF-8"%>
<%@ taglib prefix="html" uri="http://struts.apache.org/tags-html" %>
<%@ taglib prefix="bean" uri="http://struts.apache.org/tags-bean" %>
<%@ taglib prefix="logic" uri="http://struts.apache.org/tags-logic" %>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"
	"http://www.w3.org/TR/html4/loose.dtd">
<html:html lang="true">
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>글목록</title>
</head>
<body>
<logic:empty name="rows" scope="request">
<p>글 목록이 없습니다.</p>
</logic:empty>
<logic:notEmpty name="rows" scope="request">
	<logic:iterate id="row" name="rows">
		<bean:write name="row" property="no"/>:
		<bean:write name="row" property="title"/>:
		<bean:write name="row" property="writer"/>:
		<bean:write name="row" property="wtime"
			format="yyyy년 MM월 dd월 hh시 mm분 ss초"/>
		<br>
	</logic:iterate>
</logic:notEmpty>
</body>
</html:html>

액션폼(ListAction.java)

package net.jeongsam.bboard.struts1.action;

import java.util.List;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import net.jeongsam.bboard.model.BasicBoardDAO;
import net.jeongsam.bboard.model.BasicBoardDataBean;

import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;

public class ListAction extends Action {
	@Override
	public ActionForward execute(ActionMapping mapping,
			ActionForm form,
			HttpServletRequest request,
			HttpServletResponse response) throws Exception {
		ActionForward forward = null;
		String $pageNo = request.getParameter("pageNo");
		int pageNo = Integer.parseInt(
				$pageNo != null ? $pageNo : "1");
		
		BasicBoardDAO boardMgr = new BasicBoardDAO();
		List rows = boardMgr.list(pageNo);
		
		request.setAttribute("rows", rows);
		forward = mapping.findForward("LIST");
		
		return forward;
	}
}

매핑설정(struts-config.xml)

	<action
			path="/list"
			type="net.jeongsam.bboard.struts1.action.ListAction"
			name="listForm"
			scope="request"
			validate="false">
			<forward name="LIST" path="/bboard/struts1/listForm.jsp"/>
	</action>
저작자 표시 비영리 동일 조건 변경 허락

Posted by 정샘

스트러츠는 JSP에서의 필터와 같은 기능을 RequestProcessor 클래스를 확장하는 방법으로 제공한다. 예를 들어 폼을 이용하여 데이터를 읽어들이는데 ActionForm을 이용하게 되면 한글 처리를 위해 인코딩 변경 코드를 넣을 곳이 마땅하지 않다. Action에 넣으면 되겠지만 만일 ActionForm에서 입력데이터의 검증시 한글을 처리해야 할 경우 역시 문제가 된다.

참고로 HTML-FORM에 입력된 데이터는 ActionForm으로 전달되어 입력 데이터의 검증을 거치고 Action을 통해 모델로 전달된다. 여기서 HTML-FORM과 ActionForm이 뷰가 되고 ActionServlet이라는 컨트롤러에 의해 적당한 Action이 호출되어 모델로 데이터를 전달하는데, 여기서는 2가지 이슈가 발생한다. 첫번째는 ActionForm자체가 빈이므로 ActionForm자체를 모델로 전달할 것이가 하는 문제인데 이는 유연성을 위해 데이터빈을 별도로 작성하여 ActionForm으로부터 데이터빈으로 데이터를 저장한 뒤 이 데이터빈을 모델로 전달하는 것이 원칙이다. 두번째는 Action을 컨트롤러로 볼 것인지 모델로 볼 것인지 하는 문제인데 이 문제는 스트러츠 프레임워크 제작팀과 MVC 패턴 신봉자들간의 문제로 남겨두는 것이 정신건강에 유익할 것 같다.

다시 원래의 문제로 돌아가서 한글 처리를 위한 코드를 어디에 넣느냐하는 문제가 남는데 이를 위해 RequestProcessor 클래스를 상속하여 확장할 필요가 있다. RequestProcessor 클래스에는 여러 메서드가 제공되는데 여기서는 processoPreprocess() 메서드를 오버라이딩하여 처리한다.

package net.jeongsam.bboard.struts1;

import java.io.UnsupportedEncodingException;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.struts.action.RequestProcessor;

public class KoRequestProcessor extends RequestProcessor {
	@Override
	protected boolean processPreprocess(HttpServletRequest request,
			HttpServletResponse resoponse) {
		try {
			request.setCharacterEncoding("UTF-8");
		} catch (UnsupportedEncodingException e) {
			e.printStackTrace();
		}
		
		return true;
	}
}
저작자 표시 비영리 동일 조건 변경 허락

Posted by 정샘

스트러츠는 JSP의 모델2를 구현한 프레임워크이다. 현재는 스트러츠2로 새로이 바뀌었지만 관공서 등 기존 작성된 대부분의 프로젝트는 스트러츠1을 기반으로 작성된 것이 많으므로 스트러츠1을 기반으로 한 예제를 만들어 보려고 한다.

예제에 사용된 환경은 다음과 같다.

  • Tomcat 6.0.20
  • JSTL 1.2
  • Struts 1.3.10
  • Eclipse 3.5
  • MySQL 5.1

예제를 단순화시키기 위해 게시판은 기본적인 구조를 가지도록 스키마를 작성했다.

스키마는 JSP 모델1과 동일하다.

이클립스에서 실행시키기 위해 Struts 1.3 라이브러리를 프로젝트의 lib 폴더로 옮겨놓는다. 참고를 위해 프로젝트 탐색기의 구조를 캡쳐해서 올려놓았다.

스트러츠1은 입력폼(writeForm.jsp)과 입력폼의 데이터를 검증하기 위한 액션 폼(InsertForm.java), 그리고 입력폼의 데이터를 모델로 전달하는 액션(InsertAction.java)을 구현한다. 그리고 struts-config.xml을 통해 액션 폼과 폼, 액션을 연결하여 컨트롤러가 실행하도록 한다. 물론 컨드롤러의 배포기술자는 web.xml에 작성한다.

입력폼(writerForm.jsp) 소스

<%@ page language="java" contentType="text/html; charset=UTF-8"
    pageEncoding="UTF-8"%>
<%@ taglib prefix="html" uri="http://struts.apache.org/tags-html" %>
<%@ taglib prefix="bean" uri="http://struts.apache.org/tags-bean" %>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"
	"http://www.w3.org/TR/html4/loose.dtd">
<html:html lang="true">
<head>
<title><bean:message key="writeform.title"/></title>
<html:base/>
<link href="${pageContext.request.contextPath}/bboard/css/writeForm.css"
	rel="stylesheet" type="text/css">
</head>
<body>
<h1><bean:message key="writeform.title"/></h1>
<html:form method="post" action="insert" lang="UTF-8" focus="title">
<table border="1">
<colgroup>
<col class="tableHeader">
<col>
</colgroup>
<tr>
<td colspan="2"><html:errors/></td>
</tr>
<tr>
<th><bean:message key="writeform.form.title"/></th>
<td><html:text property="title" size="50"/>
<html:errors property="title"/></td>
</tr>
<tr>
<th><bean:message key="writeform.form.writer"/></th>
<td><html:text property="writer" size="10"/>
<html:errors property="writer"/></td>
</tr>
<tr>
<th><bean:message key="writeform.form.content"/></th>
<td><html:errors property="content"/>
<html:textarea property="content" cols="50" rows="10"/>
</tr>
<tr>
<td colspan="2"><html:submit titleKey="writeform.form.submit"/></td>
</tr>
</table>
</html:form>
</body>
</html:html>

액션 폼(InsertForm.java) 소스

package net.jeongsam.bboard.struts1.form;

import javax.servlet.http.HttpServletRequest;
import org.apache.struts.action.ActionErrors;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionMapping;
import org.apache.struts.action.ActionMessage;

@SuppressWarnings("serial")
public class InsertForm extends ActionForm {
	private String title;
	private String writer;
	private String content;
	
	public String getTitle() {
		return title;
	}
	public void setTitle(String title) {
		this.title = title;
	}
	public String getWriter() {
		return writer;
	}
	public void setWriter(String writer) {
		this.writer = writer;
	}
	public String getContent() {
		return content;
	}
	public void setContent(String content) {
		this.content = content;
	}
	
	@Override
	public ActionErrors validate(ActionMapping mapping,
			HttpServletRequest request) {
		ActionErrors errors = new ActionErrors();
		if (getTitle() == null || getTitle().length() == 0) {
			errors.add("title", new ActionMessage("writeform.error.title"));
		}
		if (getWriter() == null || getWriter().length() == 0) {
			errors.add("writer", new ActionMessage("writeform.error.writer"));
		}
		if (getContent() == null || getContent().length() == 0) {
			errors.add("content", new ActionMessage("writeform.error.content"));
		}
		
		return errors;
	}
}

액션(InsertAction.java) 소스

package net.jeongsam.bboard.struts1.action;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import net.jeongsam.bboard.model.BasicBoardDAO;
import net.jeongsam.bboard.model.BasicBoardDataBean;
import net.jeongsam.bboard.struts1.form.InsertForm;

import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;

public class InsertAction extends Action {
	@Override
	public ActionForward execute(ActionMapping mapping,
			ActionForm form,
			HttpServletRequest request,
			HttpServletResponse response)
		throws Exception {
		
		BasicBoardDataBean bbRow = new BasicBoardDataBean();
		BasicBoardDAO boardMgr = new BasicBoardDAO();
		
		bbRow.setTitle(((InsertForm)form).getTitle());
		bbRow.setWriter(((InsertForm)form).getWriter());
		bbRow.setContent(((InsertForm)form).getContent());
		
		boardMgr.insert(bbRow);
		
		return mapping.findForward("Success");
	}
}

BasicBoard_ko_KR.properties

#Generated by ResourceBundle Editor (http://eclipse-rbe.sourceforge.net)

errors.footer = </ul>
errors.header = <ul>
errors.prefix = <li>
errors.suffix = </li>

writeform.error.content = 본문을 입력하세요.
writeform.error.title   = 제목을 입력하세요.
writeform.error.writer  = 저자를 입력하세요.
writeform.form.content  = 본문
writeform.form.title    = 제목
writeform.form.writer   = 저자
writeform.title         = 글쓰기

struts-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE struts-config PUBLIC
	"-//Apache Software Foundation//DTD Struts Configuration 1.3//EN"
	"http://struts.apache.org/dtds/struts-config_1_3.dtd">
<struts-config>
	<form-beans>
		<form-bean
			name="insertForm"
			type="net.jeongsam.bboard.struts1.form.InsertForm">
			<form-property name="" type=""></form-property>
		</form-bean>
	</form-beans>
	
	<action-mappings>
		<action
			name="insertForm"
			type="net.jeongsam.bboard.struts1.action.InsertAction"
			path="/insert"
			scope="request"
			validate="true"
			input="/bboard/struts1/writeForm.jsp">
			<forward name="Success" path="/bboard/struts1/result.jsp" redirect="true"/>
			<forward name="Fail" path="/bboard/struts1/writeForm.jsp"/>
		</action>
	</action-mappings>
	
	<controller
		processorClass="net.jeongsam.bboard.struts1.KoRequestProcessor"
		contentType="text/html;charset=UTF-8"
		locale="true"
		nocache="true"/>
		
    <message-resources
    	parameter="net.jeongsam.bboard.struts1.BasicBoard"
    	null="false"/>
</struts-config>

web.xml

<servlet>
		<servlet-name>Struts1Action</servlet-name>
		<servlet-class>org.apache.struts.action.ActionServlet</servlet-class>
		<init-param>
			<param-name>config</param-name>
			<param-value>/WEB-INF/struts1-config.xml</param-value>
		</init-param>
		<load-on-startup>1</load-on-startup>
	</servlet>
	<servlet-mapping>
		<servlet-name>Struts1Action</servlet-name>
		<url-pattern>/struts1/bboard/*</url-pattern>
	</servlet-mapping>

server.xml

<Context
	docBase="MySamples"
	path="/MySamples"
	reloadable="true"
	source="org.eclipse.jst.jee.server:MySamples">
	<Resource
		auth="Container"
		driverClassName="com.mysql.jdbc.Driver"
		maxActive="100"
		maxIdle="30"
		maxWait="10000"
		name="jdbc/MySamples"
		type="javax.sql.DataSource"
		url="jdbc:mysql://127.0.0.1:3306/example?autoReconnect=true"
		username="****"
		password="****"/>
</Context>

한가지 덧붙이자면, MVC 모델에서 컨트롤러는 사용자의 요청을 받아 뷰와 모델을 선택하는 단순한 기능만을 구현하도록 하고 있다. 그래서 스트러츠1에서도 액션 폼을 컨트롤러로 보아야 하는지 모델로 보아야 하는지에 대한 논의가 상당수 있는 듯하다. 원칙론자라면 액션 폼이 컨트롤러에 종속된 면이 없지않은 이유로 모델로 볼 수 없고, 게다가 같은 이유로 모델로 볼 수도 없다는 입장이며 그런 이유로 스트러츠는 완벽하게 이론적인 MVC를 구현했다고 볼 수 없다는 의견이 있다.

저작자 표시 비영리 동일 조건 변경 허락

Posted by 정샘

1. 데이터베이스 스키마 (MySQL 5.x)

-- 기본형 게시판 스키마
DROP TABLE IF EXISTS bboard;
CREATE TABLE bboard (
    no SERIAL, -- 글번호
    title VARCHAR(100) NOT NULL, -- 제목
    content LONGTEXT NOT NULL, -- 본문
    writer VARCHAR(50) NOT NULL, -- 글 올린 이
    wtime DATETIME NOT NULL, -- 글 쓴 시간
    PRIMARY KEY (no)
) ENGINE MyISAM;

2. 모델 설계 (POJO)

1) 데이터빈

package net.jeongsam.models.bboard;

import java.sql.Timestamp;

public class BasicBoardDataBean {
	private long no;
	private String title;
	private String content;
	private String writer;
	private Timestamp wtime;
	
	public long getNo() {
		return no;
	}
	public void setNo(long no) {
		this.no = no;
	}
	public String getTitle() {
		return title;
	}
	public void setTitle(String title) {
		this.title = title;
	}
	public String getContent() {
		return content;
	}
	public void setContent(String content) {
		this.content = content;
	}
	public String getWriter() {
		return writer;
	}
	public void setWriter(String writer) {
		this.writer = writer;
	}
	public Timestamp getWtime() {
		return wtime;
	}
	public void setWtime(Timestamp wtime) {
		this.wtime = wtime;
	}
}

2) 데이터 액세스 객체(DAO)

package net.jeongsam.models.bboard;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;

/**
 * 기본형 게시판 Data Access Object
 * @author 정승용
 * 2009.12.03
 */
public class BasicBoardDAO {
	private static final String _INSERT = "INSERT INTO bboard "
		+ "(title, content, writer, wtime) "
		+ "VALUES (?, ?, ?, NOW())"; 
	
	private Connection _getConnection() {
		Connection conn = null;
		DataSource ds = null;
		
		try {
			Context envCtx = new InitialContext();
			ds = (DataSource)envCtx.lookup("java:/comp/env/jdbc/MySamples"); 
			conn = ds.getConnection();
		} catch (NamingException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		return conn;
	}
	
	/**
	 * 글 쓰기 메서드
	 * 노트: 컬럼 타입을 LONGTEXT로 설정하면 264byte의 글자를 입력할 수 있는데 이때 
	 *     com.mysql.jdbc.PacketTooBigException:
	 *     Packet for query is too large (1048587 > 1048576).
	 *     라는 오류가 발생할 수 있다.
	 *     이를 해결하기 위해 my.ini 설정 파일에 다음과 같이 설정한다.
	 *     max_allowed_packet=1073741824
	 *     위와 같이 설정하면 JDBC를 통해 최대 1GB의 데이터를 전송할 수 있게 된다.
	 * @param bbRow BasicBoardDataBean
	 * @throws SQLException 글 등록 에러
	 */
	public void insert(BasicBoardDataBean bbRow) throws SQLException {
		Connection conn = null;
		PreparedStatement pstmt = null;
		
		conn = _getConnection();
		
		try {
			pstmt = conn.prepareStatement(_INSERT);
			pstmt.setString(1, bbRow.getTitle());
			pstmt.setString(2, bbRow.getContent());
			pstmt.setString(3, bbRow.getWriter());
			
			pstmt.executeUpdate();
		} finally {
			try {
				pstmt.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}

			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			
			pstmt = null;
			conn = null;
		}	
	}
}

3. 입력 양식과 처리

1) 입력 양식 (insert.jsp)

<%@ page language="java" contentType="text/html; charset=UTF-8"
	pageEncoding="UTF-8"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"
	"http://www.w3.org/TR/html4/loose.dtd">
<html lang="ko">
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>글쓰기</title>
</head>
<body>
<h1>글쓰기</h1>
<form method="post" action="insertAction.jsp">
<table>
	<tr>
		<th>제목:</th>
		<td><input type="text" name="title" /></td>
	</tr>
	<tr>
		<th>글쓴이:</th>
		<td><input type="text" name="writer" /></td>
	</tr>
	<tr>
		<th>내용:</th>
		<td><textarea name="content" cols="50" rows="20"></textarea></td>
	</tr>
	<tr>
		<td colspan="2"><input type="submit" value="글올리기" /></td>
	</tr>
</table>
</form>
</body>
</html>

3) 처리 (inputAction.jsp)

<%-- 스크립틀릿과 표준액션을 사용한 모델1 --%>

<%@ page pageEncoding="UTF-8"%>
<%@ page import="java.sql.SQLException" %>
<%@ page import="net.jeongsam.models.bboard.BasicBoardDAO" %>

<% request.setCharacterEncoding("UTF-8"); %>

<jsp:useBean id="boardData"
	class="net.jeongsam.models.bboard.BasicBoardDataBean"
	scope="request">
	<jsp:setProperty name="boardData" property="*"/>
</jsp:useBean>

<%
BasicBoardDAO boardMgr = new BasicBoardDAO();
try {
	boardMgr.insert(boardData);
} catch(SQLException e) {
	e.printStackTrace();
}
out.println("글 등록 성공");
%>
저작자 표시 비영리 동일 조건 변경 허락

Posted by 정샘

모델 프로그래밍

package net.jeongsam.board;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

public class BoardDAO {
	public static enum CLASS { basic, hire }
	
	// private static String DATASOURCE_DB_NAME = "java:/comp/env/jdbc/testboards";
	
	private static String _SQLBASIC = "SELECT id, p_id, subject, create_date "
		+ "FROM (SELECT a.id, a.p_id, a.subject, a.create_date, ROWNUM AS rnum "
		+ "FROM test_boards a WHERE ROWNUM <= :MAX_ROWS) "
		+ "WHERE rnum >= :MIN_ROWS "
		+ "ORDER BY id DESC";
	private static String _SQLHIRE = "SELECT id, p_id, title, create_date "
		+ "FROM (SELECT a.id, a.p_id, LPAD(' ', 2 * (LEVEL - 1)) || a.subject title, "
		+ "a.create_date, ROWNUM AS rnum "
		+ "FROM test_boards a "
		+ "WHERE ROWNUM <= :MAX_ROWS "
		+ "START WITH a.p_id IS NULL "
		+ "CONNECT BY PRIOR a.id = a.p_id "
		+ "ORDER SIBLINGS BY a.id DESC) "
		+ "WHERE rnum >= :MIN_ROWS";
	private static String _SQLREAD = "SELECT id, p_id, subject, content, create_date "
		+ "FROM test_boards WHERE id = :ID";
	private static String _SQLINSERT = "INSERT INTO test_boards VALUES ("
		+ "(SELECT MAX(id) + 1 FROM test_boards), NULL, :SUBJECT, :CONTENT, SYSDATE)";
	private static String _SQLREPLY = "INSERT INTO test_boards VALUES ("
		+ "(SELECT MAX(id) + 1 FROM test_boards), :PNUM, "
		+ "'[엮인글] ' ||  :SUBJECT, :CONTENT, SYSDATE)";
	
	public BoardDAO() {
		                                                                   
	}
	
	private Connection _getConnection() throws BoardDAOExcept {
		Connection conn = null;
		String url = "jdbc:oracle:thin:@127.0.0.1:1521:xe";
		String username = "test";
		String password = "1234";
		try {
			Class.forName("oracle.jdbc.OracleDriver");
			conn = DriverManager.getConnection(url, username, password);
		} catch (ClassNotFoundException e) {
			throw new BoardDAOExcept(e);
		} catch (SQLException e) {
			throw new BoardDAOExcept(e);
		}	
		return conn;
	}
	
	/**
	 * 글 목록 표시하기
	 * @param c 기본형과 답변형 선택
	 * @param startRow 표시할 시작 행 값
	 * @param endRow 표시할 마지막 행 값
	 * @return List<BoardTO> 글 목록
	 * @throws BoardDAOExcept 
	 */
	private List<BoardTO> _getList(BoardDAO.CLASS c, int startRow, int endRow) throws BoardDAOExcept {
		String sql = null;
		
		ArrayList<BoardTO> articles = new ArrayList<BoardTO>();
		
		Connection conn = null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		
		if (c == BoardDAO.CLASS.basic) {
			sql = _SQLBASIC;
		} else {
			sql = _SQLHIRE;
		}
		
		try {
			conn = _getConnection();
			
			pstmt = conn.prepareStatement(sql);
			pstmt.setInt(2, startRow);
			pstmt.setInt(1, endRow);
			
			rs = pstmt.executeQuery();
			
			while (rs.next()) {
				BoardTO article = new BoardTO();
				article.setId(rs.getInt(1));
				article.setPid(rs.getInt(2));
				article.setSubject(rs.getString(3));
				article.setCtime(rs.getTimestamp(4));
				
				articles.add(article);
			}
		} catch (SQLException e) {
			throw new BoardDAOExcept(e);
		} finally {
			if (rs != null)
				try {
					rs.close();
					rs = null;
				} catch(Exception e) {
					throw new BoardDAOExcept(e);
				}
			if (pstmt != null) {
				try {
					pstmt.close();
					pstmt = null;
				} catch(Exception e) {
					throw new BoardDAOExcept(e);
				}
			}
			if (conn != null) {
				try {
					conn.close();
					conn = null;
				} catch(Exception e) {
					throw new BoardDAOExcept(e);
				}
			}
		}
		return articles;
	}
	
	/**
	 * 지정된 페이지의 로우 출력
	 * @param c 게시판 종류 선택
	 * @param pageNum 페이지 번호
	 * @return List<BoardTO> 게시판 데이터
	 * @throws BoardDAOExcept
	 */
	public List<BoardTO> getList(BoardDAO.CLASS c, int pageNum) throws BoardDAOExcept {
		int pagePerRows = 10;
		int startRow = pagePerRows * (pageNum - 1) + 1;
		int endRow = pagePerRows * pageNum;
		
		return _getList(c, startRow, endRow);
	}
	
	/**
	 * 글 내용 읽기
	 * @param id 글 번호
	 * @return BoardTO 글 내용을 저장할 빈
	 * @throws BoardDAOExcept 
	 */
	public BoardTO readArticle(int id) throws BoardDAOExcept {
		Connection conn = null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		BoardTO article = null;
		
		try {
			conn = _getConnection();
			
			pstmt = conn.prepareStatement(_SQLREAD);
			pstmt.setInt(1, id);
			
			rs = pstmt.executeQuery();
			
			if (rs.next()) {
				article = new BoardTO();
				article.setId(rs.getInt(1));
				article.setPid(rs.getInt(2));
				article.setSubject(rs.getString(3));
				article.setCtime(rs.getTimestamp(4));
			}
		} catch (BoardDAOExcept e) {
			throw new BoardDAOExcept(e);
		} catch (SQLException e) {
			throw new BoardDAOExcept(e);
		} finally {
			if (rs != null)
				try {
					rs.close();
					rs = null;
				} catch(Exception e) {
					throw new BoardDAOExcept(e);
				}
			if (pstmt != null) {
				try {
					pstmt.close();
					pstmt = null;
				} catch(Exception e) {
					throw new BoardDAOExcept(e);
				}
			}
			if (conn != null) {
				try {
					conn.close();
					conn = null;
				} catch(Exception e) {
					throw new BoardDAOExcept(e);
				}
			}
		}
		return article;
	}
	
	/**
	 * 글 쓰기
	 * @param article 글 내용 저장 (BoardTO)
	 * @throws BoardDAOExcept 
	 */
	public void insertArticle(BoardTO article) throws BoardDAOExcept {
		Connection conn = null;
		PreparedStatement pstmt = null;
		try {
			conn = _getConnection();
			
			pstmt = conn.prepareStatement(_SQLINSERT);
			pstmt.setString(1, article.getSubject());
			pstmt.setString(2, article.getContent());
			
			pstmt.executeUpdate();
			
		} catch (SQLException e) {
			throw new BoardDAOExcept(e);
		} finally {
			if (pstmt != null) {
				try {
					pstmt.close();
					pstmt = null;
				} catch(Exception e) {
					throw new BoardDAOExcept(e);
				}
			}
			if (conn != null) {
				try {
					conn.close();
					conn = null;
				} catch(Exception e) {
					throw new BoardDAOExcept(e);
				}
			}
		}
	}
	
	/**
	 * 답변 쓰기
	 * @param article 글 내용 저장 (BoardTO)
	 * @throws BoardDAOExcept 
	 */
	public void replyArticle(BoardTO article) throws BoardDAOExcept {
		Connection conn = null;
		PreparedStatement pstmt = null;
		try {
			conn = _getConnection();
			
			pstmt = conn.prepareStatement(_SQLREPLY);
			pstmt.setInt(1, article.getPid());
			pstmt.setString(2, article.getSubject());
			pstmt.setString(3, article.getContent());
			
			pstmt.executeUpdate();
			
		} catch (SQLException e) {
			throw new BoardDAOExcept(e);
		} finally {
			if (pstmt != null) {
				try {
					pstmt.close();
					pstmt = null;
				} catch(Exception e) {
					throw new BoardDAOExcept(e);
				}
			}
			if (conn != null) {
				try {
					conn.close();
					conn = null;
				} catch(Exception e) {
					throw new BoardDAOExcept(e);
				}
			}
		}
	}
	
	/**
	 * 전체 로우 수를 리턴
	 * @return 전체 로우 수
	 */
	public int getTotalRows() {
		return 0;
	}
}
저작자 표시 비영리 동일 조건 변경 허락

Posted by 정샘

답변형 게시판 만들기

SQL (for oracle)

-- 글목록 출력 (등록순)
-- 게시판 페이지 알고리즘 Top-N Query 사용
SELECT id, p_id, subject, create_date
FROM (
    SELECT a.id, a.p_id, a.subject, a.create_date,
      ROWNUM AS rnum
    FROM test_boards a
    WHERE ROWNUM <= :MAX_ROWS)
WHERE rnum >= :MIN_ROWS
ORDER BY id DESC;

-- 글목록 출력 (답변형)
SELECT id, p_id, title, create_date
FROM (
    SELECT a.id, a.p_id, LPAD(' ', 2 * (LEVEL - 1)) || a.subject title,
      a.create_date, ROWNUM AS rnum
    FROM test_boards a
    WHERE ROWNUM <= :MAX_ROWS
    START WITH a.p_id IS NULL
    CONNECT BY PRIOR a.id = a.p_id
    ORDER SIBLINGS BY a.id DESC)
WHERE rnum >= :MIN_ROWS;

-- 글올리기
INSERT INTO test_boards VALUES (
  (SELECT MAX(id) + 1 FROM test_boards), NULL, :SUBJECT, :CONTENT, SYSDATE);

-- 글내용 보기
SELECT id, p_id, subject, content, create_date
FROM test_boards
WHERE id = :ID;

-- 답글쓰기
INSERT INTO test_boards VALUES (
  (SELECT MAX(id) + 1 FROM test_boards), :PNUM,
  '[엮인글] ' ||  :SUBJECT, :CONTENT, SYSDATE);

-- 글 삭제 (자식 글이 존재하면 삭제 불가)
SELECT CONNECT_BY_ISLEAF FROM test_boards
WHERE id = :ID
START WITH p_id IS NULL
CONNECT BY PRIOR id = p_id;

DELETE FROM test_boards WHERE id = :ID

-- 글 수정
UPDATE test_boards
SET subject = :SUBJECT, content = :CONTENT, create_date = SYSDATE
WHERE id = :ID;
저작자 표시 비영리 동일 조건 변경 허락

Posted by 정샘

예전 작업 소스들

Java : 2009/11/11 12:17

package net.jeongsam.prjpkg;
      import java.sql.Connection;
      import java.sql.PreparedStatement;
      import java.sql.ResultSet;
      import java.sql.SQLException;
      import java.util.ArrayList;
      import java.util.Iterator;
      import java.util.List;
      public class ContentDAO {
       private Connection conn = null;
       private PreparedStatement pstmt = null;
       private ResultSet rs = null;
       private String sql = null;
       
       private ContentDAO() {
        conn = ConnectionManager.getConnection();
       }
       
       public static ContentDAO getInstance() {
        return new ContentDAO();
       }
       
       /**
        * 글을 데이터베이스에 삽입한다. 이때 태그는 별도의 테이블에 목록을 만들어 저장한다.
        * 태그의 경우 리스트를 만들어 리스트의 목록을 차례대로 태그가 저장된 테이블의 데이터와 비교하여
        * 기존 태그의 카운트를 증가하거나 새로운 태그를 저장한다.
        * ※ 현재 구현만 해두었고 코드를 다듬어서 최적화시킬 필요가 있다.
        * @param content
        */
       public void insertArticle(ContentDomain content) {
        sql = "INSERT INTO cont (num, title, content, tag_list) ";
        sql += "VALUES (seq_cont.NEXTVAL, ?, ?, ?)";
        
        try {
         pstmt = conn.prepareStatement(sql);
         pstmt.setString(1, content.getTitle());
         pstmt.setString(2, content.getContent());
         pstmt.setString(3, content.getTags());
         pstmt.executeUpdate();
         
         Iterator tagList = content.toTagList().iterator();
         while (tagList.hasNext()) {
          String tag = tagList.next();
          sql = "SELECT tag_name FROM tag_list ";
          sql += "WHERE tag_name LIKE ?";
          pstmt = conn.prepareStatement(sql);
          pstmt.setString(1, "%" + tag + "%");
          if (pstmt.executeUpdate() > 0) {
           sql = "UPDATE tag_list SET tag_count = tag_count + 1 ";
           sql += "WHERE tag_name = ?";
           pstmt = conn.prepareStatement(sql);
           pstmt.setString(1, tag);
           pstmt.executeUpdate();
          } else {
           sql = "INSERT INTO tag_list (num, tag_name, tag_count) ";
           sql += "VALUES (seq_tag_list.NEXTVAL, ?, ?)";
           pstmt = conn.prepareStatement(sql);
           pstmt.setString(1, tag);
           pstmt.setString(2, "1");
           pstmt.executeUpdate();
          }
         }
        } catch (SQLException e) {
         e.printStackTrace();
        } finally {
         try {
          if (pstmt != null) pstmt.close();
          if (conn != null) conn.close();
         } catch (SQLException e) {
          e.printStackTrace();
         }
        }
       }
       
       public ContentDomain getArticle(int num) {
        // 데이터베이스에서 글 읽어오기
        return new ContentDomain();
       }
       
       public List getTagList() {
        // 데이터베이스에서 태그 목록 리턴
        return new ArrayList();
       }
       
       public static void main(String[] args) {
        ContentDomain article = new ContentDomain();
        ContentDAO cdao = getInstance();
        Iterator itrArticle = null;
        
        article.setTitle("두번째 글");
        article.setContent("테스트 글입니다.\n테스트 글입니다.");
        article.setTags("태그, test, 두번째글, second");
        
        itrArticle = article.toTagList().iterator();
        while (itrArticle.hasNext())
         System.out.println(itrArticle.next());
        cdao.insertArticle(article);
       }
      }

 /**
       * 문자열 컬렉션 타입 지정
       * 태그 배열을 파라메터로 받기 위해 선언
       */
      CREATE OR REPLACE TYPE type_tag_list IS TABLE OF VARCHAR2(100) NOT NULL;
      /**
       * 태그 배열을 파라메터로 받아서 태그 카운트를 갱신하거나
       * 신규 태그를 등록한다.
       */
      CREATE OR REPLACE PROCEDURE insert_tag (tags IN type_tag_list)
      IS
       idx INTEGER;
      BEGIN
       idx := tags.FIRST;     -- 컬렉션 인텍스 시작값으로 초기화
       LOOP
           EXIT WHEN idx IS NULL;   -- 컬렉션 데이터가 없으면 LOOP 빠져나감
             
              UPDATE tag_list     -- 태그가 존재하면 태그 카운트 증가
              SET tag_count = tag_count + 1
              WHERE tag_name = tags(idx);
             
              IF SQL%NOTFOUND THEN   -- UPDATE의 WHERE 조건 만족하는 row가 없을 때
               INSERT INTO tag_list  -- 태그 추가
         (num, tag_name, tag_count)
         VALUES (seq_tag_list.NEXTVAL, tags(idx), '1');
              END IF;
                                 
              idx := tags.NEXT(idx);
          END LOOP;
      END;

   package net.jeongsam.prjpkg;
   import java.util.ArrayList;
      import java.util.Iterator;
      import java.util.List;
    import java.sql.CallableStatement;
      import java.sql.Connection;
      import java.sql.PreparedStatement;
      import java.sql.SQLException;
   import oracle.sql.ARRAY;
      import oracle.sql.ArrayDescriptor;
   public class ContentDAO {
       private ContentDAO() { }
       
       public static ContentDAO getInstance() {
        return new ContentDAO();
       }
       
       /**
        * 글을 데이터베이스에 삽입한다. 이때 태그는 별도의 테이블에 목록을 만들어 저장한다.
        * 태그의 경우 리스트를 만들어 리스트의 목록을 차례대로 태그가 저장된 테이블의 데이터와
        * 비교하여 기존 태그의 카운트를 증가하거나 새로운 태그를 저장한다.
        * @param content 글정보를 담은 JavaBean
        * @throws SQLException SQL Exception 처리
        */
       public void insertArticle(ContentDomain content) throws SQLException {
        Connection conn = null;
        PreparedStatement pstmt = null;
        CallableStatement cstmt = null;
        String query = null;
        String qproc = null;
        
        query = "INSERT INTO cont (num, title, content, tag_list) ";
        query += "VALUES (seq_cont.NEXTVAL, ?, ?, ?)";
        
        qproc = "{CALL INSERT_TAG(:TAGS)}";
        
        try {
         conn = ConnectionManager.getConnection();
         // 글을 추가한다.
         pstmt = conn.prepareStatement(query);
         pstmt.setString(1, content.getTitle());
         pstmt.setString(2, content.getContent());
         pstmt.setString(3, content.getTags());
         pstmt.executeUpdate();
         
         // 태그 목록을 갱신, 추가하기 위해 Oracle Procedure 호출
         cstmt = conn.prepareCall(qproc);
         ArrayDescriptor desc1 =
          ArrayDescriptor.createDescriptor("TYPE_TAG_LIST",conn);
         ARRAY input =
          new ARRAY(desc1, conn, content.toTagList().toArray());
         cstmt.setArray(1, input);
         cstmt.executeUpdate();
        } finally {
         if (pstmt != null) pstmt.close();
         if (cstmt != null) cstmt.close();
         if (conn != null) conn.close();
        }
       }
       
       public ContentDomain getArticle(int num) {
        // 데이터베이스에서 글 읽어오기
        return new ContentDomain();
       }
       
       public List getTagList() {
        // 데이터베이스에서 태그 목록 리턴
        return new ArrayList();
       }
       /**
        * 클래스 테스트 코드
        * insertArticel() 메서드 테스트
        * @param args 미사용 파라메터
        */
       public static void main(String[] args) {
        ContentDomain article = new ContentDomain();
        ContentDAO cdao = getInstance();
        Iterator itrArticle = null;
        
        article.setTitle("일곱번째 글");
        article.setContent("테스트 글입니다.\n테스트 글입니다.");
        article.setTags("일곱번째 글, 태그, 7th, example");
        
        itrArticle = article.toTagList().iterator();
        while (itrArticle.hasNext())
         System.out.println(itrArticle.next());
        try {
         cdao.insertArticle(article);
        } catch (SQLException e) {
         e.printStackTrace();
        }
       }
      } 


저작자 표시 비영리 동일 조건 변경 허락

Posted by 정샘

처리 순서로 본 코딩

package net.jeongsam.testsuit;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

/**
 * JDBC 이용 코드 v1
 * @author 정샘
 *
 */
public class JdbcCodeEx01 {
	public void delete(long articleNo) throws ClassNotFoundException, SQLException {
		// Driver 클래스 로딩
		Class.forName("com.mysql.jdbc.Driver");
		// Connection 인스턴스 생성 - DBMS에 연결
		String url = "jdbc:mysql://127.0.0.1:3306/example"; // 사용할 Database 지정
		String user = "root"; // 로그인 사용자
		String password = "1234"; // 암호
		Connection conn = DriverManager.getConnection(url, user, password);
		// 실행할 SQL문 작성 : 삭제할 번호는 매개변수 articleNo에서 가져옴.
		String sql = "DELETE FROM board_data WHERE no = " + articleNo;
		// Statement 인스턴스 생성 : Connection 객체에서 만들어 짐.
		Statement stmt = conn.createStatement();
		// SQL문 실행 : Statement 객체를 이용
		// INSERT, DELETE, UPDATE문은 executeUpdate() 사용
		// SELECT문은 executeQuery() 사용
		stmt.executeUpdate(sql);
		// Statement 객체를 close 시켜서 자원 반납 (운영체제에게 JVM이 반납)
		stmt.close();
		// Statement 객체를 가비지 컬렉션 대상으로 만듬 (JVM에게 자원 반납)
		stmt = null;
		// Connection 객체를 close 시켜서 자원 반납 (운영체제에게 JVM이 반납)
		// DBMS에 연결하기 위해 운영체제는 Socket 등 자원을 사용. JVM에게 대여.
		conn.close();
		// Connection 객체를 가비지 컬렉션 대상으로 만듬 (JVM에게 자원 반납)
		conn = null;
		/* 작업 종료 */
	}
}

중복코드를 정리한 코딩

package net.jeongsam.begin;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public class JdbcCodeEx02 {	
	public void delete(long articleNo) throws ClassNotFoundException, SQLException {
		/* 메서드내에서 사용할 지역변수의 선언 */
		Connection conn = null;
		Statement stmt = null;
		// 실행할 SQL문 작성 : 삭제할 번호는 매개변수 articleNo에서 가져옴.
		String sql = "DELETE FROM board_data WHERE no = " + articleNo;
		
		try {
			conn = getConnection();
			// Statement 인스턴스 생성 : Connection 객체에서 만들어 짐.
			stmt = conn.createStatement();
			// SQL문 실행 : Statement 객체를 이용
			// INSERT, DELETE, UPDATE문은 executeUpdate() 사용
			// SELECT문은 executeQuery() 사용
			stmt.executeUpdate(sql);
		} finally {
			if (stmt != null) { // Statement 객체가 존재할 경우만 close()가 의미있음
				// Statement 객체를 close 시켜서 자원 반납 (운영체제에게 JVM이 반납)
				stmt.close();
				// Statement 객체를 가비지 컬렉션 대상으로 만듬 (JVM에게 자원 반납)
				stmt = null;
			}
			if (conn != null) { // Connection 객체가 존재할 경우만 close()가 의미있음
				// Connection 객체를 close 시켜서 자원 반납 (운영체제에게 JVM이 반납)
				// DBMS에 연결하기 위해 운영체제는 Socket 등 자원을 사용. JVM에게 대여.
				conn.close();
				// Connection 객체를 가비지 컬렉션 대상으로 만듬 (JVM에게 자원 반납)
				conn = null;
			}
		}
		/* 작업 종료 */
	}
	
	/**
	 * Connection 인스턴스 생성(DB 연결) 부분은 모든 메서드에서 공통으로 사용하므로
	 * 중복 코드를 별도의 메서드로 분리합니다.
	 * @return Connection 인스턴스를 리턴
	 * @throws ClassNotFoundException JDBC 드라이버 로딩 오류
	 * @throws SQLException DB 연결 오류
	 */
	private Connection getConnection() throws ClassNotFoundException, SQLException {
		String url = "jdbc:mysql://127.0.0.1:3306/example"; // 사용할 Database 지정
		String user = "root"; // 로그인 사용자
		String password = "1234"; // 암호
		// Driver 클래스 로딩
		Class.forName("com.mysql.jdbc.Driver");
		// Connection 인스턴스 생성 - DBMS에 연결
		return DriverManager.getConnection(url, user, password);
	}
}

Properties 클래스를 이용한 getConnection() 재 작성

/**
	 * Connection 인스턴스 생성(DB 연결) 부분은 모든 메서드에서 공통으로 사용하므로
	 * 중복 코드를 별도의 메서드로 분리합니다.
	 * @return Connection 인스턴스를 리턴
	 * @throws ClassNotFoundException JDBC 드라이버 로딩 오류
	 * @throws SQLException DB 연결 오류
	 * @throws IOException 프로퍼티스 정보 저장 파일 로딩 오류
	 */
	private Connection getConnection() throws ClassNotFoundException, SQLException, IOException {
		String url = "jdbc:mysql://127.0.0.1:3306/example"; // 사용할 Database 지정
		BufferedReader reader = null;
		Properties prop = new Properties();
		
		// Driver 클래스 로딩
		Class.forName("com.mysql.jdbc.Driver");
		// Connection 인스턴스 생성 - DBMS에 연결
		// mysecret.txt 파일에 다음과 같은 형식으로 저장합니다.
		// user=root
		// password=1234
		reader = new BufferedReader(new FileReader("C:\\mysecret.txt"));
		prop.load(reader);
		
		return DriverManager.getConnection(url, prop);
	}
저작자 표시 비영리 동일 조건 변경 허락

Posted by 정샘

게시판 클래스다이어그램

그림을 클릭하면 원래 크기로 볼 수 있습니다.

게시판 테이블 물리설계

-- 게시판 테이블 생성
DROP TABLE IF EXISTS board_data;
CREATE TABLE board_data (
    no SERIAL,
    title VARCHAR(100) NOT NULL,
    article VARCHAR(800) NOT NULL,
    writer VARCHAR(50) NOT NULL DEFAULT '아무개',
    wdate TIMESTAMP,
    hitcnt SMALLINT UNSIGNED NOT NULL DEFAULT '0',
    PRIMARY KEY (no)
    ) ENGINE = MyISAM
    COLLATE utf8_general_ci;

-- list()
-- 페이징 계산 필요 offset = (pageNum - 1) * rows
SELECT no, title, article, writer, wdate, hitcnt
FROM board_data
ORDER BY no DESC
LIMIT 0, 10;

-- write()
INSERT INTO board_data (title, article, writer)
VALUES ('제목1', '안녕하세요.', '홍길동');

-- delete()
DELETE FROM board_data
WHERE no = ?;

-- edit()
UPDATE board_data
SET title = '제목1', article = '안녕하세요', writer = '홍길동', hitcnt = hitcnt + 1;

-- view()
SELECT no, title, article, writer, wdate, hitcnt
FROM board_data
WHERE no = ?;

-- search()
SELECT no, title, article, writer, wdate, hitcnt
FROM board_data
WHERE ? LIKE ?;

게시판 row를 담을 빈 설계

package net.jeongsam.board;

import java.sql.Timestamp;

/**
 * 게시판 row 데이터 저장 빈
 * 2009. 9. 18
 * @author 정승용
 *
 */
public class BoardData {
	private Long no;
	private String title;
	private String article;
	private String writer;
	private Timestamp wDate;
	private Integer hitCnt;
	
	public Long getNo() {
		return no;
	}
	public void setNo(Long no) {
		this.no = no;
	}
	public String getTitle() {
		return title;
	}
	public void setTitle(String title) {
		this.title = title;
	}
	public String getArticle() {
		return article;
	}
	public void setArticle(String article) {
		this.article = article;
	}
	public String getWriter() {
		return writer;
	}
	public void setWriter(String writer) {
		this.writer = writer;
	}
	public Timestamp getwDate() {
		return wDate;
	}
	public void setwDate(Timestamp wDate) {
		this.wDate = wDate;
	}
	public Integer getHitCnt() {
		return hitCnt;
	}
	public void setHitCnt(Integer hitCnt) {
		this.hitCnt = hitCnt;
	}
}

정렬 데이터를 담을 빈 설계

package net.jeongsam.board;

/**
 * 정렬 기준 필드 이름과 정렬 방법을 저장할 자바빈
 * @author 정승용
 *
 */
public class SortData {
	private String fieldName; // 컬럼 이름
	private String order; // 정렬 방식 "ASC"와 "DESC" 중 선택
	
	public String getFieldName() {
		return fieldName;
	}
	public void setFieldName(String fieldName) {
		this.fieldName = fieldName;
	}
	public String getOrder() {
		return order;
	}
	public void setOrder(String order) {
		this.order = order;
	}
}

게시판 관리 클래스

package net.jeongsam.board;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Collection;

/**
 * 게시판 관리
 * 2009. 9. 18
 * @author 정승용
 *
 */
public class BoardMgr {
	/**
	 *  게시판 표시 기본 행 수
	 */
	public static int DEFAULT_ROW = 10;
	
	/**
	 * DB 연결 정보
	 */
	private String url = "jdbc:mysql://127.0.0.1/example";
	private String user = "root";
	private String password = "1234";
	
	private Connection conn = null;
	
	/**
	 *  목록 표시 원형
	 *  @param pageNum 표시할 페이지
	 *  @param rows 한 페이지 당 표시할 행 수
	 *  @param sort 정렬 기준 컬럼 이름과 정렬 순서 값을 저장할 자바빈
	 *  @return 결과 테이블 구조를 저장할 컬렉션 
	 * @throws SQLException 
	 * @throws ClassNotFoundException 
	 */
	public Collection<BoardData> list(int pageNum, int rows, SortData sort)
			throws ClassNotFoundException, SQLException {
		Statement stmt = null;
		ResultSet rs = null;
		ArrayList<BoardData> table = new ArrayList();
		// Limit offset, row_count
		// offset = (페이지 번호 - 1) * 페이지당 행 수
		int offset = (pageNum - 1) * rows;
		
		String sql = "SELECT no, title, article, writer, wdate, hitcnt ";
		sql += "FROM board_data ";
		sql += "ORDER BY " + sort.getFieldName() + " " + sort.getOrder() + " ";
		sql += "LIMIT " + offset + ", " + rows;
		
		conn = getConnection();
		stmt = conn.createStatement();
		rs = stmt.executeQuery(sql);
		
		if (rs == null) {
			System.out.println("글이 없습니다."); // 사용자 정의 예외 처리가 원칙
		} else {
			while (rs.next()) {
				BoardData rec = new BoardData();
				rec.setNo(rs.getLong(1));
				rec.setTitle(rs.getString(2));
				rec.setArticle(rs.getString(3));
				rec.setWriter(rs.getString(4));
				rec.setwDate(rs.getTimestamp(5));
				rec.setHitCnt(rs.getInt(6));
				
				table.add(rec);
			}
		}	
		return table;
	}
	
	/**
	 * 필드별 정렬하여 목록 표시
	 * @param pageNum 표시할 페이지
	 * @param sort 정렬 기준 컬럼 이름과 정렬 순서 값을 저장할 자바빈
	 * @return 결과 테이블 구조를 저장할 컬렉션 
	 * @throws SQLException 
	 * @throws ClassNotFoundException 
	 */
	public Collection<BoardData> list(int pageNum, SortData sort)
			throws ClassNotFoundException, SQLException {
		return list(pageNum, DEFAULT_ROW, sort);
	}
	
	/**
	 *  기본 목록 표시
	 * @param pageNum 표시할 페이지
	 * @return 결과 테이블 구조를 저장할 컬렉션
	 * @throws SQLException 
	 * @throws ClassNotFoundException 
	 */
	public Collection<BoardData> list(int pageNum)
			throws ClassNotFoundException, SQLException {
		SortData sort = new SortData();
		
		sort.setFieldName("no");
		sort.setOrder("DESC");
		
		return list(pageNum, DEFAULT_ROW, sort);
	}
	
	/**
	 *  글 올리기
	 * @param article 게시물을 저장할 자바빈
	 * @throws SQLException JDBC 드라이버 로딩 오류
	 * @throws ClassNotFoundException MySQL DBMS 연결 오류
	 */
	public void write(BoardData article) throws ClassNotFoundException, SQLException {
		Statement stmt = null;
		String sql = "INSERT INTO board_data (title, article, writer) ";
		sql += "VALUES ('" + article.getTitle() + "', '" 
				+ article.getArticle() + "', '" + article.getWriter() + "')";
		// Debug 코드
		System.out.println("write() : " + sql);
		try {
			conn = getConnection();
			stmt = conn.createStatement();
			stmt.executeUpdate(sql);
		} finally {
			if (stmt != null) {
				stmt.close();
				stmt = null;
			}
			if (conn != null) {
				conn.close();
				conn = null;
			}
		}
	}
	
	/**
	 * 글 삭제
	 * @param articleNo 삭제할 글 번호
	 * @throws ClassNotFoundException JDBC 드라이버 로딩 오류
	 * @throws SQLException MySQL DBMS 연결 오류
	 */
	public void delete(long articleNo) throws ClassNotFoundException, SQLException {
		Statement stmt = null;
		String sql = "DELETE FROM board_data WHERE no = " + articleNo;
		// Debug 코드
		System.out.println("delete() : " + sql);
		try {
			conn = getConnection();
			stmt = conn.createStatement();
			stmt.executeUpdate(sql);
		} finally {
			if (stmt != null) {
				stmt.close();
				stmt = null;
			}
			if (conn != null) {
				conn.close();
				conn = null;
			}
		}
	}
	
	/**
	 * 글 편집
	 * @param article 편집 내용을 담은 자바빈
	 * @throws SQLException JDBC 드라이버 로딩 오류
	 * @throws ClassNotFoundException MySQL DBMS 연결 오류
	 */
	public void edit(BoardData article) throws ClassNotFoundException, SQLException {
		Statement stmt = null;
		String sql = "UPDATE board_data ";
		sql += "SET title = '" + article.getTitle() + "', article = '";
		sql += article.getArticle() + "', writer = '" + article.getWriter() + "', hitcnt = hitcnt + 1";
		// Debug 코드
		System.out.println("edit() : " + sql);
		try {
			conn = getConnection();
			stmt = conn.createStatement();
			stmt.executeUpdate(sql);
		} finally {
			if (stmt != null) {
				stmt.close();
				stmt = null;
			}
			if (conn != null) {
				conn.close();
				conn = null;
			}
		}
	}
	
	/**
	 * 글 보기
	 * @param articleNo 화면에 표시할 글 번호
	 * @return 화면에 표시될 내용을 담은 자바빈
	 */
	public BoardData view(long articleNo) {
		return null;
	}
	
	/**
	 * 찾기
	 * @param fieldName 검색할 컬럼 이름
	 * @param value 검색할 데이터
	 * @return 검색 결과로 표시된 테이블을 담을 컬렉션
	 */
	public Collection<BoardData> search(String fieldName, String value) {
		return null;
	}
	
	/**
	 * MySQL DBMS에 연결하여 Connection 객체 생성
	 * @return Connection 인스턴스
	 * @throws ClassNotFoundException JDBC 드라이버 로딩 오류
	 * @throws SQLException MySQL DBMS 연결 오류
	 */
	private Connection getConnection() throws ClassNotFoundException, SQLException {
		Class.forName("com.mysql.jdbc.Driver");
		return DriverManager.getConnection(url, user, password);
	}
}
저작자 표시 비영리 동일 조건 변경 허락

Posted by 정샘

우편번호 저장 빈

package net.jeongsam.zipfinder;

public class ZipData {
	private Integer seq;
	private String zipcode;
	private String sido;
	private String gugun;
	private String dong;
	private String bunji;
	
	public Integer getSeq() {
		return seq;
	}
	public void setSeq(Integer seq) {
		this.seq = seq;
	}
	public String getZipcode() {
		return zipcode;
	}
	public void setZipcode(String zipcode) {
		this.zipcode = zipcode;
	}
	public String getSido() {
		return sido;
	}
	public void setSido(String sido) {
		this.sido = sido;
	}
	public String getGugun() {
		return gugun;
	}
	public void setGugun(String gugun) {
		this.gugun = gugun;
	}
	public String getDong() {
		return dong;
	}
	public void setDong(String dong) {
		this.dong = dong;
	}
	public String getBunji() {
		return bunji;
	}
	public void setBunji(String bunji) {
		this.bunji = bunji;
	}
}

우편번호 매니저

package net.jeongsam.zipfinder;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Collection;

public class ZipManager {
	private Collection<ZipData>zipTable = new ArrayList<ZipData>();
	
	public Collection<ZipData> search(String dong)
			throws ClassNotFoundException, SQLException {
		Connection conn = null;
		Statement stmt = null;
		ResultSet rs = null;
		
		// DB 접속 정보 (URL 형식)
		String url = "jdbc:mysql://127.0.0.1/example";
		// DB에 전달할 SQL문
		StringBuilder sql = new StringBuilder();
		
		sql.append("SELECT seq, zipcode, sido, gugun, dong, bunji ");
		sql.append("FROM ziptable ");
		sql.append("WHERE dong LIKE '%" + dong + "%'");
		
//		System.out.println(sql.toString());
		try {
			// JDBC 드라이버 로딩
			Class.forName("com.mysql.jdbc.Driver");
			// DBMS에 연결 : Connection 인스턴스 생성
			conn = DriverManager.getConnection(url, "root", "암호");
			// Query 객체 생성 : SQL문 DB로 전달
			stmt = conn.createStatement();
			// SQL 문 DB로 전달 실행하여 ResultSet으로 결과 받음
			rs = stmt.executeQuery(sql.toString());
			// ResultSet에 담긴 데이터를 JavaBean 컬렉션으로 복사
			while (rs.next()) {
				// 행(row)를 담을 JavaBean 인스턴스 생성
				ZipData zipRecord = new ZipData();
				// JavaBean에 ResultSet 행(row)를 복사
				zipRecord.setSeq(rs.getInt(1));
				zipRecord.setZipcode(rs.getString(2));
				zipRecord.setSido(rs.getString(3));
				zipRecord.setGugun(rs.getString(4));
				zipRecord.setDong(rs.getString(5));
				zipRecord.setBunji(rs.getString(6));
				// JavaBean을 컬렉션에 추가
				zipTable.add(zipRecord);
			}
		} finally {
			
		}
		return zipTable;
	}
}

우편번호 찾기 메인 클래스

package net.jeongsam.zipfinder;

import java.sql.SQLException;
import java.util.Collection;
import java.util.Iterator;

public class ZipFinder {

	public static void main(String[] args) {
		ZipManager zipMgr = new ZipManager();
		Collection<ZipData> result = null;
		try {
			if (args.length != 1) {
				System.out.println("Usage: ZipFinder 동이름");
			} else {
				result = zipMgr.search(args[0]);
				if (result == null) {
					System.out.println("찾는 주소가 없습니다.");
				} else {
					Iterator<ZipData> itZipTable = result.iterator();
					while (itZipTable.hasNext()) {
						ZipData zipRec = itZipTable.next();
						System.out.print(zipRec.getZipcode() + " ");
						System.out.print(zipRec.getSido() + " ");
						System.out.print(zipRec.getGugun() + " ");
						System.out.print(zipRec.getDong() + " ");
						System.out.println(zipRec.getBunji() + " ");
					}
				}
			}
		} catch (ClassNotFoundException e) {
			System.err.println("JDBC 드라이버 로딩 에러!!");
		} catch (SQLException e) {
			System.err.println("DB 연결 에러!!");
			e.printStackTrace();
		}
	}

}
저작자 표시 비영리 동일 조건 변경 허락

Posted by 정샘