EJB - Persistencia

EJB 3.0, el bean de entidad utilizado en EJB 2.0 se reemplaza en gran medida por el mecanismo de persistencia. Ahora, el bean de entidad es un POJO simple que tiene un mapeo con la tabla.

Los siguientes son los actores clave en la API de persistencia:

  • Entity- Un objeto persistente que representa el registro del almacén de datos. Es bueno ser serializable.

  • EntityManager- Interfaz de persistencia para realizar operaciones de datos como agregar / eliminar / actualizar / buscar en un objeto persistente (entidad). También ayuda a ejecutar consultas usandoQuery interfaz.

  • Persistence unit (persistence.xml) - Unidad de persistencia describe las propiedades del mecanismo de persistencia.

  • Data Source (*ds.xml)- Fuente de datos describe las propiedades relacionadas con el almacén de datos, como la URL de conexión. nombre de usuario, contraseña, etc.

Para demostrar el mecanismo de persistencia de EJB, debemos realizar las siguientes tareas:

  • Step 1 - Crear tabla en base de datos.

  • Step 2 - Crear clase de entidad correspondiente a la tabla.

  • Step 3 - Creación de fuente de datos y unidad de persistencia.

  • Step 4 - Cree un EJB sin estado que tenga una instancia de EntityManager.

  • Step 5- Actualización de EJB sin estado. Agregue métodos para agregar registros y obtener registros de la base de datos a través del administrador de entidades.

  • Step 6 - Un cliente de aplicación basado en consola accederá al EJB sin estado para conservar los datos en la base de datos.

Crear mesa

Crea una tabla books en la base de datos predeterminada postgres.

CREATE TABLE books (
   id     integer PRIMARY KEY,
   name   varchar(50)
);

Crear clase de entidad

//mark it entity using Entity annotation 
//map table name using Table annotation
@Entity
@Table(name="books")
public class Book implements Serializable{
    
   private int id;
   private String name;

   public Book() {        
   }

   //mark id as primary key with autogenerated value
   //map database column id with id field
   @Id
   @GeneratedValue(strategy= GenerationType.IDENTITY)
   @Column(name="id")
   public int getId() {
      return id;
   }
   ...
}

Crear unidad de fuente de datos y persistencia

Fuente de datos (jboss-ds.xml)

<?xml version = "1.0" encoding = "UTF-8"?>
<datasources>
   <local-tx-datasource>
      <jndi-name>PostgresDS</jndi-name>
      <connection-url>jdbc:postgresql://localhost:5432/postgres</connection-url>
      <driver-class>org.postgresql.driver</driver-class>
      <user-name>sa</user-name>
      <password>sa</password>
      <min-pool-size>5</min-pool-size>
      <max-pool-size>20</max-pool-size>
      <idle-timeout-minutes>5</idle-timeout-minutes>
   </local-tx-datasource>
</datasources>

Unidad de persistencia (persistence.xml)

<persistence version = "1.0" xmlns = "http://java.sun.com/xml/ns/persistence" xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd">

   <persistence-unit name = "EjbComponentPU" transaction-type = "JTA">
      <jta-data-source>java:/PostgresDS</jta-data-source>
      <exclude-unlisted-classes>false</exclude-unlisted-classes>
      <properties/>
   </persistence-unit>
   
   <persistence-unit name = "EjbComponentPU2" transaction-type = "JTA">
      <provider>org.hibernate.ejb.HibernatePersistence</provider>
      <jta-data-source>java:/PostgresDS</jta-data-source>
      <exclude-unlisted-classes>false</exclude-unlisted-classes>
	  
      <properties>
         <property name="hibernate.hbm2ddl.auto" value="update"/>
      </properties>
   </persistence-unit>
   
</persistence>

Crear EJB sin estado con una instancia EntityManager

@Stateless
public class LibraryPersistentBean implements LibraryPersistentBeanRemote {
	
   //pass persistence unit to entityManager.
   @PersistenceContext(unitName="EjbComponentPU")
   private EntityManager entityManager;         

   public void addBook(Book book) {
      entityManager.persist(book);
   }    

   public List<Book> getBooks() {        
      return entityManager.createQuery("From Books").getResultList();
   }
   ...
}

Después de construir el módulo EJB, necesitamos un cliente para acceder al bean sin estado, que crearemos en la siguiente sección.

Aplicación de ejemplo

Creemos una aplicación EJB de prueba para probar el mecanismo de persistencia de EJB.

Paso Descripción
1

