spring - 春季交易池。我用哪一个？

Question

我最初用 xapool 设置 spring，但事实证明这是一个死项目，似乎有很多问题。

我切换到 c3p0，但现在我了解到 @Transactional 注释在与 c3p0 一起使用时实际上不会创建事务。如果我执行以下操作，即使在方法中抛出异常，它也会将该行插入 Foo 中：

@Service
public class FooTst
{
    @PersistenceContext(unitName="accessControlDb") private EntityManager em;

    @Transactional
    public void insertFoo() {
        em.createNativeQuery("INSERT INTO Foo (id) VALUES (:id)")
            .setParameter("id", System.currentTimeMillis() % Integer.MAX_VALUE )
            .executeUpdate();

        throw new RuntimeException("Foo");
    }

}

这很奇怪，因为如果我注释掉 @Transactional 注释，它实际上会失败并抱怨将事务设置为仅回滚：

java.lang.IllegalStateException: Cannot get Transaction for setRollbackOnly
    at org.objectweb.jotm.Current.setRollbackOnly(Current.java:568)
    at org.hibernate.ejb.AbstractEntityManagerImpl.markAsRollback(AbstractEntityManagerImpl.java:421)
    at org.hibernate.ejb.AbstractEntityManagerImpl.throwPersistenceException(AbstractEntityManagerImpl.java:576)
    at org.hibernate.ejb.QueryImpl.executeUpdate(QueryImpl.java:48)
    at com.ipass.rbac.svc.FooTst.insertFoo(FooTst.java:21)
    at com.ipass.rbac.svc.SingleTst.testHasPriv(SingleTst.java:78)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
    at java.lang.reflect.Method.invoke(Method.java:597)
    at org.springframework.test.context.junit4.SpringTestMethod.invoke(SpringTestMethod.java:160)
    at org.springframework.test.context.junit4.SpringMethodRoadie.runTestMethod(SpringMethodRoadie.java:233)
    at org.springframework.test.context.junit4.SpringMethodRoadie$RunBeforesThenTestThenAfters.run(SpringMethodRoadie.java:333)
    at org.springframework.test.context.junit4.SpringMethodRoadie.runWithRepetitions(SpringMethodRoadie.java:217)
    at org.springframework.test.context.junit4.SpringMethodRoadie.runTest(SpringMethodRoadie.java:197)
    at org.springframework.test.context.junit4.SpringMethodRoadie.run(SpringMethodRoadie.java:143)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.invokeTestMethod(SpringJUnit4ClassRunner.java:160)
    at org.junit.internal.runners.JUnit4ClassRunner.runMethods(JUnit4ClassRunner.java:51)
    at org.junit.internal.runners.JUnit4ClassRunner$1.run(JUnit4ClassRunner.java:44)
    at org.junit.internal.runners.ClassRoadie.runUnprotected(ClassRoadie.java:27)
    at org.junit.internal.runners.ClassRoadie.runProtected(ClassRoadie.java:37)
    at org.junit.internal.runners.JUnit4ClassRunner.run(JUnit4ClassRunner.java:42)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:97)
    at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:45)
    at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:460)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:673)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:386)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)

所以，很明显它注意到了@Transactional 注释。但是，它实际上并没有在方法开始时将自动提交设置为关闭。

以下是我在 applicationContext.xml 中设置事务性内容的方式。它是否正确？如果不是，这应该是什么？

<bean id="jotm" class="org.springframework.transaction.jta.JotmFactoryBean"/>
<bean id="txManager" class="org.springframework.transaction.jta.JtaTransactionManager">
    <property name="transactionManager" ref="jotm"/>
    <property name="userTransaction" ref="jotm"/>
    <property name="allowCustomIsolationLevels" value="true"/>
</bean>
<tx:annotation-driven  transaction-manager="txManager" proxy-target-class="false"/>

经过大量搜索后，我找到了一个名为 Bitronix 的连接池，但他们的 spring 设置页面描述了有关 JMS 的内容，这些内容甚至没有任何意义。JMS 与设置连接池有什么关系？

所以我被困住了。我实际上应该做什么？我不明白为什么连接池需要支持事务。所有连接都支持打开和关闭自动提交，所以我不知道这里有什么问题。

