camel jpa コンポーネントを使用してデータベースにエンティティを書き込もうとしています。問題は私が得ることです
javax.persistence.TransactionRequiredException: no transaction is in progress
at org.hibernate.internal.SessionImpl.checkTransactionNeeded(SessionImpl.java:3428)
at org.hibernate.internal.SessionImpl.doFlush(SessionImpl.java:1395)
at org.hibernate.internal.SessionImpl.flush(SessionImpl.java:1391)
at org.apache.camel.component.jpa.JpaProducer$1.doInTransaction(JpaProducer.java:85)
永続ユニットが解析され、テーブルが作成されます。ここに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="pu" transaction-type="RESOURCE_LOCAL">
<provider>org.hibernate.jpa.HibernatePersistenceProvider</provider>
<properties>
<property name="hibernate.archive.autodetection" value="class" />
<property name="hibernate.dialect" value="org.hibernate.dialect.Oracle10gDialect" />
<property name="hibernate.connection.driver_class" value="oracle.jdbc.driver.OracleDriver" />
<property name="hibernate.connection.url" value="jdbc:oracle:thin:@localhost:1521:xe" />
<property name="hibernate.connection.username" value="user" />
<property name="hibernate.connection.password" value="pass" />
<property name="hibernate.hbm2ddl.auto" value="update" />
</properties>
</persistence-unit>
</persistence>
1 つのエンティティを作成するテストを作成しました。
/**
* Created by moritz on 16.09.2016.
*/
public class JpaTest extends CamelTestSupport {
@EndpointInject(uri = "mock:out")
protected MockEndpoint out;
@EndpointInject(uri = "direct:in")
protected DirectEndpoint in;
@EndpointInject()
@Test
public void writeSome() throws Exception {
PartnerFactaEntity e = new PartnerFactaEntity();
e.setNameIrs("huhu");
e.setPartnerId("1");
e.setUsDokumentGueltigBis(new Date());
e.setUsDokumentGueltigVon(new Date());
context.start();
ProducerTemplate template = context.createProducerTemplate();
template.sendBody(in, e);
}
@Before
public void setup() throws Exception {
EntityManagerFactory emf = Persistence.createEntityManagerFactory("pu");
// ( (JndiRegistry) context.getRegistry() ).bind(
// "EntityManagerFactory", emf );
// ( (JndiRegistry) context.getRegistry() ).bind( "TransactionManager",
// new JpaTransactionManager() );
JpaComponent jpaComponent = context.getComponent("jpa", JpaComponent.class);
jpaComponent.setEntityManagerFactory(emf);
JpaTransactionManager taM = new JpaTransactionManager();
taM.setEntityManagerFactory( emf );
jpaComponent.setTransactionManager( taM );
context.addRoutes(new TestRoute());
}
@Override
public boolean isUseRouteBuilder() {
return false;
}
private class TestRoute extends RouteBuilder {
@Override
public void configure() throws Exception {
from(in).to("jpa:PartnerFactaEntity").to(out);
}
}
}
キャメルセマンティックでトランザクションを開始および終了する実際の方法がないため、問題はセットアップに関連していると思いますか?
では、これを修正する方法は？
編集
私はクラウスのアドバイスに従い.transacted()、ルートに追加しました。これによりNo bean could be found in the registry of type: PlatformTransactionManager
、次の行がセットアップメソッドに追加されました。
((JndiRegistry)( (PropertyPlaceholderDelegateRegistry) context.getRegistry()).getRegistry()).bind( "PlatformTransactionManager", taM );
そして、これもまた得られjavax.persistence.TransactionRequiredException: no transaction is in progressます。
JpaComponent で何を構成し、レジストリに何をバインドするかがわかりません。
その間、私は少しデバッグしました。例外をスローしているJpaProducer のフィールドを確認しましたentityManager.flush(): trasactionTemplate は正しい JpaTransactionManager で "PRPAGATION_REQUIRED,ISOLATION_DEFAULT" に設定されています。