1

尝试将 Spring、Hibernate-OGM 与 MongoDB 一起使用。但是遇到交易问题。我知道 MongoDB 不支持它们，但是我想使用注释 @transactional 所以我不必开始，提交。

例外

org.springframework.transaction.CannotCreateTransactionException: Could not open JPA EntityManager for transaction; nested exception is java.lang.IllegalStateException: A JTA EntityManager cannot use getTransaction()
at org.springframework.orm.jpa.JpaTransactionManager.doBegin(JpaTransactionManager.java:430)
at org.springframework.transaction.support.AbstractPlatformTransactionManager.getTransaction(AbstractPlatformTransactionManager.java:373)
at org.springframework.transaction.interceptor.TransactionAspectSupport.createTransactionIfNecessary(TransactionAspectSupport.java:420)
at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:257)
at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:95)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:644)

数据库上下文.xml

    <bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalEntityManagerFactoryBean">
    <property name="persistenceUnitName" value="mongo-hibernate"/>    
  </bean>

  <bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">
    <property name="entityManagerFactory" ref="entityManagerFactory"/>
  </bean>

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

持久性.xml

<persistence-unit name="mongo-hibernate" transaction-type="JTA">
        <provider>org.hibernate.ogm.jpa.HibernateOgmPersistence</provider>

        <properties>
           <property name="hibernate.current_session_context_class" value="thread"/>                        
           <property name="hibernate.ogm.datastore.provider" value="mongodb"/>
           <property name="hibernate.ogm.datastore.grid_dialect" value="org.hibernate.ogm.datastore.mongodb.MongoDBDialect"/>           
           <property name="hibernate.transaction.factory_class" value="org.hibernate.transaction.JTATransactionFactory"/>                
            <property name="hibernate.ogm.datastore.database" value="mongodbtest"/>
            <property name="hibernate.ogm.mongodb.database" value="mongodbtest"/>
            <property name="hibernate.ogm.mongodb.host" value="localhost"/>
            <property name="hibernate.ogm.mongodb.associations.store" value="IN_ENTITY"/>
        </properties>

    </persistence-unit>
</persistence>

道

@PersistenceContext
protected EntityManager entityManager;

@Transactional(readOnly = false)
public <E> void updateObject(E entity) {
   entityManager.persist(entity);
 }

任何帮助表示赞赏。谢谢

4

2 回答 2

1

So far I moved a little further, I changed some files to:

DB context.xml

   <bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalEntityManagerFactoryBean">
    <property name="persistenceUnitName" value="mongo-hibernate"/>    
  </bean>

  <bean class="com.arjuna.ats.jta.TransactionManager" factory-method="transactionManager" id="arjunaTransactionManager"/>
  <bean class="com.arjuna.ats.jta.UserTransaction" factory-method="userTransaction" id="arjunaUserTransaction"/>  

  <bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
    <property name="transactionManager" ref="arjunaTransactionManager"/>
    <property name="userTransaction" ref="arjunaUserTransaction"/>
  </bean>

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

DAO: 

@PersistenceContext
protected EntityManager entityManager;

@Transactional(readOnly = false)
public <E> void updateObject(E entity) {

    Session session = entityManager.unwrap(Session.class);          
    org.hibernate.Transaction tx = session.getTransaction();  
    tx.begin();
    session.persist(entity);
    tx.commit();

}

This way eveything is working fine, however I would really like it to work more simplier like:

@Transactional(readOnly = false)
public <E> void updateObject(E entity) {
   entityManager.persist(entity);
 }

Any suggestions?

于 2014-08-29T20:33:19.383 回答
-2

是的，我有一个建议：阅读文档。;)

“MongoDB 不支持事务。”

于 2014-08-30T21:13:18.923 回答