Tutoriales

CMP Entity Beans y MySql

Por

3 octubre, 2003

29608

CMP Entity Bean con MySql

Como comentamos en el anteriortutorial, la persistencia de un Entity Bean
puede ser gestionada por el contenedor.

En este tutorial vamos a ver los pequeños cambios que debemos realizar sobre
nuestro EJB, del mismo modo que os vamos a enseñar el truquillo para poder usar
la implementación de referencia de J2EE de Sun (J2EE RI) para usar MySql como
base de datos.

Como podemos suponer, pocas cosas deben cambiar… aunque hay algunas
sutilizas.

Lo que es realmente importante, es la definición del despliegue

Definición de interfaz Remoto

El único cambio, que además tiene mucho sentido, es la eliminación de la
definición del metodo setId.

Digo que tiene sentido porque cambiar la clave primaria normalmente requiere de otras precauciones.

package ejbfacturas;

/**
 *
 * Interfaz remoto a nuestro EJB de Facturas
 *
 * @author  Roberto Canales
 */
import java.rmi.*;
import javax.ejb.*;
import facturascomun.*;
import java.util.*;

public interface iFacturaItemCMP extends EJBObject
{
    public String getConcepto() throws java.rmi.RemoteException;
    public void setConcepto(String sConcepto) throws java.rmi.RemoteException;
    public String getFecha() throws java.rmi.RemoteException;
    public void setFecha(String sFecha) throws java.rmi.RemoteException;
    public String getDireccion() throws java.rmi.RemoteException;
    public void setDireccion(String sDireccion) throws java.rmi.RemoteException ;
    public String getTitular() throws java.rmi.RemoteException;
    public void setTitular(String sTitular) throws java.rmi.RemoteException;
    public String getCif() throws java.rmi.RemoteException;
    public void setCif(String sCif) throws java.rmi.RemoteException;
    public String getId() throws java.rmi.RemoteException;
<font color="#008000">    //public void setId(String iId) throws RemoteException, EJBException;
</font>    public double getCantidad() throws java.rmi.RemoteException;
    public void setCantidad(double dCantidad) throws java.rmi.RemoteException;
}

package ejbfacturas;

/**

* Interfaz remoto a nuestro EJB de Facturas

* @author Roberto Canales

import java.rmi.*;

import javax.ejb.*;

import facturascomun.*;

import java.util.*;

public interface iFacturaItemCMP extends EJBObject

{

public String getConcepto() throws java.rmi.RemoteException;

public void setConcepto(String sConcepto) throws java.rmi.RemoteException;

public String getFecha() throws java.rmi.RemoteException;

public void setFecha(String sFecha) throws java.rmi.RemoteException;

public String getDireccion() throws java.rmi.RemoteException;

public void setDireccion(String sDireccion) throws java.rmi.RemoteException ;

public String getTitular() throws java.rmi.RemoteException;

public void setTitular(String sTitular) throws java.rmi.RemoteException;

public String getCif() throws java.rmi.RemoteException;

public void setCif(String sCif) throws java.rmi.RemoteException;

public String getId() throws java.rmi.RemoteException;

//public void setId(String iId) throws RemoteException, EJBException;

public double getCantidad() throws java.rmi.RemoteException;

public void setCantidad(double dCantidad) throws java.rmi.RemoteException;

}

Definición del Interfaz Home

La definicón del interfaz Home, en este caso cambia en el tipo de retorno
del metodo findByPrimaryKey

package ejbfacturas;
/**
 *
 * @author  Roberto Canales
 */

import java.rmi.*;
import javax.ejb.*;
import java.io.*;
import java.util.*;

import facturascomun.*;

/**
 * Interfaz Home para definir los méodos de creación de nuestro EJB
 *
 */
public interface iFacturaItemHomeCMP extends EJBHome
{
    // ver las diferencias entre las declaraciones del Home y del Bean
    public iFacturaItemCMP create(Factura pFactura) throws CreateException, RemoteException;
    public <font color="#800000"><b>iFacturaItemCMP</b></font> <b>findByPrimaryKey</b>(String pParam) throws FinderException, RemoteException;
}

package ejbfacturas;