Answer 1

这需要大量的搜索和实验，但我终于让一切正常了。这是我的结果：

• enhydra xapool 是一个糟糕的连接池。我不会列举它引起的问题，因为这无关紧要。自 2006 年 12 月以来，该池的最新版本没有更新。这是一个死项目。
• 我将 c3p0 放入我的应用程序上下文中，并让它相当容易地工作。但是，由于某种原因，即使在单个方法中，它似乎也不支持回滚。如果我将一个方法标记为 @Transactional 然后插入到表中然后抛出一个 RuntimeException （肯定没有在方法的 throws 列表中声明，因为该方法上没有 throws 列表）它仍然会保留插入到那张桌子。它不会回滚。
• 我打算尝试 Apache DBCP，但我的搜索发现了很多关于它的投诉，所以我没有打扰。
• 我尝试了 Bitronix，但在 Tomcat 下让它正常工作时遇到了很多麻烦，但一旦我弄清楚了神奇的配置，它就可以很好地工作。接下来是您需要做的所有事情才能正确设置它。
• 我简单地涉足了 Atomkos 连接池。看起来应该不错，但我先让 Bitronix 工作，所以我没有尝试过多使用它。

下面的配置在独立单元测试和 Tomcat 下工作。那是我遇到的主要问题。我发现的大多数关于如何使用 Bitronix 设置 Spring 的示例都假设我使用的是 JBoss 或其他一些完整的容器。

配置的第一位是设置 Bitronix 事务管理器的部分。

<!-- Bitronix transaction manager -->
<bean id="btmConfig" factory-method="getConfiguration" class="bitronix.tm.TransactionManagerServices">
    <property name="disableJmx" value="true" />
</bean>
<bean id="btmManager" factory-method="getTransactionManager" class="bitronix.tm.TransactionManagerServices" depends-on="btmConfig" destroy-method="shutdown"/>
<bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
    <property name="transactionManager" ref="btmManager" />
    <property name="userTransaction" ref="btmManager" />
    <property name="allowCustomIsolationLevels" value="true" />
</bean>
<tx:annotation-driven transaction-manager="transactionManager" />

该代码与我发现的示例之间的主要区别是“disableJmx”属性。如果您不使用 JMX 但启用它，它会在运行时引发异常。

下一点配置是连接池数据源。注意连接池类名不是普通的oracle类“oracle.jdbc.driver.OracleDriver”。它是一个 XA 数据源。我不知道其他数据库中的等效类是什么。

<bean id="dataSource" class="bitronix.tm.resource.jdbc.PoolingDataSource" init-method="init" destroy-method="close">
    <property name="uniqueName" value="dataSource-BTM" />
    <property name="minPoolSize" value="1" />
    <property name="maxPoolSize" value="4" />
    <property name="testQuery" value="SELECT 1 FROM dual" />
    <property name="driverProperties"><props>
        <prop key="URL">${jdbc.url}</prop>
        <prop key="user">${jdbc.username}</prop>
        <prop key="password">${jdbc.password}</prop>
    </props></property>
    <property name="className" value="oracle.jdbc.xa.client.OracleXADataSource" />
    <property name="allowLocalTransactions" value="true" />
</bean>

另请注意，uniqueName 需要与您配置的任何其他数据源不同。

testQuery 当然需要特定于您正在使用的数据库。驱动程序属性特定于我正在使用的数据库类。出于某种愚蠢的原因，OracleXADataSource 对于相同的值具有不同的 OracleDriver 设置器名称。

对我来说，allowLocalTransactions 必须设置为 true。我发现建议不要在网上将其设置为 true。但是，这似乎是不可能的。如果它设置为 false，它将不起作用。我对这些事情的了解不足，无法知道为什么会这样。

最后我们需要配置实体管理器工厂。

<util:map id="jpa_property_map">
    <entry key="hibernate.transaction.manager_lookup_class" value="org.hibernate.transaction.BTMTransactionManagerLookup"/>
    <entry key="hibernate.current_session_context_class" value="jta"/>
</util:map>

