Pruebas de transacción distribuida JTA XA con JPA / Hibernación / MySQL

Question

Mi objetivo es tener una solución independiente para construir pruebas de JUnit para transacciones locales y distribuidas utilizando JPA sobre Hibernate sobre MySQL.

Hasta ahora, he podido usar un XadataSource para acceder a Xaresource y administrar la transacción distribuida después del protocolo de confirmación de 2 fases. Sin embargo, tengo que emitir declaraciones SQL directamente.

He estado tratando de hacer lo mismo, pero usando la persistencia de JPA 2.0. Estoy usando Simple-JNDI para tener una implementación de JNDI en memoria.

Sin embargo, sigo recibiendo nullpointerException cada vez que Hibernate intenta acceder a la transacción.

¿Algunas ideas? ¿Qué falta en mi configuración?

Esto es lo que me gustaría hacer:

    // Create the XA datasource instance directly
    MysqlXADataSource mysqlDS = new MysqlXADataSource();
    mysqlDS.setServerName("localhost");
    mysqlDS.setDatabaseName("test");
    mysqlDS.setUser("root");
    mysqlDS.setPassword("rootroot");

    // setup local JNDI
    final XADataSource xaDataSource = (XADataSource) mysqlDS;

    InitialContext ctx = new InitialContext(  );
    ctx.bind("java:/ExampleDS", xaDataSource);

    {
        System.out.println("Lookup...");
        Object o = ctx.lookup("java:/ExampleDS");
        System.out.println("Test lookup: " + o);
    }

    // XID - transaction ID

    // global transaction identifier
    // -      --          --
    byte[] gtrid = new byte[] { 0x44, 0x11, 0x55, 0x66 };

    // branch qualifier
    // -      ----
    byte[] bqual = new byte[] { 0x00, 0x22, 0x00 };

    // combination of gtrid and bqual must be unique

    Xid xid1 = new com.mysql.jdbc.jdbc2.optional.MysqlXid(gtrid, bqual, 0);
        // byte[] gtrid, byte[] bqual, int formatId


    // before transaction
    {
        XADataSource xaDS = (XADataSource) ctx.lookup("java:/ExampleDS");

        XAConnection xaconn = xaDS.getXAConnection();
        Connection conn = xaconn.getConnection();
        XAResource xares = xaconn.getXAResource();

        /* the transaction begins */
        System.out.println("Start transaction");
        xares.start(xid1, TMNOFLAGS);
    }


    // JPA code

    EntityManagerFactory emf;
    emf = Persistence.createEntityManagerFactory("MyPersistenceUnit"); // defined in persistence.xml
    EntityManager em = emf.createEntityManager();

    // System.out.println("begin");
    // em.getTransaction().begin();

    System.out.println("new ContactBook");
    ContactBook contactBook = new ContactBook("Alice");

    System.out.println("addContacts");
    contactBook.addContact("Alice", 100100100);
    contactBook.addContact("Bob", 200200200);
    contactBook.addContact("Charlie", 300300300);

    System.out.println("persist");
    em.persist(contactBook);
    //em.flush();

    // System.out.println("commit");
    // em.getTransaction().commit();


    // after transaction
    {
        XADataSource xaDS = (XADataSource) ctx.lookup("java:/ExampleDS");
        System.out.println("xaDS " + xaDS);

        XAConnection xaconn = xaDS.getXAConnection();
        Connection conn = xaconn.getConnection();
        XAResource xares = xaconn.getXAResource();

        System.out.println("End transaction");
        xares.end(xid1, TMSUCCESS);

        // prepare, commit

        System.out.print("Prepare... ");
        int rc1 = xares.prepare(xid1);
        System.out.println(xaString(rc1));

        if (rc1 == XA_OK) {
            System.out.println("Commit");
            xares.commit(xid1, /*onePhase*/ false);
        } else if(rc1 == XA_RDONLY) {
            System.out.println("Commit no necessary - operations were read only");
        } else {
            throw new IllegalStateException("Unexpected case!");
        }
    }

Aquí está persistencia.xml:

<persistence 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_2_0.xsd"
version="2.0">
<persistence-unit name="ContactBookPersistenceUnit" transaction-type="JTA">
    <provider>org.hibernate.ejb.HibernatePersistence</provider>
    <jta-data-source>java:/ExampleDS</jta-data-source>
    <properties>
        <property name="hibernate.dialect" value="org.hibernate.dialect.MySQLDialect" />
        <property name="hibernate.hbm2ddl.auto" value="create" />
        <property name="hibernate.show_sql" value="true" />

        <property name="hibernate.transaction.manager_lookup_class" value="org.hibernate.transaction.JBossTransactionManagerLookup"/>

        <property name="current_session_context_class" value="jta"/>
        <!-- <property name="hibernate.session_factory_name" value="java:/hibernate/MySessionFactory"/> optional -->

        <property name="hibernate.transaction.factory_class" value="org.hibernate.transaction.JTATransactionFactory"/>
        <property name="hibernate.connection.release_mode" value="auto"/>
        <!-- setting above is important using XA-DataSource on SQLServer,
            otherwise SQLServerException: The function START: has failed. No transaction cookie was returned.-->

        <!--property name="hibernate.cache.use_second_level_cache" value="true"/-->
        <!--property name="hibernate.cache.use_query_cache" value="true"/-->

        <!-- property name="hibernate.cache.region.factory_class"   value="org.hibernate.cache.infinispan.InfinispanRegionFactory"/-->
    </properties>
</persistence-unit>

Answer 1

Creo que no puede usar las transacciones de JTA cuando esté fuera de un contenedor Java EE (o al menos no haya una manera fácil de hacer esto).

Usa Recursos-Local

No hay nada que requiera JTA en su ejemplo: solo está buscando una fuente de datos en un entorno Java SE. Creo que declara su fuente de datos XA como de recursos locales Resolvería tu problema. Pon esto en tu persistence.xml:

<persistence-unit name="ContactBookPersistenceUnit" transaction-type="RESOURCE-LOCAL">
    [...]
    <non-jta-data-source>java:/ExampleDS</jta-data-source>

No he probado este código directamente, pero he usado un enfoque similar en aplicaciones web escritas para el servidor Apache Tomcat.

Ver también: Tipos de entidades

Use un contenedor incrustado

Otra opción que puede investigar implica comenzar un contenedor de Java EE incrustado en pruebas de Junit. Aquí hay un par de punteros, con ejemplos para GlassFish 3:

• Embedidando glassfish v3 en la prueba de unidad
• Pez glaseado incrustado