Cree un proyecto con un nombre EjbComponent en un paquete com.tutorialspoint.entity como se explica en el capítulo EJB - Crear aplicación . También puede utilizar el proyecto creado en el capítulo EJB - Crear aplicación como tal para este capítulo para comprender los conceptos de persistencia de EJB.
2

Cree Book.java en el paquete com.tutorialspoint.entity y modifíquelo como se muestra a continuación.
3

Cree LibraryPersistentBean.java y LibraryPersistentBeanRemote como se explica en los capítulos EJB - Crear aplicación y modifíquelos como se muestra a continuación.
4

Cree jboss-ds.xml enEjbComponent > setup carpeta y persistence.xml enEjbComponent > src > conf carpeta. Estas carpetas se pueden ver en la pestaña de archivos en Netbeans. Modifique estos archivos como se muestra arriba.
5

Limpie y compile la aplicación para asegurarse de que la lógica empresarial funcione según los requisitos.
6

Finalmente, implemente la aplicación en forma de archivo jar en JBoss Application Server. El servidor de aplicaciones JBoss se iniciará automáticamente si aún no se ha iniciado.
7

Ahora cree el cliente EJB, una aplicación basada en consola de la misma manera que se explica en el capítulo EJB - Crear aplicación en el temaCreate Client to access EJB. Modifíquelo como se muestra a continuación.

EJBComponent (módulo EJB)

Book.java

package com.tutorialspoint.entity;

import java.io.Serializable;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.EntityListeners;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.Table;

@Entity
@Table(name="books")
public class Book implements Serializable{
    
   private int id;
   private String name;

   public Book() {        
   }

   @Id
   @GeneratedValue(strategy= GenerationType.IDENTITY)
   @Column(name="id")
   public int getId() {
      return id;
   }

   public void setId(int id) {
      this.id = id;
   }

   public String getName() {
      return name;
   }

   public void setName(String name) {
      this.name = name;
   }    
}

LibraryPersistentBeanRemote.java

package com.tutorialspoint.stateless;

import com.tutorialspoint.entity.Book;
import java.util.List;
import javax.ejb.Remote;

@Remote
public interface LibraryPersistentBeanRemote {

   void addBook(Book bookName);

   List<Book> getBooks();
    
}

LibraryPersistentBean.java

package com.tutorialspoint.stateless;

import com.tutorialspoint.entity.Book;
import java.util.List;
import javax.ejb.Stateless;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;

@Stateless
public class LibraryPersistentBean implements LibraryPersistentBeanRemote {
    
   public LibraryPersistentBean() {
   }

   @PersistenceContext(unitName="EjbComponentPU")
   private EntityManager entityManager;         

   public void addBook(Book book) {
      entityManager.persist(book);
   }    

   public List<Book> getBooks() {
      return entityManager.createQuery("From Book").getResultList();
   }
}

  • Tan pronto como implemente el proyecto EjbComponent en JBOSS, observe el registro de jboss.

  • JBoss ha creado automáticamente una entrada JNDI para nuestro bean de sesión - LibraryPersistentBean/remote.

  • Usaremos esta cadena de búsqueda para obtener un objeto comercial remoto de tipo: com.tutorialspoint.stateless.LibraryPersistentBeanRemote

Salida de registro del servidor de aplicaciones JBoss

...
16:30:01,401 INFO  [JndiSessionRegistrarBase] Binding the following Entries in Global JNDI:
   LibraryPersistentBean/remote - EJB3.x Default Remote Business Interface
   LibraryPersistentBean/remote-com.tutorialspoint.stateless.LibraryPersistentBeanRemote - EJB3.x Remote Business Interface
16:30:02,723 INFO  [SessionSpecContainer] Starting jboss.j2ee:jar=EjbComponent.jar,name=LibraryPersistentBeanRemote,service=EJB3
16:30:02,723 INFO  [EJBContainer] STARTED EJB: com.tutorialspoint.stateless.LibraryPersistentBeanRemote ejbName: LibraryPersistentBean
16:30:02,731 INFO  [JndiSessionRegistrarBase] Binding the following Entries in Global JNDI:

   LibraryPersistentBean/remote - EJB3.x Default Remote Business Interface
   LibraryPersistentBean/remote-com.tutorialspoint.stateless.LibraryPersistentBeanRemote - EJB3.x Remote Business Interface
...

EJBTester (cliente EJB)

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

  • Estas propiedades se utilizan para inicializar el objeto InitialContext del servicio de nombres de Java.

  • El objeto InitialContext se utilizará para buscar un bean de sesión sin estado.

EJBTester.java

package com.tutorialspoint.test;
   
