Web

java-school.net

엔티티 빈(BMP)

워크스페이스를 C:/ejb 로 선택하고 이클립스를 실행합니다.
student 라는 새로운 프로젝트를 생성합니다.
student 프로젝트에 weblogic.jar 를 Add External JARs.. 버튼을 이용하여 추가합니다.

studenttable 테이블을 생성합니다.

create table studenttable (
  ssn number primary key,
  name varchar2(255),
  grade number
);

원격 인터페이스 작성

Student.java

package kr.co.hanbitbook.ejb.examples.student;

import java.rmi.RemoteException;

import javax.ejb.EJBObject;

public interface Student extends EJBObject {

	public Integer getSsn() throws RemoteException;

	public String getName() throws RemoteException;
	
	public int getGrade() throws RemoteException;
	
	public void setGrade(int grade) throws RemoteException;
	
}

홈 인터페이스 작성

StudentHome.java

package kr.co.hanbitbook.ejb.examples.student;

import java.rmi.RemoteException;
import java.util.Collection;

import javax.ejb.CreateException;
import javax.ejb.EJBHome;
import javax.ejb.FinderException;

public interface StudentHome extends EJBHome {

	public Student create(String name, int ssn, int grade)
		throws CreateException, RemoteException;
	
	public Student findByPrimaryKey(Integer ssn) 
		throws FinderException, RemoteException;
	
	public Collection findStudentsInGrade(int grade)
		throws FinderException, RemoteException;
	
}

빈 클래스 작성

이클립스의 소스 작성시에 사용하는 기본 기능과 에디터 뷰에서 컨텍스트 메뉴(Source - Override/Implement Methods ... ) 를 이용하면 아래와 같은 소스를 구할 수 있습니다.

StudentBean.java

package kr.co.hanbitbook.ejb.examples.student;

import java.rmi.RemoteException;

import javax.ejb.EJBException;
import javax.ejb.EntityBean;
import javax.ejb.EntityContext;
import javax.ejb.RemoveException;

public class StudentBean implements EntityBean {

	/**
	 * 
	 */
	private static final long serialVersionUID = -4434920310680456336L;

	public void ejbActivate() throws EJBException, RemoteException {
		// TODO Auto-generated method stub
		
	}

	public void ejbLoad() throws EJBException, RemoteException {
		// TODO Auto-generated method stub
		
	}

	public void ejbPassivate() throws EJBException, RemoteException {
		// TODO Auto-generated method stub
		
	}

	public void ejbRemove() throws RemoveException, EJBException,
			RemoteException {
		// TODO Auto-generated method stub
		
	}

	public void ejbStore() throws EJBException, RemoteException {
		// TODO Auto-generated method stub
		
	}

	public void setEntityContext(EntityContext arg0) throws EJBException,
			RemoteException {
		// TODO Auto-generated method stub
		
	}

	public void unsetEntityContext() throws EJBException, RemoteException {
		// TODO Auto-generated method stub
		
	}
	
	

}

필드를 추가합니다.

StudentBean.java

	private Integer ssn;
	private String name;
	private int grade;

setEntityContext 와 unsetEntityContext 메소드를 아래와 같이 수정합니다.
먼저 EntityContext 와 DataSource 필드를 추가합니다.

StudentBean.java

	private EntityContext ctx;
	private DataSource dataSource;
	
	public void setEntityContext(EntityContext c) throws EJBException,
			RemoteException {
		ctx = c;
		
		try {
			Context envCtx = new InitialContext();
			dataSource = (DataSource) envCtx.lookup("ora9");
		} catch (NamingException e) {
			throw new EJBException(e);
		}
		
	}

	public void unsetEntityContext() throws EJBException, RemoteException {
		ctx = null;
		
	}

ejbCreate, ejbPostCreate 와 ejbFindByPrimaryKey 메소드를 아래와 같이 추가합니다.

