Java/EJB3/Resource

Содержание

1 EJB Tutorial from JBoss: resource reference
2 Mark Resource
3 Reference Resource In EJB
4 Resource With Name

EJB Tutorial from JBoss: resource reference

   <source lang="java">

File: TestENC.java /*

* JBoss, Home of Professional Open Source.
* Copyright 2006, Red Hat Middleware LLC, and individual contributors
* as indicated by the @author tags. See the copyright.txt file in the
* distribution for a full listing of individual contributors.
*
* This is free software; you can redistribute it and/or modify it
* under the terms of the GNU Lesser General Public License as
* published by the Free Software Foundation; either version 2.1 of
* the License, or (at your option) any later version.
*
* This software is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this software; if not, write to the Free
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
*/

package org.jboss.tutorial.jboss_resource_ref.bean; import java.rmi.RemoteException; import javax.naming.NamingException; /** @author Scott.Stark@jboss.org @version $Revision: 57207 $

/

public interface TestENC {

  public void accessENC() throws NamingException;
  
  public void remove();

}

File: TestENCBean.java /*

* JBoss, Home of Professional Open Source.
* Copyright 2006, Red Hat Middleware LLC, and individual contributors
* as indicated by the @author tags. See the copyright.txt file in the
* distribution for a full listing of individual contributors.
*
* This is free software; you can redistribute it and/or modify it
* under the terms of the GNU Lesser General Public License as
* published by the Free Software Foundation; either version 2.1 of
* the License, or (at your option) any later version.
*
* This software is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this software; if not, write to the Free
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
*/

package org.jboss.tutorial.jboss_resource_ref.bean; import javax.naming.Context; import javax.naming.InitialContext; import javax.naming.NamingException; import javax.ejb.Remove; import org.apache.log4j.Logger; import org.jboss.ejb3.Container; /** A bean that does nothing but access resources from the ENC

to test ENC usage.
@author Scott.Stark@jboss.org
@version $Revision: 57207 $
*/

public class TestENCBean implements TestENC {

  Logger log = Logger.getLogger(getClass());
  public void accessENC() throws NamingException
  {
     // Obtain the enterprise beans environment naming context.
     Context initCtx = new InitialContext();
     Context myEnv = (Context) initCtx.lookup(Container.ENC_CTX_NAME + "/env");
     
     // This bean should have the full ENC setup of the ENCBean
     testJdbcDataSource(initCtx, myEnv);
     testMail(initCtx, myEnv);
     testJMS(initCtx, myEnv);
     testResourceEnvEntries(initCtx, myEnv);
  }
  private void testJdbcDataSource(Context initCtx, Context myEnv) throws NamingException
  {
     // JDBC DataSource
     Object obj = myEnv.lookup("jdbc/DefaultDS");
     if ((obj instanceof javax.sql.DataSource) == false)
        throw new NamingException("jdbc/DefaultDS is not a javax.sql.DataSource");
     log.info("Found data source resource ref");
  }
  private void testMail(Context initCtx, Context myEnv) throws NamingException
  {
     // JavaMail Session
     Object obj = myEnv.lookup("mail/DefaultMail");
     if ((obj instanceof javax.mail.Session) == false)
        throw new NamingException("DefaultMail is not a javax.mail.Session");
     log.info("Found mail resource ref");
  }
  private void testJMS(Context initCtx, Context myEnv) throws NamingException
  {
     // JavaMail Session
     Object obj = myEnv.lookup("jms/QueFactory");
     if ((obj instanceof javax.jms.QueueConnectionFactory) == false)
        throw new NamingException("mail/DefaultMail is not a javax.jms.QueueConnectionFactory");
     log.info("Found jms queue resource ref");
  }
  private void testResourceEnvEntries(Context initCtx, Context myEnv) throws NamingException
  {
     Object obj = myEnv.lookup("res/aQueue");
     if ((obj instanceof javax.jms.Queue) == false)
        throw new NamingException("res/aQueue is not a javax.jms.Queue");
     log.info("Found jms queue resource env ref");
  }
  