/**

* @author Roberto Canales

import java.rmi.*;

import javax.ejb.*;

import java.io.*;

import java.util.*;

import facturascomun.*;

/**

* Interfaz Home para definir los méodos de creación de nuestro EJB

public interface iFacturaItemHomeCMP extends EJBHome

{

// ver las diferencias entre las declaraciones del Home y del Bean

public iFacturaItemCMP create(Factura pFactura) throws CreateException, RemoteException;

public iFacturaItemCMP findByPrimaryKey(String pParam) throws FinderException, RemoteException;

}

Implementación del Bean

Hay que realizar una definición de métodos abstractos

    public
abstract String getConcepto();
    public abstract void setConcepto(String sConcepto);
    public abstract String getFecha();
    public abstract void setFecha(String sFecha);
    public abstract String getDireccion();
    public abstract void setDireccion(String sDireccion);
    public abstract String getTitular();
    public abstract void setTitular(String sTitular);
    public abstract String getCif() ;
    public abstract void setCif(String sCif);
    public abstract String getId();
    public abstract void setId(String iId);
    public abstract double getCantidad();
    public abstract void setCantidad(double dCantidad);

Para asignar los valores del Bean, debemos invocar a los metodos, en el
ejbCreate

Por último, lo único que queda por hacer en el código, es borrar el
código que gestiona la persistencia.

package ejbfacturas;

/**
 * @author Roberto Canales
 */

import java.rmi.*;
import javax.ejb.*;
import java.sql.*;
import javax.sql.*;
import java.util.*;

import facturascomun.*;


public abstract class <b>iFacturaItemBeanCMP</b> implements EntityBean
{
    private void depura(String cadena)
    {
        System.out.println("EJB iFacturaItemBeanCMP: " + cadena);
    }


    private EntityContext context = null;

    /**
     * Metodo destinado a construir nuestro objeto
     *
     * Debe retornar la clave primaria del objeto creado
     */
    public String <b>ejbCreate</b>(Factura pFactura) throws CreateException
    {
        if (pFactura == null)
        {
            throw new CreateException("El Objeto retornado es nulo");
        }

       <font color="#800000"> // asignamos las propiedades a los miembros de nuestra clase
        this.setId(pFactura.getId());  // clave primaria de nuestra factura
        this.setTitular(pFactura.getTitular());
        this.setConcepto(pFactura.getConcepto());
        this.setCif(pFactura.getCif());
        this.setDireccion(pFactura.getDireccion());
        this.setFecha(pFactura.getFecha());
        this.setCantidad(pFactura.getCandidad());

        return null;  // en un CMP se retorna NULL</font>
    }

    /**
     * PosCreate del create construido
     */
    public void <b>ejbPostCreate</b>(Factura pFactura) throws CreateException
    {
        depura("Enviado post-create");
        // no es necesario código aunque si el metodo por haber escrito un create
    }


    /**
     * Metodo invocado por el contenedor para reactivar la instancia
     */
    public void <b>ejbActivate</b>() {
         depura("Se activa el EJB");
    }


    /**
     * Metodo invocado por el contenedor para desactivar la instancia
     */
    public void <b>ejbPassivate</b>() {
        depura("Se pasiva el EJB");
    }

    /**
     * Metodo invocado por el contenedor para borrar la instancia
     */
    public void <b>ejbRemove</b>()  throws RemoveException {
        depura("Borramos el EJB para id ");
     }

    /**
     * Metodo invocado por el contenedor para cargar de BBDD los datos de la instancia
     */
    public void <b>ejbLoad</b>() throws javax.ejb.EJBException, java.rmi.RemoteException {

        depura("Cargamos datos el EJB ");
    }

     /**
     * Metodo invocado por el contenedor para almacenar los datos cambiados
     */
    public void <b>ejbStore</b>() throws javax.ejb.EJBException, java.rmi.RemoteException {
        depura("Guardamos datos el EJB");
    }


     /**
     * Metodo invocado por el contenedor para pasarnos y desactivar el contexto
     */
    public void <b>setEntityContext</b>(javax.ejb.EntityContext entityContext) throws javax.ejb.EJBException, java.rmi.RemoteException {
            depura("Establecemos el contexto");
            this.context = entityContext; // si se nos olvida fallara el ejbActivate
    }


