2

私の目標は、JPA over Hibernate over MySQLを使用して、ローカルトランザクションと分散トランザクションのJUnitテストを構築するためのスタンドアロンソリューションを用意することです。

これまでのところ、XADataSourceを使用してXAResourceにアクセスし、2フェーズコミットプロトコルに従って分散トランザクションを管理することができました。ただし、SQLステートメントを直接発行する必要があります。

私は同じことをしようとしていますが、JPA2.0の永続性を使用しています。simple-jndiを使用して、メモリ内にJNDIを実装しています。

ただし、HibernateがTransactionManagerにアクセスしようとするたびにNullPointerExceptionが発生し続けます。

何か案は？構成に何が欠けていますか？

これが私がやりたいことです：

    // 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!");
        }
    }

これがpersistence.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>

4

1 に答える 1

3

Java EEコンテナの外部にいるときはJTAトランザクションを使用できないと思います（または少なくともこれを行う簡単な方法はありません）。

RESOURCE-LOCALを使用する

この例では、JTAを必要とするものは何もありません。JavaSE環境でデータソースを検索しているだけです。XAデータソースをリソースローカルとして宣言すると、問題が解決すると思います。これをあなたの中に入れてくださいpersistence.xml：

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

このコードを直接テストしたことはありませんが、ApacheTomcatサーバー用に作成されたWebアプリケーションで同様のアプローチを使用しました。

参照：EntityManagerのタイプ

埋め込みコンテナを使用する

調査する可能性のある別のオプションには、JUnitテストで組み込みJavaEEコンテナーを開始することが含まれます。ここに、Glassfish3の例を含むいくつかのポインタがあります。

于 2013-08-02T16:29:45.680 に答える