  @Remove
  public void remove()
  {
     
  }

}

File: Client.java /*

* JBoss, Home of Professional Open Source.
* Copyright 2006, Red Hat Middleware LLC, and individual contributors
* as indicated by the @author tags. See the copyright.txt file in the
* distribution for a full listing of individual contributors.
*
* This is free software; you can redistribute it and/or modify it
* under the terms of the GNU Lesser General Public License as
* published by the Free Software Foundation; either version 2.1 of
* the License, or (at your option) any later version.
*
* This software is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this software; if not, write to the Free
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
*/

package org.jboss.tutorial.jboss_resource_ref.client; import javax.naming.InitialContext; import org.jboss.tutorial.jboss_resource_ref.bean.TestENC; /**

* Comment
*
* @author

Mark Resource

   <source lang="java">

File: EmployeeServiceLocal.java

import java.util.Collection; import javax.ejb.Local; @Local public interface EmployeeServiceLocal {

   public void doAction();

}

File: EmployeeServiceRemote.java

import java.util.Collection; import javax.ejb.Remote; @Remote public interface EmployeeServiceRemote{

 public void doAction();

}

File: EntityListener.java

import javax.persistence.PostLoad; import javax.persistence.PostPersist; import javax.persistence.PostRemove; import javax.persistence.PostUpdate; public class EntityListener {

  @PostUpdate
  public void update(Object entity)
  {
     System.out.println("@PostUpdate: " + entity.getClass().getName());
  }
  @PostPersist
  public void persist(Object entity)
  {
     System.out.println("@PostPersist: " + entity.getClass().getName());
  }
  @PostLoad
  public void load(Object entity)
  {
     System.out.println("@PostLoad: " + entity.getClass().getName());
  }
     
  @PostRemove
  public void remove(Object entity)
  {
     System.out.println("@PostRemove: " + entity.getClass().getName());
  }

}

File: Employee.java import javax.persistence.Entity; import javax.persistence.EntityListeners; import javax.persistence.GeneratedValue; import javax.persistence.Id; import javax.persistence.PostRemove; @Entity @EntityListeners(EntityListener.class) public class Employee implements java.io.Serializable {

 private int id;
 private String firstName;
 private String lastName;
 @Id
 @GeneratedValue
 public int getId() {
   return id;
 }

 @PostRemove
 public void postRemove()
 {
    System.out.println("@PostRemove");
 }
 public void setId(int id) {
   this.id = id;
 }
 public String getFirstName() {
   return firstName;
 }
 public void setFirstName(String first) {
   this.firstName = first;
 }
 public String getLastName() {
   return lastName;
 }
 public void setLastName(String last) {
   this.lastName = last;
 }

}

File: EmployeeService.java

import java.sql.Connection; import java.sql.PreparedStatement; import javax.annotation.Resource; import javax.ejb.Stateless; import javax.persistence.EntityManager; import javax.persistence.PersistenceContext; import javax.sql.DataSource; @Stateless public class EmployeeService implements EmployeeServiceLocal, EmployeeServiceRemote {

 @PersistenceContext(unitName="EmployeeService")
 EntityManager em;
 
 @Resource(mappedName="java:/DefaultDS") DataSource dataSource;
 
 public EmployeeService() {
 }
 public void doAction(){

/* Employee employee = new Employee();

   employee.setFirstName("E");
   employee.setLastName("E");
   em.persist(employee);
   employee.setLastName("New");
   em.merge(employee);
   
   em.remove(employee);
   
   em.flush();
   System.out.println("saved");
   
   
   List list = em.createQuery("FROM Employee p").getResultList();
   */
   PreparedStatement ps = null;
   Connection con = null;
   try
   {
      con = dataSource.getConnection();
      System.out.println("Creating table PAYMENT...");
      ps = con.prepareStatement("CREATE TABLE PAYMENT ( " +
                                "CUSTOMER_ID INT, " +
                                "CREDIT_EXP_DATE DATE" +
                                ")");
      ps.execute();
      System.out.println("...done!");    
   }catch(Exception e){
     
   }       
 }

}