    public void <b>unsetEntityContext</b>() throws javax.ejb.EJBException, java.rmi.RemoteException {
            depura("Des-establecemos el contexto");
            context = null;
    }


    <font color="#800000">public abstract String <b>getConcepto</b>();
    public abstract void <b>setConcepto</b>(String sConcepto);
    public abstract String <b>getFecha</b>();
    public abstract void <b>setFecha</b>(String sFecha);
    public abstract String <b>getDireccion</b>();
    public abstract void <b>setDireccion</b>(String sDireccion);
    public abstract String <b>getTitular</b>();
    public abstract void <b>setTitular</b>(String sTitular);
    public abstract String <b>getCif</b>() ;
    public abstract void <b>setCif</b>(String sCif);
    public abstract String <b>getId</b>();
    public abstract void <b>setId</b>(String iId);
    public abstract double <b>getCantidad</b>();
    public abstract void <b>setCantidad</b>(double dCantidad);
</font>
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

package ejbfacturas;

/**

* @author Roberto Canales

import java.rmi.*;

import javax.ejb.*;

import java.sql.*;

import javax.sql.*;

import java.util.*;

import facturascomun.*;

public abstract class iFacturaItemBeanCMP implements EntityBean

{

private void depura(String cadena)

{

System.out.println("EJB iFacturaItemBeanCMP: " + cadena);

}

private EntityContext context = null;

/**

* Metodo destinado a construir nuestro objeto

* Debe retornar la clave primaria del objeto creado

public String ejbCreate(Factura pFactura) throws CreateException

{

if (pFactura == null)

{

throw new CreateException("El Objeto retornado es nulo");

}

// asignamos las propiedades a los miembros de nuestra clase

this.setId(pFactura.getId()); // clave primaria de nuestra factura

this.setTitular(pFactura.getTitular());

this.setConcepto(pFactura.getConcepto());

this.setCif(pFactura.getCif());

this.setDireccion(pFactura.getDireccion());

this.setFecha(pFactura.getFecha());

this.setCantidad(pFactura.getCandidad());

return null; // en un CMP se retorna NULL

}

/**

* PosCreate del create construido

public void ejbPostCreate(Factura pFactura) throws CreateException

{

depura("Enviado post-create");

// no es necesario código aunque si el metodo por haber escrito un create

}

/**

* Metodo invocado por el contenedor para reactivar la instancia

public void ejbActivate() {

depura("Se activa el EJB");

}

/**

* Metodo invocado por el contenedor para desactivar la instancia

public void ejbPassivate() {

depura("Se pasiva el EJB");

}

/**

* Metodo invocado por el contenedor para borrar la instancia

public void ejbRemove() throws RemoveException {

depura("Borramos el EJB para id ");

}

/**

* Metodo invocado por el contenedor para cargar de BBDD los datos de la instancia

public void ejbLoad() throws javax.ejb.EJBException, java.rmi.RemoteException {

depura("Cargamos datos el EJB ");

}

/**

* Metodo invocado por el contenedor para almacenar los datos cambiados

public void ejbStore() throws javax.ejb.EJBException, java.rmi.RemoteException {

depura("Guardamos datos el EJB");

}

/**

* Metodo invocado por el contenedor para pasarnos y desactivar el contexto

public void setEntityContext(javax.ejb.EntityContext entityContext) throws javax.ejb.EJBException, java.rmi.RemoteException {

depura("Establecemos el contexto");

this.context = entityContext; // si se nos olvida fallara el ejbActivate

}

public void unsetEntityContext() throws javax.ejb.EJBException, java.rmi.RemoteException {

depura("Des-establecemos el contexto");

context = null;

}

public abstract String getConcepto();

public abstract void setConcepto(String sConcepto);

public abstract String getFecha();

public abstract void setFecha(String sFecha);

public abstract String getDireccion();

public abstract void setDireccion(String sDireccion);

public abstract String getTitular();

public abstract void setTitular(String sTitular);

public abstract String getCif() ;

public abstract void setCif(String sCif);

public abstract String getId();

public abstract void setId(String iId);

public abstract double getCantidad();

public abstract void setCantidad(double dCantidad);

}

Despliegue de la aplicación

Añadimos el EJB como hicimos con los anteriores

En la lengüeta de Entity asignamos un nombre para nuestras consultas EJB
(MICMP). Deberia ser un poco más estricto en la notación pero asi se ve mejor
…. 😉

Al pinchar el botón de Deployment Settings, aparece la configuración de la
base de datos.

Pulsamos Database Settings …

Asignamos el nombre JNDI de la base de datos (ver más abajo)

Pincharemos el botón de generar Default SQL

Y ya tenemos lista para funcionar nuestra aplicación. Ahora vamos a
configurar el entorno para poder usar MySql
(en Windows)

Registro de MySql

Pinchamos en la opción de configurar el servidor

Registramos un nuevo driver y nombre JNDI para la base de datos que queremos
utilizar

Hay un problema al hacer esto…. y es que las consultas SQL que genera el
CMP entity Bean, tienen dobles comillas.

Esto hace que falle…. el truco esta en cambiar la configuración de MySql
añadiendo un parámetro sql_mode=ansi

Dependiendo del sistema, se hace de un modo y otro. Nosotros como tenemos
instalado MySql como un servicio en Windows, vamos a cambiar el fichero de
configuración .

Ojo con ponerlo donde esta especificado y no meter espacios entre medias (en
el fichero My.ini)

#This File was made using the WinMySQLAdmin 1.4 Tool
#03/06/2003 11:33:57

#Uncomment or Add only the keys that you know how works.
#Read the MySQL Manual for instructions

<font color="#008000">[mysqld]</font>
<b><font color="#800000">sql_mode=ansi</font></b>
basedir=C:/mysql
#bind-address=10.43.20.18
datadir=C:/mysql/data
#language=C:/mysql/share/your language directory
#slow query log#=
#tmpdir#=
#port=3306
#set-variable=key_buffer=16M
[WinMySQLadmin]
Server=C:/mysql/bin/mysqld-nt.exe
user=rcanales

#This File was made using the WinMySQLAdmin 1.4 Tool

#03/06/2003 11:33:57

#Uncomment or Add only the keys that you know how works.

#Read the MySQL Manual for instructions

[mysqld]

sql_mode=ansi

basedir=C:/mysql

#bind-address=10.43.20.18

datadir=C:/mysql/data

#language=C:/mysql/share/your language directory

#slow query log#=

#tmpdir#=

#port=3306

#set-variable=key_buffer=16M

[WinMySQLadmin]

Server=C:/mysql/bin/mysqld-nt.exe

user=rcanales

Para que J2EE RI encuentre el driver JDBC de MySQL, hay que descargarselo de
internet … (podeis ver el tutorial dedicado a su instalación yprueba) y
modificar el fichero userconfig.bat

Debemos añadir el trayecto donde lo hemos instalado

REM
REM Copyright 2002 Sun Microsystems, Inc. All rights reserved.
REM SUN PROPRIETARY/CONFIDENTIAL. Use is subject to license terms.
REM

rem J2EE_CLASSPATH is appended to the classpath referenced by the EJB server.
rem J2EE_CLASSPATH must include the location of the JDBC driver classes
rem (except for the Cloudscape driver shipped with this release).
rem Each directory is delimited by a semicolon.
rem
<font color="#800000"><b>set J2EE_CLASSPATH=C:\java\mysql-connector-java-3.0.7-stable\mysql-connector-java-3.0.7-stable-bin.jar</b></font>
rem
rem JAVA_HOME refers to the directory where the Java(tm) 2 SDK
rem Standard Edition software is installed.
rem
rem set JAVA_HOME=
rem

REM

REM SUN PROPRIETARY/CONFIDENTIAL. Use is subject to license terms.

REM

rem J2EE_CLASSPATH is appended to the classpath referenced by the EJB server.

rem J2EE_CLASSPATH must include the location of the JDBC driver classes

rem (except for the Cloudscape driver shipped with this release).

rem Each directory is delimited by a semicolon.

rem

set J2EE_CLASSPATH=C:\java\mysql-connector-java-3.0.7-stable\mysql-connector-java-3.0.7-stable-bin.jar

rem

rem JAVA_HOME refers to the directory where the Java(tm) 2 SDK

rem Standard Edition software is installed.

rem

rem set JAVA_HOME=

rem

Si ahora ejecutamos un código para probar nuestro EJB CMP…. hemos
cambiado en EJB de sesión …..

     public boolean insertaNuevaFactura(Factura pFactura)
    {

        depura("Comenzamos la insercion de elementos CMP");

        try
        {
            Context contexto = new InitialContext();
            depura("Hemos creado el contexto y vamos a buscar objeto CMP");

            <b><font color="#800000">iFacturaItemHomeCMP</font></b> miHome = null;

            Object objetoGenerico = contexto.lookup("<font color="#008000">java:comp/env/ejb/entidadfacturacmp</font>");

            depura("La clase original es " + objetoGenerico.getClass().getName());
            miHome = (iFacturaItemHomeCMP) PortableRemoteObject.narrow(objetoGenerico,iFacturaItemHomeCMP.class);

            <font color="#800000"><b>iFacturaItemCMP</b></font> miFactura = miHome.<font color="#008000"><b>create</b></font>( pFactura);

            miFactura = miHome.findByPrimaryKey("22");
            depura("Vemos si se recupera " + miFactura.getId());

            depura("La operacion ha finalizado");
        }
        catch(Exception e)
        {
            depura("Error al probar ejb de entidad: " + e.getMessage());
        }

        return true;
    }

public boolean insertaNuevaFactura(Factura pFactura)

{

depura("Comenzamos la insercion de elementos CMP");

try

{

Context contexto = new InitialContext();

depura("Hemos creado el contexto y vamos a buscar objeto CMP");

iFacturaItemHomeCMP miHome = null;

Object objetoGenerico = contexto.lookup("java:comp/env/ejb/entidadfacturacmp");

depura("La clase original es " + objetoGenerico.getClass().getName());

miHome = (iFacturaItemHomeCMP) PortableRemoteObject.narrow(objetoGenerico,iFacturaItemHomeCMP.class);

iFacturaItemCMP miFactura = miHome.create( pFactura);

miFactura = miHome.findByPrimaryKey("22");

depura("Vemos si se recupera " + miFactura.getId());

depura("La operacion ha finalizado");

}

catch(Exception e)

{

depura("Error al probar ejb de entidad: " + e.getMessage());

}

return true;

}

Y tambien un servlet

            contexto = getInitialContext();
            Object objetoGenerico = contexto.lookup("java:comp/env/ejb/gestorfacturas");
            miHome = (iFacturasHome)PortableRemoteObject.narrow(objetoGenerico,iFacturasHome.class);

            iFacturas ejbGestorFacturas = miHome.create();
            depura(out,"Número de facturas en BBDD = " + ejbGestorFacturas.recuperaNumeroFacturas());

            depura(out,"Vamos a insertar un nuevo elemento con EJB CMP");
            ejbGestorFacturas.insertaNuevaFactura(new Factura("73","AdictosAlTrabajo","Consultoria Tecnologica","54332112s", "Calle del Olivo", "28/10/2003", 5644.21));
            ejbGestorFacturas.insertaNuevaFactura(new Factura("22","AdictosAlTrabajo2","Consultoria Tecnologica2","54332112s2", "Calle del Olivo2", "28/12/2003", 5543.21));
            depura(out,"La operacion se ejecuto satisfactoriamente");

contexto = getInitialContext();

Object objetoGenerico = contexto.lookup("java:comp/env/ejb/gestorfacturas");

miHome = (iFacturasHome)PortableRemoteObject.narrow(objetoGenerico,iFacturasHome.class);

iFacturas ejbGestorFacturas = miHome.create();

depura(out,"Número de facturas en BBDD = " + ejbGestorFacturas.recuperaNumeroFacturas());

depura(out,"Vamos a insertar un nuevo elemento con EJB CMP");

ejbGestorFacturas.insertaNuevaFactura(new Factura("73","AdictosAlTrabajo","Consultoria Tecnologica","54332112s", "Calle del Olivo", "28/10/2003", 5644.21));

ejbGestorFacturas.insertaNuevaFactura(new Factura("22","AdictosAlTrabajo2","Consultoria Tecnologica2","54332112s2", "Calle del Olivo2", "28/12/2003", 5543.21));

depura(out,"La operacion se ejecuto satisfactoriamente");