Dlaczego różne jednostki trwałości z oddzielonymi źródłami danych wysyłają zapytanie do tego samego źródła danych?
Opracowuję aplikację internetową, która wymaga dostępu do dwóch różnych serwerów baz danych (H2 i Oracle). Kontener jestApache Tomee 1.5.1 i używam stosu Java EE z bibliotekami w nim zawartymi (JSF, JPA, CDI, EJB itp.).
Próbuję użyć dwóch menedżerów encji wewnątrz transakcji XA, aby wyodrębnić dane z bazy danych Oracle i utrzymać ją w H2 po jej transformacji, ALE wszystkie zapytania są wykonywane na bazie danych H2 bez względu na używanego menedżera encji. Jakaś pomoc?
EDYTOWAĆ: Odkryłem, że jeśli próbuję uzyskać dostęp do menedżerów encji w odwrotnej kolejności, ich zachowanie jest takie samo, ale dostęp do Oracle. To znaczy: menedżerowie jednostek pozostają przy pierwszej dostępnej bazie danych.
EJB, gdzie to się dzieje (dzwonienieservice.getFoo()
z JSF):
@Named
@Stateless
public class Service {
@Inject
@OracleDatabase
private EntityManager emOracle;
@Inject
@H2Database
private EntityManager emH2;
@TransactionAttribute(TransactionAttributeType.REQUIRED)
public List<Foo> getFoo() {
TypedQuery<Foo> q = emH2.createQuery(
"SELECT x FROM Foo f", Foo.class);
List<Foo> l = q.getResultList();
if (l == null || l.isEmpty()) {
update();
}
return q.getResultList();
}
@TransactionAttribute(TransactionAttributeType.REQUIRED)
public void update() {
// FAIL: This query executes against H2 with Oracle entity manager!
List<Object[]> l = emOracle.createNativeQuery("SELECT * FROM bar ").getResultList();
//more stuff...
}
}
Producent zasobów (CDI) dla menedżerów encji (gdzie są @ H2Database i @OracleDatabasekwalifikatorzy):
public class Resources {
@Produces
@PersistenceContext(unitName = "OraclePU")
@OracleDatabase
private EntityManager emOracle;
@Produces
@PersistenceContext(unitName = "H2PU")
@H2Database
private EntityManager emH2;
}
Mójperistence.xml wygląda tak:
<?xml version="1.0" encoding="UTF-8"?>
<persistence version="2.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_2_0.xsd">
<persistence-unit name="H2PU"
transaction-type="JTA">
<provider>org.apache.openjpa.persistence.PersistenceProviderImpl</provider>
<jta-data-source>H2DS</jta-data-source>
<class>my.app.h2.Foo</class>
<exclude-unlisted-classes>true</exclude-unlisted-classes>
</persistence-unit>
<persistence-unit name="OraclePU" transaction-type="JTA">
<provider>org.apache.openjpa.persistence.PersistenceProviderImpl</provider>
<jta-data-source>OracleDS</jta-data-source>
<class>my.app.oracle.Bar</class>
<exclude-unlisted-classes>true</exclude-unlisted-classes>
</persistence-unit>
</persistence>
I wreszcie źródła danych w środkutomee.xml (w tym pliku nie ma żadnych innych źródeł danych):
<Resource id="OracleDS" type="javax.sql.DataSource">
jdbcDriver = oracle.jdbc.xa.client.OracleXADataSource
jdbcUrl = jdbc:oracle:thin:@server:port:instance
jtaManaged = true
password = abcde
userName = user
</Resource>
<Resource id="H2DS" type="javax.sql.DataSource">
jdbcDriver=org.h2.jdbcx.JdbcDataSource
jdbcUrl=jdbc:h2:h2/db;AUTO_SERVER=TRUE
jtaManaged = true
password = edcba
userName = user
</Resource>