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); 
    } 
}