JAVA教程之在Java EE情况下利用Kodo EJB - 仓酷云

packageorg.vivianj.kodo.examples.ejb.stateless;importjava.rmi.RemoteException;importjava.util.Collection;importjavax.ejb.EJBException;importjavax.ejb.SessionBean;importjavax.ejb.SessionContext;importjavax.naming.InitialContext;importjavax.naming.NamingException;importjavax.persistence.EntityManager;importjavax.persistence.EntityManagerFactory;importjavax.persistence.PersistenceContextType;importjavax.persistence.Query;importkodo.persistence.KodoPersistence;importorg.vivianj.kodo.examples.beans.Book;/***BookBean供应SessionBean的完成类*/publicclassBookBeanimplementsSessionBean{protectedSessionContextctx;privateEntityManagerFactoryemf;/***getBookById依据Book对象的id属性查找、前往切合前提的Book对象**@paramid*Book对象的编号*@return编号为id的Book对象*@throwsRemoteException*/publicBookgetBookById(intid)throwsRemoteException{/*取得EJB的实体办理器*/EntityManagerem=emf.createEntityManager(PersistenceContextType.EXTENDED);try{/*入手下手事件*/em.getTransaction().begin();/*处置营业*/Bookbook=em.find(Book.class,id);/*停止事件*/em.getTransaction().commit();returnbook;}finally{/*封闭EJB实体办理器*/em.close();}}/***updateBook更新Book对象的信息**@parambook*必要更新的Book对象*@throwsRemoteException*/publicvoidupdateBook(Bookbook)throwsRemoteException{/*取得EJB的实体办理器*/EntityManagerem=emf.getEntityManager();try{/*入手下手事件*/em.getTransaction().begin();/*处置营业*/em.merge(book);/*停止事件*/em.getTransaction().commit();}finally{/*封闭EJB实体办理器*/em.close();}}/***createBook办法用于耐久化新的Book对象**@parambook*被耐久化的Book对象*@throwsRemoteException*/publicvoidcreateBook(Bookbook)throwsRemoteException{/*取得EJB的实体办理器*/EntityManagerem=emf.getEntityManager();try{/*入手下手事件*/em.getTransaction().begin();/*处置营业*/em.persist(book);/*停止事件*/em.getTransaction().commit();}finally{/*封闭EJB实体办理器*/em.close();}}publicvoiddeleteBook(Bookbook)throwsRemoteException{/*取得EJB的实体办理器*/EntityManagerem=emf.getEntityManager();try{/*入手下手事件*/em.getTransaction().begin();/*处置营业*/Queryq=em.createQuery("deletefromBookcwherec.id=:id");q.setParameter("id",book.id);q.executeUpdate();/*停止事件*/em.getTransaction().commit();}finally{/*封闭EJB实体办理器*/em.close();}}publicCollectiongetBooks(StringqueryString)throwsRemoteException{/*取得EJB的实体办理器*/EntityManagerem=emf.getEntityManager();try{/*入手下手事件*/em.getTransaction().begin();/*处置营业*/ListallBooks=em.createQuery(queryString).getResultList();/*停止事件*/em.getTransaction().commit();returnallBooks;}finally{/*封闭EJB实体办理器*/em.close();}}publicvoidsetSessionContext(SessionContextctx){this.ctx=ctx;try{/*猎取JAVAEE容器高低文情况*/ContextejbContext=newInitialContext();Objecto=null;try{/*依据JNDI查找kodo.persistence.EntityManagerFactoryImpl的实例*/o=ejbContext.lookup("ejb/kodo/emf");}catch(Exceptione){/*假如没有找到，实验将kodo.persistence.EntityManagerFactoryImpl的实例绑定到JNDI上*/EntityManagerFactoryemfForEjb=Persistence.createEntityManagerFactory(null);ejbContext.bind("ejb/kodo/emf",emfForEjb);}if(o==null){/*假如没有找到，实验再次查找*/emf=(EntityManagerFactory)ejbContext.lookup("ejb/kodo/emf");}else{emf=(EntityManagerFactory)o;}}catch(NamingExceptione){thrownewRuntimeException(e);}}publicvoidejbCreate()throwsRemoteException{}publicvoidejbActivate()throwsEJBException,RemoteException{}publicvoidejbPassivate()throwsEJBException,RemoteException{}publicvoidejbRemove()throwsEJBException,RemoteException{}publicvoidunsetSessionContext(){ctx=null;}}

复制代码

packageorg.vivianj.kodo.examples.ejb.stateless;importjava.rmi.RemoteException;importjavax.ejb.CreateException;importjavax.ejb.EJBHome;/***BookHome类供应SessionBean的home接口*/publicinterfaceBookHomeextendsEJBHome{publicBookRemotecreate()throwsCreateException,RemoteException;}

复制代码

packageorg.vivianj.kodo.examples.ejb.stateless;importjava.rmi.RemoteException;importjava.util.Collection;importjavax.ejb.EJBObject;importorg.vivianj.kodo.examples.beans.Book;/***BookRemote类供应SessionBean的remote接口*/publicinterfaceBookRemoteextendsEJBObject{publicBookgetBookById(intid)throwsRemoteException;publicvoidupdateBook(Bookbook)throwsRemoteException;publicvoidcreateBook(Bookbook)throwsRemoteException;publicvoiddeleteBook(Bookbook)throwsRemoteException;publicCollectiongetBooks(StringqueryString)throwsRemoteException;}

复制代码

<?xmlversion="1.0"encoding="UTF-8"?><ejb-jarxmlns="http://java.sun.com/xml/ns/j2ee"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee
http://java.sun.com/xml/ns/j2ee/ejb-jar_2_1.xsd"version="2.1"><display-name>SampleKodoEJB</display-name><enterprise-beans><session><ejb-name>BookEJB</ejb-name><home>org.vivianj.kodo.examples.ejb.stateless.BookHome</home><remote>org.vivianj.kodo.examples.ejb.stateless.BookRemote</remote><ejb-class>org.vivianj.kodo.examples.ejb.stateless.BookBean</ejb-class><session-type>Stateless</session-type><transaction-type>Container</transaction-type></session></enterprise-beans><assembly-descriptor><container-transaction><method><ejb-name>BookEJB</ejb-name><method-name>*</method-name></method><trans-attribute>Required</trans-attribute></container-transaction></assembly-descriptor></ejb-jar>

复制代码

<?xmlversion="1.0"?><weblogic-ejb-jarxmlns="http://www.bea.com/ns/weblogic/90"xmlns:j2ee="http://java.sun.com/xml/ns/j2ee"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.bea.com/ns/weblogic/90http://www.bea.com/ns/weblogic/90/weblogic-ejb-jar.xsd"><weblogic-enterprise-bean><ejb-name>BookEJB</ejb-name><jndi-name>ejb/kodo/book</jndi-name></weblogic-enterprise-bean></weblogic-ejb-jar>

复制代码

/*供应Weblogic服务器的信息*/Hashtable<String,String>h=newHashtable<String,String>();h.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory");h.put(Context.PROVIDER_URL,"t3://localhost:7001");/*猎取指定服务器的高低文路径*/Contextctx=newInitialContext(h);/*从JNDI中猎取SessionBean的home接口*/Objecto=ctx.lookup("ejb/kodo/book");BookHomehome=(BookHome)PortableRemoteObject.narrow(o,BookHome.class);/*取得SessionBean的remote接口*/BookRemoteremote=home.create();/*挪用营业办法*/System.out.println(remote.getBookById(1).name);

复制代码