Spring/spring-data-commons
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DATACMNS-73 - Created dedicated cross-store package.

Browse Source 
Adding back/moving missing classes
This commit is contained in:
Thomas Risberg
2011-10-12 10:54:20 -04:00
parent a31046f634
commit 60d0b9c428
2 changed files with 61 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

60
spring-data-commons-core/src/main/java/org/springframework/data/crossstore/ChangeSetBackedTransactionSynchronization.java Normal file
View File

@@ -0,0 +1,60 @@
package org.springframework.data.crossstore;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.transaction.support.TransactionSynchronization;
public class ChangeSetBackedTransactionSynchronization implements TransactionSynchronization {
protected final Log log = LogFactory.getLog(getClass());
private ChangeSetPersister<Object> changeSetPersister;
private ChangeSetBacked entity;
private int changeSetTxStatus = -1;
public ChangeSetBackedTransactionSynchronization(ChangeSetPersister<Object> changeSetPersister, ChangeSetBacked entity) {
this.changeSetPersister = changeSetPersister;
this.entity = entity;
}
public void afterCommit() {
log.debug("After Commit called for " + entity);
changeSetPersister.persistState(entity, entity.getChangeSet());
changeSetTxStatus = 0;
}
public void afterCompletion(int status) {
log.debug("After Completion called with status = " + status);
if (changeSetTxStatus == 0) {
if (status == STATUS_COMMITTED) {
// this is good
log.debug("ChangedSetBackedTransactionSynchronization completed successfully for " + this.entity);
} else {
// this could be bad - TODO: compensate
log.error("ChangedSetBackedTransactionSynchronization failed for " + this.entity);
}
}
}
public void beforeCommit(boolean readOnly) {
}
public void beforeCompletion() {
}
public void flush() {
}
public void resume() {
throw new IllegalStateException(
"ChangedSetBackedTransactionSynchronization does not support transaction suspension currently.");
}
public void suspend() {
throw new IllegalStateException(
"ChangedSetBackedTransactionSynchronization does not support transaction suspension currently.");
}
}

3
spring-data-commons-core/src/main/java/org/springframework/data/persistence/HashMapChangeSet.java → spring-data-commons-core/src/main/java/org/springframework/data/crossstore/HashMapChangeSet.java
View File

@@ -1,11 +1,10 @@
package org.springframework.data.persistence;
package org.springframework.data.crossstore;
import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
import org.springframework.core.convert.ConversionService;
import org.springframework.data.crossstore.ChangeSet;
/**
* Simple ChangeSet implementation backed by a HashMap.