Spring + Hibernate4 + JTA + JBossTS答案

【问题标题】：Spring + Hibernate4 + JTA + JBossTSSpring + Hibernate4 + JTA + JBossTS
【发布时间】：2013-09-27 13:22:49
【问题描述】：

为了使用独立的 Java 应用程序设置 JTA，我已经苦苦挣扎了 2 天多，但不幸的是 id 不起作用，我将不胜感激。

一般信息：

春季版：3.2.3
休眠版本：4.2.3
Jbossts 版本： 4.17.7，我只将 narayana-jta.jar 添加到我的类路径中。

Spring配置文件：

<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 class="org.springframework.transaction.jta.JtaTransactionManager" id="transactionManager">
    <property name="transactionManager">
        <ref bean="arjunaTransactionManager" />
    </property>
    <property name="userTransaction">
        <ref bean="arjunaUserTransaction" />
    </property>
</bean>

<tx:annotation-driven />

休眠配置文件：

<?xml version='1.0' encoding='utf-8'?>
<!DOCTYPE hibernate-configuration PUBLIC
  "-//Hibernate/Hibernate Configuration DTD//EN"
  "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">
<hibernate-configuration>
    <session-factory>
        <!-- Database connection settings -->
        <property name="connection.driver_class">com.microsoft.sqlserver.jdbc.SQLServerDriver</property>
        <property name="connection.url">jdbc:sqlserver://localhost:1433;databaseName=TestDB</property>
        <property name="connection.username">user</property>
        <property name="connection.password">password</property>

        <!-- JDBC connection pool (use the built-in) -->
        <property name="connection.pool_size">1</property>

        <!-- SQL dialect -->
        <property name="dialect">org.hibernate.dialect.SQLServerDialect</property>

        <!-- Enable Hibernate's automatic session context management -->
        <property name="current_session_context_class">jta</property>

        <!-- Disable the second-level cache -->
        <property name="cache.provider_class">org.hibernate.cache.internal.NoCacheProvider</property>

        <!-- Echo all executed SQL to stdout -->
        <property name="show_sql">true</property>

        <property name="transaction.factory_class">org.hibernate.transaction.JTATransactionFactory</property>
        <property name="transaction.jta.platform">org.hibernate.service.jta.platform.internal.JBossStandAloneJtaPlatform</property>
    </session-factory>
</hibernate-configuration>

此时我需要创建休眠会话工厂，并且我想以编程方式创建它，为此我使用了以下代码 sn-p，其中我创建了一个 Spring LocalSessionFactoryBean 传递给它的休眠配置资源并检索使用 .getObject() 方法从中获取 SessionFactory。

这段代码正常工作并创建了一个SessionFactory对象，这个对象在下一段代码sn-p中使用。

LocalSessionFactoryBean sessionFactoryBean = new LocalSessionFactoryBean();
JtaTransactionManager trxManager = applicationContext.getBean(JtaTransactionManager.class);
sessionFactoryBean.setJtaTransactionManager(trxManager);
sessionFactoryBean.setConfigLocation(resource);
sessionFactoryBean.afterPropertiesSet();
SessionFactory sessionFactory = sessionFactoryBean.getObject();

之后，我有一个服务类可以插入到表中：

package com.core.service;

import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

@Component
@Scope("prototype")
public class TestService {

    @Transactional
    public void testTrx() throws Exception {
        SessionFactory sessionFactory = // retrieve session factory created before

        Session session = sessionFactory.getCurrentSession();
        Query query = session.createSQLQuery("insert into TABLE1 (col1, col2) values (:v1, :v2)");
        query.setParameter("v1", "value1");
        query.setParameter("v2", "value2");

        query.executeUpdate();
    }
}

最后是一个加载 Spring 上下文并初始化所有内容的 JUnit 测试，然后执行以下几行：

@Test
public void testTransactionRollback() throws Exception {
    TestService testService = applicationContext.getBean(TestService.class);
    testService.testTrx();
}

问题：当我执行 JUnit 测试时，我看到一个绿色条，我看到有一条 SQL 语句插入到表中，并且我看到一个事务已打开并提交，但是，如果我去数据库，我看不到插入的行。

我的结论：我尝试设置休眠配置 connection.autocommit=true 并且在数据库中正确创建了行，所以我假设是 JTA 事务是打开和关闭，但 Hibernate Session Factory 没有使用它们，而是使用它自己的。我是否缺少一些配置？