<bean id="dataSource-emf" name="accessControlDb" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
    <property name="dataSource" ref="dataSource"/>
    <property name="persistenceXmlLocation" value="classpath*:META-INF/foo-persistence.xml" />
    <property name="jpaVendorAdapter">
        <bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter">
            <property name="showSql" value="true"/>
            <property name="databasePlatform" value="org.hibernate.dialect.Oracle10gDialect"/>
        </bean>
    </property>
    <property name="jpaPropertyMap" ref="jpa_property_map"/>
    <property name="jpaDialect"><bean class="org.springframework.orm.jpa.vendor.HibernateJpaDialect"/></property>
</bean>

注意 dataSource 属性是指我声明的 dataSource 的 id。persistenceXmlLocation 是指存在于类路径中某处的持久性 xml 文件。classpath*: 表示它可能在任何 jar 中。没有 * 如果它出于某种原因放在罐子里，它将找不到它。

我发现 util:map 是一种将 jpaPropertyMap 值放在一个位置的便捷方法，这样当我在一个应用程序上下文中使用多个实体管理器工厂时就不需要重复它们。

请注意，除非您在外部 beans 元素中包含正确的设置，否则上面的 util:map 将不起作用。这是我使用的 xml 文件的标头：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:tx="http://www.springframework.org/schema/tx" xmlns:util="http://www.springframework.org/schema/util"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
    http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
    http://www.springframework.org/schema/context
    http://www.springframework.org/schema/context/spring-context-2.5.xsd
    http://www.springframework.org/schema/tx
    http://www.springframework.org/schema/tx/spring-tx-2.5.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd">

最后，为了让 Bitronix（或显然任何支持两阶段提交的 cpool）与 Oracle 一起工作，您需要以 SYS 用户身份运行以下授权。（参见http://publib.boulder.ibm.com/infocenter/wasinfo/v6r0/index.jsp?topic=/com.ibm.websphere.express.doc/info/exp/ae/rtrb_dsaccess2.html和http:// /docs.codehaus.org/display/BTM/FAQ和http://docs.codehaus.org/display/BTM/JdbcXaSupportEvaluation#JdbcXaSupportEvaluation-Oracle）

grant select on pending_trans$ to <someUsername>;
grant select on dba_2pc_pending to <someUsername>;
grant select on dba_pending_transactions to <someUsername>;
grant execute on dbms_system to <someUsername>;

无论您是否实际对任何内容进行任何修改，都需要为设置了连接池的任何用户运行这些授权。它显然会在建立连接时查找这些表。

其他一些杂项问题：

• 在使用 Bitronix 时，您无法在 Spring @Transactional 块内查询 Oracle 中远程同义词的表（您将获得 ORA-24777）。使用物化视图或直接指向另一个数据库的单独 EntityManager。
• 由于某种原因，applicationContext.xml 中的 btmConfig 在设置配置值时存在问题。而是创建一个 bitronix-default-config.properties 文件。您可以在http://docs.codehaus.org/display/BTM/Configuration13中找到您可以使用的配置值。该文件的其他一些配置信息位于http://docs.codehaus.org/display/BTM/JdbcConfiguration13但我没有使用它。
• Bitronix 使用一些本地文件来存储事务性内容。我不知道为什么，但我知道如果您有多个带有本地连接池的 web 应用程序，您会遇到问题，因为它们都会尝试访问相同的文件。要解决此问题，请为每个应用程序的 bitronix-default-config.properties 中的 bitronix.tm.journal.disk.logPart1Filename 和 bitronix.tm.journal.disk.logPart2Filename 指定不同的值。
• Bitronix javadocs 位于http://www.bitronix.be/uploads/api/index.html。

差不多就是这样。让它工作起来非常繁琐，但现在它正在工作，我很高兴。我希望所有这一切都能帮助那些正在经历与我一样的麻烦的其他人，以使这一切顺利进行。

Answer 2

当我进行连接池时，我倾向于使用我正在部署的应用服务器提供的连接池。那时它只是 Spring 的 JNDI 名称。

由于我在测试时不想担心应用服务器，因此在进行单元测试时我使用 DriverManagerDataSource 及其关联的事务管理器。我在测试时并不关心池化或性能。我确实希望测试能够有效地运行，但在这种情况下，池化并不是一个交易破坏者。