StudentBean.java

	public Integer ejbCreate(String name, int ssn, int grade) {
		this.name = name;
		this.ssn = new Integer(ssn);
		this.grade = grade;
		
		Connection con = null;
		PreparedStatement ps = null;
		
		try {
			con = dataSource.getConnection();
			ps = con.prepareStatement("insert into " + tableName + " (name, ssn, grade) values (?, ?, ?)");
			
			ps.setString(1, name);
			ps.setInt(2, ssn);
			ps.setInt(3, grade);
			ps.executeUpdate();
			
			return this.ssn;
		} catch (SQLException e) {
			try {
				ejbFindByPrimaryKey(this.ssn);
			
				throw new DuplicateKeyException("A student with social " + "security number: " + ssn+" already exists.");
			} catch (Exception e1) {}
			
			e.printStackTrace();
			throw new EJBException(e);
		} finally {
			try {
				if ( ps != null ) ps.close();
				if ( con != null ) con.close();
			} catch (Exception e) {}
		}
	}
	
	public void ejbPostCreate(String name, int ssn, int grade) {}
	
	public Integer ejbFindByPrimaryKey(Integer pk) throws ObjectNotFoundException {
		Connection con = null;
		PreparedStatement ps = null;
		ResultSet rs = null;
		
		try {
			con = dataSource.getConnection();
			ps = con.prepareStatement("select ssn from " + tableName + " where ssn = ?");
			ps.setInt(1, pk.intValue());
			ps.executeQuery();
			
			rs = ps.getResultSet();
			if ( rs.next() ) {
				return pk;
			} else {
				throw new ObjectNotFoundException("Student with social " + "security number: " + ssn + "no longer exists");
			}
		} catch (SQLException e) {
			throw new EJBException(e);
		} finally {
			try {
				if ( rs != null ) rs.close();
				if ( ps != null ) ps.close();
				if ( con != null ) con.close();
			} catch ( Exception e) {}
		}
	}

ejbLoad 메소드를 아래와 같이 수정합니다.

StudentBean.java

	public void ejbLoad() throws EJBException, RemoteException {
		ssn = (Integer) ctx.getPrimaryKey();
		
		Connection con = null;
		PreparedStatement ps = null;
		ResultSet rs = null;
		
		try {
			con = dataSource.getConnection();
			ps = con.prepareStatement("select name, grade from " + tableName + " where ssn = ?");
			ps.setInt(1, ssn.intValue());
			ps.executeQuery();
			rs = ps.getResultSet();
			
			if ( rs.next() ) {
				name = rs.getString(1);
				grade = rs.getInt(2);
			} else {
				throw new NoSuchEntityException("Student with social security number: " + ssn + " no longer exists.");
			}
		} catch (SQLException e) {
			throw new EJBException(e);
		} finally {
			try {
				if ( rs != null ) rs.close();
				if ( ps != null ) ps.close();
				if ( con != null ) con.close();
			} catch (Exception e) {
			}
		}
		
	}

ejbStore 메소드를 아래와 같이 수정합니다.

StudentBean.java

	public void ejbStore() throws EJBException, RemoteException {
		Connection con = null;
		PreparedStatement ps = null;
		
		try {
			con = dataSource.getConnection();
			ps = con.prepareStatement("update " + tableName + " SET name=?, grade=? where ssn=?");
			ps.setString(1, name);
			ps.setInt(2, grade);
			ps.setInt(3, ssn.intValue());
			
			ps.executeUpdate();
		} catch (SQLException e) {
			throw new EJBException(e);
		} finally {
			try {
				if ( ps != null ) ps.close();
				if ( con != null ) con.close();
			} catch (Exception e) {}
		}
		
	}

ejbRemove 메소드를 아래와 같이 수정합니다.

StudentBean.java

	public void ejbRemove() throws RemoveException, EJBException,
			RemoteException {
		Connection con = null;
		PreparedStatement ps = null;
		
		try {
			con = dataSource.getConnection();
			ps = con.prepareStatement("delete from " + tableName + " where ssn=?");
			ps.setInt(1, ssn.intValue());
			 
			if ( ps.executeUpdate() < 1 ) {
				throw new RemoveException("Error removing Student with ssn: " + ssn);
			}
		} catch (SQLException e) {
			throw new EJBException(e);
		} finally {
			try {
				if ( ps != null ) ps.close();
				if ( con != null ) con.close();
			} catch (Exception e) {}
		}
		
	}

