the beginning of the Sping Data Common sub-project

src/main/java/org/springframework/data/transaction/ChangedSetBackedTransactionSynchronization.java

@@ -0,0 +1,69 @@
+package org.springframework.data.transaction;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+import org.springframework.data.support.ChangeSetBacked;
+import org.springframework.data.support.ChangeSetPersister;
+import org.springframework.transaction.support.TransactionSynchronization;
+
+public class ChangedSetBackedTransactionSynchronization implements TransactionSynchronization {
+
+	protected final Log log = LogFactory.getLog(getClass());
+
+	private ChangeSetPersister<Object> changeSetPersister;
+
+	private ChangeSetBacked entity;
+
+	private int changeSetTxStatus = -1;
+
+	public ChangedSetBackedTransactionSynchronization(ChangeSetPersister<Object> changeSetPersister, ChangeSetBacked entity) {
+		this.changeSetPersister = changeSetPersister;
+		this.entity = entity;
+	}
+	
+	@Override
+	public void afterCommit() {
+		log.debug("After Commit called for " + entity);
+		changeSetPersister.persistState(entity.getClass(), entity.getChangeSet());
+		changeSetTxStatus = 0;
+	}
+
+	@Override
+	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);
+			}
+		}
+	}
+
+	@Override
+	public void beforeCommit(boolean readOnly) {
+	}
+
+	@Override
+	public void beforeCompletion() {
+	}
+
+	@Override
+	public void flush() {
+	}
+
+	@Override
+	public void resume() {
+		throw new IllegalStateException("ChangedSetBackedTransactionSynchronization does not support transaction suspension currently.");
+	}
+
+	@Override
+	public void suspend() {
+		throw new IllegalStateException("ChangedSetBackedTransactionSynchronization does not support transaction suspension currently.");
+	}
+	
+}