File: Main.java import java.util.Collection; import javax.naming.InitialContext;

public class Main {

 public static void main(String[] a) throws Exception {
   EmployeeServiceRemote service = null;
   // Context compEnv = (Context) new InitialContext().lookup("java:comp/env");
   // service = (HelloService)new InitialContext().lookup("java:comp/env/ejb/HelloService");
   service = (EmployeeServiceRemote) new InitialContext().lookup("EmployeeService/remote");
   
   
   
   
   service.doAction();
 }

}

File: jndi.properties java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces java.naming.provider.url=localhost:1099

      </source>

Reference Resource In EJB

   <source lang="java">

File: Employee.java import javax.persistence.Entity; import javax.persistence.EntityListeners; import javax.persistence.GeneratedValue; import javax.persistence.Id; import javax.persistence.PostRemove; @Entity @EntityListeners(EntityListener.class) public class Employee implements java.io.Serializable {

 private int id;
 private String firstName;
 private String lastName;
 @Id
 @GeneratedValue
 public int getId() {
   return id;
 }

 @PostRemove
 public void postRemove()
 {
    System.out.println("@PostRemove");
 }
 public void setId(int id) {
   this.id = id;
 }
 public String getFirstName() {
   return firstName;
 }
 public void setFirstName(String first) {
   this.firstName = first;
 }
 public String getLastName() {
   return lastName;
 }
 public void setLastName(String last) {
   this.lastName = last;
 }

}

File: EmployeeService.java

import java.sql.Connection; import java.sql.PreparedStatement; import javax.annotation.Resource; import javax.ejb.Stateless; import javax.persistence.EntityManager; import javax.persistence.PersistenceContext; import javax.sql.DataSource; @Stateless public class EmployeeService implements EmployeeServiceLocal, EmployeeServiceRemote {

 @PersistenceContext(unitName="EmployeeService")
 EntityManager em;
 
 DataSource dataSource;
 int minCheckNumber = 100;
 public EmployeeService() {
 }
 public void doAction(){

/* Employee employee = new Employee();

   employee.setFirstName("E");
   employee.setLastName("E");
   em.persist(employee);
   employee.setLastName("New");
   em.merge(employee);
   
   em.remove(employee);
   
   em.flush();
   System.out.println("saved");
   
   
   List list = em.createQuery("FROM Employee p").getResultList();
   */

 }

}

File: EmployeeServiceLocal.java

import java.util.Collection; import javax.ejb.Local; @Local public interface EmployeeServiceLocal {

   public void doAction();

}

File: EmployeeServiceRemote.java

import java.util.Collection; import javax.ejb.Remote; @Remote public interface EmployeeServiceRemote{

 public void doAction();

}

File: EntityListener.java

import javax.persistence.PostLoad; import javax.persistence.PostPersist; import javax.persistence.PostRemove; import javax.persistence.PostUpdate; public class EntityListener {

  @PostUpdate
  public void update(Object entity)
  {
     System.out.println("@PostUpdate: " + entity.getClass().getName());
  }
  @PostPersist
  public void persist(Object entity)
  {
     System.out.println("@PostPersist: " + entity.getClass().getName());
  }
  @PostLoad
  public void load(Object entity)
  {
     System.out.println("@PostLoad: " + entity.getClass().getName());
  }
     
  @PostRemove
  public void remove(Object entity)
  {
     System.out.println("@PostRemove: " + entity.getClass().getName());
  }

}

File: jndi.properties java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces java.naming.provider.url=localhost:1099

File: Main.java import java.util.Collection; import javax.naming.InitialContext;

public class Main {

