Почему разные персистентные единицы с раздельными источниками данных запрашивают один и тот же источник данных?
Я разрабатываю веб-приложение, которому нужен доступ к двум различным серверам баз данных (H2 и Oracle). Контейнер являетсяApache Tomee 1.5.1 и я использую стек Java EE с библиотеками (JSF, JPA, CDI, EJB и т. д.).
Я пытаюсь использовать два менеджера сущностей внутри транзакции XA для извлечения данных из базы данных Oracle и сохранения их в H2 после преобразования, НО все запросы выполняются к базе данных H2 независимо от того, какой менеджер сущностей я использую. Любая помощь?
РЕДАКТИРОВАТЬЯ обнаружил, что если я пытаюсь получить доступ к менеджерам сущностей в обратном порядке, они ведут себя одинаково, но получают доступ к Oracle. Т.е.: менеджеры сущностей остаются с первой доступной базой данных.
EJB, где это происходит (вызовservice.getFoo()
от 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...
}
}
Источник ресурсов (CDI) для менеджеров сущностей (где @ H2Database и @OracleDatabase:классификаторы):
public class Resources {
@Produces
@PersistenceContext(unitName = "OraclePU")
@OracleDatabase
private EntityManager emOracle;
@Produces
@PersistenceContext(unitName = "H2PU")
@H2Database
private EntityManager emH2;
}
мойperistence.xml выглядит так:
<?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>
И, наконец, источники данных внутриtomee.xml (внутри этого файла нет других источников данных):
<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>