Last Modified : 2010.03.02
세션 빈과 엔티티 빈을 이용한 게시판 예제
C:/ejb 워크스페이스에 새로운 프로젝트 sboard2 를 생성하고, Add External JARs.. 버튼을 이용하여 weblogic.jar 를
Build Path 에 추가합니다.
세션 빈을 이용한 게시판 sboard 의 자바 소스를 sboard2 에 복사하여 추가합니다.
엔티티 빈 작성
1. 원격 인터페이스 작성
Board.java
package kr.co.hanbitbook.ejb.examples.board;
import java.sql.Timestamp;
import javax.ejb.EJBLocalObject;
public interface Board extends EJBLocalObject {
public Integer getSeq();
public void setName(String name);
public String getName();
public void setPasswd(String passwd);
public String getPasswd();
public void setTitle(String title);
public String getTitle();
public void setContent(String content);
public String getContent();
public void setRegdate(Timestamp regdate);
public Timestamp getRegdate();
public void setReadcount(int readcount);
public int getReadcount();
}
2. 홈 인터페이스 작성
BoardHome.java
package kr.co.hanbitbook.ejb.examples.board;
import java.sql.Timestamp;
import javax.ejb.CreateException;
import javax.ejb.EJBLocalHome;
import javax.ejb.FinderException;
public interface BoardHome extends EJBLocalHome {
public Board create(
String name,
String passwd,
String title,
String content,
Timestamp regdate,
int readcount) throws CreateException;
public Board findByPrimaryKey(Integer seq) throws FinderException;
}
3. 빈 클래스 작성
BoardBean.java
package kr.co.hanbitbook.ejb.examples.board;
import java.io.IOException;
import java.io.Reader;
import java.io.StringReader;
import java.io.StringWriter;
import java.io.Writer;
import java.rmi.RemoteException;
import java.sql.Clob;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Timestamp;
import javax.ejb.CreateException;
import javax.ejb.EJBException;
import javax.ejb.EntityBean;
import javax.ejb.EntityContext;
import javax.ejb.FinderException;
import javax.ejb.RemoveException;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;
public class BoardBean implements EntityBean {
private static final long serialVersionUID = -6689027768660964193L;
EntityContext entityContext;
Integer seq;
String name;
String passwd;
String title;
String content;
Timestamp regdate;
int readcount;
DataSource ds;
Context initial;
public void setSeq(Integer seq) {
this.seq = seq;
}
public Integer getSeq() {
return seq;
}
public void setName(String name) {
this.name = name;
}
public String getName() {
return name;
}
public void setPasswd(String passwd) {
this.passwd = passwd;
}
public String getPasswd() {
return passwd;
}
public void setTitle(String title) {
this.title = title;
}
public String getTitle() {
return title;
}
public void setContent(String content) {
this.content = content;
}
public String getContent() {
return content;
}
public void setRegdate(Timestamp regdate) {
this.regdate = regdate;
}
public Timestamp getRegdate() {
return regdate;
}
public void setReadcount(int readcount) {
this.readcount = readcount;
}
public int getReadcount() {
return readcount;
}
public Integer ejbCreate(
String name,
String passwd,
String title,
String content,
Timestamp regdate,
int readcount) throws CreateException {
Connection con = null;
PreparedStatement ps = null;
ResultSet rs = null;
int iseq = 0;
try {
con = ds.getConnection();
ps = con.prepareStatement("insert into sboard values (sboard_seq.NEXTVAL, ?, ?, ?, empty_clob(), ?, 0)");
ps.setString(1, name);
ps.setString(2, passwd);
ps.setString(3, title);
ps.setTimestamp(4, regdate);
ps.executeUpdate();
ps.close();
ps = con.prepareStatement("select sboard_seq.CURRVAL from dual");
rs = ps.executeQuery();
rs.next();
iseq = rs.getInt(1);
ps = con.prepareStatement("select content from sboard where seq = ? for update");
ps.setInt(1, iseq);
rs = ps.executeQuery();
rs.next();
Clob clob_content = rs.getClob(1);
Writer writer = clob_content.setCharacterStream(0L);
StringReader sr = new StringReader(content);
char[] buffer = new char[512];
int readCount = 0;
while ( (readCount = sr.read(buffer)) != -1 ) {
writer.write(buffer, 0, readCount);
}
sr.close();
writer.close();
} catch (SQLException e) {
System.out.println("ejbCreate() : " + e.toString());
} catch (IOException e) {
System.out.println("ejbCreate() : " + e.toString());
} finally {
if(rs != null) {
try {
rs.close();
}catch(Exception e){}
}
if(ps != null) {
try {
ps.close();
}catch(Exception e){}
}
if(con != null) {
try {
con.close();
}catch(Exception e){}
}
}
setSeq(new Integer(iseq));
setName(name);
setPasswd(passwd);
setTitle(title);
setContent(content);
setRegdate(regdate);
setReadcount(0);
return new Integer(iseq);
}
public void ejbPostCreate(
String name,
String passwd,
String title,
String content,
Timestamp regdate,
int readcount) throws CreateException {
}
public Integer ejbFindByPrimaryKey(Integer seq) throws FinderException {
Connection con = null;
PreparedStatement ps = null;
ResultSet rs = null;
int iseq = 0;
try {
con = ds.getConnection();
ps = con.prepareStatement("select seq from sboard where seq = ?");
ps.setInt(1, seq.intValue());
rs = ps.executeQuery();
rs.next();
iseq = rs.getInt(1);
} catch (SQLException e) {
System.out.println("ejbFindByPrimaryKey() : " + e.toString());
} finally {
if ( rs != null ) {
try {
rs.close();
} catch (Exception e) {}
}
if ( ps != null ) {
try {
ps.close();
} catch (Exception e) {}
}
if ( con != null ) {
try {
con.close();
} catch ( Exception e) {}
}
}
return new Integer(iseq);
}
public void ejbActivate() throws EJBException, RemoteException {
try {
initial = new InitialContext();
Object obj = initial.lookup("ora9");
ds = (DataSource)obj;
} catch (NamingException e) {
System.out.println("ejbActivate() : " + e.toString());
}
}
public void ejbLoad() throws EJBException, RemoteException {
Connection con = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
Integer iseq = (Integer)entityContext.getPrimaryKey();
con = ds.getConnection();
ps = con.prepareStatement("selct seq, name, passwd, title, content, regdate, readcount from sboard where seq = ?");
ps.setInt(1, iseq.intValue());
rs = ps.executeQuery();
if ( rs.next() ) {
int seq = rs.getInt(1);
String name = rs.getString(2);
String passwd = rs.getString(3);
String title = rs.getString(4);
Clob clob_content = rs.getClob(5);
Timestamp regdate = rs.getTimestamp(6);
int readcount = rs.getInt(7);
Reader reader = clob_content.getCharacterStream();
StringWriter writer = new StringWriter();
char[] buffer = new char[512];
int readCount = 0;
while ( (readCount = reader.read(buffer)) != -1 ) {
writer.write(buffer, 0, readCount);
}
String content = writer.toString();
this.seq = new Integer(seq);
this.name = name;
this.passwd = passwd;
this.title = title;
this.content = content;
this.regdate = regdate;
this.readcount = readcount;
}
} catch (Exception e) {
System.out.println("ejbLoad() : " + e.toString());
}
}
public void ejbPassivate() throws EJBException, RemoteException {
initial = null;
ds = null;
}
public void ejbRemove() throws RemoveException, EJBException,
RemoteException {
Connection con = null;
PreparedStatement ps = null;
try {
con = ds.getConnection();
ps = con.prepareStatement("delete from sboard where seq = ?");
ps.setInt(1, seq.intValue());
ps.executeUpdate();
} catch (SQLException e) {
System.out.println("ejbRemove() 메소드 호출시 오류 " + e.toString());
} finally {
if (ps != null) {
try {
ps.close();
} catch (SQLException e) {}
}
if (con != null) {
try {
con.close();
} catch (SQLException e) {}
}
}
}
public void ejbStore() throws EJBException, RemoteException {
Connection con = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
con = ds.getConnection();
ps = con.prepareStatement("update sboard set name = ?, title = ?, content = empty_clob() where seq = ?");
ps.setString(1, name);
ps.setString(2, title);
ps.setInt(3, seq.intValue());
ps.executeUpdate();
ps.close();
ps = con.prepareStatement("select content from sboard where seq = ? for update");
ps.setInt(1, seq.intValue());
rs = ps.executeQuery();
rs.next();
Clob clob_content = rs.getClob(1);
Writer writer = clob_content.setCharacterStream(0L);
StringReader sr = new StringReader(content);
char[] buffer = new char[512];
int readCount = 0;
while ((readCount = sr.read(buffer)) != -1) {
writer.write(buffer, 0, readCount);
}
sr.close();
writer.close();
} catch (SQLException e) {
System.out.println("ejbStore() : " + e.toString());
} catch (IOException e) {
System.out.println("ejbStore() : " + e.toString());
} finally {
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {}
}
if (ps != null) {
try {
ps.close();
} catch (SQLException e) {}
}
if (con != null) {
try {
con.close();
} catch (SQLException e) {}
}
}
}
public void setEntityContext(EntityContext entityContext) throws EJBException,
RemoteException {
this.entityContext = entityContext;
try {
initial = new InitialContext();
Object obj = initial.lookup("ora9");
ds = (DataSource)obj;
} catch (Exception e) {
System.out.println("setEntityContext() : " + e.toString());
}
}
public void unsetEntityContext() throws EJBException, RemoteException {
entityContext = null;
}
}
세션 빈 수정
BoardManagerBean.java 세션 빈을 수정합니다.
addBoardData() 메소드 수정
public void addBoardData(BoardData boardData) {
try {
Object obj = initial.lookup("Board");
BoardHome home = (BoardHome) PortableRemoteObject.narrow(obj, BoardHome.class);
home.create(boardData.getName(), boardData.getPasswd(), boardData.getTitle(), boardData.getContent(), boardData.getCurrentTimestamp(), boardData.getReadcount());
} catch (Exception e) {
System.out.println("addBoardData() :" + e.toString());
}
}
deleteBoardData() 메소드 수정
public void deleteBoardData(int seq) {
try {
Object obj = initial.lookup("Board");
BoardHome home = (BoardHome) PortableRemoteObject.narrow(obj, BoardHome.class);
home.remove(new Integer(seq));
} catch (Exception e) {
System.out.println("deleteBoardData() :" + e.toString());
}
}
updateBoardData() 메소드 수정
public void updateBoardData(BoardData boardData) {
try {
Object obj = initial.lookup("Board");
BoardHome home = (BoardHome) PortableRemoteObject.narrow(obj, BoardHome.class);
Board board = home.findByPrimaryKey(new Integer(boardData.getSeq()));
board.setName(boardData.getName());
board.setTitle(boardData.getTitle());
board.setContent(boardData.getContent());
} catch (Exception e) {
System.out.println("updateBoardData() :" + e.toString());
}
}
getBoardData() 메소드 수정
public BoardData getBoardData(int seq) {
BoardData bd = new BoardData();
try {
Object obj = initial.lookup("Board");
BoardHome home = (BoardHome) PortableRemoteObject.narrow(obj, BoardHome.class);
Board board = home.findByPrimaryKey(new Integer(seq));
bd.setSeq(board.getSeq().intValue());
bd.setName(board.getName());
bd.setTitle(board.getTitle());
bd.setContent(board.getContent());
bd.setRegdate(board.getRegdate());
bd.setReadcount(board.getReadcount());
} catch (Exception e) {
System.out.println("getBoardData() :" + e.toString());
}
return bd;
}
배치 디스크립터 작성(웹로직 빌더 이용), EJB jar 파일 생성, 배치, 테스트
웹로직 빌더를 실행하고 컴파일된 경로인 C:\ejb\sboard\bin 를 선택합니다.
좌측메뉴에서 BoardManagerBean 를 선택하고 General 탭에서 JNDI Name: 항목의 값이 BoardManager 로 수정합니다.
Resources 메뉴의 Resource References 탭에서 DataSource 를 설정합니다.
Advanced 탭에서 Enable call by reference 를 체크합니다.
좌측메뉴에서 BoardBean 를 선택하고 General 탭에서 JNDI Name: 항목의 값이 Board 로 수정합니다.
엔티티 빈을 구성하는 클래스가 올바른지 확인합니다.
주 키 클래스가 java.lang.Integer 로 올바르게 설정되었는지 확인합니다.
Resources 메뉴의 Resource References 탭에서 DataSource 를 설정합니다.
Archive... 메뉴을 이용해서 sboard.jar 생성합니다.
웹로직 콘솔에서 세션 빈만을 이용했던 sboard.jar 를 지운 다음 C:/ejb/sboard2/sboard.jar 를 배치합니다.
http://localhost:7001/sboard/list.jsp 를 방문하여 테스트합니다.
참고 문서
알기쉽게 풀어 쓴 웹로직과 EJB 12장 -한빛미디어,김성박 저-
예제에 쓰였던 jar,war,ear 파일 (배치시 익셥션 발생할 때 참고용)