 public static void main(String[] a) throws Exception {
   EmployeeServiceRemote service = null;
   // Context compEnv = (Context) new InitialContext().lookup("java:comp/env");
   // service = (HelloService)new InitialContext().lookup("java:comp/env/ejb/HelloService");
   service = (EmployeeServiceRemote) new InitialContext().lookup("EmployeeService/remote");
   
   
   
   
   service.doAction();
 }

}

      </source>

Resource With Name

   <source lang="java">

File: EmployeeService.java

import java.sql.Connection; import java.sql.PreparedStatement; import javax.annotation.Resource; import javax.ejb.Stateless; import javax.persistence.EntityManager; import javax.persistence.PersistenceContext; import javax.sql.DataSource; @Stateless public class EmployeeService implements EmployeeServiceLocal, EmployeeServiceRemote {

 @PersistenceContext(unitName="EmployeeService")
 EntityManager em;
 
 @Resource(name="min") int minCheckNumber = 100;
 public EmployeeService() {
 }
 public void doAction(){

/* Employee employee = new Employee();

   employee.setFirstName("E");
   employee.setLastName("E");
   em.persist(employee);
   employee.setLastName("New");
   em.merge(employee);
   
   em.remove(employee);
   
   em.flush();
   System.out.println("saved");
   
   
   List list = em.createQuery("FROM Employee p").getResultList();
   */

 }

}

File: EmployeeServiceLocal.java

import java.util.Collection; import javax.ejb.Local; @Local public interface EmployeeServiceLocal {

   public void doAction();

}

File: EmployeeServiceRemote.java

import java.util.Collection; import javax.ejb.Remote; @Remote public interface EmployeeServiceRemote{

 public void doAction();

}

File: EntityListener.java

import javax.persistence.PostLoad; import javax.persistence.PostPersist; import javax.persistence.PostRemove; import javax.persistence.PostUpdate; public class EntityListener {

  @PostUpdate
  public void update(Object entity)
  {
     System.out.println("@PostUpdate: " + entity.getClass().getName());
  }
  @PostPersist
  public void persist(Object entity)
  {
     System.out.println("@PostPersist: " + entity.getClass().getName());
  }
  @PostLoad
  public void load(Object entity)
  {
     System.out.println("@PostLoad: " + entity.getClass().getName());
  }
     
  @PostRemove
  public void remove(Object entity)
  {
     System.out.println("@PostRemove: " + entity.getClass().getName());
  }

}

File: Employee.java import javax.persistence.Entity; import javax.persistence.EntityListeners; import javax.persistence.GeneratedValue; import javax.persistence.Id; import javax.persistence.PostRemove; @Entity @EntityListeners(EntityListener.class) public class Employee implements java.io.Serializable {

 private int id;
 private String firstName;
 private String lastName;
 @Id
 @GeneratedValue
 public int getId() {
   return id;
 }

 @PostRemove
 public void postRemove()
 {
    System.out.println("@PostRemove");
 }
 public void setId(int id) {
   this.id = id;
 }
 public String getFirstName() {
   return firstName;
 }
 public void setFirstName(String first) {
   this.firstName = first;
 }
 public String getLastName() {
   return lastName;
 }
 public void setLastName(String last) {
   this.lastName = last;
 }

}

File: jndi.properties java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces java.naming.provider.url=localhost:1099

File: Main.java import java.util.Collection; import javax.naming.InitialContext;

public class Main {

 public static void main(String[] a) throws Exception {
   EmployeeServiceRemote service = null;
   // Context compEnv = (Context) new InitialContext().lookup("java:comp/env");
   // service = (HelloService)new InitialContext().lookup("java:comp/env/ejb/HelloService");
   service = (EmployeeServiceRemote) new InitialContext().lookup("EmployeeService/remote");
   
   
   
   
   service.doAction();
 }

}

      </source>

Java/EJB3/Resource

Содержание

EJB Tutorial from JBoss: resource reference

Mark Resource

Reference Resource In EJB

Resource With Name

Навигация

Персональные инструменты

Пространства имён

Варианты

Просмотры

Ещё

Поиск

Разделы

Навигация

Инструменты