@@ -101,10 +101,6 @@ public class ChainedTransactionManager implements PlatformTransactionManager {
|
||||
this.transactionManagers = asList(transactionManagers);
|
||||
}
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.transaction.PlatformTransactionManager#getTransaction(org.springframework.transaction.TransactionDefinition)
|
||||
*/
|
||||
public MultiTransactionStatus getTransaction(@Nullable TransactionDefinition definition) throws TransactionException {
|
||||
|
||||
var mts = new MultiTransactionStatus(transactionManagers.get(0));
|
||||
@@ -148,10 +144,6 @@ public class ChainedTransactionManager implements PlatformTransactionManager {
|
||||
return mts;
|
||||
}
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.transaction.PlatformTransactionManager#commit(org.springframework.transaction.TransactionStatus)
|
||||
*/
|
||||
public void commit(TransactionStatus status) throws TransactionException {
|
||||
|
||||
var multiTransactionStatus = (MultiTransactionStatus) status;
|
||||
@@ -196,10 +188,6 @@ public class ChainedTransactionManager implements PlatformTransactionManager {
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.transaction.PlatformTransactionManager#rollback(org.springframework.transaction.TransactionStatus)
|
||||
*/
|
||||
public void rollback(TransactionStatus status) throws TransactionException {
|
||||
|
||||
Exception rollbackException = null;
|
||||
|
||||
@@ -83,52 +83,28 @@ class MultiTransactionStatus implements TransactionStatus {
|
||||
transactionManager.rollback(getTransactionStatus(transactionManager));
|
||||
}
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.transaction.TransactionStatus#isRollbackOnly()
|
||||
*/
|
||||
public boolean isRollbackOnly() {
|
||||
return getMainTransactionStatus().isRollbackOnly();
|
||||
}
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.transaction.TransactionStatus#isCompleted()
|
||||
*/
|
||||
public boolean isCompleted() {
|
||||
return getMainTransactionStatus().isCompleted();
|
||||
}
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.transaction.TransactionStatus#isNewTransaction()
|
||||
*/
|
||||
public boolean isNewTransaction() {
|
||||
return getMainTransactionStatus().isNewTransaction();
|
||||
}
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.transaction.TransactionStatus#hasSavepoint()
|
||||
*/
|
||||
public boolean hasSavepoint() {
|
||||
return getMainTransactionStatus().hasSavepoint();
|
||||
}
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.transaction.TransactionStatus#setRollbackOnly()
|
||||
*/
|
||||
public void setRollbackOnly() {
|
||||
for (var ts : transactionStatuses.values()) {
|
||||
ts.setRollbackOnly();
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.transaction.SavepointManager#createSavepoint()
|
||||
*/
|
||||
public Object createSavepoint() throws TransactionException {
|
||||
|
||||
var savePoints = new SavePoints();
|
||||
@@ -139,27 +115,15 @@ class MultiTransactionStatus implements TransactionStatus {
|
||||
return savePoints;
|
||||
}
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.transaction.SavepointManager#rollbackToSavepoint(java.lang.Object)
|
||||
*/
|
||||
public void rollbackToSavepoint(Object savepoint) throws TransactionException {
|
||||
var savePoints = (SavePoints) savepoint;
|
||||
savePoints.rollback();
|
||||
}
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.transaction.SavepointManager#releaseSavepoint(java.lang.Object)
|
||||
*/
|
||||
public void releaseSavepoint(Object savepoint) throws TransactionException {
|
||||
((SavePoints) savepoint).release();
|
||||
}
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.transaction.TransactionStatus#flush()
|
||||
*/
|
||||
public void flush() {
|
||||
for (var transactionStatus : transactionStatuses.values()) {
|
||||
transactionStatus.flush();
|
||||
|
||||
@@ -28,26 +28,14 @@ enum SpringTransactionSynchronizationManager implements SynchronizationManager {
|
||||
|
||||
INSTANCE;
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.data.transaction.SynchronizationManager#initSynchronization()
|
||||
*/
|
||||
public void initSynchronization() {
|
||||
TransactionSynchronizationManager.initSynchronization();
|
||||
}
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.data.transaction.SynchronizationManager#isSynchronizationActive()
|
||||
*/
|
||||
public boolean isSynchronizationActive() {
|
||||
return TransactionSynchronizationManager.isSynchronizationActive();
|
||||
}
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.data.transaction.SynchronizationManager#clearSynchronization()
|
||||
*/
|
||||
public void clearSynchronization() {
|
||||
TransactionSynchronizationManager.clear();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user