使用应用程序管理持久性上下文的Spring Boot

Question

应用程序管理的持久性上下文允许我们控制如何创建EntityManager（例如，提供不同的数据源JNDI以在运行时为特定的DB创建适当的EntityManager）。

例如。

    Map properties = new HashMap();

    properties.put(PersistenceUnitProperties.TRANSACTION_TYPE, "JTA");

    //the datasource JNDI is by configuration and without prior knowledge about the number of databases
    //currently, DB JNDI are stored in a externalized file
    //the datasource is setup by operation team
    properties.put(PersistenceUnitProperties.JTA_DATASOURCE, "datasource-jndi");

    properties.put(PersistenceUnitProperties.CACHE_SHARED_DEFAULT, "false");
    properties.put(PersistenceUnitProperties.SESSION_NAME, "xxx");

    //create the proper EntityManager for connect to database decided on runtime                

    EntityManager em = Persistence.createEntityManagerFactory("PU1", properties).createEntityManager();     

    //query or update DB
    em.persist(entity);
    em.createQuery(...).executeUpdate();

当部署在EJB容器（例如WebLogic）中，使用适当的TransactionAttribute（例如TransactionAttributeType.Required）时，容器将负责事务的开始/结束/回滚。

javax.persistence.TransactionRequiredException：“当前没有事务处于活动状态”

下面的示例代码：

    //for data persistence
    @Service
    class DynamicServiceImpl implements DynamicService {

        //attempt to start a transaction
        @Transactional(propagation = Propagation.REQUIRED)
        public void saveData(DbJndi, EntityA){

            //this return false that no transaction started
            TransactionSynchronizationManager.isActualTransactionActive();

            //create an EntityManager based on the input DbJndi to dynamically
            //determine which DB to save the data
            EntityManager em = createEm(DbJndi);

            //save the data 
            em.persist(EntityA);
        }
    }

    //restful service
    @RestController
    class RestController{

        @Autowired
        DynamicService service;

        @RequestMapping( value = "/saveRecord", method = RequestMethod.POST)
        public @ResponseBody String saveRecord(){
             //save data
             service.saveData(...)
        }
    }

    //startup application
    @SpringBootApplication
    class TestApp {

        public static void main(String[] args) {
            SpringApplication.run(TestApp.class, args);
        }
    }

    persistence.xml
    -------------------------------------------

    &ltpersistence-unit name="PU1" transaction-type="JTA">

        &ltproperties>

            <!-- comment for spring to handle transaction??? -->
            <!--property name="eclipselink.target-server" value="WebLogic_10"/ -->
        </properties>

    </persistence-unit>

    -------------------------------------------

    application.properties (just 3 lines of config)
    -------------------------------------------
    spring.jta.enabled=true 
    spring.jta.log-dir=spring-test # Transaction logs directory.
    spring.jta.transaction-manager-id=spring-test
    -------------------------------------------

我的使用模式并不遵循大多数典型的用例（例如，已知数量的DBS-Spring+JPA+多个持久性单元：注入EntityManager）。

Answer 1

您自己基本上已经回答了这个问题：“当部署在EJB容器（例如WebLogic）中，使用适当的TransactionAttribute（例如TransactionAttributeType.Required）时，容器将负责事务的开始/结束/回滚”。

WebLogic符合Java Enterprise Edition规范，这可能是它以前工作的原因，但现在您使用的是Tomcat（嵌入式模式），而不是。所以你不能做你想做的事。persistence.xml文件中的以下语句：

需要企业服务器（WebLogic,Glassfish,JBoss等）

对于Tomcat，您只能执行以下操作：

myEntityManager.getTransaction.begin();
... //Do your transaction stuff
myEntityManager.getTransaction().commit();