스프링3.X 게시판 (DI설정을 애노테이션으로 변경),
XML설정-->Annotation으로...
지금까지 구현한 게시판의 기본 기능은 다음과 같다.
이번 강좌에서는 이 소스를 기본으로 스프링 주입(DI)을 애노테이션으로 변경해 보자. Spring Framework XML설정 파일이
깔끔해 진다.
그리고 다음 강좌에서 진행될 DAO단 Spring AOP를 적용하여 로깅하기를 위해 미라 SqlProvider를 구현하자.
(jdbcTemplate에서 실행 sql문을 받아 내기 위해)
1. BoardDAO.java
package onj.board.dao;
import java.util.List;
import onj.board.model.BoardDTO;
import
onj.board.model.CommentDTO;
import
org.springframework.dao.DataAccessException;
public interface BoardDAO {
//게시물 리스트 보기
public
List<BoardDTO> boardList() throws DataAccessException;
//게시물 본문
미리보기
public String preView(String seq) throws
DataAccessException;
//게시물 본문 읽기
public BoardDTO readContent(String
seq) throws DataAccessException;
//읽은 글의 조회수 1증가
public int
updateReadCount(String seq) throws
DataAccessException;
//Comment저장
public int
insertComment(CommentDTO commentDTO) throws DataAccessException
;
//Comment조회
public List<CommentDTO> commentList(String seq)
throws DataAccessException;
//게시글 입력
public int
insertBoard(BoardDTO board) throws DataAccessException;
//글
수정
public int updateBoard(BoardDTO board) throws
DataAccessException;
//글 삭제
public int deleteBoard(String sid ,
String password) throws DataAccessException;
//답글 달기
public int
replyBoard(BoardDTO board) throws DataAccessException;
//SQL리턴용
public String
getSql();
}
2. onj.board.dao.SpringBoardDAO.java
package onj.board.dao;
import java.sql.ResultSet;
import java.sql.SQLException;
import
java.util.List;
import javax.sql.DataSource;
import onj.board.model.BoardDTO;
import
onj.board.model.CommentDTO;
import org.springframework.beans.factory.annotation.Autowired;
import
org.springframework.dao.DataAccessException;
import
org.springframework.jdbc.core.JdbcTemplate;
import
org.springframework.jdbc.core.RowMapper;
import
org.springframework.jdbc.core.SqlProvider;
import
org.springframework.stereotype.Component;
//아래 SqlProvider는 jdbcTemplate이 실행될 때의 SQL문장을 받아내기 위하여 구현,
getSql()
@Component("boardDAO")
public class
SpringBoardDAO implements BoardDAO, SqlProvider {
private JdbcTemplate jdbcTemplate = null;
String sql =
"";
@Autowired
private DataSource
dataSource;
public JdbcTemplate getTemplate() {
if
(jdbcTemplate == null) {
this.jdbcTemplate = new
JdbcTemplate(dataSource);
}
return jdbcTemplate;
}
@Override
public String getSql() {
// TODO
Auto-generated method stub
return sql;
}
// /게시판 전체 리스트 보기(list.html)
public List<BoardDTO>
boardList() throws DataAccessException {
List<BoardDTO> boardList =
null;
// String sql = "select * from board";
sql = " select * from
(select seq, name , passwd, "
+ " title, content,
filename, regdate, "
+ " readcount, reply,
reply_step, "
+ " reply_level , rownum r
"
+ " from board "
+ " order by
reply desc , reply_step asc)";
boardList = getTemplate().query(sql, new RowMapper() {
public
Object mapRow(ResultSet rs, int rowNum) throws SQLException {
BoardDTO
board = new BoardDTO();
board.setSeq(rs.getInt("seq"));
board.setName(rs.getString("name"));
board.setPasswd(rs.getString("passwd"));
board.setTitle(rs.getString("title"));
board.setContent(rs.getString("content"));
board.setFileName(rs.getString("filename"));
board.setRegDate(rs.getString("regdate"));
board.setReadCount(rs.getInt("readcount"));
board.setReply(rs.getInt("reply"));
board.setReply_step(rs.getInt("reply_step"));
board.setReply_level(rs.getInt("reply_level"));
return board;
}
});
return boardList;
}
// 게시물 본문내용 미리보기(/preView)
public String preView(String seq) throws
DataAccessException {
sql = "select * from board where seq = ?";
String preContent = (String) getTemplate().queryForObject(sql,
new
Object[] { seq }, new RowMapper() {
public Object mapRow(ResultSet rs,
int rowNum)
throws SQLException {
return
rs.getString("content");
}
});
return
preContent;
}
// 게시판 상세보기, 게시글 읽기
public BoardDTO readContent(String seq) throws
DataAccessException {
sql = "select * from board where seq = ?";
BoardDTO boardDTO = (BoardDTO)
getTemplate().queryForObject(sql,
new Object[] { seq }, new RowMapper()
{
public Object mapRow(ResultSet rs, int rowNum)
throws
SQLException {
BoardDTO board = new BoardDTO();
board.setSeq(rs.getInt("seq"));
board.setName(rs.getString("name"));
board.setPasswd(rs.getString("passwd"));
board.setTitle(rs.getString("title"));
board.setContent(rs.getString("content"));
board.setFileName(rs.getString("filename"));
board.setRegDate(rs.getString("regdate"));
board.setReadCount(rs.getInt("readcount"));
board.setReply(rs.getInt("reply"));
board.setReply_step(rs.getInt("reply_step"));
board.setReply_level(rs.getInt("reply_level"));
return board;
}
});
// 글 조회수
1증가
this.updateReadCount(new Integer(boardDTO.getSeq()).toString());
return boardDTO;
}
// 읽은 글의 조회수를 1증가
public int updateReadCount(String seq) throws
DataAccessException {
sql = "update board set readcount = nvl(readcount,0)
+ 1 where seq = ?";
Object[] obj = { seq };
return getTemplate().update(sql, obj);
}
// 커맨트 입력
public int insertComment(CommentDTO commentDTO) throws
DataAccessException {
sql = "insert into comment_t(seq, name, comm) values
(?, ?, ?)";
Object[] obj = { commentDTO.getSeq(), //
게시글순번
commentDTO.getName(), // 작성자
commentDTO.getComment() }; //
커맨트
return getTemplate().update(sql, obj);
}
// 커맨트 조회
public List<CommentDTO> commentList(String seq) throws
DataAccessException {
sql = "select * from comment_t where seq = ?";
List<CommentDTO> commentList = getTemplate().query(sql,
new
Object[] { seq }, new RowMapper() {
public Object mapRow(ResultSet rs,
int rowNum)
throws SQLException {
CommentDTO commentDTO = new
CommentDTO();
commentDTO.setName(rs.getString("name"));
commentDTO.setComment(rs.getString("comm"));
return commentDTO;
}
});
return
commentList;
}
// 글쓰기
public int insertBoard(BoardDTO board) throws
DataAccessException {
sql = "insert into board values(board_seq.nextval , ? , ? , ? , ? , ? ,
sysdate , 0 , board_seq.currval , 0 , 0)";
if (board.getFileName() == null) {
Object[] obj = {
board.getName(), board.getPasswd(),
board.getTitle(),
board.getContent(), "" };
return getTemplate().update(sql, obj);
}
else {
Object[] obj = { board.getName(),
board.getPasswd(),
board.getTitle(), board.getContent(),
board.getFileName() };
return getTemplate().update(sql, obj);
}
}
// 게시글 수정
public int updateBoard(BoardDTO board) throws
DataAccessException {
sql = "update board set title = ? , content = ? where seq =
?";
Object[] obj = { board.getTitle(), board.getContent(), board.getSeq()
};
return getTemplate().update(sql, obj);
}
// 게시글 삭제
public int deleteBoard(String seq, String
passwd)
throws DataAccessException {
int result = 0;
String sql
= "delete from board where seq = ? and passwd = ?";
result =
getTemplate().update(sql, new Object[] { seq, passwd });
return result;
}
// 답글달기
public int replyBoard(BoardDTO boardDTO) throws
DataAccessException {
int result = 0;
String name = boardDTO.getName();
String passwd =
boardDTO.getPasswd();
String title = boardDTO.getTitle();
String
content = boardDTO.getContent();
String fileName =
boardDTO.getFileName();
int reply = boardDTO.getReply();
int
reply_step = boardDTO.getReply_step();
int reply_level =
boardDTO.getReply_level();
// 현재 답변을 단 게시물 보다 더 높은 스텝의 게시물이 있다면 스텝을 하나씩 상승시킴
sql = "update
board set reply_step = reply_step + 1 "
+ "where reply = " + reply + "
and reply_step > " + reply_step;
getTemplate().update(sql);
sql = "insert into board values(board_seq.nextval , ? , ? , ? , ? , ? ,
sysdate , 0 , ? , ? , ?)";
// reply_step과 reply_level을 1씩 증가시킨 후 내용을 저장
Object[] obj2 = { name,
passwd, title, content, fileName, reply,
reply_step + 1, reply_level + 1
};
result = getTemplate().update(sql, obj2);
return 0;
}
}
3. BoardServiceImpl.java
package onj.board.service;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import
org.springframework.stereotype.Component;
import onj.board.dao.BoardDAO;
import
onj.board.model.BoardDTO;
import onj.board.model.CommentDTO;
@Component("boardService")
public class
BoardServiceImpl implements BoardService {
@Autowired
private BoardDAO boardDAO;
//게시물 리스트
보기
public List<BoardDTO> boardList() {
return
boardDAO.boardList();
}
//게시물 본문 내용 미리보기
public
String preView(String seq) {
return boardDAO.preView(seq);
}
//게시글 읽기
public BoardDTO readContent(String seq) {
return
boardDAO.readContent(seq);
}
//커맨트 입력
public int insertComment(CommentDTO commentDTO) {
return
boardDAO.insertComment(commentDTO);
}
//커맨트 조회
public List<CommentDTO> commentList(String seq)
{
return boardDAO.commentList(seq);
}
//게시글 입력
public
int insertBoard(BoardDTO board) {
return
boardDAO.insertBoard(board);
}
//게시글 수정
public int
updateBoard(BoardDTO board) {
return
boardDAO.updateBoard(board);
}
//게시글 삭제
public int
deleteBoard(String seq, String passwd) {
return boardDAO.deleteBoard(seq,
passwd);
}
//답글 등록
public int replyBoard(BoardDTO
board){
return boardDAO.replyBoard(board);
}
}
4. /WEB-INF/boardConfig.xml
<aop:aspectj-autoproxy/>
<context:component-scan
base-package="onj.board.dao"/>
<context:component-scan
base-package="onj.board.service"/> </beans>