15:14:20.423 [main]            DEBUG o.s.b.f.s.DefaultListableBeanFactory - Finished creating instance of bean 'testService'
15:14:20.425 [main]            DEBUG o.s.b.f.s.DefaultListableBeanFactory - Returning cached instance of singleton bean 'transactionManager'
15:14:20.432 [main]            DEBUG o.s.t.jta.JtaTransactionManager - Creating new transaction with name [com.core.service.TestService.testTrx]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT; ''
15:14:20.448 [main]            INFO  com.arjuna.ats.arjuna - ARJUNA012163: Starting service com.arjuna.ats.arjuna.recovery.ActionStatusService on port 36097
15:14:20.453 [main]            INFO  com.arjuna.ats.arjuna - ARJUNA012337: TransactionStatusManagerItem host: 127.0.0.1 port: 36097
15:14:20.460 [main]            INFO  com.arjuna.ats.arjuna - ARJUNA012170: TransactionStatusManager started on port 36097 and host 127.0.0.1 with service com.arjuna.ats.arjuna.recovery.ActionStatusService
15:14:20.488 [main]            DEBUG o.s.b.f.s.DefaultListableBeanFactory - Returning cached instance of singleton bean 'sessionFactoryManagerImpl'
15:14:20.524 [main]            DEBUG o.h.e.j.i.LogicalConnectionImpl - Connection provider reports to not support aggressive release; overriding
15:14:20.533 [main]            DEBUG o.h.e.t.i.TransactionCoordinatorImpl - successfully registered Synchronization
15:14:20.565 [main]            DEBUG org.hibernate.SQL - insert into TABLE1 (col1, col2) values (?, ?)
Hibernate: insert into TABLE1 (col1, col2) values (?, ?)
15:14:20.566 [main]            DEBUG o.h.e.j.i.LogicalConnectionImpl - Obtaining JDBC connection
15:14:20.566 [main]            DEBUG o.h.e.j.i.LogicalConnectionImpl - Obtained JDBC connection
15:14:20.575 [main]            DEBUG o.h.e.q.spi.NativeSQLQueryPlan - bindNamedParameters() value1 -> v1 [1]
15:14:20.582 [main]            DEBUG o.h.e.q.spi.NativeSQLQueryPlan - bindNamedParameters() value2 -> v2 [2]
15:14:20.589 [main]            DEBUG o.s.t.jta.JtaTransactionManager - Initiating transaction commit
15:14:20.590 [main]            DEBUG o.h.e.j.i.LogicalConnectionImpl - Aggressively releasing JDBC connection
15:14:20.590 [main]            DEBUG o.h.e.j.i.LogicalConnectionImpl - Releasing JDBC connection
15:14:20.590 [main]            DEBUG o.h.e.j.i.LogicalConnectionImpl - Released JDBC connection
15:14:20.595 [Listener:36097]  DEBUG com.arjuna.ats.arjuna - Recovery listener existing com.arjuna.ats.arjuna.recovery.ActionStatusService

【问题讨论】：

为什么要以编程方式创建 SessionFactory bean？！这真的应该在 XML 中，旁边你不应该直接操作/使用ApplicationContext。在您的配置中，我看不到<tx:annotation-driven ../>，它基本上使您的服务无需事务即可工作。是否可以查看整个项目（可能在 github 上或作为 zip 文件）。
@M.Deinum 你是对的我错过了错误地，以编程方式创建 SessionFactory 因为数据库连接参数可以在运行时而不是设计时加载，我知道不建议直接使用 ApplicationContext 但这是我目前的情况，无法更改。显示的源代码是对源代码的抽象，而不是真正的代码。
在属性文件中指定参数并使用 PropertyPlaceholder 来配置数据源。还要确保组件与 tx:annotation-driven 处于相同的上下文中。
我只有一个ApplicationContext。您是否建议将休眠配置从 XML 文件切换到属性文件？

标签： java spring hibernate jta

【解决方案1】：

我认为这是因为您的数据库连接未与 JTA 绑定。您只将休眠与 JTA 同步。您应该使用 com.arjuna.ats.jdbc.TransactionalDriver 来创建连接：

TransactionalDriver arjunaJDBC2Driver = new TransactionalDriver();
Connection connection = arjunaJDBC2Driver.connect(url, dbProps);

春天的例子：

 <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
  <property name="driverClassName">
   <value>com.arjuna.ats.jdbc.TransactionalDriver</value>
  </property>
  <property name="url" value="jdbc:arjuna:mysql://host:3306/dbName"/>
  <property name="connectionProperties">
    <ref bean="dsProps"/>
  </property>
 </bean>

希望有帮助

【讨论】：