LocalContainerEntityManagerFactoryBean的EntityManager不會將實體持久存儲到數據庫中

Question

問題是，在Spring託管bean中注入@PersistenceContext的EntityManager不會將實體持久存儲到數據庫。我嘗試在AddDao bean上使用@Transactional，其中entityManager.persist()被調用（我啓用了註釋驅動事務）。

事務從Camel Java DSL中的.transacted()實例化的另一個bean開始。該豆有一個@Autowired財產，這是DAO和EntityManager注入@PersistenceContext。

使用事務管理器Bitronix。

的Spring XML配置文件的一部分是這樣的：

<bean id="localContainerEntityManagerFactoryBean" depends-on="btmConfig" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"> 
    <property name="jtaDataSource" ref="dataSource"/> 
    <property name="persistenceUnitName" value="nameFromPersistenceXml"/> 
    <property name="persistenceProvider"> 
     <bean class="org.hibernate.ejb.HibernatePersistence"/> 
    </property> 
    <property name="jpaVendorAdapter"> 
     <bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter"/> 
    </property> 
    <property name="jpaDialect"> 
     <bean class="org.springframework.orm.jpa.vendor.HibernateJpaDialect"/> 
    </property> 
    <property name="packagesToScan" value="package with @Entity POJOs"/> 

    </bean> 



    <bean id="btmConfig" factory-method="getConfiguration" 
     class="bitronix.tm.TransactionManagerServices"> 
    <property name="serverId" value="spring-btm" /> 
    </bean> 

    <!-- create BTM transaction manager --> 
    <bean id="BitronixTransactionManager" factory-method="getTransactionManager" 
     class="bitronix.tm.TransactionManagerServices" depends-on="btmConfig" 
     destroy-method="shutdown" /> 
    <!-- Spring JtaTransactionManager --> 
    <bean id="springTransactionManager" 
     class="org.springframework.transaction.jta.JtaTransactionManager"> 
    <property name="transactionManager" ref="BitronixTransactionManager" /> 
    <property name="userTransaction" ref="BitronixTransactionManager" /> 
    </bean> 

    <tx:annotation-driven transaction-manager="springTransactionManager" /> 

編輯：在一個過分簡化的版本，它看起來是這樣的：

在駱駝的Java DSL有

from("wsLayer") 
    .transacted() 
    .otherProcessing() 
    .to("bean:addBean?method=addMyEntity") 

加豆看起來像這樣：

@Component 
public class AddBean { 
    @Autowired 
    private AddDao addDao; 

    public void addMyEntity(MyEntity myEntity) { 
     //other business logic 
     addDao.persistMyEntity(myEntity); 
    } 
} 

@Component 
public class AddDao { 
    @PersistenceContext 
    private EntityManager entityManager; 

    //I have tried here 
    //@Transactional and 
    //@Transactional(propagation = PropagationType.REQUIRES_NEW) 
    public void persistMyEntity(MyEntity myEntity) { 
     entityManager.persist(myEntity); 
    } 
} 

從數據庫讀取效果很好。

查看資料來源：

<bean id="dataSource" class="bitronix.tm.resource.jdbc.PoolingDataSource" 
    init-method="init" destroy-method="close"> 
    <property name="uniqueName" value="theName" /> 
    <property name="maxPoolSize" ><value>${db.pool.maxSize}</value></property> 
    <property name="minPoolSize" ><value>${db.pool.minSize}</value></property>  
    <property name="allowLocalTransactions" ><value>true</value></property> 
    <property name="automaticEnlistingEnabled" ><value>true</value></property> 
    <property name="className" ><value>${db.pool.datasource}</value></property> 
    <property name="driverProperties" ref="databaseProperties" /> 
</bean> 

，其中屬性在Maven的pom.xml這樣設置：

db.pool.maxSize=15 
db.pool.maxSize=5 
db.pool.datasource=org.postgresql.xa.PGXADataSource 

Answer 1

你有沒有試圖執行em.persist後em.flush（）（實體）？ 根據Java EE文檔：

em.persist（entity）：使一個實例管理並持久化。 但是 em.flush（實體）：將持久性上下文同步到底層數據庫。

所以，你可以這樣做：

em.persist(myEntity); 
em.flush(); 

，並檢查是否這種變化有所作爲。

Answer 2

從有限的症狀給出，似乎JTA事務沒有被啓動和傳播。你的EM可以正常工作 - 從數據庫中讀取數據，允許數據改變它的持久性上下文緩存，但不會寫入數據庫。

認爲這是一個配置問題，您的@Transaction註釋被忽略。

我已啓用註釋驅動的事務。

確保它的配置爲您的Spring配置如下：

<tx:annotation-driven transaction-manager="springTransactionManager"/> 

其中：

xmlns:tx="http://www.springframework.org/schema/tx" 

Answer 3

所以，用apache camel jpa文件根據，你必須把它描述的URI你的方法的行爲，它描述了一個選項「flushOnSend」，也許你必須添加該URI。 Here它描述了一個Hibernate的例子。 而​​一類，它是一個測試，也許你可以使用它，請檢查您是否未能通過任何;-)

Answer 4

嘗試@Transactional這樣

@Component 
public class AddDao { 
    @PersistenceContext 
    private EntityManager entityManager; 

    @Transactional("BitronixTransactionManager") 
    public void persistMyEntity(MyEntity myEntity) { 
     entityManager.persist(myEntity); 
    } 
}