【问题标题】:spring transactional cpool. Which one do I use?春季交易池。我用哪一个?
【发布时间】:2009-12-29 22:35:06
【问题描述】:

我最初用 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 setup 页面描述了一些关于 JMS 的内容,这些内容甚至没有任何意义。 JMS 与设置连接池有什么关系?

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

【问题讨论】:

    标签: spring transactions jotm


    【解决方案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.htmlhttp://docs.codehaus.org/display/BTM/FAQhttp://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

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

    【讨论】:

      【解决方案2】:

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

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

      【讨论】:

      • 我用的是tomcat,所以什么都没有。
      • 当然可以 - 为什么不要求它使用 Jakarta DBCP 提供连接池? tomcat.apache.org/tomcat-6.0-doc/…
      • 无论如何,我需要将应用程序上下文设置为独立运行或在 tomcat 下运行。在我的一生中,我无法弄清楚如何让事情运行起来,以便在 @Transactional 方法中引发的异常导致在同一方法中完成的插入回滚。这非常令人沮丧。我不需要 2 阶段提交或类似的东西。只是一个单一方法的简单交易。除此之外的任何东西都是奖金。
      • 您需要声明一个事务管理器。这不仅仅是@Transactional
      • 除了我在原始问题中已经指定的内容之外,我还需要什么?在应用程序上下文中,我创建了 JotmFactoryBean bean 并将其与 tx:annotation-driven 声明使用的 JtaTransactionManager 一起使用。还有什么?
      猜你喜欢
      • 1970-01-01
      • 2011-08-27
      • 1970-01-01
      • 2020-12-18
      • 2019-02-14
      • 2014-05-28
      • 1970-01-01
      • 1970-01-01
      • 2012-08-10
      相关资源
      最近更新 更多