Browse Source

Resource-based PlatformTransactionManager implementations defensively catch Throwable in doBegin in order to reliably close resource in case of OutOfMemoryError

Issue: SPR-10755
pull/322/merge
Juergen Hoeller 13 years ago committed by unknown
parent
commit
2e4eb9fc10
  1. 2
      spring-jdbc/src/main/java/org/springframework/jdbc/datasource/DataSourceTransactionManager.java
  2. 4
      spring-jms/src/main/java/org/springframework/jms/connection/JmsTransactionManager.java
  3. 2
      spring-orm-hibernate4/src/main/java/org/springframework/orm/hibernate4/HibernateTransactionManager.java
  4. 2
      spring-orm/src/main/java/org/springframework/orm/hibernate3/HibernateTransactionManager.java
  5. 2
      spring-orm/src/main/java/org/springframework/orm/jdo/JdoTransactionManager.java
  6. 2
      spring-orm/src/main/java/org/springframework/orm/jpa/JpaTransactionManager.java
  7. 7
      spring-tx/src/main/java/org/springframework/jca/cci/connection/CciLocalTransactionManager.java

2
spring-jdbc/src/main/java/org/springframework/jdbc/datasource/DataSourceTransactionManager.java

@ -238,7 +238,7 @@ public class DataSourceTransactionManager extends AbstractPlatformTransactionMan @@ -238,7 +238,7 @@ public class DataSourceTransactionManager extends AbstractPlatformTransactionMan
}
}
catch (Exception ex) {
catch (Throwable ex) {
DataSourceUtils.releaseConnection(con, this.dataSource);
throw new CannotCreateTransactionException("Could not open JDBC Connection for transaction", ex);
}

4
spring-jms/src/main/java/org/springframework/jms/connection/JmsTransactionManager.java

@ -1,5 +1,5 @@ @@ -1,5 +1,5 @@
/*
* Copyright 2002-2012 the original author or authors.
* Copyright 2002-2013 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@ -196,7 +196,7 @@ public class JmsTransactionManager extends AbstractPlatformTransactionManager @@ -196,7 +196,7 @@ public class JmsTransactionManager extends AbstractPlatformTransactionManager
TransactionSynchronizationManager.bindResource(
getConnectionFactory(), txObject.getResourceHolder());
}
catch (JMSException ex) {
catch (Throwable ex) {
if (con != null) {
try {
con.close();

2
spring-orm-hibernate4/src/main/java/org/springframework/orm/hibernate4/HibernateTransactionManager.java

@ -500,7 +500,7 @@ public class HibernateTransactionManager extends AbstractPlatformTransactionMana @@ -500,7 +500,7 @@ public class HibernateTransactionManager extends AbstractPlatformTransactionMana
txObject.getSessionHolder().setSynchronizedWithTransaction(true);
}
catch (Exception ex) {
catch (Throwable ex) {
if (txObject.isNewSession()) {
try {
if (session.getTransaction().isActive()) {

2
spring-orm/src/main/java/org/springframework/orm/hibernate3/HibernateTransactionManager.java

@ -583,7 +583,7 @@ public class HibernateTransactionManager extends AbstractPlatformTransactionMana @@ -583,7 +583,7 @@ public class HibernateTransactionManager extends AbstractPlatformTransactionMana
txObject.getSessionHolder().setSynchronizedWithTransaction(true);
}
catch (Exception ex) {
catch (Throwable ex) {
if (txObject.isNewSession()) {
try {
if (session.getTransaction().isActive()) {

2
spring-orm/src/main/java/org/springframework/orm/jdo/JdoTransactionManager.java

@ -366,7 +366,7 @@ public class JdoTransactionManager extends AbstractPlatformTransactionManager @@ -366,7 +366,7 @@ public class JdoTransactionManager extends AbstractPlatformTransactionManager
closePersistenceManagerAfterFailedBegin(txObject);
throw ex;
}
catch (Exception ex) {
catch (Throwable ex) {
closePersistenceManagerAfterFailedBegin(txObject);
throw new CannotCreateTransactionException("Could not open JDO PersistenceManager for transaction", ex);
}

2
spring-orm/src/main/java/org/springframework/orm/jpa/JpaTransactionManager.java

@ -425,7 +425,7 @@ public class JpaTransactionManager extends AbstractPlatformTransactionManager @@ -425,7 +425,7 @@ public class JpaTransactionManager extends AbstractPlatformTransactionManager
closeEntityManagerAfterFailedBegin(txObject);
throw ex;
}
catch (Exception ex) {
catch (Throwable ex) {
closeEntityManagerAfterFailedBegin(txObject);
throw new CannotCreateTransactionException("Could not open JPA EntityManager for transaction", ex);
}

7
spring-tx/src/main/java/org/springframework/jca/cci/connection/CciLocalTransactionManager.java

@ -1,5 +1,5 @@ @@ -1,5 +1,5 @@
/*
* Copyright 2002-2012 the original author or authors.
* Copyright 2002-2013 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@ -29,8 +29,8 @@ import org.springframework.transaction.TransactionException; @@ -29,8 +29,8 @@ import org.springframework.transaction.TransactionException;
import org.springframework.transaction.TransactionSystemException;
import org.springframework.transaction.support.AbstractPlatformTransactionManager;
import org.springframework.transaction.support.DefaultTransactionStatus;
import org.springframework.transaction.support.TransactionSynchronizationManager;
import org.springframework.transaction.support.ResourceTransactionManager;
import org.springframework.transaction.support.TransactionSynchronizationManager;
/**
* {@link org.springframework.transaction.PlatformTransactionManager} implementation
@ -141,7 +141,6 @@ public class CciLocalTransactionManager extends AbstractPlatformTransactionManag @@ -141,7 +141,6 @@ public class CciLocalTransactionManager extends AbstractPlatformTransactionManag
@Override
protected void doBegin(Object transaction, TransactionDefinition definition) {
CciLocalTransactionObject txObject = (CciLocalTransactionObject) transaction;
Connection con = null;
try {
@ -169,7 +168,7 @@ public class CciLocalTransactionManager extends AbstractPlatformTransactionManag @@ -169,7 +168,7 @@ public class CciLocalTransactionManager extends AbstractPlatformTransactionManag
ConnectionFactoryUtils.releaseConnection(con, getConnectionFactory());
throw new CannotCreateTransactionException("Could not begin local CCI transaction", ex);
}
catch (ResourceException ex) {
catch (Throwable ex) {
ConnectionFactoryUtils.releaseConnection(con, getConnectionFactory());
throw new TransactionSystemException("Unexpected failure on begin of CCI local transaction", ex);
}

Loading…
Cancel
Save