홈 인터페이스에서 정의한 ejbFindStudentsInGrade 메소드를 아래와 같이 추가합니다.

StudentBean.java

	public Collection ejbFindStudentsInGrade(int gradeValue) {
		Connection con = null;
		PreparedStatement ps = null;
		ResultSet rs = null;
		
		ArrayList keys = new ArrayList();
		
		try {
			con = dataSource.getConnection();
			ps = con.prepareStatement("select ssn from " + tableName + " where grade=?");
			ps.setInt(1, gradeValue);
			ps.executeQuery();
			
			rs = ps.getResultSet();
			
			while (rs.next()) {
				keys.add(new Integer(rs.getInt(1)));
			}
			
			return keys;
		} catch(SQLException e) {
			throw new EJBException(e);
		} finally {
			try {
				if ( rs != null ) rs.close();
				if ( ps != null ) ps.close();
				if ( con != null ) con.close();
			} catch (Exception e) {}
		}
	}

원격 인터페이스에서 정의한 메소드들을 아래와 같이 추가합니다.

StudentBean.java

	public String getName() {
		return name;
	}
	
	public Integer getSsn() {
		return ssn;
	}
	
	public int getGrade() {
		return grade;
	}
	
	public void setGrade(int grade) {
		this.grade = grade;
	}

배치 디스크립터 작성(웹로직 빌더 이용) 및 배치

웹로직 빌더를 실행하고 Open 버튼을 이용해서 student 프로젝트의 bin 폴더를 선택합니다.
이어지는 화면에서 다음과 같이 설정되어 있는지 확인합니다.

Resource 항목을 선택한 후 Resource Reference 에서 데이터 소스와 리소스 레퍼런스를 추가합니다.

Save 버튼을 클릭하여 저장합니다.
Archive...메뉴를 이용해서 student.jar 파일을 생성한 다음 웹로직 콘솔에서 배치합니다.

테스트

테스트를 위한 새로운 프로젝트를 student_client 란 이름으로 생성합니다
배치시 사용했던 student.jar 와 weblogic.jar 를 Add External JARs... 버튼을 이용해서 video_client 프로젝트에 등록합니다.
다음과 같이 클라이언트 파일을 작성합니다.

StudentClient.java

import javax.rmi.*;
import javax.naming.*;
import kr.co.hanbitbook.ejb.examples.student.*;

public class StudentClient{
	public static void main(String args[]){
		Context ctx = null;
		try{
			java.util.Properties p = new java.util.Properties();
			p.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");
			p.put(Context.PROVIDER_URL, "t3://localhost:7001");
			ctx = new InitialContext(p);
			Object h = ctx.lookup("StudentBean");
			StudentHome home = (StudentHome)PortableRemoteObject.narrow(h, StudentHome.class);
			Student student = home.create("홍길동", 10, 90);
			System.out.println("저장되었습니다.");
		}catch(Exception e){
			System.out.println(e.toString());
		}
	}
}

실행한 후에 SQL*PLUS로 확인합니다.

참고 문서

알기쉽게 풀어 쓴 웹로직과 EJB 9장 -한빛미디어,김성박 저-
예제에 쓰였던 jar,war,ear 파일 (배치시 익셥션 발생할 때 참고용)

EJB

• WebLogic 8.1
  • WebLogic 8.1 SP6 설치
  • JDBC 설정
  • JMS
  • JNDI
  • 무상태 세션 빈
  • 무상태 세션 빈 예제
  • 상태유지 세션 빈
  • 세션 빈을 이용한 게시판
  • 엔티티 빈(CMP)
  • 엔티티 빈(BMP)
  • CMP(EJB-QL 이용)
  • CMR
  • 메시지 드리븐 빈
  • 세션 빈과 엔티티 빈을 이용한 게시판 예제
  • 쇼핑카트 예제

홈페이지

• 홈페이지 제작
  • 회사홍보용 : 10 만원
• 홈페이지 관리
  • 작업당 단가
  • 정액제