Kodo EJB是一個支持對象/關系映射的框架,根據EJB3規范的要求,Kodo EJB除了支持在普通java應用中提供輕量級的持久層框架之外,也支持在JAVA EE容器中使用滿足重量級企業應用的需求,充分利用JAVA EE容器中提供的優越特性如容器治理事務、遠程(Remote)訪問。
基于Kodo EJB開發的應用支持使用EJB或者JCA標準接入到JAVA EE環境中:
本文中我們將以通過一個簡單的例子,簡單的講解和演示如何在Weblogic9上通過JNDI方式來訪問Kodo EJB應用。
由于Kodo是基于注釋機制的框架,我們必須使用JDK5.0完成開發工作。所以下載、安裝Kodo之前,請確保您已經下載和安裝了JDK5.0。
為了演示的需要,我們選擇MySQL數據庫作為持久化的目標數據庫,請大家自己到www.mysql.com下載最新的MySQL數據庫后安裝。
Kodo的最新版本是Kodo 4.0.0 Early access 4,目前大家可以到http://www.solarmetric.com/去下載試用版本,下載時需要注冊,你會得到30天的License。
將下載的壓縮文件解壓到c:/kodo4目錄下(后面將使用%KODO_HOME%來引用這個目錄),打開%KODO_HOME%/bin/kodocmd.cmd文件,將其中的KODODIR設置為您的Kodo的安裝目錄,將JDKHOME設置為Java的安裝目錄。
Kodo EJB在JAVA EE環境下運行時需要EJB容器支持EJB3標準,BEA最新發布的Weblogic9服務器就支持EJB3標準,因此我們選擇Weblogic9作為演示時使用的目標服務器。大家可以到http://www.bea.com下載Weblogic9,然后將Weblogic9安裝到自己的機器上。
[注]本文中的實例是實現可遠程訪問的EJB實例,因此你可以將Weblogic9安裝到其他機器上,不過客戶端調用的時候需要增加一些環境變量,請參考后面的說明。
由于篇幅的關系,我們直接使用《Kodo EJB:符合EJB3規范的持久層框架》一文中已經創建好的例子,包括環境預備、持久化類創建、數據庫創建等工作,下面的章節中將盡量不再重復《Kodo EJB:符合EJB3規范的持久層框架》一文中已經提到的步驟,而是重點描述需要額外完成的工作。
在EJB開發中,我們通常都采用session Façade設計模式,因此下面的例子也使用了這種設計模式來封裝Kodo EJB應用。
我們使用一個無狀態的Session Bean來封裝對Book類的所有操作,由于Kodo EJB應用中需要開發者完成kodo.persistence.EntityManagerFactoryImpl的實例到JNDI的綁定,我們把這部分工作訪在Session Bean中完成,下面是Session Bean的接口和實現的全部代碼,請注重代碼中增加的注釋,他們有助于您了解Kodo EJB如何工作的。
下面是BookBean類的源代碼,請大家非凡注重BookBean類中的setSessionContext方法,其中的代碼將
kodo.persistence.EntityManagerFactoryImpl的實例綁定到JNDI上。
package org.vivianj.kodo.examples.ejb.stateless;import java.rmi.RemoteException;import java.util.Collection;import javax.ejb.EJBException;import javax.ejb.SessionBean;import javax.ejb.SessionContext;import javax.naming.InitialContext;import javax.naming.NamingException;import javax.persistence.EntityManager;import javax.persistence.EntityManagerFactory;import javax.persistence.PersistenceContextType;import javax.persistence.Query;import kodo.persistence.KodoPersistence;import org.vivianj.kodo.examples.beans.Book;/** * BookBean 提供Session Bean的實現類 */public class BookBean implements SessionBean { PRotected SessionContext ctx; private EntityManagerFactory emf; /** * getBookById 根據Book對象的id屬性查找、返回符合條件的Book對象 * * @param id * Book對象的編號 * @return 編號為id的Book對象 * @throws RemoteException */ public Book getBookById(int id) throws RemoteException { /* 獲得EJB的實體治理器 */ EntityManager em = emf .createEntityManager(PersistenceContextType.EXTENDED); try { /* 開始事務 */ em.getTransaction().begin(); /* 處理業務 */ Book book = em.find(Book.class, id); /* 結束事務 */ em.getTransaction().commit(); return book; } finally { /* 關閉EJB實體治理器 */ em.close(); } } /** * updateBook 更新Book對象的信息 * * @param book * 需要更新的Book對象 * @throws RemoteException */ public void updateBook(Book book) throws RemoteException { /* 獲得EJB的實體治理器 */ EntityManager em = emf.getEntityManager(); try { /* 開始事務 */ em.getTransaction().begin(); /* 處理業務 */ em.merge(book); /* 結束事務 */ em.getTransaction().commit(); } finally { /* 關閉EJB實體治理器 */ em.close(); } } /** * createBook 方法用于持久化新的Book對象 * * @param book * 被持久化的Book對象 * @throws RemoteException */ public void createBook(Book book) throws RemoteException { /* 獲得EJB的實體治理器 */ EntityManager em = emf.getEntityManager(); try { /* 開始事務 */ em.getTransaction().begin(); /* 處理業務 */ em.persist(book); /* 結束事務 */ em.getTransaction().commit(); } finally { /* 關閉EJB實體治理器 */ em.close(); } } public void deleteBook(Book book) throws RemoteException { /* 獲得EJB的實體治理器 */ EntityManager em = emf.getEntityManager(); try { /* 開始事務 */ em.getTransaction().begin(); /* 處理業務 */ Query q = em.createQuery("delete from Book c where c.id = :id"); q.setParameter("id", book.id); q.executeUpdate(); /* 結束事務 */ em.getTransaction().commit(); } finally { /* 關閉EJB實體治理器 */ em.close(); } } public Collection getBooks(String queryString) throws RemoteException { /* 獲得EJB的實體治理器 */ EntityManager em = emf.getEntityManager(); try { /* 開始事務 */ em.getTransaction().begin(); /* 處理業務 */ List allBooks = em.createQuery(queryString).getResultList(); /* 結束事務 */ em.getTransaction().commit(); return allBooks; } finally { /* 關閉EJB實體治理器 */ em.close(); } } public void setSessionContext(SessionContext ctx) { this.ctx = ctx; try { /* 獲取JAVA EE容器上下文環境 */ Context ejbContext = new InitialContext (); Object o = null; try{ /* 根據JNDI查找kodo.persistence.EntityManagerFactoryImpl的實例 */ o = ejbContext.lookup("ejb/kodo/emf"); }catch(Exception e){ /* 假如沒有找到,嘗試將kodo.persistence.EntityManagerFactoryIm pl的實例綁定到JNDI上 */ EntityManagerFactory emfForEjb = Persistence.createEntityManagerFactory(null); ejbContext.bind("ejb/kodo/emf",emfForEjb); } if (o == null) { /* 假如沒有找到,嘗試再次查找 */ emf = (EntityManagerFactory)ejbContext.lookup("ejb/kodo/emf"); } else { emf = (EntityManagerFactory)o; } } catch (NamingException e) { throw new RuntimeException(e); } } public void ejbCreate() throws RemoteException { } public void ejbActivate() throws EJBException, RemoteException { } public void ejbPassivate() throws EJBException, RemoteException { } public void ejbRemove() throws EJBException, RemoteException { } public void unsetSessionContext() { ctx = null; }}
package org.vivianj.kodo.examples.ejb.stateless;import java.rmi.RemoteException;import javax.ejb.CreateException;import javax.ejb.EJBHome;/** * BookHome 類提供Session Bean的home接口 */public interface BookHome extends EJBHome { public BookRemote create() throws CreateException, RemoteException;}
package org.vivianj.kodo.examples.ejb.stateless;import java.rmi.RemoteException;import java.util.Collection;import javax.ejb.EJBObject;import org.vivianj.kodo.examples.beans.Book;/** * BookRemote 類提供Session Bean的remote接口 */public interface BookRemote extends EJBObject { public Book getBookById(int id) throws RemoteException; public void updateBook(Book book) throws RemoteException; public void createBook(Book book) throws RemoteException; public void deleteBook(Book book) throws RemoteException; public Collection getBooks(String queryString) throws RemoteException;}
新聞熱點
疑難解答