import com.tutorialspoint.stateless.LibraryPersistentBeanRemote;
import java.io.BufferedReader;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.List;
import java.util.Properties;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class EJBTester {

   BufferedReader brConsoleReader = null; 
   Properties props;
   InitialContext ctx;
   {
      props = new Properties();
      try {
         props.load(new FileInputStream("jndi.properties"));
      } catch (IOException ex) {
         ex.printStackTrace();
      }
      try {
         ctx = new InitialContext(props);            
      } catch (NamingException ex) {
         ex.printStackTrace();
      }
      brConsoleReader = 
      new BufferedReader(new InputStreamReader(System.in));
   }
   
   public static void main(String[] args) {

      EJBTester ejbTester = new EJBTester();

      ejbTester.testEntityEjb();
   }
   
   private void showGUI() {
      System.out.println("**********************");
      System.out.println("Welcome to Book Store");
      System.out.println("**********************");
      System.out.print("Options \n1. Add Book\n2. Exit \nEnter Choice: ");
   }
   
   private void testEntityEjb() {

      try {
         int choice = 1; 

         LibraryPersistentBeanRemote libraryBean =
         LibraryPersistentBeanRemote)ctx.lookup("LibraryPersistentBean/remote");

         while (choice != 2) {
            String bookName;
            showGUI();
            String strChoice = brConsoleReader.readLine();
            choice = Integer.parseInt(strChoice);
            if (choice == 1) {
               System.out.print("Enter book name: ");
               bookName = brConsoleReader.readLine();
               Book book = new Book();
               book.setName(bookName);
               libraryBean.addBook(book);          
            } else if (choice == 2) {
               break;
            }
         }

         List<Book> booksList = libraryBean.getBooks();

         System.out.println("Book(s) entered so far: " + booksList.size());
         int i = 0;
         for (Book book:booksList) {
            System.out.println((i+1)+". " + book.getName());
            i++;
         }           
      } catch (Exception e) {
         System.out.println(e.getMessage());
         e.printStackTrace();
      }finally {
         try {
            if(brConsoleReader !=null) {
               brConsoleReader.close();
            }
         } catch (IOException ex) {
            System.out.println(ex.getMessage());
         }
      }
   }
}

EJBTester realiza las siguientes tareas.

  • Cargue las propiedades de jndi.properties e inicialice el objeto InitialContext.

  • En el método testStatefulEjb (), la búsqueda de jndi se realiza con el nombre - "LibraryStatefulSessionBean / remote" para obtener el objeto de negocio remoto (ejb con estado).

  • Luego, se muestra al usuario una interfaz de usuario de la tienda de la biblioteca y se le pide que ingrese la opción.

  • Si el usuario ingresa 1, el sistema solicita el nombre del libro y guarda el libro usando el método addBook () del bean de sesión sin estado. Session Bean mantiene el libro en la base de datos a través de la llamada EntityManager.

  • Si el usuario ingresa 2, el sistema recupera libros usando el método getBooks () del bean de sesión con estado y sale.

  • Luego, se realiza otra búsqueda de jndi con el nombre - "LibraryStatelessSessionBean / remote" para obtener el objeto comercial remoto (EJB sin estado) nuevamente y se realiza la lista de libros.

Ejecute el cliente para acceder a EJB

Busque EJBTester.java en el explorador de proyectos. Haga clic derecho en la clase EJBTester y seleccionerun file.

Verifique la siguiente salida en la consola de Netbeans:

run:
**********************
Welcome to Book Store
**********************
Options 
1. Add Book
2. Exit 
Enter Choice: 1
Enter book name: Learn Java
**********************
Welcome to Book Store
**********************
Options 
1. Add Book
2. Exit 
Enter Choice: 2
Book(s) entered so far: 1
1. learn java
BUILD SUCCESSFUL (total time: 15 seconds)

Ejecute el cliente nuevamente para acceder a EJB

Reinicie JBoss antes de acceder a EJB.

Busque EJBTester.java en el explorador de proyectos. Haga clic derecho en la clase EJBTester y seleccionerun file.

Verifique la siguiente salida en la consola de Netbeans.

run:
**********************
Welcome to Book Store
**********************
Options 
1. Add Book
2. Exit 
Enter Choice: 1
Enter book name: Learn Spring
**********************
Welcome to Book Store
**********************
Options 
1. Add Book
2. Exit 
Enter Choice: 2
Book(s) entered so far: 2
1. learn java
2. Learn Spring
BUILD SUCCESSFUL (total time: 15 seconds)

El resultado que se muestra arriba indica que los libros se almacenan en almacenamiento persistente y se recuperan de la base de datos.