JTAトランザクションイベントをインターセプトして、トランザクションに関連付けられている現在のEntityManagerへの参照を取得するにはどうすればよいですか。

これは私自身がこの投稿ですぐに答えましたが、これを克服するために2週間以上かけてさまざまな戦略を試したという事実を隠しました。それで、これが私たちが使用することに決めた最終的な実装です。

基本的な考え方： javax.persistence.spi.PersistenceProviderの独自の実装を作成します Hibernateによって提供されたものを拡張することによって。すべての効果について、これは、コードがHibernateまたはその他のベンダー固有の実装に関連付けられる唯一のポイントです。

public class MyHibernatePersistenceProvider extends org.hibernate.jpa.HibernatePersistenceProvider {

    @Override
    public EntityManagerFactory createContainerEntityManagerFactory(PersistenceUnitInfo info, Map properties) {
        return new EntityManagerFactoryWrapper(super.createContainerEntityManagerFactory(info, properties));
    }

}

アイデアは、hibernateのバージョンの EntityManagerFactoryをラップすることです。 およびEntityManager あなた自身の実装で。したがって、これらのインターフェースを実装するクラスを作成し、ベンダー固有の実装を内部に保持する必要があります。

これはEntityManagerFactoryWrapperです

public class EntityManagerFactoryWrapper implements EntityManagerFactory {

    private EntityManagerFactory emf;

    public EntityManagerFactoryWrapper(EntityManagerFactory originalEMF) {
        emf = originalEMF;
    }

    public EntityManager createEntityManager() {
        return new EntityManagerWrapper(emf.createEntityManager());
    }

    // Implement all other methods for the interface
    // providing a callback to the original emf.

EntityManagerWrapperはインターセプトポイントです。インターフェイスからすべてのメソッドを実装する必要があります。エンティティを変更できるすべてのメソッドには、データベースにローカル変数を設定するためのカスタムクエリの呼び出しが含まれています。

public class EntityManagerWrapper implements EntityManager {

    private EntityManager em;
    private Principal principal;

    public EntityManagerWrapper(EntityManager originalEM) {
        em = originalEM;
    }

    public void setAuditVariables() {
        String userid = getUserId();
        String ipaddr = getUserAddr();
        String sql = "SET LOCAL application.userid='"+userid+"'; SET LOCAL application.ipaddr='"+ipaddr+"'";
        em.createNativeQuery(sql).executeUpdate();
    }

    protected String getUserAddr() {
        HttpServletRequest httprequest = CDIBeanUtils.getBean(HttpServletRequest.class);
        String ipaddr = "";
        if ( httprequest != null ) {
            ipaddr = httprequest.getRemoteAddr();
        }
        return ipaddr;
    }

    protected String getUserId() {
        String userid = "";
        // Try to look up a contextual reference
        if ( principal == null ) {
            principal = CDIBeanUtils.getBean(Principal.class);
        }

        // Try to assert it from CAS authentication
        if (principal == null || "anonymous".equalsIgnoreCase(principal.getName())) {
            if (AssertionHolder.getAssertion() != null) {
                principal = AssertionHolder.getAssertion().getPrincipal();
            }
        }
        if ( principal != null ) {
            userid = principal.getName();
        }
        return userid;
    }

    @Override
    public void persist(Object entity) {
        if ( em.isJoinedToTransaction() ) {
            setAuditVariables();
        }
        em.persist(entity);
    }

    @Override
    public <T> T merge(T entity) {
        if ( em.isJoinedToTransaction() ) {
            setAuditVariables();
        }
        return em.merge(entity);
    }

    @Override
    public void remove(Object entity) {
        if ( em.isJoinedToTransaction() ) {
            setAuditVariables();
        }
        em.remove(entity);
    }

    // Keep implementing all methods that can change
    // entities so you can setAuditVariables() before
    // the changes are applied.
    @Override
    public void createNamedQuery(.....

欠点： インターセプトクエリ（SET LOCAL）は、特に1回のサービス呼び出しで複数のステートメントが作成された場合に、1回のトランザクション内で数回実行される可能性があります。状況を考慮して、PostgreSQLへのメモリ内の単純なSET LOCAL呼び出しであるため、この方法を維持することにしました。関係するテーブルがないので、パフォーマンスのヒットに耐えることができます。

ここで、persistence.xml内のHibernateの永続性プロバイダーを置き換えるだけです。 ：

<?xml version="1.0" encoding="UTF-8"?>
<persistence xmlns="http://xmlns.jcp.org/xml/ns/persistence"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence http://xmlns.jcp.org/xml/ns/persistence/persistence_2_1.xsd"
             version="2.1">
<persistence-unit name="petstore" transaction-type="JTA">
        <provider>my.package.HibernatePersistenceProvider</provider>
        <jta-data-source>java:app/jdbc/exemplo</jta-data-source>
        <properties>
            <property name="hibernate.transaction.jta.platform" value="org.hibernate.service.jta.platform.internal.SunOneJtaPlatform" />
            <property name="hibernate.dialect" value="org.hibernate.dialect.PostgreSQLDialect"/>
        </properties>
</persistence-unit>

ちなみに、これは特別な機会にBeanマネージャーを支援する必要があるCDIBeanUtilsです。この場合、これを使用してHttpServletRequestとPrincipalへの参照を検索しています。

public class CDIBeanUtils {

    public static <T> T getBean(Class<T> beanClass) {

        BeanManager bm = CDI.current().getBeanManager();

        Iterator<Bean<?>> ite = bm.getBeans(beanClass).iterator();
        if (!ite.hasNext()) {
            return null;
        }
        final Bean<T> bean = (Bean<T>) ite.next();
        final CreationalContext<T> ctx = bm.createCreationalContext(bean);
        final T t = (T) bm.getReference(bean, beanClass, ctx);
        return t;
    }

}

公平を期すために、これはトランザクションイベントを正確に傍受しているわけではありません。ただし、必要なカスタムクエリをトランザクション内に含めることができます。

うまくいけば、これは他の人が私たちが経験した痛みを避けるのに役立つでしょう。